之前已经讲了直连模型，现在开始说这个扇形模型的使用，也就是fanout模型的使用，这个是扇出，也就是广播

这个是有交换机的。

自定义交换机，并且将消息发送给交换机

我们rabbitmq默认是有一些交换机，但是现在我们要自己创建一个交换机，用代码如何进行创建交换机。

public class Provider { public static void main(String[] args) throws IOException { Connection connection = RabbitMqUtils.getConnection(); // 创建通道 Channel channel = connection.createChannel(); // 将通道声明指定的交换机 参数1：交换机的名称 参数2：交换机的类型 fanout 广播类型 channel.exchangeDeclare("logs","fanout"); // 发送消息 channel.basicPublish("logs","",null,"message".getBytes()); // 释放资源 RabbitMqUtils.closeConnectionAndChannel(channel,connection); } }

以上代码和队列就没有什么关系了，直接是将消息发送到我们自定义的交换机里面的。

运行完代码之后，我们就可以看到界面上面生成了一个我们自定义的交换机

创建临时队列，并且将队列和交换机进行绑定，之后从队列里面拿出数据

也就是这个广播的模型，只要和这个广播模型的交换机相连的队列，那么只要在这个交换机里面发送了消息，所有绑定的队列都会得到消息

public class Customer1 { public static void main(String[] args) throws IOException { Connection connection = RabbitMqUtils.getConnection(); // 创建通道 Channel channel = connection.createChannel(); // 将通道声明指定的交换机 参数1：交换机的名称 参数2：交换机的类型 fanout 广播类型 channel.exchangeDeclare("logs","fanout"); // 创建临时队列 String queue = channel.queueDeclare().getQueue(); // 绑定交换机和队列 channel.queueBind(queue,"logs",""); // 消费消息 channel.basicConsume(queue,true,new DefaultConsumer(channel){ @Override public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { System.out.println("消费者1："+new String(body)); } }); } }