eventbus 的项目扩展与二次开发

eventbus 是一个基于 Spring Boot Starter 的分布式业务消息分发总线组件，支持发布/订阅模式，并提供延时消息功能。该组件通过屏蔽底层不同的消息引擎，提供统一的接口调用，简化了事件处理的编程模型，使得基于事件的开发更加灵活和易于维护。

项目的核心功能

1. 消息投递和接收：支持及时消息和延时消息的投递和接收。
2. 消息订阅：支持多种方式订阅消息，包括通过统一接口和注解。
3. 失败重试：支持消息投递失败时的重试机制，可以自定义重试次数和下次投递时间。
4. 拦截器：支持全局拦截器，可以实现发送前、发送后、投递前、投递后以及最后一次投递失败时的拦截逻辑。
5. 消息轮询：通过注解自定义消息的轮询行为。
6. 消息类型转换：支持将及时消息转换为延时消息，并可以配置延时投递时间。
7. 消息持久化：提供示例，可以通过 BsHelper 实现消息投递状态的持久化。
8. 订阅监听器开关：支持通过外部配置来控制消息订阅监听器的开关。
9. 无缝切换消息中间件：无需修改业务代码，即可切换不同的消息中间件。
10. 网络断开重连：支持消息中间件在网络断开时的自动重连机制。

项目使用了哪些框架或库？

1. Spring Boot：作为项目的核心框架，提供自动配置和依赖注入等功能。
2. Spring AMQP：用于与 RabbitMQ 消息中间件集成。
3. Spring Data Redis：用于与 Redis 消息引擎集成。
4. Apache RocketMQ：用于与 RocketMQ 消息中间件集成。
5. JSON 序列化库：如 Fastjson、Jackson、Gson 等，用于消息的序列化和反序列化。

项目的代码目录及介绍

likavn/
├── eventbus-core          # 核心模块，包含消息处理的基础逻辑和接口
├── eventbus-demo          # 示例模块，展示如何使用 eventbus
├── eventbus-spring-boot-starter  # Spring Boot Starter 模块，提供自动配置和依赖
└── eventbus-spring-boot3-starter # Spring Boot 3 Starter 模块，提供自动配置和依赖

对项目进行扩展或者二次开发的方向

1. 支持更多消息中间件：如 ActiveMQ、Kafka 等。
2. 增强消息持久化功能：支持更多持久化方式和存储方案，如使用数据库或其他 NoSQL 数据库。
3. 改进拦截器机制：提供更灵活的拦截器配置和扩展方式。
4. 增加消息监控和统计功能：支持对消息投递、处理等过程的监控和统计。
5. 优化性能和扩展性：针对高并发和大规模消息处理场景进行性能优化和扩展性改进。
6. 集成更多开发框架：如与 Spring Cloud、Dubbo 等集成，提供更丰富的功能和应用场景。