一、RocketMQ环境基本的介绍
实现顺序消息,保证只有一个消费者:
二、RocketMQ与其他MQ的区别
三、NameServer核心的作用
四、RocketMQ底层核心实现原理
五、RocketMQ与kafka底层实现区别
1、RocketMQ和kafka有那些区别呢?。
- 在kafka注册采用zookeeper.
2.RocketMQ采用自己独立编写nameServer.
2、RocketMQ不用zk而是用nameServer呢?
- 因为zk选举必须要满足过半机制才可以使用,而我们nameServer去中心化。
只需要有一个nameServer在,整个注册中心环境就可以使用。。
2.自己编写注册中心可以快速实现扩展功能
在kafka中Broker是物理概念但是在RocketMQ一个Broker等于多个master组合
其次新增事务消息、顺序消息。
六、Linux环境搭建单机版本RocketMQ
RocketMQ单机版本安装
上传最新的RocketMQ安装包 rocketmq-all-4.6.0-bin-release
1.解压配置文件
unzip rocketmq-all-4.6.0-bin-release.zip
-bash: unzip: 未找到命令
解决办法:yum install -y unzip zip
2.修改NameServer、Broker服务器内存 默认为4g内存、8G
runserver.sh
JAVA_OPT="${JAVA_OPT} -server –Xms128m –Xmx128m –Xmn128m"
runbroker.sh
JAVA_OPT="${JAVA_OPT} -server –Xms128m –Xmx128m –Xmn128m"
3.启动NameServer
nohup sh bin/mqnamesrv &
4.启动mqbroker
nohup sh bin/mqbroker -c ./conf/broker.conf -n 127.0.0.1:9876 &
说明启动成功
cat nohup.out
broker地址:10911 成功注册到了 name sever上了
5、进入broker.conf
0表示主节点
七、RocketMQ控制台的使用
八、SpringBoot整合RocketMQ
生产者必须分组:
服务器时间:
自动转化成json: