SpringBoot整合Rabbitmq之===RabbitMQ的 Routing之Dir模型（无废话版）--------------------------------------------（五）

╰+哭是因爲堅強的太久メ 2022-12-27 11:22 229阅读 0赞

# 代码地址：[https://github.com/heidaodageshiwo/ZqRabbitMq][https_github.com_heidaodageshiwo_ZqRabbitMq] #

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70][]

生产者：

package org.example.Direct;
    
    import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    import com.rabbitmq.client.MessageProperties;
    import java.io.IOException;
    import org.example.RabbitMQUtils;
    import org.junit.Test;
    
    /**
     * java类简单作用描述
     *
     * @ProjectName: rabbitmq
     * @Package: org.example.Direct
     * @ClassName: Provider3
     * @Description: java类作用描述
     * @Author: zhangq
     * @CreateDate: 2020-12-10 18:52
     * @UpdateUser: zhangq
     * @UpdateDate: 2020-12-10 18:52
     * @UpdateRemark: The modified content
     * @Version: 1.0 *
     */
    public class Provider3 {
    
      @Test
      public void sendmessage() throws IOException {
        //获取连接对象
        Connection connection = RabbitMQUtils.getConnection();
        //获取连接中通道
        Channel channel = connection.createChannel();
        //参数1 交换机名称  参数2 类型
        channel.exchangeDeclare("logs_direct", "direct");
        String routingkey="info";
        //发布消息
        channel.basicPublish("logs_direct", routingkey, MessageProperties.PERSISTENT_TEXT_PLAIN,
            ("张强测试direct:").getBytes());
    
        RabbitMQUtils.closeConnectionFactory(channel, connection);
    
    
      }
    
    }

消费者1：

package org.example.Direct;
    
    import com.rabbitmq.client.AMQP.BasicProperties;
    import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    import com.rabbitmq.client.DefaultConsumer;
    import com.rabbitmq.client.Envelope;
    import java.io.IOException;
    import org.example.RabbitMQUtils;
    
    /**
     * java类简单作用描述
     *
     * @ProjectName: rabbitmq
     * @Package: org.example.Work
     * @ClassName: consum1
     * @Description: java类作用描述
     * @Author: zhangq
     * @CreateDate: 2020-12-10 18:08
     * @UpdateUser: zhangq
     * @UpdateDate: 2020-12-10 18:08
     * @UpdateRemark: The modified content
     * @Version: 1.0 *
     */
    public class consum11 {
    
      public static void main(String[] args) throws IOException {
        Connection connection = RabbitMQUtils.getConnection();
        Channel channel = connection.createChannel();
        //参数1 交换机名称  参数2 类型
        channel.exchangeDeclare("logs_direct", "direct");
      //临时队列名称
        String queneName=channel.queueDeclare().getQueue();
        //基于route 绑定交换机和队列
        channel.queueBind(queneName,"logs_direct","error");
    
        //autoAck 置位 false
        channel.basicConsume(queneName, true, new DefaultConsumer(channel) {
          @Override
          public void handleDelivery(String consumerTag, Envelope envelope, BasicProperties properties,
              byte[] body) throws IOException {
    
            System.out.println("消费者-1：" + new String(body));
    
          }
        });
      }
    }

消费者2：

package org.example.Direct;
    
    import com.rabbitmq.client.AMQP.BasicProperties;
    import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    import com.rabbitmq.client.DefaultConsumer;
    import com.rabbitmq.client.Envelope;
    import java.io.IOException;
    import org.example.RabbitMQUtils;
    
    /**
     * java类简单作用描述
     *
     * @ProjectName: rabbitmq
     * @Package: org.example.Work
     * @ClassName: consum1
     * @Description: java类作用描述
     * @Author: zhangq
     * @CreateDate: 2020-12-10 18:08
     * @UpdateUser: zhangq
     * @UpdateDate: 2020-12-10 18:08
     * @UpdateRemark: The modified content
     * @Version: 1.0 *
     */
    public class consum22 {
    
      public static void main(String[] args) throws IOException {
        Connection connection = RabbitMQUtils.getConnection();
        Channel channel = connection.createChannel();
        //参数1 交换机名称  参数2 类型
        channel.exchangeDeclare("logs_direct", "direct");
      //临时队列名称
        String queneName=channel.queueDeclare().getQueue();
        //基于route 绑定交换机和队列
        channel.queueBind(queneName,"logs_direct","error");
        channel.queueBind(queneName,"logs_direct","info");
        channel.queueBind(queneName,"logs_direct","warning");
    
        //autoAck 置位 false
        channel.basicConsume(queneName, true, new DefaultConsumer(channel) {
          @Override
          public void handleDelivery(String consumerTag, Envelope envelope, BasicProperties properties,
              byte[] body) throws IOException {
    
            System.out.println("消费者-1：" + new String(body));
    
          }
        });
      }
    }

运行看效果：

生产者发送的是

String routingkey="info";

info类型；

消费者1 绑定的是：error

channel.queueBind(queneName,"logs_direct","error");

消费者2 绑定的是：error ,info,warning

//基于route 绑定交换机和队列
    channel.queueBind(queneName,"logs_direct","error");
    channel.queueBind(queneName,"logs_direct","info");
    channel.queueBind(queneName,"logs_direct","warning");

消费者1 没有订阅error，所以接收不到消息

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 1][]

消费者2订阅了能接收到消息

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 2][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 3][]

[https_github.com_heidaodageshiwo_ZqRabbitMq]: https://github.com/heidaodageshiwo/ZqRabbitMq
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70]: /images/20221120/7e48ab82da00457b819647217763033d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 1]: /images/20221120/d693eb52eb2940e9ad5bfcaf40b5419f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20201210190027317.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/20201210190041354.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl,size_16,color_FFFFFF,t_70

SpringBoot整合Rabbitmq之===RabbitMQ的 Routing之Dir模型（无废话版）--------------------------------------------（五）

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 rabbitmq入门（五）rabbitmq整合springboot（Routing、Topics）

相关 SpringBoot整合Rabbitmq之===Rabbitmq集群搭建（无废话版）--------------------------------------------（八）

相关 SpringBoot整合Rabbitmq之===Springboot整合Rabbitmq（无废话版）--------------------------------------------（七）

相关 SpringBoot整合Rabbitmq之===RabbitMQ的 Routing之Topic（无废话版）--------------------------------------------（六）

相关 SpringBoot整合Rabbitmq之===RabbitMQ的 Routing之Dir模型（无废话版）--------------------------------------------（五）

相关 SpringBoot整合Rabbitmq之===RabbitMQ的 Fanout模型（无废话版）--------------------------------------------（四）

相关 SpringBoot整合Rabbitmq之===RabbitMQ的 Work 模型（无废话版）--------------------------------------------（三）

相关 SpringBoot整合Rabbitmq之===RabbitMQ的HelloWorld模型（无废话版）--------------------------------------------（二）

相关 SpringBoot整合Rabbitmq之===RabbitMQ的安装（无废话版）--------------------------------------------（一）

相关 Springboot整合之--RabbitMQ