SpringBoot集成rabbitmq（一）

时间 2019-11-24

原文原文链接

前言

Rabbitmq是一个开源的消息代理软件，是AMQP协议的实现。核心做用就是建立消息队列，异步发送和接收消息。一般用来在高并发中处理削峰填谷、延迟处理、解耦系统之间的强耦合、处理秒杀订单。入门rabbitmq以前主要是想了解下秒杀排队订单入库后，异步通知客户端秒杀结果。html

基础知识

一、基本概念（角色）

了解rabbitmq以前先要了解3个基本概念：生产者、消费者、代理（队列）。 rabbitmq在生产者和代理中间作了一层抽象。这样消息生产者和队列就没有直接联系，在中间加入了一层交换器（Exchange）。这样消息生产者把消息交给交换器，交换器根据路由策略再把消息转发给对应队列。java

二、消息发送原理

首先要发送消息必须先链接到rabbitmq-server。那怎么链接和发送消息呢？首先你的应用程序和rabbitmq会建立一个TCP连接。一旦TCP连接并经过认证。认证就是你试图链接rabbitmq时服务器的用户名和密码。认证经过，你的应用程序和rabbitmq之间就建立了一条AMQP信道（Channel），后续全部的消息都是基于这个信道完成。web

三、为何不直接经过TCP直接发送消息

对于操做系统来讲建立和销毁TCP链接是很是昂贵的开销，而在并发高峰期时再去处理TCP建立与销毁显然是不合适的。这就形成了TCP的巨大浪费，并且操做系统每秒建立TCP的能力也是有限的，所以直接经过TCP发送消息会很快遇到瓶颈。spring

交换器（Exchange）

前面提到rabbitmq在你的应用程序和队列中间增长了一层代理，代理根据路由策略把消息路由到指定队列。交换器分为4类：ubuntu

direct（默认）
headers
fanout
topic

一、direct。是交换器的默认实现，根据路由规则匹配上就会把消息投递到对应队列。服务器

二、headers。是一个自定义匹配规则类型，在队列和交换器绑定时，会设置一组键值对，消息中也包含一组键值对，当这些键值对匹配上，则会投递消息到对应队列。并发

三、fanout。是一种发布订阅模式，当你发送一条消息时，交换器会把消息广播到全部附加到这个交换器的队列上。对于fanout来讲routingkey是无效的。app

四、topic。能够更灵活的匹配本身想订阅的消息。也是routingkey用处最大的一种。相似咱们配置request mapping中的通配符。异步

安装rabbitmq

我是本机ubuntu16中安装，没有配置软件源，安装速度倒还能接收。rabbitmq是erlang开发，因此先安装erlang,再安装rabbitmq-server高并发

sudo apt-get install erlang

sudo apt-get install rabbitmq-server

安装完成后查看运行状态 systemctl status rabbitmq-server

启动 service rabbitmq-server start

中止 serivce rabbitmq-server stop

重启 service rabbitmq-server restart

安装好rabbitmq后，启用web客户端 rabbitmq-plugines enable rabbitmq_management。

启动后默认使用guest/guest访问，仅支持localhost访问： http://localhost:15672。 web站点默认端口15672。 rabbitmq默认端口5672

在SpringBoot中集成rabbitmq

一、配置信息

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

二、默认交换器（direct）实现

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


@Configuration
public class DirectConfig {

    @Bean
    public Queue directQueue(){
        return new Queue("direct",false); //队列名字，是否持久化
    }

    @Bean
    public DirectExchange directExchange(){
        return new DirectExchange("direct",false,false);//交换器名称、是否持久化、是否自动删除
    }

    @Bean
    Binding binding(Queue queue, DirectExchange exchange){
        return BindingBuilder.bind(queue).to(exchange).with("direct");
    }

}

　消息生产者（发送者）

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

/**
 * 消息发送--生产消息
 */
@Component
public class Sender {

    @Autowired
    AmqpTemplate rabbitmqTemplate;

    public void send(String message){
        System.out.println("发送消息："+message);
        rabbitmqTemplate.convertAndSend("direct",message);
    }
}

　消息消费者（接收者）

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


@Component
@RabbitListener(queues = "direct")
public class Receiver {

    @RabbitHandler
    public void handler(String message){
        System.out.println("接收消息："+message);
    }

}

　OK，来测试下，默认状况下，只能本机访问，我本地是在ubuntu虚拟机中，我在虚拟机中运行demo

import com.zhangfei.mq.Sender;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

@Controller
@RequestMapping("/rabbitmq")
public class MyRabbitmqController {

    
    @Autowired
    Sender sender;

    @RequestMapping("/sender")
    @ResponseBody
    public String sender(){
        System.out.println("send string:hello world");
        sender.send("hello world");
        return "sending...";
    }
}

　运行结果

参考资料

http://www.javashuo.com/article/p-thixepto-hr.html 【推荐。做者：王磊】这里基础概念里有示意图，能够对rabbit涉及到的基础概念和流程有一个直观的认识

http://www.javashuo.com/article/p-qalwxbqb-hh.html