Loading [MathJax]/jax/input/TeX/config.js
首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >专栏 >无公网IP,在外公网远程访问RabbitMQ服务「内网穿透」

无公网IP,在外公网远程访问RabbitMQ服务「内网穿透」

作者头像
iOS Magician
发布于 2023-04-17 12:13:13
发布于 2023-04-17 12:13:13
2.3K00
代码可运行
举报
运行总次数:0
代码可运行

转载自远控源码文章:无公网IP,在外公网远程访问RabbitMQ服务「内网穿透」

前言

RabbitMQ是一个在 AMQP(高级消息队列协议)基础上完成的,可复用的企业消息系统,是当前最主流的消息中间件之一。 由erlang开发的AMQP(Advanced Message Queue 高级消息队列协议 )的开源实现,由于erlang 语言的高并发特性,性能较好,本质是个队列,FIFO 先入先出,里面存放的内容是message,下面介绍通过在ubuntu+cpolar+rabbitMQ环境下,实现mq服务端远程访问。

1.安装erlang 语言

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

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
sudo apt-get install erlang-nox

2.安装rabbitMQ

安装最新版rabbitMQ

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
sudo apt-get install rabbitmq-server

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

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
sudo systemctl status rabbitmq-server

设置访问MQ用户名账号和密码,admin表示账号(可自定义),123456表示密码(可自定义)

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
sudo rabbitmqctl add_user admin 123456

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

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
sudo rabbitmqctl set_user_tags admin administrator

设置admin角色权限

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
sudo rabbitmqctl set_permissions -p "/" admin ".*" ".*" ".*"

以上信息设置好后,我们往下走。

3. 内网穿透

接着我们使用cpolar穿透本地MQ服务,使得远程可以进行访问连接,cpolar支持http/https/tcp协议,不限制流量,操作简单,无需公网IP,也无需路由器

cpolar官网:https://www.cpolar.com/

3.1 安装cpolar内网穿透(支持一键自动安装脚本)

  • cpolar 安装(国内使用)
代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
curl -L https://www.cpolar.com/static/downloads/install-release-cpolar.sh | sudo bash
  • 或 cpolar短链接安装方式:(国外使用)
代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
curl -sL https://git.io/cpolar | sudo bash
  • 查看版本号
代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
cpolar version
  • token认证

登录cpolar官网后台,点击左侧的验证,查看自己的认证token,之后将token贴在命令行里

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
cpolar authtoken xxxxxxx
  • 向系统添加服务
代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
sudo systemctl enable cpolar
  • 启动cpolar服务
代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
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坐标

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
<dependency>
			<groupId>com.rabbitmq</groupId>
			<artifactId>amqp-client</artifactId>
			<version>5.10.0</version>
		</dependency>

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

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
       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();
                }
            }
        }

