// 默认连接用户
private static final String USERNAME = "admin";
// 默认连接密码
private static final String PASSWORD = "admin";
// 默认连接URL
private static final String BROKERURL = "tcp://139.224.235.172:61613";
public static void main(String[] args) {
// 连接工厂
ConnectionFactory connectionFactory;
// 连接
Connection connection = null;
// 会话
Session session;
// 消息目的地
Destination destination;
// 消息消费者
MessageConsumer consumer;
// 实例化工厂
connectionFactory = new ActiveMQConnectionFactory(USERNAME, PASSWORD,
BROKERURL);
try {
// 创建连接
connection = connectionFactory.createConnection();
// 启动连接
connection.start();
// 创建会话
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
// 创建消息队列
destination = session
.createQueue("p171024103004.response.payonline");
// 创建消费者
consumer = session.createConsumer(destination);
while (true) {
// 参数:接收消息的超时时间,为0的话则不超时,receive返回下一个消息,但是超时了或者消费者被关闭,返回null
Message message = (Message) consumer.receive(10*1000);
if (message != null) {
System.out.println("收到的消息:" + ((TextMessage) message).getText());
} else {
System.out.println("没有收到消息");
break;
}
}
} catch (Exception e) {
e.printStackTrace();
}
}