Java RabbitMQ 推送数据到队列 - 使用交换机和 Routing Key

以下是使用 Java 往 RabbitMQ 的交换机 "testchange"，使用 routingKey ".test."，向队列 "testqueue" 中推送数据的示例代码：\n\njava\nimport com.rabbitmq.client.Channel;\nimport com.rabbitmq.client.Connection;\nimport com.rabbitmq.client.ConnectionFactory;\n\npublic class RabbitMQProducer {\n private static final String EXCHANGE_NAME = \"testchange\";\n private static final String ROUTING_KEY = \"*.test.*\";\n private static final String QUEUE_NAME = \"testqueue\";\n\n public static void main(String[] args) {\n try {\n // 创建连接工厂\n ConnectionFactory factory = new ConnectionFactory();\n factory.setHost(\"localhost\");\n factory.setUsername(\"guest\");\n factory.setPassword(\"guest\");\n\n // 创建连接\n Connection connection = factory.newConnection();\n\n // 创建信道\n Channel channel = connection.createChannel();\n\n // 声明交换机\n channel.exchangeDeclare(EXCHANGE_NAME, \"direct\");\n\n // 声明队列\n channel.queueDeclare(QUEUE_NAME, false, false, false, null);\n\n // 绑定队列到交换机\n channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, ROUTING_KEY);\n\n // 发送消息\n String message = \"Hello RabbitMQ!\";\n channel.basicPublish(EXCHANGE_NAME, ROUTING_KEY, null, message.getBytes(\"UTF-8\"));\n System.out.println(\"Sent message: \" + message);\n\n // 关闭信道和连接\n channel.close();\n connection.close();\n } catch (Exception e) {\n e.printStackTrace();\n }\n }\n}\n\n\n请确保已经安装了 RabbitMQ，并且已经在本地运行。