tips:最近在使用RocketMQ作为消息中间件使用，于是在本地windows上也安装了一个，计划模拟测试各项功能。但是发现想要修改端口，修改nameserver等都不成功，程序要么连接不是nameserver，要么发送消息失败。摸索了一阵子，记录使用过程。（网上挺多关于Linux下的使用，windows较少，于是补充）

Windows下使用RocketMQ

关于RocketMQ

RocketMQ 是阿里巴巴开源的分布式消息中间件。就不具体说了，网上资料说的清楚。主要名词有：

我把RocketMQ理解为一台路由器

1. Broker 存储消息，转发消息，当作一条路由信息（包含topic）
2. NameServer 当作是一个路由注册中心，比如路由器中的路由表。它记录了一条条broker（路由信息），能够根据topic找到相应的broker
3. Producer 连接上路由表（NameServer），提供topic找到路由信息（broker），发消息给broker存储
4. Consumer 连接上路由表（NameServer），提供topic找到路由信息（broker）并保持连接，用于接收来自topic对应broker的消息

流程：

启动NameServer——》启动 Broker，注册路由信息到NameServer中

启用Producer——》指定NameServer，获取Topic信息——》根据topic找到对应的Broker——》Producer发送消息到Broker

启用Consumer——》指定NameServer，获取Topic信息——》根据所监听的topic找到对应的Broker——》监听接收相应Broker消息

使用RocketMQ

RocketMQ安装就不说了。下载解压即可。记得配置环境变量

默认启动

启动服务

1. 进入bin目录，执行：start mqnameSrv.cmd 启动nameServer，不关闭窗口
2. 进入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/
—————————————————————————
作为初学者，很多知识都没有掌握，见谅，如有错误请指出，以期进步，感谢！。后续有新的学习，继续补充上来。