RocketMQ整理 概念 broker MQ服务节点 topic 主题 message queue 消息队列,类似于kafka中的partition producer 生产者,先去连接name server,查询到对应的broker信息,再去连接broker consumer 消费者,先去连接na ...
分类:
其他好文 时间:
2019-07-23 11:39:13
阅读次数:
85
rocketmq的主要部分是由4种集群构成的:namesrv集群、broker集群、producer集群和consumer集群。 namesrv集群:也就是注册中心,rocketmq在注册中心这块没有使用第三方的中间件,而是自己写的代码来实现的,代码行数才1000行,producer、broker和 ...
分类:
其他好文 时间:
2019-07-22 15:20:47
阅读次数:
81
一、安装: http://rocketmq.apache.org/dowloading/releases/ https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.5.1/rocketmq-all-4.5.1-bin-release.zip 启动 ...
分类:
其他好文 时间:
2019-07-20 13:17:11
阅读次数:
92
https://blog.csdn.net/haoyuyang/article/details/53243785 1.为什么选择Netty 上一篇文章我们已经了解了Socket通信(IO/NIO/AIO)编程,对于通信模型已经有了一个基本的认识。其实上一篇文章中,我们学习的仅仅是一个模型,如果想把这 ...
分类:
Web程序 时间:
2019-07-20 12:57:21
阅读次数:
153
1.系统构架 企业服务总线(ESB)、微服务、面向服务的架构(SOA) 2.系统系统集成技术 Wsbservice、Socket 3.RPC远程调用的相关开源框架: dubbo、zookeeper、netty 4.关系型数据库 sqlserver oracle db2 mysql postgis 熟 ...
分类:
编程语言 时间:
2019-07-20 09:19:48
阅读次数:
141
1、RocketMQ结构 通过topic确定将消息发送到不同broker;broker中有多个messagequeue,消息放松到broker后经过轮询算法、hash算法等将消息发送到不同的messagequeue上 messagequeue本身不存放消息,真正的消息存放在commitlog中,me ...
分类:
其他好文 时间:
2019-07-11 15:47:20
阅读次数:
172
7 月 6 日,Apache Flink Meetup X Apache RocketMQ · 上海站,来自阿里巴巴、网易的 Flink 技术专家与 Apache RocketMQ 社区大咖一起分享关于 Flink、RocketMQ 的应用实践与前沿技术。
分类:
Web程序 时间:
2019-07-09 20:49:12
阅读次数:
151
1.引入相关Maven依赖: <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-i ...
分类:
编程语言 时间:
2019-07-07 16:07:47
阅读次数:
204
rocketMq建立监听: 一个groupId下通常会挂载多个consumer实例。 集群订阅方式 (默认):一个监听到之后,另一个consumer实例就不会再监听到(不管在不在一个服务器上)。 由于默认集群订阅方式,只能有一个监听到,所以,本地测试和服务器上topic不能一致,否则会影响服务器上监 ...
分类:
其他好文 时间:
2019-07-04 21:28:58
阅读次数:
163
RocketMQ 是一款分布式消息中间件,最初是由阿里巴巴消息中间件团队研发并大规模应用于生产系统,满足线上海量消息堆积的需求, 在 2016 年底捐赠给 Apache 开源基金会成为孵化项目,经过不到一年时间正式成为了 Apache 顶级项目。早期阿里曾经基于 ActiveMQ 研发消息系统, 随 ...
分类:
其他好文 时间:
2019-07-03 20:03:06
阅读次数:
142