java一个rbmq的公共连接方法调用发送消息

更新时间：2024-01-08 15:52:49 作者：肥宅-季波我要评论(0)

下面是一个使用公共连接方法调用发送消息到 RabbitMQ 的示例：

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import java.io.IOException;
public class RabbitMQSender {
private static final String QUEUE_NAME = "hello";
private static final String EXCHANGE_NAME = "my_exchange";
private static final String ROUTING_KEY = "my_routing_key";
private static Connection connection;
public static void main(String[] args) throws Exception {
try {
// 创建连接
createConnection();
// 创建通道
Channel channel = connection.createChannel();
// 发送消息
sendMessage(channel, "Hello RabbitMQ!");
// 关闭通道
channel.close();
} finally {
// 关闭连接
closeConnection();
}
}
private static void createConnection() throws IOException {
// 创建连接工厂
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
factory.setUsername("guest");
factory.setPassword("guest");
// 创建连接
connection = factory.newConnection();
}
private static void closeConnection() throws IOException {
if (connection != null && connection.isOpen()) {
connection.close();
}
}
private static void sendMessage(Channel channel, String message) throws IOException {
// 声明交换机
channel.exchangeDeclare(EXCHANGE_NAME, "direct");
// 声明队列
channel.queueDeclare(QUEUE_NAME, false, false, false, null);
// 绑定队列到交换机
channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, ROUTING_KEY);
// 发布消息到交换机
channel.basicPublish(EXCHANGE_NAME, ROUTING_KEY, null, message.getBytes("UTF-8"));
System.out.println("Sent: " + message);
}
}