消息监听
之前在Consumer端接收消息时，使用的是while(true)死循环阻塞等待消息来到后使用consumer.receive()接受，但这样明显不科学。ActiveMQ提供了一个方法，当ActiveMQ检测到消息过来后，将消息push给消费端，具体实现如下：
//初始化ActiveMQ
ConnectionFactory connectionFactior = new ActiveMQConnectionFactory("用户名", "密码", "tcp://localhost:61616");
//创建connection连接
Connection con = connectionFactior.createConnection();
con.start();
Session session = con.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue("first");
MessageConsumer consumer = session.createConsumer(destination);
/*通过MessageConsumer设置一个消息监听器，其中MesssageListener为一个接口，当消息接受过来
之后会自动出发这个该消息监听器，对消息的具体操作均在onMessage（）方法中实现，传过来的消
息均为Message的子类的实例，之后再通过instanceof判断message是否为TextMessage或者
MapMessage或者其他的Message类型，并进行对应的处理*/
consumer.setMessageListener(new MessageListener() {
@Override
public void onMessage(Message message) {
if(message instanceof TextMessage){
}
if(message instanceof MapMessage){
MapMessage mapMessage = (MapMessage)message;
try {
System.out.println(mapMessage);
System.out.println(mapMessage.getString("name"));
System.out.println(mapMessage.getStringProperty("color"));
System.out.println(mapMessage.getIntProperty("id"));
} catch (JMSException e) {
e.printStackTrace();
}
}
}
});
消息过滤
ActiveMQ支持将收到的消息进行过滤，可以使不同的Consumer找出自己所要处理的消息进行处理，如此可以使不同的消费端协同处理以提高效率，或者使消费端找到自己所需的消息进行处理。
首先看如何设置过滤规则：
consumer = session.createConsumer(destination, "JMSType = 'car' AND weight > 2500");
在JMS Selectors表达式中，可以使用IN、NOT IN、LIKE等，例如： LIKE '12%3' （'123' true，'12993' true，'1234' false） LIKE 'l_se' （'lose' true，'loose' false） LIKE '_%' ESCAPE '' （'_foo' true，'foo' false） 需要注意的是，JMS Selectors表达式中的日期和时间需要使用标准的long型毫秒值。另外表达式中的属性不会自动进行类型转换
如何将过滤规则加载到消费者的实例中？
//过滤规则举例：
//注意如果为String类型的应该加单引号' '
public final String SELECT1 = "color = 'white'";
public final String SELECT2 = "id > 2";
consumer =session.createConsumer(destination, SELECT2 );
如此一来该consumer便可以之接受符合自己过滤规则的消息
需要注意的是如何在生产者（producer）设置过滤属性，以使消费端过滤。
不论使那种类型的TextMessage，MapMessage均有设置属性的方法，consumer就是根据这个属性来进行过滤的。设置属性的方法为：
MapMessage mapMessage = this.session.createMapMessage();
//设置属性用来使consumer过滤的方法均是以Property结尾的。
mapMessage.setStringProperty("color", "white");
mapMessage.setIntProperty("id", 3);
//下面的两个就是添加的普通String参数，不会作为筛选器筛选的条件
mapMessage2.setString("name", "saber");
mapMessage2.setString("age", "25");
//以上设置的参数均可在consumer中的mapMassage.getString("name")，或者mapMessage.getStringProperty("color")得到
MapMessage
MapMessage也没啥，看上面的mapMassage.setxxxxxx方法就可以了，大概是这么个意思
消息订阅：
消息订阅的意思是当生产者发送一个消息出去后，所有的监听该Topic的消费者均可以做出响应。
相反如果是普通的生产者生产一个消息，然后消费者消费的话，即使有n多个消费者都在监听，最终仍然只有一个消费者会处理这个消息。
生产者端消息订阅机制的实现方法：
//只需将原本的session.createQueue()，替换成session.createTopic(“队列名”)即可
//session为：javax.jms.Session下的session
Destination destination = session.createTopic("pt");
MessageProducer messageProducer = session.createProducer(null);
mesageProducer.send(destination ,Message mes);
消费者端的订阅消息的实现方法：
//同样只需将原本的session.createQueue()，替换成session.createTopic(“队列名”)即可
Destination destination = session.createTopic("pt");
MessageConsumer consumer = session.createConsumer(destination);
//然后用consumer接收即可
consumer.setMessageListener(new MessageListener() {
...........................
};
