Fanout交换机是RabbitMQ中最简单的一种交换机类型。它会将所有接收到的消息广播给所有与之绑定的队列。无论消息的路由键是什么，Fanout交换机都会将消息发送给所有与之绑定的队列。这种广播模式非常适合需要将消息发送给多个消费者的场景。
Fanout交换机的基本概念
Fanout交换机的工作方式非常简单。当它接收到一条消息时，它会将该消息广播给所有与之绑定的队列。它不关心消息的路由键，只负责将消息复制到所有队列中。
Fanout交换机的关键特点如下：
- 消息广播：Fanout交换机会将接收到的消息广播给所有与之绑定的队列。
- 无需路由键：Fanout交换机不关心消息的路由键，它只负责将消息复制到所有队列中。
- 队列绑定：队列需要将自己绑定到Fanout交换机上，以接收交换机广播的消息。
使用Java代码创建Fanout交换机、绑定队列并发送消息的示例：
代码语言：javascript复制import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.util.concurrent.TimeoutException;
public class FanoutExchangeExample {
private static final String EXCHANGE_NAME = "fanout_exchange";
public static void main(String[] args) throws IOException, TimeoutException {
// 创建连接工厂
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
// 创建连接
Connection connection = factory.newConnection();
// 创建信道
Channel channel = connection.createChannel();
// 声明Fanout交换机
channel.exchangeDeclare(EXCHANGE_NAME, "fanout");
// 声明队列1
String queue1Name = channel.queueDeclare().getQueue();
// 声明队列2
String queue2Name = channel.queueDeclare().getQueue();
// 绑定队列1到交换机
channel.queueBind(queue1Name, EXCHANGE_NAME, "");
// 绑定队列2到交换机
channel.queueBind(queue2Name, EXCHANGE_NAME, "");
// 发送消息
String message = "Hello, RabbitMQ!";
channel.basicPublish(EXCHANGE_NAME, "", null, message.getBytes(StandardCharsets.UTF_8));
System.out.println("Sent message: " message);
// 关闭信道和连接
channel.close();
connection.close();
}
}在这个示例中，我们首先创建了一个名为"fanout_exchange"的Fanout交换机。然后，我们创建了两个队列并将它们分别绑定到Fanout交换机上。绑定时，我们使用空字符串作为路由键，因为Fanout交换机不关心路由键的值。
最后，我们使用channel.basicPublish方法发送一条消息到Fanout交换机。这条消息会被Fanout交换机广播给所有与之绑定的队列。发送的消息是"Hello, RabbitMQ!"。
