本文主要是介绍fanout模式，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
生产者：
public class Provider {public static void main(String[] args) throws IOException {Connection connection = RabbitMQUtils.getConnection();Channel channel = connection.createChannel();//通道声明指定的交换机 参数1：交换机名称 参数2：交换机类型 fanout广播类型// 在交换机不存在的时候创建这个logs交换机channel.exchangeDeclare("logs","fanout");//发布消息channel.basicPublish("logs","",null,"fanout模型".getBytes());RabbitMQUtils.closeConnectionAndChanel(channel,connection);}
}
- 参数一：交换机的名字
- 参数二：routingKey:路由。 在这种广播里面，这个routingKey是没有任何意义的。
- 参数三：消息持久化的特性。我们这里面还给一个null
消费者1：
public class Customer1 {public static void main(String[] args) throws IOException {Connection connection = RabbitMQUtils.getConnection();Channel channel = connection.createChannel();//通道绑定交换机channel.exchangeDeclare("logs","fanout");String queueName = channel.queueDeclare().getQueue();channel.queueBind(queueName,"logs","");}}这篇关于fanout模式的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
