首页java代码中发消息到rabbitmq

java代码中发消息到rabbitmq

时间: 2023-08-13 21:13:46 浏览: 146

在Java代码中使用RabbitMQ发送消息需要使用RabbitMQ的Java客户端API，以下是一个简单的Java代码示例： ```java import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; public class RabbitMQSender { private final static String QUEUE_NAME = "hello"; public static void main(String[] argv) throws Exception { // 创建连接工厂 ConnectionFactory factory = new ConnectionFactory(); factory.setHost("localhost"); // 创建连接 Connection connection = factory.newConnection(); Channel channel = connection.createChannel(); // 创建消息队列 channel.queueDeclare(QUEUE_NAME, false, false, false, null); // 发送消息 String message = "Hello World!"; channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8")); System.out.println(" [x] Sent '" + message + "'"); // 关闭连接 channel.close(); connection.close(); } } ``` 以上代码连接到本地RabbitMQ服务器，创建一个名为“hello”的消息队列，并发送一条消息“Hello World!”到该队列中。需要注意的是，Java客户端API需要添加RabbitMQ的Java客户端库依赖，可以在Maven中添加以下依赖： ```xml <dependency> <groupId>com.rabbitmq</groupId> <artifactId>amqp-client</artifactId> <version>5.12.0</version> </dependency> ``` 或者在Gradle中添加以下依赖： ```gradle implementation 'com.rabbitmq:amqp-client:5.12.0' ```

阅读全文