SpringBoot1.5.* RockerMQ集成插件

        
            org.apache.rocketmq
            rocketmq-client
            4.4.0
        
        
            com.zjs.mic
            zjs-spring-boot-mq
            最新版本
        

        @Component
        public class MessageListener implements MessageListenerConsumerInterface
        {
   
            @Autowired
            private MqProducer mqProducer;
   
            /**
             * 生成者使用示例
             */
            public void sendMQ()
            {
                try {
                    mqProducer.send("","","");
                } catch (UnsupportedEncodingException e) {
                    e.printStackTrace();
                }
            }
   
            /**
             * 消费者使用示例
             */
            @Override
            public ConsumeConcurrentlyStatus consumeMessage(String strBody, MessageExt msg, ConsumeConcurrentlyContext context) {
                System.out.println(strBody);
                return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
            }
        }

配置：

rocketmq:
  # Name Server 地址列表
  namesrvAddr: 10.10.0.01:9876;10.10.0.02:9876
  # Producer 组名， 多个 Producer 如果属于一 个应用，发送同样的消息，则应该将它们 归为同一组
  producerGroupName: testliwen
  # 生产者名称
  instanceName: testliwen
  # 超时时间 默认 20000
  sendMsgTimeout: 20000
  # 消费端组名
  consumerGroup: atliwenconsumer
  # 消息处理次数 默认12  只是服务自己判断，非 rocketmq 自身   -1 为不生效
  # 没有实现 MqExceedCountInterface 接口的 bean 也不会触发。
  count: 12
  # 消费端 Topic
  Topics:
    - {Topic: ‘testAAA‘, Tags: ‘*‘}