内网穿透实现在外远程连接RabbitMQ服务

Posted 2023-04-11 _苏沐

文章目录

• 前言
• 1.安装erlang 语言
• 2.安装rabbitMQ
• 3. 内网穿透
• • 3.1 安装cpolar内网穿透(支持一键自动安装脚本)
  • 3.2 创建HTTP隧道
• 4. 公网远程连接
• 5.固定公网TCP地址
• • 5.1 保留一个固定的公网TCP端口地址
  • 5.2 配置固定公网TCP端口地址

转载自远控源码文章：无公网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);

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

没有公网ip 也可以实现内网穿透的工具

参考技术A 对于没有公网 IP 的内网用户来说，远程管理或在外网访问内网机器上的服务一直是个大难题。这个时候，我们就要用到内网穿透来解决这个问题，随着信息化的飞速发展，内网穿透技术也有很多工具可以实现。那么，哪个才是最好用的呢？

Ngrok，相信很多的搞网络运维的都听过这么个大名鼎鼎的产品，但是设置的话没有网络基础将会相当的困难，看着教程都很吃力的那种，如果你和我一样，对网络技术不是很敏感，这个技术就算了。而且这服务器是国外的，速度也不是很快，不过是开源的这是亮点。

FRP 是一个使用 Go 语言开发的高性能的反向代理应用，可以帮助您轻松地进行内网穿透，对外网提供服务。自己组建的话需要外网一台有公网IP的设备，启动需要手动驱动客户端和服务端，这点比较麻烦，也是对技术有一定的要求。

花生棒，硬件小巧玲珑，携带方便，价格能接受，基础版配置完以后稳定性还可以，只是限流量，限带宽，这点不太友好

零遁的公网IP设备，价位也合适，能做域名和IP转发，也是限带宽的，但是不限流量，不限终端数，稳定性也可以，主要是可以做域名转发

对于几款内网穿透工具的介绍今天就到这里了，

哪个最好用，主要还是看你个人应用的需要和性比价来综合考量了，适合自己的，才能说是最好用的。