java根据rabbitmq队列名称获取队列Queue 对象
可以使用RabbitMQ Java客户端来获取队列对象。以下是一个示例代码:
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Queue.DeclareOk;
public class QueueGetter {
private static final String QUEUE_NAME = "myQueue";
private static final String HOST = "localhost";
private static final int PORT = 5672;
private static final String USERNAME = "guest";
private static final String PASSWORD = "guest";
public static void main(String[] args) throws Exception {
ConnectionFactory factory = new ConnectionFactory();
factory.setHost(HOST);
factory.setPort(PORT);
factory.setUsername(USERNAME);
factory.setPassword(PASSWORD);
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();
// 声明队列
DeclareOk declareOk = channel.queueDeclarePassive(QUEUE_NAME);
System.out.println("队列名称: " + declareOk.getQueue());
System.out.println("消息数量: " + declareOk.getMessageCount());
System.out.println("消费者数量: " + declareOk.getConsumerCount());
channel.close();
connection.close();
}
}
在上面的代码中,我们使用channel.queueDeclarePassive()方法来声明队列,该方法返回一个DeclareOk对象,其中包含了队列的名称、消息数量和消费者数量等信息。
请确保使用正确的RabbitMQ连接参数,例如主机名、端口号、用户名和密码
原文地址: https://www.cveoy.top/t/topic/h1sF 著作权归作者所有。请勿转载和采集!