Ubuntu安装RabbitMQ server - 在外远程访问

2023-09-21 18:08:47

文章目录

前言

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

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

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

3. 内网穿透

接着我们使用[cpolar](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

20230116114805

  • 向系统添加服务
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

点击创建

image-20230227174954395

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

image-20230228114252675

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。

image-20230228174014355

5.固定公网TCP地址

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

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

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

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

点击保留

image-20230228175005804

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

image-20230228175229884

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

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

image-20230228175405748

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

  • 端口类型：修改为固定tcp端口
  • 预留的tcp地址：填写保留成功的地址

点击更新

image-20230228175516881

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

image-20230228175557721

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

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

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

image-20230228175908567

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

更多推荐

python学习--字符串的常用操作

字符串查询操作功能方法名称作用查询方法index（）查找子串substr第一次出现的位置，如果查找的子串不存在时，则抛出valueError查询方法rindex（）查找子串sunstr最后一次出现的位置，如果查找的子串不存在时，则抛出valueError查询方法find（）查找子串sunstr第一次出现的位置，如果查找

DGUS 功能升级：任意页面控件均可灵活叠加

针对进一步提升DGUS平台控件组合灵活度的市场需求，迪文在DGUS平台中新增设了“页面叠加开关”接口，可用于实现全局动态报警提示等功能。使用该功能，用户可以将任意页面的控件叠加到全部剩余页面上，叠加页面的控件默认为最高优先级，叠加页面上的控件处于被叠加页面的最上层（包含叠加页面的全部显示控件和触摸控件）。触摸控件的优先

spring security教程（一）--认证

零.简介【1】简介【2】登录校验流程【3】原理（入门的时候先了解一下就好）一.思路分析二.建表确保你已经建立好一张用户表，并且引入springboot，mybatis，mp,slf4j等基础依赖。即使你有多个角色你也可以将他们的相同信息（如用户名密码登都提取到一张表中）。并根据表编写对应实体类和mapper。上面是我建

【SpringMVC】JSON数据传输与异常处理的使用

文章目录一、Jackson1.1Jackson是什么1.2常用注解1.3实例1.3.1导入依赖1.3.2配置spring-mvc.xml1.3.3JsonController.java二、SpringMVC异常处理机制2.1使用原因2.2SpringMVC异常处理2.2.1异常处理机制流程图2.2.2异常处理的三种方式

基于SpringBoot的超市管理系统

基于SpringBoot+Vue的超市管理系统、超市进销存系统，前后端分离开发语言：Java数据库：MySQL技术：SpringBoot、Vue、MybaitsPlus、ELementUI工具：IDEA/Ecilpse、Navicat、Maven【主要功能】角色：管理员、员工管理员：个人信息管理、员工管理、客户管理、供

数据结构之时间复杂度&&空间复杂度的计算

数据结构：计算机如何存储数据的问题。DS关心的是如何高效的进行数据的读写。算法：在特定的数据集上（不关心怎么进行具体数据的读写），如何利用数据完成特定的功能。算法本质上就是一系列运算的先后集合。那么，如何评价一个算法的好坏？从两种维度进行：时间效率与空间效率时间复杂度：主要衡量一个算法的运行速度（不是实际计算机的运行速

Java实现单链表

目录一.单链表二.单链表基本操作的实现1.单链表类、属性的定义2.求链表长度3.链表是否包含值为key的节点4.添加元素5.删除节点6.清空链表三、完整代码一.单链表链表是一种在物理存储结构上非连续的存储结构，数据元素的逻辑顺序通过链表中的引用链接次序实现。链表的结构多样，我们通过实现无头单向非循环链表，来进一步理解链

【记录成长】大学时光已过半， 分享我的大二暑期实习经历

你好，我是cpt，本文章记录我大二暑期找实习的过程，以及工作中的点点滴滴，还有一些经验分享，希望能够帮助到你。实习投递(BOSS1k沟通10+面)投递我是2023.6.16才开始投递的当时真的很晚了基本很少hc而且小公司基本不要大二学生下面这两篇短文是当时面试遇到的问题25三本鼠鼠投500面试0难QAQ_牛客网请问各位

Opengl绘制三角形

节点对象学习：顶点数组对象：VertexArrayObject，VAO顶点缓冲对象：VertexBufferObject，VBO：表示存储在GPU显存中的大量顶点数据。我们可以通过这个对象，一次性向GPU发送大量的数据，而不是一次次地从CPU中发送数据到GPU，这是个很慢的过程。元素缓冲对象：ElementBuffer

三步实现Mybatis（Mybatis-Plus）多数据源配置

前言要实现多数据源可以采用dynamic-datasource或者mybatis-mate，本文就以dynamic-datasource为例dynamic-datasource简介springboot快速集成多数据源的启动器使用文档(opensnewwindow)支持数据源分组，适用于多种场景纯粹多库读写分离一主多从混

SpringBoot实战案例：图书管理系统

SpringBoot实战案例：图书管理系统在本文中，我们将介绍如何使用SpringBoot框架构建一个简单的图书管理系统。我们将从零开始，逐步完成系统的搭建。本文将分为以下七个部分：系统需求分析搭建项目框架实现数据访问层实现业务逻辑层实现控制层前端页面与交互测试与部署1.系统需求分析在开始构建图书管理系统之前，我们首先

热文推荐
  1. 单例模式的安全写法

    要想知道怎么写单例模式，那么必须得知道什么是单例模式。单例模式是一种设计模式，它确保某个类只有一个实例，并且提供一个全局访问该实例的方法。单例模式不会创建实例副本，而是返回对已创建实例的引用。单例模式的创建可以分为两类。第一类是饿汉式单例模式，它在类加载时就创建了唯一的实例对象，并在全局范围内提供访问点。第二类是懒汉式

  2. 如何制作一个成功的超市购物小程序

    随着互联网的普及和移动支付的便捷性，越来越多的消费者选择在网上购物，这也促使越来越多的商家开始搭建自己的小程序商城。对于超市便利店来说，拥有一个便捷、易用的小程序商城能够吸引更多的消费者，提高销售效率。那么如何快速搭建一个超市便利店小程序呢？下面我们将通过乔拓云平台来介绍这个过程。步骤1：登录乔拓云网后台，进入商城管理

  3. rabbitmq 面试题

    1.交换机类型RabbitMQ是一个开源的消息队列系统，它支持多种交换机类型，用于在消息的生产者和消费者之间路由和分发消息DirectExchange（直接交换机）：Direct交换机是最简单的交换机类型之一。它将消息按照消息的RoutingKey（路由键）与绑定的队列的RoutingKey进行精确匹配，并将消息发送到

  4. 一键自助建站系统源码带安装教程 傻瓜式部署搭建,让您的建站更高效

    在这个数字时代，网站已成为企业或个人展示形象、推广业务的重要工具。为了满足这一需求，许多自助建站系统应运而生，大大降低了用户建站的门槛。给大家分享一款傻瓜式部署搭建的一键自助建站系统源码，让您轻松拥有高效建站能力。一、一键自助建站系统源码介绍这款一键自助建站系统源码具有以下特点：简单易用：用户只需通过简单的鼠标点击和输

  5. Golang Gorm 一对多 关联模式 Association + Find 查询关联

    查找关联//User拥有并属于多种language，`user_languages`是连接表typeUserstruct{gorm.ModelLanguages[]Language`gorm:"many2many:user_languages;"`}typeLanguagestruct{gorm.ModelNamest

  6. I Pa?sWorD

    2023icpc网络赛第一场I题意：题目给出只包含大小写字母，数字以及'?'的字符串，对于每一个小写字母，这一位字符既有可能是该小写字母，也有可能是该小写字母的对应大写字母，也就是该位的字符有两种可能，对于问号，可能是所有大写字母或者所有小写字母，或者所有单数字，则共有62种情况，而对于大写字母和数字位则都是确定的只有

  7. Hive【非交互式使用、三种参数配置方式】

    前言今天开始学习Hive，因为毕竟但凡做个项目基本就避不开用Hive，争取这学期结束前做个小点的项目。第一篇博客内容还是比较少的，环境的搭建配置太琐碎没有写。Hive常用使用技巧交互式使用就是我们正常的进入hive命令行下的使用模式。非交互式使用所谓非交互式，也就是不需要进入hive命令行，直接在我们linuxShel

  8. STViT-R 代码阅读记录

    目录一、SwinTransformer1、原理2、代码二、STViT-R1、中心思想2、代码与原文本次不做具体的训练。只是看代码。所以只需搭建它的网络，执行一次前向传播即可。一、SwinTransformer1、原理主要思想，将token按区域划分成窗口，只需每个窗口内的token单独进行self-attention。

  9. Mybatis sql参数自动填充

    问题描述在日常开发中，经常会遇到Mybatissql语句的操作问题，由于Mybatis实现sql的动态拼接，开发过程中，为了验证sql是否书写正确，通常需要获取的控制台打印的sql语句来检查是否拼接正确。如下图所示：那么为了验证sql的正确性，需要复制控制台sql以及sql参数，手工进行拼接后在数据库连接工具(比如na