1、简介 RocketMQ主要由 Producer、Broker、Consumer 三部分组成，其中Producer 负责生产消息，Consumer 负责消费消息，Broker 负责存储消息。Broker 在实际部署过程中对应一台服务器，每个 Broker 可以存储多个Topic的消息，每个Topic的消息也可以分片存储于不同的 Broker。Message Queue 用于存储消息的物理地址，每个Topic中的消息地址存储于多个 Message Queue 中。ConsumerGroup 由多个Consumer 实例构成。 更多信息参考官网：https://github.com/apache/rocketmq/tree/master/docs/cn 2、spring boot集成RocketMQ 2.1、引入依赖 spring boot依赖 <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</ar.... 有更新！ spring boot整合rocketmq rocketmq
1、拉取镜像 docker pull rocketmqinc/rocketmq 2、启动mqnamesrv docker run -d --name=rmqnamesrv -p 9876:9876 -v D:\download\docker\rocketmq\nameserver\logs:/root/logs -v D:\download\docker\rocketmq\nameserver\store:/root/store -e "MAX_POSSIBLE_HEAP=100000000" rocketmqinc/rocketmq sh mqnamesrv 3、启动broker 新建配置文件broker.cnf # 所属集群名称，如果节点较多可以配置多个 brokerClusterName = DefaultCluster #broker名称，master和slave使用相同的名称，表明他们的主从关系 brokerName = broker-a #0表示Master，大于0表示不同的slave brokerId = 0 #表示几点做消息删除动作，默认是凌晨4点 deleteWh.... docker安装rocketmq 程序人生
问尤龙の时光