0
点赞
收藏
分享

微信扫一扫

【Kafka】SpringBoot集成消息中间件Kafka、RocketMQ


1. 封装生产者EventProducer

        1 定义生产者配置与事件类

        2. 同步直接发送,无延迟

        3. 异步放入Deque双端队列,线程池发送消息

2. 封装消费者EventConsumer

        1. 定义消费者配置

        2. 线程池消费,订阅所有topic
        3. 定义PartitionInfo保存消费进度,消费一次保存一次最近offset

        4. 停止的时候保存所有offset

        5. 添加监听的Topic,建造者模式新增回调监听器,收到消息回调方法

        6. 指定线程池,启动消费者线程池


​​SpringBoot整合rocketmq - 简书​​


举报

相关推荐

0 条评论