根据下图所示，RabbitMQ的工作模式有六种

RabbitMQ 使用场景

服务解耦
假设有这样一个场景, 服务A产生数据, 而服务B,C,D需要这些数据, 那么我们可以在A服务中直接调用B,C,D服务,把数据传递到下游服务即可
但是,随着我们的应用规模不断扩大,会有更多的服务需要A的数据,如果有几十甚至几百个下游服务,而且会不断变更,再加上还要考虑下游服务出错的情况,那么A服务中调用代码的维护会极为困难

rabbitmq 基本概念

RabbitMQ是一种消息中间件，用于处理来自客户端的异步消息。服务端将要发送的消息放入到队列池中。接收端可以根据RabbitMQ配置的转发机制接收服务端发来的消息。RabbitMQ依据指定的转发规则进行消息的转发、缓冲和持久化操作，主要用在多服务器间或单服务器的子系统间进行通信，是分布式系统标准的配置。

Exchange

接受生产者发送的消息，并根据Binding规则将消息路由给服务器中的队列。ExchangeType决定了Exchange路由消息的行为。在RabbitMQ中，ExchangeType常用的有direct、Fanout和Topic三种

Message Queue

消息队列。我们发送给RabbitMQ的消息最后都会到达各种queue，并且存储在其中(如果路由找不到相应的queue则数据会丢失)，等待消费者来取。

Binding Key

它表示的是Exchange与Message Queue是通过binding key进行联系的，这个关系是固定。

Routing Key

生产者在将消息发送给Exchange的时候，一般会指定一个routing key，来指定这个消息的路由规则。这个routing key需要与Exchange Type及binding key联合使用才能生，我们的生产者只需要通过指定routing key来决定消息流向哪里。

rabbitmq安装

在contos 7 中下载镜像

docker pull rabbitmq:management

关闭防火墙
关闭防火墙

systemctl stop firewalld
systemctl disable firewalld

重启 docker 系统服务

systemctl restart docker

配置管理员用户名和密码

mkdir /etc/rabbitmq
vim /etc/rabbitmq/rabbitmq.conf

添加两行配置：

default_user = admin
default_pass = admin

启动Rabbitmq

docker run -d --name rabbit \
-p 5672:5672 \
-p 15672:15672 \
-v /etc/rabbitmq/rabbitmq.conf:/etc/rabbitmq/rabbitmq.conf \
-e RABBITMQ_CONFIG_FILE=/etc/rabbitmq/rabbitmq.conf \
--restart=always \
rabbitmq:management

访问管理控制台 http://192.168.64.140:15672
用户名密码是 admin

rabbitmq六种工作模式

在java项目中添加依赖

<dependency>
			<groupId>com.rabbitmq</groupId>
			<artifactId>amqp-client</artifactId>
			<version>5.4.3</version>
		</dependency>

创建生产类

package m11;
import com.rabbitmq.client.*;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
public class consumer101 {
    public static void main(String[] args) throws IOException, TimeoutException {

         ConnectionFactory cFy = new ConnectionFactory();
         cFy.setPort(5672);
         cFy.setPassword("admin");
         cFy.setUsername("admin");
         cFy.setHost("192.168.64.140");
         //
         Connection connection = cFy.newConnection();
           //创建一个连接通道
         Channel c = connection.createChannel();
         //创建一个队列
          c.queueDeclare("helloword", false, false, false, null);
         /*DeliverCallback deliverCallback= new DeliverCallback() {
            @Override
            public void handle(String s, Delivery delivery) throws IOException {

            }
           }*/

          //创建一个回调函数
          DeliverCallback deliverCallback = (consumertag,message) ->{
              byte[] body = message.getBody();
              String s = new String(body);
              System.out.println("收到"+s);
          };
          //传递回调函数处理
          CancelCallback cancelCallback = consumerTag -> {};
          c.basicConsume("helloword", true, deliverCallback,cancelCallback );

    }
}

创建消费类

package m11;
import com.rabbitmq.client.*;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
public class consumer101 {
    public static void main(String[] args) throws IOException, TimeoutException {

         ConnectionFactory cFy = new ConnectionFactory();
         cFy.setPort(5672);
         cFy.setPassword("admin");
         cFy.setUsername("admin");
         cFy.setHost("192.168.64.140");
         //
         Connection connection = cFy.newConnection();
           //创建一个连接通道
         Channel c = connection.createChannel();
         //创建一个队列
          c.queueDeclare("helloword", false, false, false, null);
         /*DeliverCallback deliverCallback= new DeliverCallback() {
            @Override
            public void handle(String s, Delivery delivery) throws IOException {

            }
           }*/

          //创建一个回调函数
          DeliverCallback deliverCallback = (consumertag,message) ->{
              byte[] body = message.getBody();
              String s = new String(body);
              System.out.println("收到"+s);
          };
          //传递回调函数处理
          CancelCallback cancelCallback = consumerTag -> {};
          c.basicConsume("helloword", true, deliverCallback,cancelCallback );

    }
}