连接实例 通配符。例如,stock. 可以匹配stock.price、stock.quantity等。 绑定键的选择取决于你的需求和消息的路由策略。通过正确设置绑定键,你可以确保消息被正确地路由到相应的队列中,以便消费者进行处理。 代码示例: import com.rabbitmq.client.BuiltinExchangeType; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; import java.io.IOException; import java.util.concurrent.TimeoutException; public class RabbitmqBindingKey { private final static String EXCHANGENAME "exchangeTest"; private final static String QUEUENAME "helloMQ"; private final static String ROUTINGKEY "test"; public static void main(String[] args) throws IOException, TimeoutException { // 创建连接工厂 ConnectionFactory factory new ConnectionFactory(); // 设置主机ip factory.setHost("192.168.3.113"); // 设置amqp的端口号 factory.setPort(5672); // 设置用户名密码 factory.setUsername("rabbitmq"); factory.setPassword("r@bb!tMQ 3333323"); // 设置Vhost,需要在控制台先创建 factory.setVirtualHost("vhost"); //基于网络环境合理设置超时时间 factory.setConnectionTimeout(30 1000); factory.setHandshakeTimeout(30 1000); factory.setShutdownTimeout(0); Connection connection factory.newConnection(); Channel channel connection.createChannel(); channel.exchangeDeclare(EXCHANGENAME, BuiltinExchangeType.DIRECT, true); // 创建 ${QueueName}。Queue 可以在控制台创建,也可以用API创建 channel.queueDeclare(QUEUENAME, true, false, false, null); // Queue 与 Exchange进行绑定,注册 BindingKeyTest channel.queueBind(QUEUENAME, EXCHANGENAME, ROUTINGKEY); connection.close(); } } 完成后,可以在实例列表的交换器选项卡和队列选项卡查看结果。
来自: