在外公网远程访问RabbitMQ服务
原创
kaixin_啊啊2023-08-16 00:38:47博主文章分类：cpolar©著作权
文章标签erlangTCP自定义文章分类代码人生yyds干货盘点阅读数152
@[TOC]
转载自远控源码文章：无公网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• 1.
2.安装rabbitMQ
安装最新版rabbitMQ
sudo apt-get install rabbitmq-server• 1.
查看rabbitMQ状态,active(running)表示在线
sudo systemctl status rabbitmq-server• 1.
设置访问MQ用户名账号和密码，admin表示账号（可自定义），123456表示密码（可自定义）
sudo rabbitmqctl add_user admin 123456• 1.
设置上面admin用户的角色,administrator表示是最高管理员
sudo rabbitmqctl set_user_tags admin administrator• 1.
设置admin角色权限
sudo rabbitmqctl set_permissions -p "/" admin ".*" ".*" ".*"• 1.
以上信息设置好后，我们往下走。
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• 1.
- 或 cpolar短链接安装方式：(国外使用）
curl -sL https://git.io/cpolar | sudo bash• 1.
- 查看版本号
cpolar version• 1.
- token认证
登录cpolar官网后台，点击左侧的验证，查看自己的认证token，之后将token贴在命令行里
cpolar authtoken xxxxxxx• 1.
- 向系统添加服务
sudo systemctl enable cpolar• 1.
- 启动cpolar服务
sudo systemctl start cpolar• 1.
正常显示为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>• 1. • 2. • 3. • 4. • 5.
这里使用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(); } } }• 1. • 2. • 3. • 4. • 5. • 6. • 7. • 8. • 9. • 10. • 11. • 12. • 13. • 14. • 15. • 16. • 17. • 18. • 19. • 20. • 21. • 22. • 23. • 24. • 25. • 26. • 27. • 28. • 29. • 30. • 31. • 32. • 33. • 34. • 35. • 36. • 37. • 38. • 39. • 40. • 41. • 42. • 43. • 44. • 45. • 46. • 47.
编写消费者
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(); }• 1. • 2. • 3. • 4. • 5. • 6. • 7. • 8. • 9. • 10. • 11. • 12. • 13. • 14. • 15. • 16. • 17. • 18. • 19. • 20. • 21. • 22. • 23. • 24. • 25. • 26. • 27. • 28. • 29. • 30. • 31. • 32. • 33. • 34. • 35. • 36. • 37. • 38. • 39. • 40. • 41. • 42. • 43.
先启动消费者,然后启动发布者,然后消费者控制台输出消费者发送的消息表示成功.我们实现了远程访问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);• 1. • 2. • 3. • 4.
然后我们重新启动消费者,再启动生产者,正常发布和消费消息表示成功
