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

Posted 叁 柒

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了内网穿透实现在外远程连接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);

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

如何使用平板连接服务器实现cpolar开发？内网穿透实例

前言

在入手iPad Pro后，为了防止“买前生产力，买后爱奇艺”，我们可以在Linux服务器上搭建code server，然后在iPad Pro上通过浏览器或者APP，来远程linux服务器，使用服务器的资源来编译代码，而iPad Pro前端只需要负责写代码编程就可以啦。

以及在实现局域网下的远程访问后，我们还可以用cpolar做内网穿透，将codeserver映射到公网上，实现在外也可以使用iPad Pro远程linux服务器，实现远程写代码搞开发。

文章目录

1. 本地环境配置

准备一台虚拟机,Ubuntu或者centos都可以,这里以VMware Ubuntu系统为例

下载code server服务

在浏览器访问:https://github.com/coder/code-server,复制下载命令

打开ubuntu命令行执行

curl -fsSL https://code-server.dev/install.sh | sh

出现需要输入ubuntu的登录账户密码,输入密码即可,然后等待安装完成

以下信息表示安装成功

接着输入以下命令设置code-server的登录密码

export PASSWORD=”000000”

再查看linux的IP地址,作局域网访问使用

ifconfig

设置好密码后启动code-server服务,输入以下命令:

code-server --host= “0.0.0.0”

出现地址和端口号信息表示成功

2. 测试局域网访问

在局域网下，打开浏览器访问code-server，http://192.168.30.128:8080/,出现welcone code-server表示成功,输入我们刚刚设置的密码,登录即可。

3. 内网穿透

测试在局域网下访问成功后，我们再用cpolar做内网穿透，将其发布到公网上，实现在外也可以远程写代码。

这里我们使用cpolar穿透本地code-server服务,使得远程可以进行访问,随时随地写代码。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

  • 简单穿透测试，有正常生成公网地址表示穿透成功，按ctrl+c退出
cpolar http 8080
  • 向系统添加服务，将cpolar配置为后台服务并开机自启动
sudo systemctl enable cpolar
  • 启动cpolar服务
sudo systemctl start cpolar
  • 查看服务状态
sudo systemctl status cpolar

正常显示为active则表示服务为正常在线启动状态

3.2 创建HTTP隧道

在服务器上安装cpolar内网穿透之后，在浏览器上访问本地9200端口，打开cpolar web ui界面:http://127.0.0.1:9200。

点击左侧仪表盘的隧道管理——创建隧道,由于code-server中配置的是8080端口，因此我们要来创建一条http隧道，指向8080端口：

  • 隧道名称：可自定义，注意不要与已有的隧道名称重复
  • 协议：http协议
  • 本地地址：8080
  • 域名类型：选择随机域名
  • 地区：选择China VIP

点击创建

创建好后,点击左侧的状态——在线隧道列表,可以看到隧道已经有生成了相应的公网地址，一个http协议，一个https协议，将其复制下来

3.3 测试远程访问

在iPad Pro上打开浏览器，访问刚刚复制的公网地址，访问后输入前面设置的密码，出现vscode界面表示成功

4. 配置固定二级子域名

4.1 保留二级子域名

由于刚刚创建隧道时使用的是默认随机地址，它生成的公网地址会在24小时内变化，不利于长期远程访问。不过我们可以为其配置二级子域名，该地址为固定地址，不会随机变化。

需要注意，配置固定二级子域名需要将cpolar升级到基础套餐或以上。

登录cpolar官网，点击左侧的预留，选择保留二级子域名，设置一个二级子域名名称，点击保留,保留成功后复制保留的二级子域名名称

  • 地区：选择China vip
  • 二级域名：可自定义填写
  • 描述：即备注，可自定义填写

4.2 配置二级子域名

访问cpolar web ui管理界面，点击左侧的隧道管理——隧道列表，找到我们刚刚创建的隧道，点击右侧的编辑，将保留成功的二级域名配置到隧道中。

修改下隧道信息：

  • 域名类型改为选择二级子域名
  • subdomain：填写刚刚保留成功的二级子域名

点击更新

