Java获取php端放入rabbitmq内的消息
- WBOY原創
- 2016-06-06 19:57:021252瀏覽
欢迎进入Java社区论坛，与200万技术人员互动交流 >>进入 // get方式主动消费 GetResponse res=channel.basicGet（queue_name, false）； if （res != null res.getMessageCount（） = 0） { System.out.println（res.getMessageCount（））； String message
欢迎进入Java社区论坛，与200万技术人员互动交流 >>进入
// get方式主动消费
GetResponse res=channel.basicGet（queue_name, false）；
if （res != null && res.getMessageCount（） >= 0）
{
System.out.println（res.getMessageCount（））；
String message = "";
message = new String（res.getBody（））；
channel.basicAck（res.getEnvelope（）。getDeliveryTag（）， false）；
System.out.println（" [x] Received '" + message + "'"）；
}
else
{
System.out.println（"消息队列中没有可消费的信息！"）；
break;
}
}
channel.close（）；
connection.close（）；
} catch （Exception e） {
e.printStackTrace（）；
}
}
}
在开发的过程中，主要报的异常是：
1.创建交换机和消息队列时，设置的属性和消息产生端的php代码设置的不一样，导致不匹配和一直重写属性
2.在调用时一直没有确定到底是用basicConsume的消费模式还是basicGet消费模式（前者带有监控效果，后者没有，不知道是不是因为一者有跳出while循环，一者没有的原因）
[1] [2]
