文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

在Ubuntu上安装和设置RabbitMQ服务器,轻松实现外部远程访问

2023-08-30 11:58

关注

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

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

sudo apt-get install erlang-nox

安装最新版rabbitMQ

sudo apt-get install rabbitmq-server

image-20230227142614479

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

sudo systemctl status rabbitmq-server

image-20230227142756286

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

sudo rabbitmqctl add_user admin 123456

image-20230228152150865

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

sudo rabbitmqctl set_user_tags admin administrator

image-20230228153113674

设置admin角色权限

sudo rabbitmqctl set_permissions -p "/" admin ".*" ".*" ".*"

image-20230228153441392

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

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

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

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

curl -L https://www.cpolar.com/static/downloads/install-release-cpolar.sh | sudo bash
curl -sL https://git.io/cpolar | sudo bash
cpolar version

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

cpolar authtoken xxxxxxx

20230116114805

sudo systemctl enable 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端口:

点击创建

image-20230227174954395

打开在线隧道列表,查看随机公网tcp地址,使用下面随机的tcp公网地址,即可远程连接MQ

image-20230228114252675

maven坐标

com.rabbitmqamqp-client5.10.0

这里使用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。

image-20230228174014355

由于以上创建的隧道使用的是随机地址隧道,地址会在24小时内变化,为了使连接更加稳定,我们还需要固定tcp地址。

5.1 保留一个固定的公网TCP端口地址

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

点击保留

image-20230228175005804

地址保留成功后,系统会生成相应的固定公网地址,将其复制下来

image-20230228175229884

5.2 配置固定公网TCP端口地址

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

image-20230228175405748

修改隧道信息,将保留成功的固定tcp地址配置到隧道中

点击更新

image-20230228175516881

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

image-20230228175557721

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

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

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

image-20230228175908567

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

来源地址:https://blog.csdn.net/m0_67768006/article/details/132481986

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-服务器
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