本文编写,参考:https://my.oschina.net/bieber/blog/725646 producer Send()的Message最终将由broker处理,处理类为:SendMessageProcessor ,处理方法:processRequet. ...
分类:
其他好文 时间:
2017-06-27 18:38:23
阅读次数:
183
‘RocketMQ部署(双Master) 参考 rocketMQ使用手册.pdf nameServer,brokerServer在同一台机器上 添加hosts信息 /etc/hosts 测试下互拼 ping rocketmq-nameserver2 . . 两台机器上传rocketmq并解压 两台创 ...
分类:
其他好文 时间:
2017-06-22 10:16:42
阅读次数:
227
之前在讲RPC通信的各种好处,特别好用,但是RPC并不是万能的,也并不是适用于各种场景的,因为他是同步的;现如今很多场景下的调用都是异步的,系统A调用B后,并不需要知道B的结果,而且对B的结果无所谓,甚至你B挂了都无所谓,那么这个时候使用消息队列是十分OK的。 最简单的场景就是发送短信和email, ...
分类:
其他好文 时间:
2017-06-14 21:17:47
阅读次数:
194
一、几个重要的地址 二、下载及编译(以下内容基本出自【快速入门】) 三、启动NameServer 四、启动Broker 五、关闭NameServer 六、关闭Broker ...
分类:
其他好文 时间:
2017-06-12 22:22:54
阅读次数:
146
最近,在公司的测试环境,遇到个问题,每次重启应用重启后,原来消费过的消息又被重复推送了一遍,消费者和生产者代码如下: 消费端代码: ...
分类:
其他好文 时间:
2017-06-11 20:07:22
阅读次数:
1439
引言 分布式系统中,我们广泛运用消息中间件进行系统间的数据交换,便于异步解耦。现在开源的消息中间件有很多,前段时间我们自家的产品 RocketMQ (MetaQ的内核) 也顺利开源,得到大家的关注。 那么,消息中间件性能究竟哪家强? 带着这个疑问,我们中间件测试组对常见的三类消息产品(Kafka、R ...
分类:
其他好文 时间:
2017-06-11 19:10:38
阅读次数:
312
一、Rocketmq简介: RocketMQ是一款分布式、队列模型的消息中间件,具有以下特点:1、支持严格的消息顺序;2、支持Topic与Queue两种模式;3、亿级消息堆积能力;4、比较友好的分布式特性;5、同时支持Push与Pull方式消费消息; (本文采用双Master架构模式。) 二、服务器 ...
分类:
其他好文 时间:
2017-06-07 18:48:14
阅读次数:
268
1.分布式系统的架构体系 基于对象的体系机构 面向服务的架构(SOA) REST风格的架构 微服务架构(MSA) 容器技术 Serverless架构 2.分布式消息服务 Apache ActiveMQ RabbitMQ RocketMQ Apache Kafka 3.分布式计算 MapReduce ...
分类:
其他好文 时间:
2017-06-04 23:04:45
阅读次数:
407