tips:最近在使用RocketMQ作为消息中间件使用，于是在本地windows上也安装了一个，计划模拟测试各项功能。但是发现想要修改端口，修改nameserver等都不成功，程序要么连接不是nameserver，要么发送消息失败。摸索了一阵子，记录使用过程。（网上挺多关于Linux下的使用，windows较少，于是补充）
Windows下使用RocketMQ
关于RocketMQ
RocketMQ 是阿里巴巴开源的分布式消息中间件。就不具体说了，网上资料说的清楚。主要名词有：
我把RocketMQ理解为一台路由器
- Broker 存储消息，转发消息，当作一条路由信息（包含topic）
- NameServer 当作是一个路由注册中心，比如路由器中的路由表。它记录了一条条broker（路由信息），能够根据topic找到相应的broker
- Producer 连接上路由表（NameServer），提供topic找到路由信息（broker），发消息给broker存储
- Consumer 连接上路由表（NameServer），提供topic找到路由信息（broker）并保持连接，用于接收来自topic对应broker的消息
流程：
启动NameServer——》启动 Broker，注册路由信息到NameServer中
启用Producer——》指定NameServer，获取Topic信息——》根据topic找到对应的Broker——》Producer发送消息到Broker
启用Consumer——》指定NameServer，获取Topic信息——》根据所监听的topic找到对应的Broker——》监听接收相应Broker消息
使用RocketMQ
RocketMQ安装就不说了。下载解压即可。记得配置环境变量
默认启动
启动服务
- 进入bin目录，执行：start mqnameSrv.cmd 启动nameServer，不关闭窗口
- 进入bin目录，执行：start mqbroker.cmd 启动broker，不关闭窗口
默认的nameserver，启动使用的是9876端口，通过netstat可以看到，随着nameserver的启动，9876端口也就使用了
关闭nameserver，9876就未使用
启动broker，指定连接-n 127.0.0.1:9876，也就是默认的nameserver
查看服务，执行jps，可以看到nameserver和broker已启动
用springboot程序测试
application.properties 配置nameSrv地址。配置完后，程序启动producer及consumer会连接相应的nameserver。因为上面已经启动broker注册路由信息到nameSrv中了，producer和consumer会从nameSrv获取相应信息找到broker进行发消息及消费消息
# 指定nameserver
rocketmq.name-server=127.0.0.1:9876
rocketmq.producer.group=first-producer-group
rocketmq.consumer.group=first-consumer-group
producer 指定要发送的topic及消息
@RestController
public class Producer {
@Autowired
private RocketMQTemplate rocketMQTemplate;
@GetMapping("send")
public void send(){
rocketMQTemplate.convertAndSend("TEST-TOPIC","Hello World!");
}
}
consumer 指定要监听的topic
@Component
@RocketMQMessageListener(topic = "TEST-TOPIC",consumerGroup = "${rocketmq.consumer.group}")
public class Consumer implements RocketMQListener<String> {
private static final Logger log = LoggerFactory.getLogger(Consumer.class);
@Override
public void onMessage(String message) {
log.info("我收到消息了！消息内容为：" + message);
}
}
启动程序测试，可以看到控制台输出消息
修改nameserver端口启动
有时候不想使用默认的9876端口，就需要修改为想要的。在conf目录下，添加namesrv.properties文件，添上如下一行
listenPort=9092
启动
1、启动namesrv:需要指定配置文件启动
执行：
start mqnamesrv.cmd -c ..\conf\namesrv.properties
可以看到9876和9092的端口使用情况，9876未使用，9092被使用
2、启动broker:需要指定9092的启动
测试
到这里，两个服务都启动了，接下来就测试一下，能否使用。还是用原来的程序，修改配置文件的nameserver
rocketmq.name-server=127.0.0.1:9092
rocketmq.producer.group=first-producer-group
rocketmq.consumer.group=first-consumer-group
如果不修改，启动程序会报错，那肯定是连不上，现在启动的是9092的nameserver了呀
到这，暂时结束rocketmq的探索。因为认知有限，有错误的地方，欢迎指出，相互探讨。
个人网站：https://liwangc.gitee.io/
—————————————————————————
58Tiu-1645883392523)]
到这，暂时结束rocketmq的探索。因为认知有限，有错误的地方，欢迎指出，相互探讨。
个人网站：https://liwangc.gitee.io/
—————————————————————————
作为初学者，很多知识都没有掌握，见谅，如有错误请指出，以期进步，感谢！。后续有新的学习，继续补充上来。