哪一个平阳网站建设,重庆网站推广招聘,网站的系统建设方式有哪些内容,携程网站建设目的1、RocketMQ基本概念
1.1 消息模型#xff08;Message Model#xff09;
RocketMQ主要由Producer、Broker、Consumer三部分组成#xff0c;其中Producer负责生产消息#xff0c;Consumer负责消费消息#xff0c;Broker负责存储消息。Broker在实际部署过程中对应一台服务…1、RocketMQ基本概念
1.1 消息模型Message Model
RocketMQ主要由Producer、Broker、Consumer三部分组成其中Producer负责生产消息Consumer负责消费消息Broker负责存储消息。Broker在实际部署过程中对应一台服务器每个Broker可以存储多个Topic的消息每个Topic的消息也可以分片存储于不同的Broker。MessageQueue用于存储消息的物理地址每个Topic中的消息地址存储于多个MessageQueue中。ConsumerGroup由多个Consumer实例构成。
1.2 代理服务器Broker Server
消息中转角色负责存储消息、转发消息。代理服务器在RocketMQ系统中负责接收从生产者发送来的消息并存储、同时为消费者的拉取请求作准备。代理服务器也存储消息相关的元数据包括消费者组、消费进度偏移和主题和队列消息等。
1.3 名字服务Name Server
名称服务充当路由消息的提供者。生产者或消费者能够通过名字服务查找各主题相应的BrokerIP列表。多个Namesrv实例组成集群但相互独立没有信息交换。
2、安装NameServer
搜索/拉取镜像
docker search rocketmqdocker pull rocketmqinc/rocketmq创建一个数据目录
mkdir -p /docker/rocketmq/nameserver/logs /docker/rocketmq/nameserver/store
运行
docker run -d --restartalways --name rmqnamesrv --privilegedtrue -p 9876:9876 -v /docker/rocketmq/nameserver/logs:/root/logs -v /docker/rocketmq/nameserver/store:/root/store -e MAX_POSSIBLE_HEAP100000000 rocketmqinc/rocketmq sh mqnamesrv参数说明
参数说明-d以守护进程的方式启动- -restartalwaysdocker重启时候容器自动重启- -name rmqnamesrv把容器的名字设置为rmqnamesrv-p 9876:9876把容器内的端口9876挂载到宿主机9876上面-v /docker/rocketmq/nameserver/logs:/root/logs目录挂载-v /docker/rocketmq/nameserver/store目录挂载rmqnamesrv容器的名字-e “MAX_POSSIBLE_HEAP100000000”设置容器的最大堆内存为100000000rocketmqinc/rocketmq使用的镜像名称sh mqnamesrv启动namesrv服务
3、安装broker
创建broker.conf配置文件我的目录是/opt/docker/rocketmq/broker.conf文件内容如下
brokerClusterName DefaultCluster
brokerName broker-a
brokerId 0
deleteWhen 04
fileReservedTime 48
brokerRole ASYNC_MASTER
flushDiskType ASYNC_FLUSH
brokerIP1 主机的IP
启动broker docker run -d --restartalways --name rmqbroker --link rmqnamesrv:namesrv -p 10911:10911 -p 10909:10909 --privilegedtrue -v /docker/rocketmq/data/broker/logs:/root/logs -v /docker/rocketmq/data/broker/store:/root/store -v /opt/docker/rocketmq/broker.conf:/opt/docker/rocketmq/broker.conf -e NAMESRV_ADDRnamesrv:9876 -e MAX_POSSIBLE_HEAP200000000 rocketmqinc/rocketmq sh mqbroker -c /opt/docker/rocketmq/broker.conf 参数 说明
-d以守护进程的方式启动--restartalwaysdocker重启时候容器自动重启--name rmqbroker把容器的名字设置为rmqbroker--link rmqnamesrv:namesrv和rmqnamesrv容器通信-p 9876:9876把容器内的端口9876挂载到宿主机9876上面-p 10909:10909把容器的vip通道端口挂载到宿主机-e “NAMESRV_ADDRnamesrv:9876”指定namesrv的地址为本机namesrv的ip地址:9876-e “MAX_POSSIBLE_HEAP200000000” rocketmqinc/rocketmq sh mqbroker指定broker服务的最大堆内存rocketmqinc/rocketmq使用的镜像名称sh mqbroker -c /opt/docker/rocketmq/broker.conf指定配置文件启动broker节点
4、安装控制台
拉取镜像
docker pull pangliang/rocketmq-console-ng
控制台启动
docker run -d --restartalways --name rmqadmin -e JAVA_OPTS-Drocketmq.namesrv.addr122.112.145.138:9876 -Dcom.rocketmq.sendMessageWithVIPChannelfalse -p 8080:8080 pangliang/rocketmq-console-ng
访问
ip:8080 访问出现如下界面
