《rocketmq》专题

Apache RocketMQ MQTT 是一种 MQTT 协议架构模型。在此基础上，RocketMQ 可以更好地支持物联网设备和移动 APP 等终端的消息。 Apache RocketMQ MQTT 基于 RocketMQ 的消息统一存储引擎，同时支持 MQTT 终端和服务器的消息收发。 架构

由 Apache RocketMQ 社区贡献并维护的 Apache RocketMQ 扩展项目。 RocketMQ-Console 使用 Spring Boot 重新设计的 RocketMQ 控制台 RocketMQ-JMS RocketMQ 的 JMS 1.1 规范实现 RocketMQ-Flume Flume RocketMQ source 和 sink 的实现 RocketMQ-Flink

rocketmq-python 是一个基于 rocketmq-client-cpp 封装的 RocketMQ Python 客户端。 示例代码： Producer from rocketmq.client import Producer, Messageproducer = Producer('PID-XXX')producer.set_namesrv_domain('http://onsaddr

rocketMq代码写法上，是否支持这个操作呢？有没有什么坑？

客户点击导出excel,这时发送一条消息到 rocketmq, rocketmq在消费时,会有超时重试机制,默认15S,重试(不管有没有错误,到时间就认为超时,虽然可以修改) 生成个excel的时间可能在3~5分钟,可能生成时发生错误(如读取数据超时,有一定容错,但无法避免完全不出问题). 这种情况是不是太适合用rocketmq来做触发和重试? 用数据库做轮询是不是比较好? 或是更好的实现方式?

我一个springboot项目里，有2个相同主题相同群组，不同tag的监听。 为了测试异常重试机制，我在监听tagA的那个逻辑里，触发一个异常，希望RocketMQ可以重发异常到这个tagA监听里。 结果神奇的是，日志显示tagA逻辑触发了异常，接下来居然是tagB被触发了，但是我压根没发送过tagB的消息啊。。。。而且tabB的逻辑还一直被触发了多次。 另外，如果tagA的逻辑不触发异常，则ta