作品集模板网站,女教师遭网课入侵视频大全播放,以公开的文化,佛山自定义网站建设RocketMQ 领域模型
RockeMQ整体结构预览 RocketMQ 中的一些概念 Topic#xff1a;主题#xff0c;可以理解为类别、分类的概念 MessageQueue#xff1a;消息队列#xff0c;存储数据的一个容器#xff08;队列索引数据#xff09;#xff0c;默认每个 Topic 下有 4 个队…RocketMQ 领域模型
RockeMQ整体结构预览 RocketMQ 中的一些概念 Topic主题可以理解为类别、分类的概念 MessageQueue消息队列存储数据的一个容器队列索引数据默认每个 Topic 下有 4 个队列被分配出来存储消息。 Message消息真正携带信息的载体概念 Producer生产者负责发送消息 Consumer消费者负责消费消息 ConsumerGroup众多消费者构成的整体或构成的集群称之为消费者组。 Subscription订阅关系消费者得知道自己需要消费哪个 Topic 下的哪个队列的数据
RocketMQ 单机服务搭建
二进制下载主页 启动文档 我这里使用docker具体的启动参数我没有研究只是搭建一个可用的跑案例:
docker run -d -p 9876:9876 -v /env/liyong/data/docker/rocketmq/namesrv/logs:/root/logs -v /env/liyong/data/docker/rocketmq/namesrv/store:/root/store --name rmqnamesrv -e MAX_POSSIBLE_HEAP100000000 apache/rocketmq:5.1.4 sh mqnamesrvdocker run -d -p 10911:10911 -p 10909:10909 -v /env/liyong/data/docker/rocketmq/broker/logs:/root/logs -v /env/liyong/data/docker/rocketmq/broker/store:/root/store -v /env/liyong/data/docker/rocketmq/broker/conf/broker.conf:/opt/rocketmq/conf/broker.conf --name rmqbroker --link rmqnamesrv:namesrv -e NAMESRV_ADDRnamesrv:9876 -e MAX_POSSIBLE_HEAP100000000 -e JAVA_OPT_EXT-server -Xms1g -Xmx1g -Xmn512m apache/rocketmq:5.1.4 sh mqbroker -c /opt/rocketmq/conf/broker.conf
#控制台
docker run -d --name rmqconsole -p 9800:8080 --link rmqnamesrv:namesrv -e JAVA_OPTS-Drocketmq.namesrv.addrnamesrv:9876 -Dcom.rocketmq.sendMessageWithVIPChannelfalse -t apacherocketmq/rocketmq-dashboard
#broker.conf
#这段配置是我网上找的,如果是要生产环境使用的话可以再研究一下官方文档
# 所属集群名称如果节点较多可以配置多个
brokerClusterName DefaultCluster
#broker名称master和slave使用相同的名称表明他们的主从关系
brokerName broker-a
#0表示Master大于0表示不同的slave
brokerId 0
#表示几点做消息删除动作默认是凌晨4点
deleteWhen 04
#在磁盘上保留消息的时长单位是小时
fileReservedTime 48
#有三个值SYNC_MASTERASYNC_MASTERSLAVE同步和异步表示Master和Slave之间同步数据的机制
brokerRole ASYNC_MASTER
#刷盘策略取值为ASYNC_FLUSHSYNC_FLUSH表示同步刷盘和异步刷盘SYNC_FLUSH消息写入磁盘后才返回成功状态ASYNC_FLUSH不需要
flushDiskType ASYNC_FLUSH
# 设置broker节点所在服务器的ip地址 我这边直接给的服务器的外网地址
brokerIP1 111.229.199.181
# 磁盘使用达到95%之后,生产者再写入消息会报错 CODE: 14 DESC: service not available now, maybe disk full
diskMaxUsedSpaceRatio95
#是否开启消息轨迹 用于记录消息
traceTopicEnabletrue需要注意这里如果内存不够是会报异常无法启动 指定这个参数即可 -e “JAVA_OPT_EXT-server -Xms1g -Xmx1g -Xmn512m”
控制台看板如果是云服务器不要忘记暴露该暴露的端口
