rabbitmq-direct（直接交换模式）

太过爱你忘了你带给我的痛 2022-05-17 07:35 157阅读 0赞

# RabbitMQ—direct（直接交换模式） #

--------------------

## 一、什么是direct（直接交换模式） ##

生产者和消费者，具有相同的交换机名称（Exchange）、交换机类型和相同的密匙（**routingKey**），那么消费者即可成功获取到消息。  
（PS：相对比只要交换机名称即可接收到消息的[广播模式（fanout）][fanout]，direct模式在其基础上，多加了一层密码限制（routingKey）。）

![kqKzcwJ.png][]

> RabbitMQ消息模型的**核心思想（core idea）**: 生产者会把消息发送给RabbitMQ的交换中心（Exchange），Exchange的一侧是生产者，另一侧则是一个或多个队列，由Exchange决定一条消息的生命周期–发送给某些队列，或者直接丢弃掉。

--------------------

## 二、代码域 ##

### 1. 生产者【DirectBoss】 ###

package com.iyungu.phantaci.test.rabbitmq;
    
    import com.rabbitmq.client.BuiltinExchangeType;
    import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    import com.rabbitmq.client.ConnectionFactory;
    import org.apache.log4j.Logger;
    
    import java.io.IOException;
    import java.util.concurrent.TimeoutException;
    //消息生产者
    public class DirectBoss {
    
    private static final Logger logger = Logger.getLogger(DirectBoss.class);
    public static void main(String[] args) {
    
        ConnectionFactory factory = new ConnectionFactory();
        try {
            factory.setHost("localhost");
            Connection connection = factory.newConnection();
            Channel channel = connection.createChannel();
            //声明交换机（名称和类型）
            channel.exchangeDeclare("directLogs", BuiltinExchangeType.DIRECT);
            String message = "2018年8月8日14:03:48";
            //消息发布（其中"directLogs"为交换机名称，"jay"为routingKey）
            channel.basicPublish("directLogs","jay",null,message.getBytes());
            logger.info("********Message********:发送成功");
            channel.close();
            connection.close();
        } catch (IOException | TimeoutException e) {
            e.printStackTrace();
        }
    }

### 2. 消费者【DirectWorker】 ###

package com.iyungu.phantaci.test.rabbitmq;
    
    import com.rabbitmq.client.*;
    import org.apache.log4j.Logger;
    
    import java.io.IOException;
    import java.util.concurrent.TimeoutException;
    
    //消息消费者
    public class DirectWorker {
    
        private static final Logger logger = Logger.getLogger(DirectWorker.class);
        public static void main(String[] args) {
    
            ConnectionFactory factory = new ConnectionFactory();
            factory.setHost("localhost");
            try {
                Connection connection = factory.newConnection();
                Channel channel = connection.createChannel();
                //交换机声明（参数为：交换机名称；交换机类型）
                channel.exchangeDeclare("directLogs", BuiltinExchangeType.DIRECT);
                //获取一个临时队列
                String queueName = channel.queueDeclare().getQueue();
                //队列与交换机绑定（参数为：队列名称；交换机名称；密匙-routingKey）
                channel.queueBind(queueName,"directLogs","jay");
    
                logger.info("********Waiting for messages********");
    
                //这里重写了DefaultConsumer的handleDelivery方法，因为发送的时候对消息进行了getByte()，在这里要重新组装成String
                Consumer consumer = new DefaultConsumer(channel) {
                    @Override
                    public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
                        super.handleDelivery(consumerTag, envelope, properties, body);
                        String message = new String(body,"UTF-8");
                        logger.info("received:" + message);
                    }
                };
    
                //声明队列中被消费掉的消息（参数为：队列名称；消息是否自动确认;consumer主体）
                channel.basicConsume(queueName,true,consumer);
                //这里不能关闭连接，调用了消费方法后，消费者会一直连接着rabbitMQ等待消费
            } catch (IOException |TimeoutException e) {
                e.printStackTrace();
            }
    
    
        }
    
    }

--------------------

## 三、direct模式效果 ##

