89.RocketMQ-RocketMQ设计思想与环境搭建

一、RocketMQ环境基本的介绍

89.RocketMQ-RocketMQ设计思想与环境搭建

实现顺序消息,保证只有一个消费者:
89.RocketMQ-RocketMQ设计思想与环境搭建

二、RocketMQ与其他MQ的区别

89.RocketMQ-RocketMQ设计思想与环境搭建
89.RocketMQ-RocketMQ设计思想与环境搭建

三、NameServer核心的作用

89.RocketMQ-RocketMQ设计思想与环境搭建

四、RocketMQ底层核心实现原理

89.RocketMQ-RocketMQ设计思想与环境搭建
89.RocketMQ-RocketMQ设计思想与环境搭建
89.RocketMQ-RocketMQ设计思想与环境搭建
89.RocketMQ-RocketMQ设计思想与环境搭建
89.RocketMQ-RocketMQ设计思想与环境搭建
89.RocketMQ-RocketMQ设计思想与环境搭建

五、RocketMQ与kafka底层实现区别

1、RocketMQ和kafka有那些区别呢?。

  1. 在kafka注册采用zookeeper.
    2.RocketMQ采用自己独立编写nameServer.

2、RocketMQ不用zk而是用nameServer呢?

  1. 因为zk选举必须要满足过半机制才可以使用,而我们nameServer去中心化。
    只需要有一个nameServer在,整个注册中心环境就可以使用。。
    2.自己编写注册中心可以快速实现扩展功能
    在kafka中Broker是物理概念但是在RocketMQ一个Broker等于多个master组合
    其次新增事务消息、顺序消息。

六、Linux环境搭建单机版本RocketMQ

89.RocketMQ-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
89.RocketMQ-RocketMQ设计思想与环境搭建

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 &
89.RocketMQ-RocketMQ设计思想与环境搭建

4.启动mqbroker

nohup sh bin/mqbroker -c ./conf/broker.conf -n 127.0.0.1:9876 &
89.RocketMQ-RocketMQ设计思想与环境搭建
89.RocketMQ-RocketMQ设计思想与环境搭建

说明启动成功
89.RocketMQ-RocketMQ设计思想与环境搭建

cat nohup.out

89.RocketMQ-RocketMQ设计思想与环境搭建
broker地址:10911 成功注册到了 name sever上了
89.RocketMQ-RocketMQ设计思想与环境搭建

5、进入broker.conf

89.RocketMQ-RocketMQ设计思想与环境搭建
89.RocketMQ-RocketMQ设计思想与环境搭建

0表示主节点
89.RocketMQ-RocketMQ设计思想与环境搭建

七、RocketMQ控制台的使用

89.RocketMQ-RocketMQ设计思想与环境搭建
89.RocketMQ-RocketMQ设计思想与环境搭建

八、SpringBoot整合RocketMQ

89.RocketMQ-RocketMQ设计思想与环境搭建
生产者必须分组:
89.RocketMQ-RocketMQ设计思想与环境搭建
89.RocketMQ-RocketMQ设计思想与环境搭建
89.RocketMQ-RocketMQ设计思想与环境搭建
服务器时间:
89.RocketMQ-RocketMQ设计思想与环境搭建
89.RocketMQ-RocketMQ设计思想与环境搭建
自动转化成json:
89.RocketMQ-RocketMQ设计思想与环境搭建

九、消费者获取消息实现消费

89.RocketMQ-RocketMQ设计思想与环境搭建
89.RocketMQ-RocketMQ设计思想与环境搭建

89.RocketMQ-RocketMQ设计思想与环境搭建89.RocketMQ-RocketMQ设计思想与环境搭建 lvhy踩坑之路 发布了118 篇原创文章 · 获赞 12 · 访问量 2万+ 私信 关注
上一篇:RocketmMQ的组成及相关概念


下一篇:wget: unable to resolve host address的解决方法