Linux 内网安装 RabbitMQ
Posted Eliauk
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Linux 内网安装 RabbitMQ相关的知识，希望对你有一定的参考价值。
1、前言
- rabbitmq安装方式有多种，本文只涉及内网环境下安装。
- 内网环境中，在依赖齐全的情况下(gcc gcc-c++ kernel-devel m4 ncurses-devel openssl-devel 等)，可以用对应的rpm包进行安装，本文章不涉及。
- 无依赖情况，以下为源码包安装过程。
2、安装前准备
2.1 下载RabbitMQ
源码下载地址：https://www.rabbitmq.com/install-generic-unix.html
2.2 下载Erlang
RabbitMQ是一款使用Erlang语言开发的，实现AMQP(高级消息队列协议)的开源消息中间件。系统须提供 Erlang环境
Erlang和RabbitMQ版本对照：https://www.rabbitmq.com/which-erlang.html
这里安装最新版本3.11.11的RabbitMQ，对应的Erlang版本推荐25.0 - 25.3，这里安装最新的25.3版本
下载地址：https://www.erlang.org/downloads
下载完 文件名为 otp_src_25.3.tar.gz
3、安装
首先将下载好的文件上传到服务器，创建一个文件夹用来存放文件，路径随意。
3.1 安装erlang
#解压
tar -zxvf otp_src_25.3.tar.gz
#进入目录
cd otp_src_21.0
#编译 (注意路径/usr/local/erlang)
./configure --prefix=/usr/local/erlang --without-javac
#安装
make && make install
执行编译如果遇到以下错误，请先安装 ncurses-devel
configure: error: No curses library functions found
ERROR: /usr/local/software/otp_src_24.2/erts/configure failed!
下载源码包：
https://invisible-island.net/ncurses/ncurses.html#download_ncurses
3.1.1 安装ncurses
#解压
tar -zxvf ncurses-6.0.tar.gz
#进入目录
cd ncurses-6.0
#编译
./configure --with-shared --without-debug --without-ada --enable-overwrite
#安装
make && make install
3.2 安装rabbitmq
#解压
xz -d rabbitmq-server-generic-unix-3.11.11.tar.xz
tar -xvf rabbitmq-server-generic-unix-3.11.11.tar
#移动文件到系统目录下
mv rabbitmq_server-3.11.11/ /usr/local/rabbitmq
4、配置及启动
4.1 添加系统变量
#打开环境变量文件
vim /etc/profile
#添加erlang rabbitmq 到环境变量
export PATH=$PATH:/usr/local/erlang/bin
export PATH=$PATH:/usr/local/rabbitmq/sbin
#重新加载环境变量
source /etc/profile
4.2 启动web插件 启动rabbitmq
#启动web插件 便于访问
rabbitmq-plugins enable rabbitmq_management
#启动rabbitmq服务 (rabbitmq-server 直接启动，如果关闭窗口或者进行其他操作会停止)
#后台启动
rabbitmq-server -detached
#关闭 (如果未找到命令请参考 --)
rabbitmqctl stop
4.3 添加远端登录账户
#添加用户 admin 密码为 123456
rabbitmqctl add_user admin 123456
#将admin 设置为管理员权限
rabbitmqctl set_user_tags admin administrator
#将admin 设置为远端登录
rabbitmqctl set_permissions -p / admin ".*" ".*" ".*"
当执行上述命令时，遇到： bash: rabbitmqctl：未找到命令
解决：
# 设置环境变量，将PATH添加/usr/sbin环境变量
vim /etc/profile
# 最后加上
export PATH=/bin:/usr/bin:/usr/sbin:$PATH
# 更新配置使环境变量生效
source /etc/profile
4.4 登录rabbitmq
访问地址： http://服务器ip:15672
rabbitmq web访问端口默认15672，如无法访问需确认端口是否开放
linux 中查看端口开放
firewall-cmd --list-all
如果未开放，设置开放的端口号
firewall-cmd --add-port=15672/tcp --permanent
重启防火墙
firewall-cmd --reload
登录成功页面
5、扩展
5.1 延迟消息插件
如果需要用到rabbitmq实现延迟消息，需要安装延迟插件
下载地址：
https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/releases
找到对应版本，下载
查看rabbitmq安装了哪些插件
rabbitmq-plugins list
如果没有rabbitmq-delayed-message-exchange
把下载的包上传至服务器，放在rabbitmq安装目录的plugins目录下
#安装命令
rabbitmq-plugins enable rabbitmq_delayed_message_exchange
此时访问页面可以看到，出现了一个名为x-delayed-message的交换机类型
内网穿透实现在外远程连接RabbitMQ服务
文章目录
转载自远控源码文章：无公网IP，在外公网远程访问RabbitMQ服务「内网穿透」
前言
RabbitMQ是一个在 AMQP(高级消息队列协议)基础上完成的，可复用的企业消息系统，是当前最主流的消息中间件之一。
由erlang开发的AMQP（Advanced Message Queue 高级消息队列协议 ）的开源实现，由于erlang 语言的高并发特性，性能较好，本质是个队列，FIFO 先入先出，里面存放的内容是message,下面介绍通过在ubuntu+cpolar+rabbitMQ环境下，实现mq服务端远程访问。
1.安装erlang 语言
由于rabbitMQ是erlang语言实现的,所以我们需要安装erlang
sudo apt-get install erlang-nox
2.安装rabbitMQ
安装最新版rabbitMQ
sudo apt-get install rabbitmq-server
查看rabbitMQ状态,active(running)表示在线
sudo systemctl status rabbitmq-server
设置访问MQ用户名账号和密码，admin表示账号（可自定义），123456表示密码（可自定义）
sudo rabbitmqctl add_user admin 123456
设置上面admin用户的角色,administrator表示是最高管理员
sudo rabbitmqctl set_user_tags admin administrator
设置admin角色权限
sudo rabbitmqctl set_permissions -p "/" admin ".*" ".*" ".*"
以上信息设置好后，我们往下走。
3. 内网穿透
接着我们使用cpolar穿透本地MQ服务,使得远程可以进行访问连接，cpolar支持http/https/tcp协议，不限制流量，操作简单，无需公网IP，也无需路由器。
cpolar官网：https://www.cpolar.com/
3.1 安装cpolar内网穿透(支持一键自动安装脚本)
- cpolar 安装（国内使用）
curl -L https://www.cpolar.com/static/downloads/install-release-cpolar.sh | sudo bash
- 或 cpolar短链接安装方式：(国外使用）
curl -sL https://git.io/cpolar | sudo bash
- 查看版本号
cpolar version
- token认证
登录cpolar官网后台，点击左侧的验证，查看自己的认证token，之后将token贴在命令行里
cpolar authtoken xxxxxxx
- 向系统添加服务
sudo systemctl enable cpolar
- 启动cpolar服务
sudo systemctl start cpolar
正常显示为active则表示服务为正常在线启动状态
3.2 创建HTTP隧道
在ubuntu系统本地安装cpolar内网穿透之后，在ubuntu浏览器上访问本地9200端口，打开cpolar web ui界面:http://127.0.0.1:9200。
点击左侧仪表盘的隧道管理——创建隧道,由于rabbitMQ中默认的是5672端口，因此我们要来创建一条http隧道，指向5672端口：
- 隧道名称：可自定义，注意不要重复
- 协议：tcp
- 本地地址：5672
- 域名类型：选择随机域名
- 地区：选择China VIP
点击创建
打开在线隧道列表,查看随机公网tcp地址,使用下面随机的tcp公网地址,即可远程连接MQ
4. 公网远程连接
maven坐标
<dependency>
<groupId>com.rabbitmq</groupId>
<artifactId>amqp-client</artifactId>
<version>5.10.0</version>
</dependency>
这里使用java 测试使用上面公网地址进行连接,编写发布者
ConnectionFactory factory = new ConnectionFactory();
//cpolar公网地址
factory.setHost("1.tcp.cpolar.cn");
//公网地址对于的端口号
factory.setPort(24889);
//用户名和密码
factory.setUsername("admin");
factory.setPassword("123456");
Connection connection = null;
Channel channel = null;
try
// 1.创建连接和通道
connection = factory.newConnection();
channel = connection.createChannel();
// 2.为通道声明exchange和exchange的类型
channel.exchangeDeclare(EXCHANGE_NAME, BuiltinExchangeType.FANOUT);
String msg = " hello world";
// 3.发送消息到指定的exchange,队列指定为空,由exchange根据情况判断需要发送到哪些队列
channel.basicPublish(EXCHANGE_NAME, "", null, msg.getBytes());
System.out.println("product send a msg: " + msg);
catch (IOException e)
e.printStackTrace();
catch (TimeoutException e)
e.printStackTrace();
finally
// 4.关闭连接
if (channel != null)
try
channel.close();
catch (IOException e)
e.printStackTrace();
catch (TimeoutException e)
e.printStackTrace();
if (connection != null)
try
connection.close();
catch (IOException e)
e.printStackTrace();
编写消费者
ConnectionFactory factory = new ConnectionFactory();
//cpolar公网地址
factory.setHost("1.tcp.cpolar.cn");
//公网地址对于的端口号
factory.setPort(24889);
//用户名和密码
factory.setUsername("admin");
factory.setPassword("123456");
Connection connection = null;
Channel channel = null;
try
// 1.创建连接和通道
connection = factory.newConnection();
channel = connection.createChannel();
// 2.为通道声明exchange以及exchange类型
channel.exchangeDeclare("exchange", BuiltinExchangeType.FANOUT);
// 3.创建随机名字的队列
String queueName = channel.queueDeclare().getQueue();
// 4.建立exchange和队列的绑定关系
channel.queueBind(queueName, "exchange", "");
System.out.println(" **** Consumer1 keep alive ,waiting for messages, and then deal them");
// 5.通过回调生成消费者并进行监听
Consumer consumer = new DefaultConsumer(channel)
@Override
public void handleDelivery(String consumerTag, Envelope envelope,
com.rabbitmq.client.AMQP.BasicProperties properties, byte[] body) throws IOException
// 获取消息内容然后处理
String msg = new String(body, "UTF-8");
System.out.println("*********** Consumer1" + " get message :[" + msg + "]");
;
// 6.消费消息
channel.basicConsume(queueName, true, consumer);
catch (IOException e)
e.printStackTrace();
catch (TimeoutException e)
e.printStackTrace();
先启动消费者,然后启动发布者,然后消费者控制台输出消费者发送的消息表示成功.我们实现了远程访问MQ。
5.固定公网TCP地址
由于以上创建的隧道使用的是随机地址隧道,地址会在24小时内变化,为了使连接更加稳定,我们还需要固定tcp地址。
5.1 保留一个固定的公网TCP端口地址
登录cpolar官网后台，点击左侧的预留，选择保留的TCP地址。
- 地区：选择China VIP
- 描述：即备注，可自定义填写
点击保留
地址保留成功后，系统会生成相应的固定公网地址，将其复制下来
5.2 配置固定公网TCP端口地址
在浏览器上访问9200端口，登录cpolar web ui管理界面，点击左侧仪表盘的隧道管理——隧道列表，找到上面创建的隧道，点击右侧的编辑
修改隧道信息，将保留成功的固定tcp地址配置到隧道中
- 端口类型：修改为固定tcp端口
- 预留的tcp地址：填写保留成功的地址
点击更新
隧道更新成功后，点击左侧仪表盘的状态在线隧道列表，找到需要编辑的隧道，可以看到公网地址已经更新成为了固定TCP地址。
更新好后,我们修改代码中的两个参数
//cpolar公网地址,改为我们固定的地址
factory.setHost("5.tcp.vip.cpolar.cn");
//固定地址对应的端口号
factory.setPort(13630);
然后我们重新启动消费者,再启动生产者,正常发布和消费消息表示成功
以上是关于Linux 内网安装 RabbitMQ的主要内容，如果未能解决你的问题，请参考以下文章