1.1 java消息服务:不同系统之间的信息交换，是我们开(9)

2、接收消息使用基于特殊标志的消息选择器:

注：消息选择器是一个字符串，语法与的SQL相似，相当于SQL语句where条件后面的内容；

具体代码如下:

发送端代码:

packagecom.bjpowernode.activemq.selector;

import org.apache.activemq.Active

MQConnectionFactory;

import javax.jms.*;

/**

* 消息发送者

*

*/

public class Sender {

/**消息服务器的连接地址**/

2.603211 192.168.1.100 -> 192.168.1.102 tcp http > 1442 [ack] seq=3291904937 ack=3325831830 win=46 len=0。action=started&browser=ie8&ver=1_26_153&bic=af21235a79a5427ebd50aac73f6572cfie&app=27096&appver=0&verifier=a9404c7652463d759edd6532307c7bab&srcid=0&subid=0&zdata=0&ff=0_89&ch=1_22_22&default=ch&os=xp32&admin=1&type=12289&asw=0","stats.apps-update.com (72.21.195.40, 80)",192.168.5.40 (192.168.5.40),"tcp, 端口 1624"。

public static void main(String[] args) {

Sender sender = new Sender();

sender.sendMessage("Hello ActiveMQ.");

}

/**

* 发送消息

*

* @param msg

*/

public void sendMessage (String msg) {

Connection connection = null;

Session session = null;

MessageProducer messageProducer = null;

try {

//1.创建一个连接工厂

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(BROKER_URL);

//2.创建一个连接

connection = connectionFactory.

createConnection();

//3.创建一个Session

session = connection.createSession(Boolean.FALSE,Session.AUTO_ACKNOWLEDGE);

//5.创建一个目的地

Destination destination = session.create

Queue("myQueue");

//6.创建一个消息的生产者（发送者）

messageProducer = session.createProducer

(destination);

//设置发送的消息是否需要持久化

messageProducer.setDeliveryMode(Delivery

Mode.NON_PERSISTENT);//这里使用不持久化

//创建一个循环,测试消息标识的使用

for (int i=0; i<20; i++) {

本文来自电脑杂谈，转载请注明本文网址：
http://www.pc-fly.com/a/jisuanjixue/article-94236-9.html