阿里云：CentOS 8.3 64位
JDK：JDK 1.8.0_311
RocketMQ：RocketMQ 4.9.2
rocketmq-dashboard : 1.0.1
二、安装RocketMQ 2.1、安装RocketMQRocketMQ 4.9.2 官网地址：
Apache RocketMQ
[root@jeespring ~]# wget https://dlcdn.apache.org/rocketmq/4.9.2/rocketmq-all-4.9.2-bin-release.zip [root@jeespring ~]# unzip rocketmq-all-4.9.2-bin-release.zip -d /usr/local/ [root@jeespring ~]# cd /usr/local/rocketmq-4.9.2/2.2、修改 bin/runserver.sh
Name Server 默认启动内存比较大，需要修改一下内存配置参数
修改 bin/runserver.sh 配置文件，建议两处都修改，一个是jdk9之前的，一个是jdk9之后的配置，默认Xms和Xmx都是4g，可以修改成适合服务器配置的值。
修改成
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m -XX:metaspaceSize=128m -XX:MaxmetaspaceSize=160m"
2.2、修改 bin/runbroker.sh
Broker默认启动内存8g，可以修改成适合服务器配置的值。
修改为：
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m"
2.3、修改conf/broker.conf
修改broker.conf 只需要配置 namesrvAddr 和 brokerIP1的地址即可。
brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
namesrvAddr = {阿里云公网IP}:9876
brokerIP1 = {阿里云公网IP}
rocketmq数据默认的存储在${user.home}目录下，如果想修改commitlog的存储位置，可以在broker.conf 配置存储文件中配置 commitlog 存储路径
brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
namesrvAddr = {阿里云公网IP}:9876
brokerIP1 = {阿里云公网IP}
storePathRootDir = /usr/local/rocketmq-4.9.2/store
storePathCommitLog = /usr/local/rocketmq-4.9.2/store/commitlog
配置完成需要在 rocketmq 根目录创建文件夹，否则启动会报错。
[root@jeespring rocketmq-4.9.2]# mkdir -p store/commitlog
broker的配置参数说明如下：
三、启动RocketMQ 3.1、启动Name Server返回到rocketmq-4.9.2目录，启动nameserver
[root@jeespring rocketmq-4.9.2]# nohup sh bin/mqnamesrv &3.2、启动Broker
返回到rocketmq-4.9.2目录，启动broker
[root@jeespring rocketmq-4.9.2]# nohup sh bin/mqbroker -c conf/broker.conf &
启动结果如下
查看启动日志是否启动成功
3.3、自定义启动脚本name server和broker 启动脚本过长，不太容易记忆，可以在根目录下面新建2个启动脚本，方便下次启动。
echo "nohup sh bin/mqnamesrv &">> nameserver-start.sh echo "nohup sh bin/mqbroker -c conf/broker.conf &">> broker-start.sh chmod 777 nameserver-start.sh chmod 777 broker-start.sh
以后启动可以使用 nameserver-start.sh 和 broker-start.sh 启动rocketmq了
四、阿里云配置 4.1、关闭防火墙系统中，关于如何开启防火墙、关闭防火墙、查看防火墙运行状态，请参考以下信息：
- 开启防火墙
systemctl start firewalld.service
- 关闭防火墙
systemctl stop firewalld.service
- 查看防火墙运行状态
firewall-cmd --state
外网访问RocketMQ，还需要在阿里上面新增安全组配置
配置安全组放行端口：9876、10911、10909 三个端口。
4.3、测试消息发送本地代码测试往阿里云发送消息
public class Producer {
public static void main(String[] args) throws Exception {
DefaultMQProducer producer = new DefaultMQProducer("producer-group");
producer.setNamesrvAddr("阿里云公网IP:9876");
producer.start();
for (int i = 0; i < 10; i++) {
//public Message(String topic, String tags, byte[] body)
String msg = "同步消息-" + i;
Message message = new Message("simple-message","sync",msg.getBytes(RemotingHelper.DEFAULT_CHARSET));
SendResult sendResult = producer.send(message);
System.out.println(JSON.toJSonString(sendResult));
}
producer.shutdown();
}
}
此时阿里云store目录已经有了数据
