1. 表達式定義的一些重要的規則

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

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

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

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

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

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項目, 同時拷入相關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. 創建一個連接工廠QueueConnectionFactory cf = new ActiveMQConnectionFactory(dftUsr, dftPwd, dftUrl);// 連接對象QueueConnection conn = null;// 會話對象QueueSession session = null;try {// 2. 創建連接conn = cf.createQueueConnection();// 3. 啟動連接conn.start();// 4. 創建會話session = conn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);// 5. 創建消息目的地。如果是點對點, 那么它的實現是Queue; 如果是訂閱模式, 那它的實現是Topic。這里我們創建一個名為queueSelector的消息隊列。Queue queue = session.createQueue(queueName);// 6. 消息生產者QueueSender sender = session.createSender(queue);// 7. 創建文本消息和發送消息TextMessage tm = session.createTextMessage();tm.setText("用戶支付");tm.setStringProperty("component", "userPay");sender.send(tm);System.out.println("發送: " + tm.getText());TextMessage msg = session.createTextMessage();msg.setText("用戶模塊");msg.setJMSType("userModel");sender.send(msg);System.out.println("發送: " + msg.getText());TextMessage message = session.createTextMessage();message.setText("商品模塊");sender.send(message);System.out.println("發送: " + 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. 創建一個連接工廠QueueConnectionFactory cf = new ActiveMQConnectionFactory(dftUsr, dftPwd, dftUrl);// 連接對象QueueConnection conn = null;// 會話對象QueueSession session = null;try {// 2. 創建連接conn = cf.createQueueConnection();// 3. 啟動連接conn.start();// 4. 創建會話session = conn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);// 5. 創建消息目的地。如果是點對點, 那么它的實現是Queue; 如果是訂閱模式, 那它的實現是Topic。這里我們創建一個名為queueSelector的消息隊列。Queue queue = session.createQueue(queueName);// 6. 消息接收者QueueReceiver receiver = session.createReceiver(queue, "JMSType ='userModel' or component like 'user%'");// 7. 創建文本消息和發送消息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

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。