隧道更新成功之后，点击左侧的状态——在线隧道列表，查看公网地址,此时可以看到地址变成了二级域名，将其复制下来

5. 访问固定二级子域名

接着我们再次打开iPad Pro浏览器，访问刚刚配置成功的固定二级子域名地址,出现vscode界面表示成功,就可以愉快的写代码啦.

6. iPad Pro通过软件远程写代码

除了可以在浏览器上远程服务器写代码外，我们还可以通过app来远程访问vscode。这里我们使用servediter for code-server软件来实现iPad Pro远程访问Linux服务器。

6.1 创建TCP隧道

servediter for code-server这个软件需要连接服务器，首先需要创建一条TCP隧道，指向我们服务器的22端口。

在linux上访问本地9200端口登录cpolar web UI管理界面，创建一条新的TCP隧道，指向本地22端口。

点击左侧的隧道管理——创建隧道：

  • 隧道名称：可自定义，注意不要与已经有的隧道名称重复
  • 协议：tcp协议
  • 本地地址：22
  • 域名类型：选择随机临时TCP端口
  • 地区：选择China VIP

点击创建

隧道创建成功之后，点击左侧的状态——在线隧道列表，将所生成的公网地址复制下来。

6.2 iPad Pro远程vscode

在iPad Pro上，点击打开app store，下载软件servediter for code-server

下载成功后点击打开，由于该软件是付费的,可以自由选择购买,这里选择免费试用，选择最后一个free

输入相关信息

参数介绍:

  • code-server URL：填写前面配置成功的http公网地址【ipad浏览器访问的那个地址】
  • Instance password：code-server配置的密码
  • Host：这里填写我们前面创建成功的22隧道的公网地址
  • Username: 这个填写ubuntu系统的用户名
  • Port: 这里默认即可无需填写
  • Authentication: 这个填写ubuntu系统用户名对应的密码

输入完信息后点击右上角save后就会自动连接,出现vscode界面表示连接成功啦

6.3 配置固定TCP端口地址

由于前面我们创建的ssh 22端口的隧道选择的是随机临时地址,该地址会在24小时内变化,为了使我们ipad里面使用vscode连接更加通畅,我们需要固定ssh 的公网地址。

注意需要将cpolar套餐升级至专业套餐或以上。

6.3.1 保留固定TCP地址

登录cpolar 官网后台 ，点击左侧的预留，找到保留的TCP地址：

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

点击保留

固定TCP地址保留成功，系统生成相应的公网地址+固定端口号，将其复制下来

6.3.2 配置固定TCP端口地址

浏览器访问http://127.0.0.1:9200/， 登录cpolar web UI管理界面，点击左侧仪表盘的隧道管理——隧道列表，找到codeserver隧道，点击右侧的编辑

修改隧道信息，配置固定TCP端口地址：

  • 端口类型：改为选择固定TCP端口
  • 预留的TCP地址：填写刚刚保留成功的固定TCP端口地址

点击更新

提示更新隧道成功，点击左侧仪表盘的状态——在线隧道列表，可以看到刚刚修改的隧道的公网地址已经更新为固定TCP端口地址，将其复制下来。

6.4 使用固定TCP地址远程vscode

在ipad pro上，打开servediter for code-server软件，修改host的参数，将其修改为我们刚刚配置成功的固定TCP端口地址。

点击左上角i标志

选择self Host Server

把Host值改为我们刚刚官网保留的tcp地址

更改完后点击右上角save,点击完后会自动连接,出现vscode界面表示成功了,至此,教程就结束了,使用iPad Pro开启愉快的编程吧！该公网地址不会再随机变化了。

以上是关于内网穿透实现在外远程连接RabbitMQ服务的主要内容，如果未能解决你的问题，请参考以下文章

搭建SFTP服务安全共享文件，实现在外远程访问「内网穿透」

无公网IP，SSH远程连接Linux CentOS服务器内网穿透

在外web浏览器远程访问jupyter notebook服务器内网穿透

无公网IP？教你在外远程访问本地wamp服务器「内网穿透」

用FRP做内网穿透使用远程桌面连接家里的windows电脑

Golang gRPC实现内网穿透