RocketMQ – 消费者异常处理和图形化监控

在消费消息时,因为异常导致消费不成功的时候,RocketMQ默认会连续进行三次重试。 可以通过下面的代码测试一下: @StreamListener("input1")public void receiveInput1(@Payload Message message) throws ValidationException {    if (0 == count) {        //此处模拟的是...

RocketMQ – 事务消息

选择RocketMQ是因为它支持事务消息,它的事务消息实现过程如下: 1. 先发送一条半消息。 2. 处理业务逻辑。 3. 业务逻辑成功,则确认消息,这时候半消息会正式推送至消费者。业务逻辑失败,则回滚消息,这时候半消息会取消。 4. 因为异常情况,导致无法确认或者回滚时,利用回查接口轮询最终的业务处理结果,再确认或者回滚消息。 上面的过程都是我抄的,只不过边读边理解,然后用自己的话...

RocketMQ – 与Spring Cloud Stream结合

最近在加班,五一看了一遍《钢之炼金术师》,空闲时间又对Netty产生了兴趣,还得陪闺女,然后TBC怀旧又要蹭一波热度去,所以时间不够用,更新十分缓慢。 我在学习RocketMQ怎么和Spring Cloud结合的时候,首先被下面这个问题困扰: Spring Cloud Bus和Spring Cloud Stream有什么不同?应用的场景都是什么样的? 后来吧,我得出了一个非常简单的结论,无论什么场景都用Spring Cloud Stream就完事了...

RocketMQ – 入门

最近鼓捣了几个小玩意: RocketMQCASJWT 有空就记录一下,顺便再梳理一下思路,以后看自己写的东西也比看别人的易于理解。 如何下载? RocketMQ的下载地址如下: http://rocketmq.apache.org/dowloading/releases/ RocketMQ对于JDK版本的要求还是挺清晰的: 这里测试的话,我没有下载源码进行编译,以后想看源码的话再说。直接下载的是rocketmq-all-4.8.0-bin-release.zip。 ...
Copyright © 字痕随行 保留所有权利.   Theme  Ality

用户登录

分享到: