温馨提示：本文基于 Kafka 2.2.1 版本。 上文 "《源码分析 Kafka 消息发送流程》" 已经详细介绍了 KafkaProducer send 方法的流程，该方法只是将消息追加到 KafKaProducer 的缓存中，并未真正的向 broker 发送消息，本文将来探讨 Kafka 的 S ...
分类：
编程语言 时间：
2020-01-08 21:24:40
阅读次数：
215
什么是消息队列？ 为什么要用消息队列？ 即，应用场景是什么，也就是用了有什么好处 解耦 多应用间通过消息队列对同一消息进行处理，避免调用接口失败导致整个过程失败 异步 多应用对消息队列中同一消息进行处理，应用间并发处理消息，相比串行处理，减少处理时间 削峰／限流 避免流量过大导致应用系统挂掉的情况 ...
分类：
其他好文 时间：
2020-01-07 21:22:46
阅读次数：
144
1、下载 https://github.com/apache/rocketmq-externals 2、解压文件tar -zxvf rocketmq-externals-master.zip 3、移动文件并修改名字 mv rocketmq-externals-master/ /usr/local/r ...
分类：
其他好文 时间：
2020-01-06 23:16:33
阅读次数：
154
1、下载安装包：https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.2.0/rocketmq-all-4.2.0-bin-release.zip 2、解压文件tar -zxvf rocketmq-all-4.2.0-bin-release.zi ...
分类：
其他好文 时间：
2020-01-06 23:03:04
阅读次数：
93
点击查看折叠代码块 / 普通消息生产者 / public class Producer { public static void main(String[] args) throws Exception { // 创建一个消息发送入口对象，主要用于消息发送，指定生产者组 DefaultMQProdu ...
分类：
其他好文 时间：
2020-01-06 14:55:32
阅读次数：
67
Rocketmq原理&最佳实践 https://www.jianshu.com/p/2838890f3284 彦帧关注 142018.08.05 15:48:44字数 3,451阅读 174,582 一、 MQ背景&选型 消息队列作为高并发系统的核心组件之一，能够帮助业务系统解构提升开发效率和系统稳 ...
分类：
其他好文 时间：
2020-01-05 18:39:42
阅读次数：
59
1.原理图： 2.设计实现思路： 1.生产者（发送方）投递事务消息到Broker中，设置该消息为半消息 不可以被消费； 2.开始执行我们的本地事务，将本地事务执行的结果（回滚或者提交）发送给Broker； 3.Broker获取回滚或者提交，如果是回滚的情况则删除该消息、如果是提交的话，该消息就可以被 ...
分类：
其他好文 时间：
2020-01-03 10:39:00
阅读次数：
486
玩转MQTT-阿里云之MQTT使用（下） 摘要 为使物联网项目在正式使用时，能顺利切换到具有高并发高负载能力的服务平台，对阿里云提供的MQTT服务进行使用验证。 引言 之前写“MQTT之阿里云使用-玩转阿里云”这篇文章时，由于时间关系（写文章也是要花费大量时间的），打算将内容拆分为两部分，将写好的一 ...
分类：
其他好文 时间：
2019-12-31 23:22:23
阅读次数：
121
1、下载 下载地址：http://rocketmq.apache.org/release_notes/执行命令： 2、创建RocketMQ存储文件的目录,执行如下命令： 3. RocketMQ配置文件 4、进入conf目录，替换所有xml中的${user.home},保证日志路径正确 注意：sed ...
分类：
其他好文 时间：
2019-12-30 20:53:54
阅读次数：
97
消息队列 为什么写这篇文章? 博主有两位朋友分别是小A和小B: 小A，工作于传统软件行业(某社保局的软件外包公司)，每天工作内容就是和产品聊聊需求，改改业务逻辑。再不然就是和运营聊聊天，写几个SQL，生成下报表。又或者接到客服的通知，某某功能故障了，改改数据，然后下班部署上线。每天过的都是这种生活， ...
分类：
其他好文 时间：
2019-12-30 11:20:33
阅读次数：
71
