1. 表達式定義的一些重要的規(guī)則

1.1. 表達式的操作符不區(qū)分大小寫, 但通常約定為大寫。

1.2. 表達式的變量名跟普通Java變量名的命名規(guī)則一致, 區(qū)分大小寫, 如articleType和articletype是兩個不同的變量。

1.3. 表達式的變量名必須是標準的消息頭名或者已存在的屬性名, 否則對應(yīng)的值會為NULL。

1.4. 表達式的值不會進行類型轉(zhuǎn)化, 即假設(shè)有message.setStringProperty("version",?"1"); 那么表達式"version=1"對于message來說, 結(jié)果是false。

1.5. 支持基本的算術(shù)操作, 邏輯操作, 括號, 取反等運算符。

1.6. 支持BETWEEN .. AND ... , IN(NOT IN)等操作。

1.7. 支持LIKE操作進行模糊匹配, %表示匹配多個任意字符, _表示匹配一個任意字符。

1.8. 支持IS NULL及IS NOT NULL。

1.9. 其它未提到的SQL 92 標準, 可以認為能在WHERE語句后使用的表達式, 在這兒都可以使用。

2. 例子

2.1. 新建一個名為JMSSelector的Java項目, 同時拷入相關(guān)jar包

2.2. 編輯MyProducer.java

package com.jmsapp.sel;import javax.jms.JMSException; import javax.jms.Queue; import javax.jms.QueueConnection; import javax.jms.QueueConnectionFactory; import javax.jms.QueueSender; import javax.jms.QueueSession; import javax.jms.Session; import javax.jms.TextMessage; import org.apache.activemq.ActiveMQConnection; import org.apache.activemq.ActiveMQConnectionFactory;public class MyProducer {// 默認連接用戶名private static final String dftUsr = ActiveMQConnection.DEFAULT_USER;// 默認用戶密碼private static final String dftPwd = ActiveMQConnection.DEFAULT_PASSWORD;// 默認連接地址private static final String dftUrl = ActiveMQConnection.DEFAULT_BROKER_URL;// 隊列名稱private static final String queueName = "queueSelector";public static void main(String[] args) {// 1. 創(chuàng)建一個連接工廠QueueConnectionFactory cf = new ActiveMQConnectionFactory(dftUsr, dftPwd, dftUrl);// 連接對象QueueConnection conn = null;// 會話對象QueueSession session = null;try {// 2. 創(chuàng)建連接conn = cf.createQueueConnection();// 3. 啟動連接conn.start();// 4. 創(chuàng)建會話session = conn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);// 5. 創(chuàng)建消息目的地。如果是點對點, 那么它的實現(xiàn)是Queue; 如果是訂閱模式, 那它的實現(xiàn)是Topic。這里我們創(chuàng)建一個名為queueSelector的消息隊列。Queue queue = session.createQueue(queueName);// 6. 消息生產(chǎn)者QueueSender sender = session.createSender(queue);// 7. 創(chuàng)建文本消息和發(fā)送消息TextMessage tm = session.createTextMessage();tm.setText("用戶支付");tm.setStringProperty("component", "userPay");sender.send(tm);System.out.println("發(fā)送: " + tm.getText());TextMessage msg = session.createTextMessage();msg.setText("用戶模塊");msg.setJMSType("userModel");sender.send(msg);System.out.println("發(fā)送: " + msg.getText());TextMessage message = session.createTextMessage();message.setText("商品模塊");sender.send(message);System.out.println("發(fā)送: " + message.getText());} catch (JMSException e) {e.printStackTrace();} finally {try {if (session != null) {session.close();}} catch (JMSException e1) {e1.printStackTrace();} finally {if (conn != null) {try {conn.close();} catch (JMSException e) {e.printStackTrace();}}}}} }

2.3. 編輯MyConsumer.java

package com.jmsapp.sel;import javax.jms.JMSException; import javax.jms.Queue; import javax.jms.QueueConnection; import javax.jms.QueueConnectionFactory; import javax.jms.QueueReceiver; import javax.jms.QueueSession; import javax.jms.Session; import javax.jms.TextMessage; import org.apache.activemq.ActiveMQConnection; import org.apache.activemq.ActiveMQConnectionFactory;public class MyConsumer {// 默認連接用戶名private static final String dftUsr = ActiveMQConnection.DEFAULT_USER;// 默認用戶密碼private static final String dftPwd = ActiveMQConnection.DEFAULT_PASSWORD;// 默認連接地址private static final String dftUrl = ActiveMQConnection.DEFAULT_BROKER_URL;// 隊列名稱private static final String queueName = "queueSelector";public static void main(String[] args) {// 1. 創(chuàng)建一個連接工廠QueueConnectionFactory cf = new ActiveMQConnectionFactory(dftUsr, dftPwd, dftUrl);// 連接對象QueueConnection conn = null;// 會話對象QueueSession session = null;try {// 2. 創(chuàng)建連接conn = cf.createQueueConnection();// 3. 啟動連接conn.start();// 4. 創(chuàng)建會話session = conn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);// 5. 創(chuàng)建消息目的地。如果是點對點, 那么它的實現(xiàn)是Queue; 如果是訂閱模式, 那它的實現(xiàn)是Topic。這里我們創(chuàng)建一個名為queueSelector的消息隊列。Queue queue = session.createQueue(queueName);// 6. 消息接收者QueueReceiver receiver = session.createReceiver(queue, "JMSType ='userModel' or component like 'user%'");// 7. 創(chuàng)建文本消息和發(fā)送消息while(true) {TextMessage msg = (TextMessage) receiver.receive(3000);if(msg == null) {break;}System.out.println("接收: " + msg.getText());}} catch (JMSException e) {e.printStackTrace();} finally {try {if (session != null) {session.close();}} catch (JMSException e1) {e1.printStackTrace();} finally {if (conn != null) {try {conn.close();} catch (JMSException e) {e.printStackTrace();}}}}} }

2.4. 運行MyProducer.java

2.5. 運行MyConsumer.java

總結(jié)

以上是生活随笔為你收集整理的010_JMS消息选择器的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。