1. 下载RocketMQ
- 访问RocketMQ官方网站:https://rocketmq.apache.org/
- 进入下载页面,选择合适的版本(如4.9.0),并选择相应操作系统的二进制文件(tar.gz)下载。
2. 解压RocketMQ
使用以下命令解压下载的压缩包:
tar -zxvf rocketmq-[version].tar.gz
3. 启动Name Server
进入解压后的RocketMQ文件夹,并找到 bin 目录。使用以下命令启动Name Server,默认监听端口为9876。
./mqnamesrv
4. 配置Broker
在RocketMQ文件夹下的 conf 目录中,复制 broker.conf 文件为 broker-[brokerName].properties,其中 [brokerName] 可以自定义。然后编辑 broker-[brokerName].properties 文件,将以下参数设置为你的Name Server的IP和端口:
namesrvAddr=[Name Server IP]:9876
你还可以根据需要设置其他参数。
5. 启动Broker
在bin目录下,使用以下命令启动Broker:
./mqbroker -c ../conf/broker-[brokerName].properties
6. 测试RocketMQ
编写一个发送消息的程序,并确保已经引入RocketMQ的客户端依赖。在程序中指定Name Server的IP和端口,通过Producer发送消息到指定的Topic。同时编写一个接收消息的程序,通过Consumer订阅并消费消息。运行测试程序,确保消息发送和消费正常。
本文暂时没有评论,来添加一个吧(●'◡'●)