【--RocketMQ--】RocketMQ实现事务消息
在RocketMQ4.3.0版本后，开放了事务消息这一特性，对于分布式事务而言，最常说的还是二阶段提交协议，那么RocketMQ的事务消息又是怎么一回事呢，这里主要带着以下几个问题来探究一下RocketMQ的事务消息： 事务消息是如何实现的 我们有哪些手段来监控事务消息的状态 事务消息 ...
原文：rocketmq--消息的产生（普通消息）
与消息发送紧密相关的几行代码： . DefaultMQProducer producer new DefaultMQProducer ProducerGroupName . producer.start . Message msg new Message ... . SendResult sendResult producer.send msg . producer.shutdown 那这几行代 ...
2017-10-25 22:14 0 3201 推荐指数：
相关推荐
RocketMQ(6)---发送普通消息（三种方式）
发送普通消息（三种方式) RocketMQ 发送普通消息有三种实现方式：可靠同步发送、可靠异步发送、单向（Oneway）发送。 注意 ：顺序消息只支持可靠同步发送。 GitHub地址: https://github.com/yudiandemingzi ...
rocketMq消息的发送和消息消费
rocketMq消息的发送和消息消费 ###一.消息推送 ```java public void pushMessage() { String message = "推送消息内容！"; try { DefaultMQProducer producer = new ...
RocketMQ（二）事务消息&顺序消息
一、事务消息的由来 1、案例 引用官方的购物案例： 小明购买一个100元的东西，账户扣款100元的同时需要保证在下游的积分系统给小明这个账号增加100积分。账号系统和积分系统是两个独立是系统，一个要减少100元，一个要增加100积分。如下图： 2、问题 账号服务扣款成功 ...
RocketMQ源码 — 八、 RocketMQ消息重试
RocketMQ的消息重试包含了producer发送消息的重试和consumer消息消费的重试。 producer发送消息重试 producer在发送消息的时候如果发送失败了，RocketMQ会自动重试。 重试几次？ 由上面可以看出发送消息的重试次数区分不同的情况： 同步发送 ...
RocketMQ （三）RocketMQ 怎么保证的消息不丢失？
一、消息发送过程 我们将消息流程分为如下三大部分，每一部分都有可能会丢失数据。 生产阶段：Producer通过网络将消息发送给Broker，这个发送可能会发生丢失，比如网络延迟不可达等。 存储阶段：Broker肯定是先把消息放到内存的，然后根据刷盘策略持久化到硬盘中，刚收到 ...
rocketMQ(七) rocketMQ 消息端配置
一.消息队列RocketMQ4.X消费者核心配置讲解 consumeFromWhere配置(某些情况失效：参考 https://blog.csdn.net/a417930422/article/details/83585397 ...
RocketMQ源码 — 九、 RocketMQ延时消息
通过设置消息被投递的时间来实现的，但是Apache RocketMQ在版本4.2.0中尚不支持指定时间 ...