RocketMQ 是一款分布式、队列模型的消息中间件,具有以下特点:
能够保证严格的消息顺序,提供丰富的消息拉取模式,高效的订阅者水平扩展能力,实时的消息订阅机制,亿级消息堆积能力,
前置知识
ssh工具
连接linux工具SecureCRT
Linux相关知识
centos7
防火墙firewalld
的基本使用,参考
- 启动:
systemctl start firewalld
- 查看状态:
systemctl status firewalld
- 停止:
systemctl disable firewalld
- 禁用:
systemctl stop firewalld
配置firewalld-cmd
- 查看版本:
firewall-cmd --version
- 查看帮助:
firewall-cmd --help
- 显示状态:
firewall-cmd --state
- 查看所有打开的端口:
firewall-cmd --zone=public --list-ports
- 更新防火墙规则:
firewall-cmd --reload
- 查看区域信息:
firewall-cmd --get-active-zones
- 查看指定接口所属区域:
firewall-cmd --get-zone-of-interface=eth0
- 拒绝所有包:
firewall-cmd --panic-on
- 取消拒绝状态:
firewall-cmd --panic-off
- 查看是否拒绝:
firewall-cmd --query-panic
开启一个对外端口步骤
- 先查看是否开启,查看所有打开的端口:
firewall-cmd --zone=public --list-ports
- 添加:
firewall-cmd --zone=public --add-port=80/tcp --permanent
(–permanent永久生效,没有此参数重启后失效)
1 | //命令含义: |
- 重新载入:
firewall-cmd --reload
- 查看是否开启:
firewall-cmd --zone=public --query-port=80/tcp
- 删除:
firewall-cmd --zone= public --remove-port=80/tcp --permanent
服务器环境(针对2m-noslave
)
序号 | IP | 用户名 | 密码 | 角色 | 模式
—|—|—|—|—|—|—|—
1 | 192.168.100.24| root| | nameServer1,brokerServer1|Master1
2 | 192.168.100.25| root| | nameServer2,brokerServer2|Master2
Hosts添加信息
修改host,做集群的通讯(两台机器都修改)
1 | vim /etc/hosts |
IP | NAME |
---|---|
192.168.100.24 | rocketmq-nameserver1 |
192.168.100.24 | rocketmq-master1 |
192.168.100.25 | rocketmq-nameserver2 |
192.168.100.25 | rocketmq-master2 |
RocketMQ
最简单部署 – 单namesrv
单broker
- 1.jdk安装
rocketmq安装
上传解压
上传
使用 rz
sz
插件,进行上传下载
1 | yum install -y lrzsz |
上传命令为rz
,下载命令为sz
解压安装
1 | tar -zxvf alibaba-rocketmq-3.2.6.tar.gz -C /usr/local //解压到指定目录下 |
创建存储路径
1 | mkdir /usr/local/rocketmq/store |
修改RocketMQ配置文件
1 | vim /usr/local/rocketmq/conf/2m-noslave/broker-a.properties |
作为broker
启动时的参数配置文件
参考配置
1 | #所属集群名字 |
修改日志配置文件
1 |
修改启动脚本参数
1 |
上面两步省略,直接上传到linux解压等即可
启动服务namesrv
1.到bin目录下
加入执行权限 chmod +x *
2.修改启动的堆内存初始大小
1 | `vim runserver.sh` //更改内存设置 |
3.启动
1 | ./mqnamesrv |
4.后台运行进程:
1 | nohup ./mqnamesrv & |
5.jps查看进程
查看是否成功: tail -f nohup.out
启动服务broker(master)
1.修改启动的堆内存初始大小
1 |
|
2. 启动
1 | nohup sh mqbroker -n "192.168.1.107:9876" & |
3.指定配置文件的方式启动
1 | nohup sh mqbroker -n "192.168.1.107:9876" -c ../conf/2m-noslave/broker-a.properties > broker.out & |
4.使用./mqadmin
来观察namesrv和broker的情况
1 | ./mqadmin clusterList -n 192.168.1.107:9876 //ip为namesrv地址 |
查看是否成功启动
1 | netstat -ntlp |
停止Rocketmq
1 | cd /usr/local/rocketmq/bin |
数据清理(停止后进行数据清理)
1 | --等待停止 |
5.RocketMQ
需要打开的防火请端口号 9876,10911,10912
原文链接: https://hzways.gitee.io/p/86274e11.html
版权声明: 转载请注明出处.