『RabbitMQ』入门指南（安装，配置，应用）-六虎

前语

RabbitMQ 是在 AMQP（Advanced Message Queuing Protocol）协议规范基础上完整的，可复用的企业音讯体系。它遵循 Mozilla Public License 开源协议，选用 Erlang 完成的工业级的音讯行列(MQ)服务器，建立在 Erlang OTP 平台上（因为选用 Erlang 开发，所以 RabbitMQ 稳定性和牢靠性比较高）

其他主流 MQ 产品

ActiveMQ：Apache 出品，最盛行的，能力强劲的开源音讯总线，基于 JMS（Java Message Service）规范
RocketMQ：阿里低推迟、高并发、高可用、高牢靠的分布式音讯中间件，基于 JMS，现在由 Apache 基金会维护
Kafka：分布式，分区的，多副本的，多订阅者的音讯发布订阅体系（分布式 MQ 体系），能够用于查找日志，监控日志，拜访日志等

本文为 RabbitMQ 入门教程，主要将会解说 RabbitMQ 装置装备（Windows），相关概念，及项目中具体运用

装置

Erlang

官网下载链接：Downloads – Erlang/OTP

RabbitMQ 服务器有必要首要装置 Erlang 运转环境，一起装置时需求注意 RabbityMQ 所依靠的 Erlang 版别，咱们能够检查下方官方版别对应信息

版别对应：RabbitMQ Erlang Version Requirements — RabbitMQ

本次运用版别 Erlang OTP 25.3（点击跳转下载链接）

双击履行 exe 装置程序，除了装置途径其他都依照默许即可

然后装备环境变量

ERLANG_HOME = D:ErlangErlangErlang OTP

并且添加 /bin 目录到 Path 环境变量中，即添加 %ERLANG_HOME%bin 到 Path 中

装置装备之后，翻开 CMD，输入 erl 然后回车键，会弹出版别信息，表示 Erlang 装置成功

RabbitMQ

官方下载页面：RabbitMQ Changelog — RabbitMQ

下载链接： RabbitMQ 3.12.0

装置 exe 文件，履行装置包，同样除了装置途径外其他保持默许

装备环境变量

RABBITMQ_SERVER = D:RabbitMQRabbitMQrabbitmq_server-3.12.0

然后添加 %RABBITMQ_SERVER%sbin 到 Path 环境变量中

检查一切插件

rabbitmq-plugins list

注：假如出现问题请参阅最后一章 彻底卸载

之后咱们需求装置 rabbitmq_management 插件，能够运用可视化的方法检查 RabbitMQ 服务器实例的状况，以及操控 RabbitMQ 服务器

# 装置插件
rabbitmq-plugins enable rabbitmq_management

拜访办理界面： http://localhost:15672/ （账号密码：guest / guest）

前期装置装备完毕，下面能够配合官方入门文档学习

官方文档：RabbitMQ Tutorials — RabbitMQ

音讯行列

界说

音讯指的是两个运用间传递的数据。数据的类型有很多种方法，或许只包括文本字符串，也或许包括嵌入对象。

“音讯行列(Message Queue)”是在音讯的传输过程中保存音讯的容器。在音讯行列中，一般有生产者和顾客两个角色。生产者只负责发送数据到音讯行列，谁从音讯行列中取出数据处理，他不论。顾客只负责从音讯行列中取出数据处理，他不论这是谁发送的数据

作用

解耦。如图所示。假设有体系 B、C、D 都需求体系 A 的数据，所以体系 A 调用三个办法发送数据到 B、C、D。这时，体系 D 不需求了，那就需求在体系 A 把相关的代码删掉。假设这时有个新的体系 E 需求数据，这时体系 A 又要添加调用体系 E 的代码。为了降低这种强耦合，就能够运用 MQ，体系 A 只需求把数据发送到 MQ，其他体系假如需求数据，则从 MQ 中获取即可

异步。如图所示。一个客户端恳求发送进来，体系 A 会调用体系 B、C、D 三个体系，同步恳求的话，呼应时刻便是体系 A、B、C、D 的总和，也便是 800ms。假如运用 MQ，体系 A 发送数据到 MQ，然后就能够回来呼应给客户端，不需求再等待体系 B、C、D 的呼应，能够大大地提高功能。关于一些非必要的事务，比方发送短信，发送邮件等等，就能够选用 MQ

