RabbitMQ当地Ubuntu体系环境部署与无公网IP远程连接服务端实战演示 ...

文章目次

• 
  
  
  
  • 前言
    
  • 1.安装erlang 语言
    
  • 2.安装rabbitMQ
    
  • 3. 安装内网穿透工具
    
  • 
    
    
    
    • 3.1 安装cpolar内网穿透
      
    • 3.2 创建HTTP隧道
      
    
    
  • 4. 公网远程连接
    
  • 5.固定公网TCP地点
    
  • 
    
    
    
    • 5.1 保留一个固定的公网TCP端口地点
      
    • 5.2 设置固定公网TCP端口地点
      
    
    
  
  

?? 保举
   前些天发现了一个巨牛的人工智能学习网站，通俗易懂，风趣幽默，忍不住分享一下给各人。【点击跳转到网站】
  前言

本文主要先容如何在Ubuntu体系环境下，安装RabbitMQ与cpolar内网穿透工具实现无公网IP随时随地远程访问当地部署的MQ服务端。
RabbitMQ是一个在 AMQP(高级消息队列协议)基础上完成的，可复用的企业消息体系，是当前最主流的消息中间件之一。
由erlang开发的AMQP（Advanced Message Queue 高级消息队列协议 ）的开源实现，由于erlang 语言的高并发特性，性能较好，本质是个队列，FIFO 先入先出，里面存放的内容是message.
1.安装erlang 语言

由于rabbitMQ是erlang语言实现的,以是我们需要安装erlang

1. sudo apt-get install erlang-nox

复制代码

2.安装rabbitMQ

安装最新版rabbitMQ

1. sudo apt-get install rabbitmq-server

复制代码

查看rabbitMQ状态,active(running)表现在线

1. sudo systemctl status rabbitmq-server

复制代码

设置访问MQ用户名账号和密码，admin表现账号（可自定义），123456表现密码（可自定义）

1. sudo rabbitmqctl add_user admin 123456

复制代码

设置上面admin用户的脚色,administrator表现是最高管理员

1. sudo rabbitmqctl set_user_tags admin administrator

复制代码

设置admin脚色权限

1. 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贴在下令行里

1. 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坐标

1. <dependency>
2.                         <groupId>com.rabbitmq</groupId>
3.                         <artifactId>amqp-client</artifactId>
4.                         <version>5.10.0</version>
5.                 </dependency>

复制代码

这里使用java 测试使用上面公网地点进行连接,编写发布者

1.        ConnectionFactory factory = new ConnectionFactory();
2.         //cpolar公网地址
3.         factory.setHost("1.tcp.cpolar.cn");
4.         //公网地址对于的端口号
5.         factory.setPort(24889);
7.         //用户名和密码
8.         factory.setUsername("admin");
9.         factory.setPassword("123456");
10.         Connection connection = null;
11.         Channel channel = null;
12.         try {
13.             // 1.创建连接和通道
14.             connection = factory.newConnection();
15.             channel = connection.createChannel();
17.             // 2.为通道声明exchange和exchange的类型
18.             channel.exchangeDeclare(EXCHANGE_NAME, BuiltinExchangeType.FANOUT);
20.             String msg = " hello world";
21.             // 3.发送消息到指定的exchange,队列指定为空,由exchange根据情况判断需要发送到哪些队列
22.             channel.basicPublish(EXCHANGE_NAME, "", null, msg.getBytes());
23.             System.out.println("product send a msg: " + msg);
24.         } catch (IOException e) {
25.             e.printStackTrace();
26.         } catch (TimeoutException e) {
27.             e.printStackTrace();
28.         } finally {
29.             // 4.关闭连接
30.             if (channel != null) {
31.                 try {
32.                     channel.close();
33.                 } catch (IOException e) {
34.                     e.printStackTrace();
35.                 } catch (TimeoutException e) {
36.                     e.printStackTrace();
37.                 }
38.             }
40.             if (connection != null) {
41.                 try {
42.                     connection.close();
43.                 } catch (IOException e) {
44.                     e.printStackTrace();
45.                 }
46.             }
47.         }

复制代码

编写消费者

1.         ConnectionFactory factory = new ConnectionFactory();
2.         //cpolar公网地址
3.         factory.setHost("1.tcp.cpolar.cn");
4.         //公网地址对于的端口号
5.         factory.setPort(24889);
7.         //用户名和密码
8.         factory.setUsername("admin");
9.         factory.setPassword("123456");
10.         Connection connection = null;
11.         Channel channel = null;
12.         try {
13.             // 1.创建连接和通道
14.             connection = factory.newConnection();
15.             channel = connection.createChannel();
17.             // 2.为通道声明exchange以及exchange类型
18.             channel.exchangeDeclare("exchange", BuiltinExchangeType.FANOUT);
20.             // 3.创建随机名字的队列
21.             String queueName = channel.queueDeclare().getQueue();
23.             // 4.建立exchange和队列的绑定关系
24.             channel.queueBind(queueName, "exchange", "");
25.             System.out.println(" **** Consumer1 keep alive ,waiting for messages, and then deal them");
26.             // 5.通过回调生成消费者并进行监听
27.             Consumer consumer = new DefaultConsumer(channel) {
28.                 @Override
29.                 public void handleDelivery(String consumerTag, Envelope envelope,
30.                                            com.rabbitmq.client.AMQP.BasicProperties properties, byte[] body) throws IOException {
32.                     // 获取消息内容然后处理
33.                     String msg = new String(body, "UTF-8");
34.                     System.out.println("*********** Consumer1" + " get message :[" + msg + "]");
35.                 }
36.             };
37.             // 6.消费消息
38.             channel.basicConsume(queueName, true, consumer);
39.         } catch (IOException e) {
40.             e.printStackTrace();
41.         } catch (TimeoutException e) {
42.             e.printStackTrace();
43.         }

复制代码

先启动消费者,然后启动发布者,然后消费者控制台输出消费者发送的消息表现乐成.我们实现了远程访问MQ。

5.固定公网TCP地点

由于以上创建的隧道使用的是随机地点隧道,地点会在24小时内变化,为了使连接更加稳固,我们还需要固定tcp地点。
5.1 保留一个固定的公网TCP端口地点

登录cpolar官网后台，点击左侧的预留，选择保留的TCP地点。

• 地域：选择China VIP
  
• 描述：即备注，可自定义填写
  

点击保留

地点保留乐成后，体系会生成相应的固定公网地点，将其复制下来

5.2 设置固定公网TCP端口地点

在欣赏器上访问9200端口，登录cpolar web ui管理界面，点击左侧仪表盘的隧道管理——隧道列表，找到上面创建的隧道，点击右侧的编辑

修改隧道信息，将保留乐成的固定tcp地点设置到隧道中

• 端口范例：修改为固定tcp端口
  
• 预留的tcp地点：填写保留乐成的地点
  

点击更新

隧道更新乐成后，点击左侧仪表盘的状态在线隧道列表，找到需要编辑的隧道，可以看到公网地点已经更新成为了固定TCP地点。

更新好后,我们修改代码中的两个参数

1.              //cpolar公网地址,改为我们固定的地址
2.         factory.setHost("5.tcp.vip.cpolar.cn");
3.         //固定地址对应的端口号
4.         factory.setPort(13630);

复制代码

然后我们重新启动消费者,再启动生产者,正常发布和消费消息表现乐成

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。