SpringCloud RabbitMQ 搭建

前言

在上一篇文章博主已经讲解了项目如何创建，不会的话可以前往学习，传送门：Spring Cloud Hoxton 版本搭建 Bus消息总线(Rabbitmq) 。

本篇用来讲解–SpringCloud RabbitMQ 搭建！

摘要

在上一篇已经列出了需要下载的内容请自行传送查阅。

AMQP

在异步通讯中，消息不会立刻到达接收方，而是被存放到一个容器中，当满足一定的条件之后，消息会被容器发送给接收方，这个容器即消息队列，而完成这个功能需要双方和容器以及其中的各个组件遵守统一的约定和规则，AMQP就是这样的一种协议，消息发送与接受的双方遵守这个协议可以实现异步通讯。这个协议约定了消息的格式和工作方式。

RabbitMQ

AMQP 是一种协议， RabbitMQ是一个由erlang开发的AMQP的开源实现，目前使用比较广泛的MQ有RabbitMQ,ActiveMQ,KafKa等等，其中ActiveMQ是基于JMS的一个开源实现，JMS 是一个接口标准或者说是一个API消息服务的规范（JAVA Message Service，java消息服务），KafKa是一种高吞吐量的分布式发布订阅消息系统，通常有吞吐量需求的日志处理和日志聚合应用会使用Kafka，性能要优于Rabbit,但是稳定性和可靠性相对而言RabbitMQ要成熟一些。

安装完成后进行配置：

Erlang

首先需要保证 ERLANG_HOME 环境配置正确
在环境变量中添加 ERLANG_HOME 的路径，如D:\erl10.6

然后在PATH中添加 %ERLANG_HOME%\bin

在cmd中输入erl ，如果能弹出erlang shell界面则表示配置正确了

rabbitMQ

配置RabbitMQ
找到安装位置，在安装位置的目录栏输入cmd，回车-->打开命令行模式cmd：

依次输入：
1. ./rabbitmq-plugins.bat enable rabbitmq_management
2. ./rabbitmq-service.bat stop
3.rabbitmq-service.bat install 这句话没用，提示：RabbitMQ service is already present - onlyupdating service parameters
4. ./rabbitmq-service.bat start
重新 start install stop 在执行第一个语句就能进去网页。
5. 打开浏览器登录：http://127.0.0.1:15672
55672好像也可以，直接跳转到下列位置
http://127.0.0.1:15672/#/
6. 账号和密码都是guest

Admin选显卡，可以创建一个springcloud账户，tags是rabbitmq的角色分类。（可以创建一个admin账户用来操作）

快速搭建基本工程

添加依赖

<!-- RabbitMQ 消息总线依赖 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
        </dependency>

创建自己的springcloud账户

在admin选项卡中进行创建

点击创建好的账户，设置virtual hosts ,否则一会链接会出错

配置yml文件

spring:
  application:
    #服务名称,随便写
    name: config-center
  cloud:
    config:
      server:
        git:
          # 配置存储配置信息的Git仓库
          uri: https://github.com/chenxiban/SpringCloud-Config.git
          # github账户名
          username: chenxiban
          # github密码
          password: w867647213
          # 开启启动时直接从git获取配置
          clone-on-start: true
          # 配置 git 存储器
          default-label: master
          # 指定配置环境所在路径
          # search-paths: /doc/config
          # 获取子目录下的配置
  #          search-paths: '{application}'
  # rabbitmq配置
  rabbitmq:
    host: localhost
    port: 5672
    username: admin
    password: admin

配置消息生产者

package com.cyj.rabbitmqcenter.sends;

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.Date;

/**
 * @Description: 消息生产者
 * @BelongsProject: Family
 * @BelongsPackage: com.cyj.rabbitmqcenter.sends
 * @Author: ChenYongJia
 * @CreateTime: 2020-01-03 14:25
 * @Email: chen87647213@163.com
 * @Version: 1.0
 */
@Component
public class Sender {

    @Autowired
    private AmqpTemplate rabbitTemplate;

    public void send() {
        String context = "Hello Xiao Zai Zi Now ===>" + new Date();
        System.out.println("sender:" + context);
        this.rabbitTemplate.convertAndSend("hello", context);
    }

}

配置消息消费者

package com.cyj.rabbitmqcenter.receiver;

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * @Description: 消息消费者
 * @BelongsProject: Family
 * @BelongsPackage: com.cyj.rabbitmqcenter.Receivers
 * @Author: ChenYongJia
 * @CreateTime: 2020-01-03 14:28
 * @Email: chen87647213@163.com
 * @Version: 1.0
 */
@Component
@RabbitListener(queues = "hello")
public class Receiver {

    @RabbitHandler
    public void process(String hello) {
        System.out.println("receiver:" + hello);
    }

}

配置基本配置类

package com.cyj.rabbitmqcenter.config;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @Description: 基本配置类
 * @BelongsProject: Family
 * @BelongsPackage: com.cyj.rabbitmqcenter.config
 * @Author: ChenYongJia
 * @CreateTime: 2020-01-03 14:30
 * @Email: chen87647213@163.com
 * @Version: 1.0
 */
@Configuration
public class RabbitmqConfig {

    @Bean
    public Queue helloQueue() {
        return new Queue("hello");
    }

}

创建测试类

package com.cyj.rabbitmqcenter.test;

import com.cyj.rabbitmqcenter.sends.Sender;
import org.junit.jupiter.api.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

/**
 * @Description: 测试消息使用
 * @BelongsProject: Family
 * @BelongsPackage: com.cyj.rabbitmqcenter
 * @Author: ChenYongJia
 * @CreateTime: 2020-01-03 14:31
 * @Email: chen87647213@163.com
 * @Version: 1.0
 */
@RunWith(SpringRunner.class)
@SpringBootTest
public class RabbitmqApplicationTests {

    @Autowired
    private Sender sender;
    @Test
    public void contextLoads() {
    }

    @Test
    public void hello() throws Exception{
        sender.send();
    }

}

结构如下：

启动项目

看到RabbitMQ Connections和Channels 连接条目

在启动测试类

控制台输出：sender:Hello Xiao Zai Zi Now ===>Fri Jan 03 14:43:16 CST 2020

切换到主控制台输出：

receiver:Hello Xiao Zai Zi Now ===>Fri Jan 03 14:43:16 CST 2020

其更多操作自己尝试一下！

最后

• 更多参考精彩博文请看这里：《陈永佳的博客》

• 喜欢博主的小伙伴可以加个关注、点个赞哦，持续更新嘿嘿！