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

忘是亡心i 2022-12-27 11:21 232阅读 0赞

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

![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 1][]

发送消息之后都能收到消息：

生产者：

package org.example.Fanout;
    
    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.Fanout
     * @ClassName: Provider2
     * @Description: java类作用描述
     * @Author: zhangq
     * @CreateDate: 2020-12-10 18:33
     * @UpdateUser: zhangq
     * @UpdateDate: 2020-12-10 18:33
     * @UpdateRemark: The modified content
     * @Version: 1.0 *
     */
    public class Provider2 {
    
      @Test
      public void sendmessage() throws IOException {
        //获取连接对象
        Connection connection = RabbitMQUtils.getConnection();
        //获取连接中通道
        Channel channel = connection.createChannel();
        //参数1 交换机名称  参数2 类型
        channel.exchangeDeclare("logs", "fanout");
        //发布消息
        channel.basicPublish("logs", "", MessageProperties.PERSISTENT_TEXT_PLAIN,
            ("张强测试fanout:").getBytes());
    
        RabbitMQUtils.closeConnectionFactory(channel, connection);
    
    
      }
    
    }

消费者1：

package org.example.Fanout;
    
    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", "fanout");
      //临时队列名称
        String queneName=channel.queueDeclare().getQueue();
        //绑定交换机和队列
        channel.queueBind(queneName,"logs","");
    
        //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.Fanout;
    
    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", "fanout");
        //临时队列名称
        String queneName=channel.queueDeclare().getQueue();
        //绑定交换机和队列
        channel.queueBind(queneName,"logs","");
    
        //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("消费者-2：" + new String(body));
    
          }
        });
      }
    }

消费者3：

package org.example.Fanout;
    
    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 consum33 {
    
      public static void main(String[] args) throws IOException {
        Connection connection = RabbitMQUtils.getConnection();
        Channel channel = connection.createChannel();
        //参数1 交换机名称  参数2 类型
        channel.exchangeDeclare("logs", "fanout");
        //临时队列名称
        String queneName=channel.queueDeclare().getQueue();
        //绑定交换机和队列
        channel.queueBind(queneName,"logs","");
    
        //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("消费者-3：" + new String(body));
    
          }
        });
      }
    }

先启动消费者，在启动生产者：

![20201210184906373.png][]

![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][]

都能收到消息

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 4][]

[https_github.com_heidaodageshiwo_ZqRabbitMq]: https://github.com/heidaodageshiwo/ZqRabbitMq
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20201210183224501.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 1]: https://img-blog.csdnimg.cn/20201210183828344.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl,size_16,color_FFFFFF,t_70
[20201210184906373.png]: https://img-blog.csdnimg.cn/20201210184906373.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20201210184910435.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/2020121018491645.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 4]: https://img-blog.csdnimg.cn/20201210184942826.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2h1bmhlaWRhb2Rl,size_16,color_FFFFFF,t_70

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

发表评论取消回复

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

相关阅读

相关 Springboot整合Rabbitmq，Direct、Fanout、Topic

相关 RabbitMQ---SpringBoot整合RabbitMQ(Fanout交换器)

相关 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的安装（无废话版）--------------------------------------------（一）