首页 > 代码库 > 消息过滤

消息过滤

如果没有消息过滤,消费者会收到所有消息,这就需要编写java代码在业务中人工过滤不想要的消息,而使用消息选择器,消费者就只能接收能通过过滤器的那些消息,消息选择器只能使用消息头和消息属性,不能使用消息体内的数据

技术分享

可用的比较运算符

技术分享

示例:

String filter = "JMSCorrelationID = ‘" + msg.getJMSMessageID() + "‘";
QueueReceiver qReceiver = qSession.createReceiver(responseQ, filter);

两种消息过滤方式:

技术分享

 

 技术分享

 

 技术分享

其中多目的地方式生产者需要对消息处理过程了解的更多,以控制消费者接受哪一条消息,使得耦合紧密且扩展较不方便(扩展时不仅需要新增一个队列接收者,还需要新增一个队列以及修改队列发送者)

另外注意在p2p模型中,消息被保证至少传给一个消费者,可以创建一个未传送消息消费者,用来接收那些被其他消息过滤器都排除掉的消息。

 

消息过滤