削峰。如图所示。这其实是 MQ 一个很重要的运用。假设体系 A 在某一段时刻恳求数暴增，有 5000 个恳求发送过来，体系 A 这时就会发送 5000 条 SQL 进入 MySQL 进行履行，MySQL 关于如此巨大的恳求当然处理不过来，MySQL 就会溃散，导致体系瘫痪。假如运用 MQ，体系 A 不再是直接发送 SQL 到数据库，而是把数据发送到 MQ，MQ 短时刻积压数据是能够承受的，然后由顾客每次拉取 2000 条进行处理，防止在恳求峰值时期大量的恳求直接发送到 MySQL 导致体系溃散

特点

牢靠性：通过支撑音讯耐久化，支撑事务，支撑消费和传输的 ack 等来保证牢靠性

路由机制：支撑主流的订阅消费形式，如播送，订阅，headers 匹配等

扩展性：多个 RabbitMQ 节点能够组成一个集群，也能够根据实践事务状况动态地扩展集群中节点

高可用性：行列能够在集群中的机器上设置镜像，使得在部分节点出现问题的状况下队依然可用

多种协议：RabbitMQ 除了原生支撑 AMQP 协议，还支撑 STOMP，MQTT 等多种音讯中间件协议

多语言客户端：RabbitMQ 简直支撑一切常用语言，比方 Java、Python、Ruby、PHP、C#、JavaScript 等

办理界面：RabbitMQ 供给了易用的用户界面，使得用户能够监控和办理音讯、集群中的节点等

插件机制：RabbitMQ 供给了许多插件，以完成从多方面进行扩展，当然也能够编写自己的插件

运用

本章将会集成 rabbitmq 到 SpringBoot 中，并运用 rabbitmq-provider （生产者）和 rabbitmq-consumer（顾客）两个项目进行具体解说, 也能够在父项目中创立这两个模块（本文选用父子模块方法）

一切代码示例已经上传到 GitHub 库房

库房地址：ReturnTmp/rabbitmq-demo: rabbitmq 实例代码 (github.com)

生产者

装备

创立子模块 rabbitmq-provider

依靠装备（也能够 IDEA 初始化模块直接勾选）

        <!--rabbitmq-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

application.yml

server:
  port: 8021  
spring:  
  application:  
    name: rabbitmq-provider  
  rabbitmq:  
    host: 127.0.0.1  
    port: 5672  
    username: root  
    password: 111111  
    virtual-host: RootHost

其间虚拟 host 装备项不是有必要的，需求自行创立 vhost，假如未自行创立，默许为 virtual-host: /

注：vhost 能够理解为虚拟 broker，即 mini-RabbitMQserver，其内部均含有独立的 queue、bind、exchange 等，最重要的是具有独立的权限体系，能够做到 vhost 范围内的用户控制。当然，从 RabbitMQ 全局角度，vhost 能够作为不同权限阻隔的手段

能够依照如下过程创立 vhost

然后创立用户（办理员）

然后咱们需求为用户分配权限，指定运用咱们刚刚创立的 vhost

代码

创立直连交换机装备类

注：RabbitMQ 共有四种交换机，分别为：直连交换机，扇形交换机，主题交换机，首部交换机。这儿运用直连交换机演示，其他读者能够自行测验

@Configuration
public class DirectRabbitConfig {
    //行列 起名：TestDirectQueue
    @Bean
    public Queue TestDirectQueue() {
        // durable:是否耐久化,默许是false,耐久化行列：会被存储在磁盘上，当音讯代理重启时依然存在，暂存行列：当时衔接有效
        // exclusive:默许也是false，只能被当时创立的衔接运用，并且当衔接关闭后行列即被删去。此参阅优先级高于durable
        // autoDelete:是否主动删去，当没有生产者或者顾客运用此行列，该行列会主动删去。
        //   return new Queue("TestDirectQueue",true,true,false);
        //一般设置一下行列的耐久化就好,其余两个便是默许false
        return new Queue("TestDirectQueue", true);
    }
    //Direct交换机 起名：TestDirectExchange
    @Bean
    DirectExchange TestDirectExchange() {
        //  return new DirectExchange("TestDirectExchange",true,true);
        return new DirectExchange("TestDirectExchange", true, false);
    }
    //绑定  将行列和交换机绑定, 并设置用于匹配键：TestDirectRouting
    @Bean
    Binding bindingDirect() {
        return BindingBuilder.bind(TestDirectQueue()).to(TestDirectExchange()).with("TestDirectRouting");
    }
    @Bean
    DirectExchange lonelyDirectExchange() {
        return new DirectExchange("lonelyDirectExchange");
    }
}

然后写简略的接口进行音讯推送（能够视状况写为守时使命）

