由 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
主要内容:一、前情提示,二、ack机制回顾,三、ack机制实现原理:delivery tag,四、RabbitMQ如何感知到仓储服务实例宕机,五、仓储服务处理失败时的消息重发,六、阶段总结一、前情提示 上一篇文章《MQ保证读写消息不丢失,这个你都不会就等着被开除吧...》我们初步介绍了之前制定的那些消息中间件数据不丢失的技术方案遗留的问题。 一个最大的问题,就是生产者投递出去的消息,可能会丢失。 丢失的原因有很多,比如消息在网络传输到一半的时候因为网络故障就丢了,或者是消息投递到MQ的内存时,M
我一个springboot项目里,有2个相同主题相同群组,不同tag的监听。 为了测试异常重试机制,我在监听tagA的那个逻辑里,触发一个异常,希望RocketMQ可以重发异常到这个tagA监听里。 结果神奇的是,日志显示tagA逻辑触发了异常,接下来居然是tagB被触发了,但是我压根没发送过tagB的消息啊。。。。而且tabB的逻辑还一直被触发了多次。 另外,如果tagA的逻辑不触发异常,则ta
客户点击导出excel,这时发送一条消息到 rocketmq, rocketmq在消费时,会有超时重试机制,默认15S,重试(不管有没有错误,到时间就认为超时,虽然可以修改) 生成个excel的时间可能在3~5分钟,可能生成时发生错误(如读取数据超时,有一定容错,但无法避免完全不出问题). 这种情况是不是太适合用rocketmq来做触发和重试? 用数据库做轮询是不是比较好? 或是更好的实现方式?
rocketMq代码写法上,是否支持这个操作呢?有没有什么坑?