网站做ssl证书有风险,河北省水利建设市场网站,男女一夜做受视频最新网站,seo系统培训哪家好2.10日学习打卡
对于MQ(Message queue)消息队列的一些解释可以看我原来写的文章 初学RabbitMQ
各大MQ产品比较
一.RocketMQ概述
发展历程 RocketMQ概念术语
生产者和消费者 生产者负责生产消息#xff0c;一般由业务系统负责生产消息#xff0c;消费者即后台系统一般由业务系统负责生产消息消费者即后台系统它负责消费消息。 消息模型Message Model 消息模型主要有队列模型和发布订阅模型RabbitMQ采用的是队列模型如下图所示 RocketMQ采用发布订阅模型模型如图所示 主题Topic 表示一类消息的集合每个主题包含若干条消息每条消息只能属于一个主题是RocketMQ进行消息订阅的基本单位。
代理服务器Broker Server 消息中转角色负责存储消息、转发消息。
名字服务Name Server
名称服务管理代理服务器broker相当于一个管理机构。 生产者组Producer Group 同一类Producer的集合这类Producer发送同一类消息且发送逻辑一致。 消费者组Consumer Group 同一类Consumer的集合这类Consumer通常消费同一类消息且消费逻辑一致。
拉取式消费Pull Consumer Consumer消费的一种类型应用通常主动调用Consumer的拉消息方法从Broker服务器拉消息、主动权由应用控制。一旦获取了批量消息应用就会启动消费过程。
推动式消费Push Consumer Consumer消费的一种类型该模式下Broker收到数据后会主动推送给消费端该消费模式一般实时性较高。 普通顺序消息Normal Ordered Message 
export PATH$PATH:$ROCKETMQ_HOME/bin启动NameServer nohup sh mqnamesrv 启动broker nohup sh mqbroker -n localhost:9876
RocketMQ管理命令
mqadmin help 命令名称
启动namesrv和broker ./mqnamesrv #启动nameserver ./mqbroker -n localhost:9876 -c /opt/alibaba-rocketmq/conf/broker.conf #启动broker #启动broker tail -f ~/logs/rocketmqlogs/namesrv.log #查看日志 tail -f ~/logs/rocketmqlogs/broker.log #查看日志 新增topic mqadmin updateTopic -n localhost:9876 -c DefaultCluster -t topicWarning 查看某个topic的状态 mqadmin topicStatus -n localhost:9876 -t topicWarning 查看所有消费组group mqadmin consumerProgress -n localhost:9876 查看所有topic mqadmin topicList -n localhost:9876 删除topic mqadmin deleteTopic -n localhost:9876 -c DefaultCluster -t topicWarning 关闭namesrv和broker服务 mqshutdown namesrv mqshutdown broker 如果我的内容对你有帮助请点赞评论收藏。创作不易大家的支持就是我坚持下去的动力