@RestController
public class SendMessageController {
    @Autowired
    RabbitTemplate rabbitTemplate;  //运用RabbitTemplate,这供给了接纳/发送等等办法
    @GetMapping("/sendDirectMessage")
    public String sendDirectMessage() {
        String messageId = String.valueOf(UUID.randomUUID());
        String messageData = "test message, hello!";
        String createTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
        Map<String, Object> map = new HashMap<>();
        map.put("messageId", messageId);
        map.put("messageData", messageData);
        map.put("createTime", createTime);
        //将音讯带着绑定键值：TestDirectRouting 发送到交换机TestDirectExchange
        rabbitTemplate.convertAndSend("TestDirectExchange", "TestDirectRouting", map);
        return "ok";
    }
}

发动项目，调用接口： http://localhost:8021/sendDirectMessage

检查 RabbitMQ 办理页面检查是否推送成功

顾客

装备

创立子模块 rabbitmq-consumer

依靠装备

        <!--rabbitmq-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

application.yml

server:
  port: 8022  
spring:  
  application:  
    name: rabbitmq-consumer  
  rabbitmq:  
    host: 127.0.0.1  
    port: 5672  
    username: root  
    password: 111111  
    virtual-host: RootHost

代码

创立音讯接纳监听类

@Component
@RabbitListener(queues = "TestDirectQueue")
public class DirectReceiver {
    @RabbitHandler
    public void process(Map testMessage) {
        System.out.println("DirectReceiver receive message: "   testMessage.toString());
    }
}

之后发动项目，检查顾客接纳状况

序列化

发送接纳音讯或许出现 Failed to convert message 问题，能够通过运用 JSON 序列化传输信息方法处理

生产者

@Configuration
public class RabbitMQConfig implements InitializingBean {
    /**
     * 主动注入RabbitTemplate模板
     */
    @Resource
    private RabbitTemplate rabbitTemplate;
    /**
     * 发送音讯JSON序列化
     */
    @Override
    public void afterPropertiesSet() {
        //运用JSON序列化
        rabbitTemplate.setMessageConverter(new Jackson2JsonMessageConverter());
    }
}

顾客

@Configuration
public class RabbitMQConfig {
    @Bean
    public MessageConverter jsonMessageConverter(ObjectMapper objectMapper) {
        return new Jackson2JsonMessageConverter(objectMapper);
    }
}

彻底卸载

咱们装置中或许出现各种问题，一般状况下是 RabbitMQ 和 Erlang 版别不对应，需求彻底卸载 RabbitMQ 和 Erlang，能够依照如下过程卸载

注：博主首次装置运用的是 Erlang 20.3 Rabbit 3.7.15 ，之后似乎小版别不对应，出现问题，需求从头卸载装置

（1）翻开 Windows 控制面板，双击“程序和功能”。

（2）在当时装置的程序列表中，右键单击 RabbitMQ Server，然后单击“卸载”。

（3）在当时装置的程序列表中，右键单击“Erlang OTP”，然后单击“卸载”。

（4）翻开 Windows 使命办理器。

（5）在使命办理器中，查找进程 epmd.exe。假如此进程仍在运转，请右键单击该进程，然后单击“结束进程”。

（6）删去 RabbitMQ 和 Erlang 的一切装置目录。

（7）删去文件 C:WindowsSystem32configsystemprofile.erlang.cookie（假如存在）。

（8）转到用户文件夹：C:Users[username]，然后删去文件.erlang.cookie。

（9）同样在 User 文件夹中，转到 AppData Roaming RabbitMQ。删去 RabbitMQ 文件夹。

（10）删去注册表 HKEY_LOCAL_MACHINESOFTWAREEricssonErlangErlSrv 的子项。

（11）翻开运转 cmd->sc delete RabbitMQ。

（12）翻开运转->regedit 找到 RabbitMQ 节点，删掉即可（假如存在）

参阅链接

本文由博客一文多发平台 OpenWrite 发布！

『RabbitMQ』入门指南（安装，配置，应用）

前语

装置

Erlang

RabbitMQ

音讯行列

界说

作用

特点

运用

生产者

装备

代码

顾客

装备

代码

序列化

生产者

顾客

彻底卸载

参阅链接

作者信息

推广

『RabbitMQ』入门指南（安装，配置，应用）

前语

装置

Erlang

RabbitMQ

音讯行列

界说

作用

特点

运用

生产者

装备

代码

顾客

装备

代码

序列化

生产者

顾客

彻底卸载

参阅链接

相关文章

Java小技巧：一个灵活的JSON提取工具

你代码的异味是故意的还是不小心？是故意的！

建设工程项目采购模式

与Go的初次见面 ｜ 青训营笔记

作者信息

推广

与Go的初次见面｜青训营笔记