### 1.1）先运行一个消费者，即【DirectWorker】 ###

![vlifSm6.png][]

### 2）把消费者【DirectWorker】里的routingKey进行修改 ###

把`channel.queueBind(queueName,"directLogs","jay");`修改为`channel.queueBind(queueName,"directLogs","jjlin");`。修改完毕后，再运行该消费者  
![DrzWSXs.png][]

#### RabbitMQ网页控制台如下，可看到两个消费者队列 ####

![JJRCs31.png][]

### 2. 再运行一个生产者，即【DirectBoss】 ###

#### 控制台效果图如下，一条消息发布后，和交换机routingKey一致的消费者收到了消息，不一致的无消息; ####

**消息是由生产者发送给交换机，所以要以生产者发布消息时的routingKey为准。此时，生产者里的routingKey为：”jay”**  
![eIhlPMZ.png][]

消费者的routingKey为：”jay“，与生产者**一致**。消息接收成功  
![YFcRJnc.png][]

消费者的routingKey为：”jjlin“，与生产者**不一致**。消息接收失败

## ![bF6iAvH.png][] ##

--------------------

## 四、多路由(routingKey)接收 ##

通过给消费者绑定多个路由（routingKey），可以使该消费者同时接收多个路由获取的消息。

如给消费者代码【DirectWorker】同时绑定两个routingKey，其余不变

channel.queueBind(queueName, "directLogs", "jjlin"); //routingKey为jjlin
    channel.queueBind(queueName, "directLogs", "jay"); //routingKey为jay

### 1.绑定两个routingKey后，运行一个消费者【DirectWorker】 ###

![z5VEcos.png][]

### 2.运行一个生产者【DirectBoss】，代码默认其routingKey为”jay” ###

![xqjdRR2.png][]  
![CSkqhWP.png][]

### 3.修改生产者routingKey为”jjlin”，然后再运行生产者【DirectBoss】 ###

把生产者代码里的routingKey进行修改，即`channel.basicPublish("directLogs","jay",null,message.getBytes());`改为`channel.basicPublish("directLogs","jjlin",null,message.getBytes());`,修改完毕后再运行生产者。  
![unkowIl.png][]  
![eCClbZU.png][]

### 4.局限性 ###

通过多路由绑定的例子，可以体会到direct模式相对比fanout模式，可以选择性的接收消息；但局限是面对更多、更复杂的路由匹配时，仍旧会力不从心，这时可以使用更全面的topic主题模式。

> 参考：[http://www.rabbitmq.com/tutorials/tutorial-four-java.html][http_www.rabbitmq.com_tutorials_tutorial-four-java.html]，[http://www.cnblogs.com/4—-/p/6518801.html][http_www.cnblogs.com_4_-_p_6518801.html]，感谢分享

[fanout]: https://blog.csdn.net/fakerswe/article/details/81455340
[kqKzcwJ.png]: https://i.imgur.com/kqKzcwJ.png
[vlifSm6.png]: https://i.imgur.com/vlifSm6.png
[DrzWSXs.png]: https://i.imgur.com/DrzWSXs.png
[JJRCs31.png]: https://i.imgur.com/JJRCs31.png
[eIhlPMZ.png]: https://i.imgur.com/eIhlPMZ.png
[YFcRJnc.png]: https://i.imgur.com/YFcRJnc.png
[bF6iAvH.png]: https://i.imgur.com/bF6iAvH.png
[z5VEcos.png]: https://i.imgur.com/z5VEcos.png
[xqjdRR2.png]: https://i.imgur.com/xqjdRR2.png
[CSkqhWP.png]: https://i.imgur.com/CSkqhWP.png
[unkowIl.png]: https://i.imgur.com/unkowIl.png
[eCClbZU.png]: https://i.imgur.com/eCClbZU.png
[http_www.rabbitmq.com_tutorials_tutorial-four-java.html]: http://www.rabbitmq.com/tutorials/tutorial-four-java.html
[http_www.cnblogs.com_4_-_p_6518801.html]: http://www.cnblogs.com/4----/p/6518801.html