消息中间件（3）—— 交换器（Fanout、Topic）

上一篇通过代码演示了最简单的交换器--direct交换器

本篇学习一下其他的交换器（Fanout、Topic）

一、Fanout交换器

又称为广播交换器，不处理路由键。只要是绑定到该交换器上的队列都能收到这个消息，Fanout交换机转发消息是最快的

创建方式很简单，只需要指定交换器的类型即可

生产者代码如下

public class FanoutProducer {public final static String EXCHANGE_NAME = "fanoutLogs";public static void main(String[] args) throws IOException, TimeoutException {//创建连接连接到MabbitMQConnectionFactory factory = new ConnectionFactory();//设置MabbitMQ所在主机ip或者主机名factory.setHost("127.0.0.1");//创建一个连接Connection connection = factory.newConnection();//创建一个信道Channel channel = connection.createChannel();/**********指定交换器的类型是广播************/channel.exchangeDeclare(EXCHANGE_NAME, BuiltinExchangeType.FANOUT);/*日志消息级别，作为路由键使用*/String[] routekeys &#