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","");}}