fanout(扇出模型)-编程知识

fanout(扇出模型)

在广播的流程下，消息发送的流程如下：

可以有多个消费者。
每个消费者有自己的queue(队列)。
每个队列都要绑定到Exchange(交换机)。
生产者发送的消息，只能发送到交换机，交换机来决定要发给哪个队列，生产者也无法决定。
交换机把消息发送给绑定过的所有队列。
所有的消费者都能拿到消息，实现一个消息被多个消费者消费。

1.生产者

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

2.消费者

public class Consumer1 {public static void main(String[] args) throws IOException {//获取连接对象Connection connection = RabbitMqUtil.getConnection();//获取连接通道Channel channel = connection.createChannel();//通道绑定交换机channel.exchangeDeclare("fanoutexchange","fanout");//临时队列String queueName = channel.queueDeclare().getQueue();//绑定交换机和队列channel.queueBind(queueName,"fanoutexchange","");channel.basicConsume(queueName,true,new DefaultConsumer(channel){@Overridepublic void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {System.out.println("consumer1得到："+new String(body));}});//注意这里不能关闭通道和连接，因为要一直监听}
}