最近正在研究rocketmq,简单记录下设计的不同 互联网系统中Rpc、服务治理、消息中间件基本都是标配,消息中间件能解耦,削峰,高可用并能间接提供达到最终一致性 消息中间件中,消息消费分为最多一次,至少一次和刚好一次,如果需要实现刚好一次,则系统设计难度增大,系统性能损失增加,权衡利弊,rocke ...
分类:
其他好文 时间:
2018-12-17 14:20:15
阅读次数:
231
<!-- flowchart 箭头图标 勿删 --> 1、服务器环境 序号 IP 用户名 角色 模式 1 192.168.100.24 root nameServer1,brokerServer1 Master1 2 192.168.100.25 root nameServer2,brokerSer ...
分类:
其他好文 时间:
2018-12-15 12:08:05
阅读次数:
233
XA协议 性能不佳; 最佳实践:仅在同一个事务上下文中需要协调多种资源(即数据库,以及消息主题或队列)时,才有必要使用X/Open XA接口。 基于消息中间件的两阶段提交协议:RocketMQ基于此;在高并发场景下,将一个分布式事务拆成一个消息事务(A系统的本地操作+发消息)+B系统的本地操作,不是 ...
分类:
其他好文 时间:
2018-12-14 13:58:44
阅读次数:
191
一:环境准备: Windows、JDK1.8+、Maven、Git 二:RocketMQ准备: 1.http://rocketmq.apache.org/release_notes/release-notes-4.2.0/ 2.选择‘Binary’进行下载 下完完毕之后解压 三:配置 进行环境变量配 ...
订阅Topic主题 ,选择Tags都是我们简单的过滤。Topic是大分类,Tags是二级分类。 RocketMQ还有一种过滤机制MessageFilter,是在服务端开启过滤服务器,消费者将指定的java上传后,在服务端过滤。 这种会在很大程度上影响服务器性能,java类要确保简单安全,不占用过多资 ...
分类:
其他好文 时间:
2018-12-10 11:29:56
阅读次数:
189
参考文献 https://blog.csdn.net/songxinjianqwe/article/details/78923482 基于Dubbo&RocketMQ实现SOA与分布式事务(三) https://ask.csdn.net/questions/368265?sort=id active ...
分类:
其他好文 时间:
2018-12-07 15:00:36
阅读次数:
184
系统环境 1、操作系统:64位CentOS Linux release 7.2.1511 (Core) 2、jdk版本:1.8.0_121 3、IP地址:192.168.1.210 下载rocketmq 访问网址:http://rocketmq.apache.org/docs/quick-start ...
分类:
其他好文 时间:
2018-12-07 12:59:34
阅读次数:
238
参考 http://www.iocoder.cn/categories/RocketMQ/ ; https://www.jianshu.com/nb/16219849 首先上启动方法,分别启动namesrv/broker/procedure/consumer ...
分类:
其他好文 时间:
2018-12-05 20:58:30
阅读次数:
188
本文将对rocktmq-spring-boot的设计实现做一个简单的介绍,读者可以通过本文了解将RocketMQ Client端集成为spring-boot-starter框架的开发细节,然后通过一个简单的示例来一步一步的讲解如何使用这个spring-boot-starter工具包来配置,发送和消费RocketMQ消息。
分类:
编程语言 时间:
2018-12-05 18:34:31
阅读次数:
184
介绍 注:没有注册中心,总共只分为三个角色,product,server,customer。 Queue 消息队列,等同于rocketmq中的topic Exchange 生产者产生的消息并不是直接发送给消息队列Queue的,而是要经过Exchange(交换器),由Exchange再将消息路由到一个 ...
分类:
其他好文 时间:
2018-12-03 12:44:46
阅读次数:
194