编写消费者

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
        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地址。

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

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
     	//cpolar公网地址,改为我们固定的地址
        factory.setHost("5.tcp.vip.cpolar.cn");
        //固定地址对应的端口号
        factory.setPort(13630);

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

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2023-04-11,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
暂无评论
推荐阅读
编辑精选文章
换一批
【RabbitMQ】RabbitMQ应用
官方安装指南:https://www.rabbitmq.com/install-rpm.html
瑞新
2021/11/08
2K0
【RabbitMQ】快速入门学习MQ
两种方式各有优劣,打电话可以立即得到响应,但是你却不能跟多个人同时通话。发送邮件可以同
陶然同学
2023/02/24
4240
【RabbitMQ】快速入门学习MQ
RabbitMQ系列(一)Hello World
消息中间件:简单的说就是用来传输消息的中间载体,就是将你的信息发送到接受方,它并不关心发送的数据是什么。RabbitMQ就是一个消息中间件。
Jensen_97
2023/07/20
1720
RabbitMQ系列(一)Hello World
RabbitMQ 系列(2) —— 用 java 连接 RabbitMQ
RabbitMQ 作为一个消息中间件,整体上采用了生产者与消费者模型,主要负责接收,存储和转发消息。
求和小熊猫
2020/12/16
1.2K0
RabbitMQ 系列(2) —— 用 java 连接 RabbitMQ
学习RabbitMQ这篇就够了快速入门上手(超详细)
而且只关心消息的发送和接收,没有业务逻辑的侵入,这样就实现了生产者和消费者的解耦。
陶然同学
2023/02/27
1.7K0
学习RabbitMQ这篇就够了快速入门上手(超详细)
快速入门RabbitMQ核心概念
我们知道RabbitMQ是基于Erlang编写的,所以在安装RabbitMQ之前需要确保安装了Erlang环境。RabbitMQ与Erlang是有版本对应关系的,可以参考官方列举的版本对应关系:
端碗吹水
2020/11/24
5820
【消息中间件】RabbitMQ的工作模式
先启动consumer1,2;再启动producer,即可看到两个消费者会争抢消费生产者生产的消息。
半旧518
2023/10/17
2590
【消息中间件】RabbitMQ的工作模式
RabbitMQ基础教程之基本使用篇
RabbitMQ基础教程之基本使用篇 最近因为工作原因使用到RabbitMQ,之前也接触过其他的mq消息中间件,从实际使用感觉来看,却不太一样,正好趁着周末,可以好好看一下RabbitMQ的相关知识点;希望可以通过一些学习,可以搞清楚以下几点 基础环境搭建 可以怎么使用 实现原理是怎样的 实际工程中的使用(比如结合SpringBoot可以怎么玩) <!-- more --> 相关博文,欢迎查看: 《RabbitMq基础教程之安装与测试》 《RabbitMq基础教程之基本概念》 I. 前提准备 在开始之前,先
一灰灰blog
2018/06/04
6380
026. RabbitMQ 入门及消息分发机制
1. RabbitMQ 简介 ---- RabbitMQ 是一个开源的 AMQP 实现,服务器端用 Erlang 语言编写,支持多种客户端。用于在分布式系统中存储转发消息,在易用性、扩展性、高可用性等方面表现不俗。 2. RabbitMQ 安装运行 ---- 1. 安装依赖环境 2. 安装 RabbitMQ 3. 启动和关闭 4. 开启 Web 管理插件 见后面的笔记。 5. 设置防火墙 3. RabbitMQ 基本配置 ---- RabbitMQ 端口 RabbitMQ 会绑定一些端口,安装完后,需要将这
山海散人
2021/03/03
6850
026. RabbitMQ 入门及消息分发机制
RabbitMQ的生产者和消费者
图 2-2 展示 了 生产者将消息存入 RabbitMQ Broker,以及消费者从 Broker 中消费数据的整 个流程。
清风冷影
2019/07/11
3.9K0
AMQP-RabbitMQ/1/概念/一对一简单模型
# JMS, AMQP, MQTT的区别与联系 JMS Java消息传递服务(Java Messaging Service ) AMQP 高级消息队列协议(Advanced Message Queueing Protocol ) MQTT 消息队列遥测传输(Message Queueing Telemetry Transport ) 简单理解: JMS是专门为Java设计的一套消息服务API,像 ActiveMQ就是对它的实现 AMQP为了解决不同平台之间的通信问题,定义了一种名为 amqp的 通信协
喜欢天文的pony站长
2020/06/29
6090
AMQP-RabbitMQ/1/概念/一对一简单模型
RabbitMQ使用教程(超详细)
下载地址:http://www.rabbitmq.com/download.html
全栈程序员站长
2022/07/21
3.1K1
RabbitMQ使用教程(超详细)
RabbitMQ入门
RabbitMQ是一个开源的AMQP(Advanced Message Queuing Protocol)实现,服务端用Erlang语言编写,支持多种客户端。用于在分布式系统中存储转发消息,在易用性,扩展性,高可用性等方面表现不俗。
CodingDiray
2020/05/13
6350
RabbitMQ入门
029. RabbitMQ 消息可靠性和插件机制
1. 消息可靠性 ---- RabbitMQ 的消息可靠性,一般是业务系统接入消息中间件时首要考虑的问题,一般通过三个方面保障: 发送可靠性:确保消息成功发送到 Broker。 存储可靠性:Broker 对消息持久化,确保消息不会丢失。 消费可靠性:确保消息成功被消费。 1. 发送可靠性 一般消息发送可靠性分为 3 个层级: At most once:最多一次,消息可能会丢失,但绝不会重复传输。 At least once:最少一次,消息绝不会丢失,但可能会重复传输。 Exactly once:
山海散人
2021/03/03
4440
029. RabbitMQ 消息可靠性和插件机制
Windows下RabbitMQ安装及入门
1.Windows下安装RabbitMQ需要以下几个步骤    (1):下载erlang,原因在于RabbitMQ服务端代码是使用并发式语言erlang编写的,下载地址:http://www.erla
庞小明
2018/03/08
6830
Windows下RabbitMQ安装及入门
05-RabbitMQ控制台入门及其Java简单操作
路由键: 就是指发送到Exchange的消息, 通过路由键的匹配规则, 分发到指定的Queue
彼岸舞
2022/10/06
2810
05-RabbitMQ控制台入门及其Java简单操作
RabbitMq 技术文档
AMQP即Advanced Message Queuing Protocol,高级消息队列协议,是面向消息中间件设计的应用层协议的一个开放标准。它的主要特点是面向消息、队列、路由(包括点对点和发布/订阅)]、可靠性和安全。 AMQP允许来自不同供应商的消息生产者和消费者实现真正的互操作扩展,就如同SMTP、HTTP、FTP等协议采用的方式一样。而此前对于消息中间件的标准化努力则集中在API层面上(比如JMS),且没有提供互操作性的途径。不同于JMS的仅仅定义API,AMQP是一个线路级的协议——它描述了通过网络传输的字节流的数据格式。因此,遵从这个协议的任何语言编写的工具均可以操作AMQP消息。 AMQP模型
WindWant
2020/09/11
2.8K0
RabbitMq 技术文档
深入解读RabbitMQ工作原理及简单使用
MQ全称是Message Queue,可以理解为消息队列的意思,简单来说就是消息以管道的方式进行传递。
磊哥
2018/08/02
5K0
深入解读RabbitMQ工作原理及简单使用
RabbitMQ架构原理及消息分发机制
在现代分布式系统中,消息队列是不可或缺的组件之一。它不仅能够解耦系统模块,还能实现异步通信和削峰填谷。在众多消息队列中,RabbitMQ 因其高并发、高可靠性和丰富的功能而备受青睐。本文将从 RabbitMQ 的基础概念、架构原理、消息分发机制、持久化与内存管理、插件管理、Java API 编程以及 Spring 集成等方面,全面解析 RabbitMQ 的核心技术和应用场景。
SmileNicky
2025/04/17
3180
【消息中间件】1小时快速上手RabbitMQ
考虑由订单系统与库存系统、支付系统、物流系统直接通过远程调用方式通信,模块耦合度较高的情况。
半旧518
2023/10/17
6010
【消息中间件】1小时快速上手RabbitMQ
相关推荐
【RabbitMQ】RabbitMQ应用
更多 >
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档
本文部分代码块支持一键运行,欢迎体验
本文部分代码块支持一键运行,欢迎体验