JavaEE(6)

1. JMS消息的类型、消息头和消息属性

消息类型：

StreamMessage

MapMessage

TextMessage

ObjectMessage

BytesMessage

JMS消息中的消息头和消息属性本质上都是一系列的key-value对，消息头的所有key都是标准的、固定的；消息属性的key和value都可以随意定义。

// 为JMS消息设置一个自定义属性
msg.setStringProperty("ConType", "txt");

2. JMS消息的传递方式和确认方式

传递方式：DeliveryMode.PERSISTENT, DeliveryMode.NON_PERSISTENT

确认方式(JMS规范)：Session.AUTO_ACKNOWLEDGE, Session.CLIENT_ACKNOWLEDGE, Session.DUPS_OK_ACKNOWLEDGE,

WebLogic提供：Session.NO_ACKNOWLEDGE, Session.MULTICAST_NO_ACKNOWLEDGE,

3. 使用消息选择器来过滤消息(NetBeans创建java project: MessageSelector)

MessageSender.java

package lee;

import javax.jms.*;
import javax.naming.*;
import java.util.Properties;

public class MessageSender {

    public void sendMessage() throws NamingException, JMSException {
        //定义WebLogic默认连接工厂的JNDI
        final String CONNECTION_FACTORY_JNDI = "weblogic.jms.ConnectionFactory";
        //获取JNDI服务所需的Context
        Context ctx = getInitialContext();
        //通过JNDI查找获取连接工厂
        ConnectionFactory connFactory = (ConnectionFactory) ctx.lookup(CONNECTION_FACTORY_JNDI);
        //通过JNDI查找获取消息目的
        Destination dest = (Destination) ctx.lookup("MessageTopic");
        //连接工厂创建连接
        Connection conn = connFactory.createConnection();
        //JMS连接创建JMS会话
        Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
        //JMS会话创建消息生产者
        MessageProducer sender = session.createProducer(dest);
        //设置消息生产者生产出来的消息的传递模式、有效时间。
        sender.setDeliveryMode(DeliveryMode.PERSISTENT);
        sender.setTimeToLive(20000);
        //通过JMS会话创建一个文本消息
        TextMessage msg = session.createTextMessage();
    //msg.setStringProperty("ConType","txt");
        //设置消息内容
        msg.setText("Hello");
        //发送消息，指定该消息的优先级为8
        sender.send(msg, DeliveryMode.PERSISTENT, 8, 30000);
        //为第二条消息设置属性
        msg.setStringProperty("ConType", "TXT");
        msg.setText("Welcome to JMS");
        //再次发送消息
        sender.send(msg);
        //关闭资源
        session.close();
        conn.close();
    }

    //工具方法，用来获取命名服务的Context对象
    private Context getInitialContext() {
        // 参看(4)
    }

    public static void main(String[] args) throws Exception {
        MessageSender sender = new MessageSender();
        sender.sendMessage();
    }
}

PriorityConsumer.java

package lee;

import javax.jms.*;
import javax.naming.*;
import java.util.Properties;

public class PriorityConsumer {

    public void receiveMessage() throws JMSException, NamingException {
        //定义WebLogic默认连接工厂的JNDI
        final String CONNECTION_FACTORY_JNDI = "weblogic.jms.ConnectionFactory";
        //获取JNDI服务所需的Context
        Context ctx = getInitialContext();
        //通过JNDI查找获取连接工厂
        ConnectionFactory connFactory = (ConnectionFactory) ctx.lookup(CONNECTION_FACTORY_JNDI);
        //通过JNDI查找获取消息目的    
        Destination dest = (Destination) ctx.lookup("MessageTopic");
        //连接工厂创建连接
        Connection conn = connFactory.createConnection();
        //启动JMS连接，让它开始传输JMS消息
        conn.start();
        //JMS连接创建JMS会话
        Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
        //JMS会话创建消息消费者,指定该消息消费者只对优先级大于5的消息感兴趣。
        MessageConsumer receiver = session.createConsumer(dest, "JMSPriority > 5");
        //同步接收消息，如果没有接收到消息，该方法会阻塞线程
        TextMessage msg = (TextMessage) receiver.receive();
        System.out.println(msg);
        System.out.println("同步接收到的消息：" + msg.getText());
        //关闭资源
        session.close();
        conn.close();
    }

    //工具方法，用来获取命名服务的Context对象
    private Context getInitialContext() {
        // 参看(4)
    }

    public static void main(String[] args) throws Exception {
        PriorityConsumer consumer = new PriorityConsumer();
        consumer.receiveMessage();
    }
}

PropertyConsumer.java

package lee;

import javax.jms.*;
import javax.naming.*;
import java.util.Properties;

public class PropertyConsumer {

    public void receiveMessage() throws JMSException, NamingException {
        //定义WebLogic默认连接工厂的JNDI
        final String CONNECTION_FACTORY_JNDI = "weblogic.jms.ConnectionFactory";
        //获取JNDI服务所需的Context
        Context ctx = getInitialContext();
        //通过JNDI查找获取连接工厂
        ConnectionFactory connFactory = (ConnectionFactory) ctx.lookup(CONNECTION_FACTORY_JNDI);
        //通过JNDI查找获取消息目的    
        Destination dest = (Destination) ctx.lookup("MessageTopic");
        //连接工厂创建连接
        Connection conn = connFactory.createConnection();
        //启动JMS连接，让它开始传输JMS消息
        conn.start();
        //JMS连接创建JMS会话
        Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
        //JMS会话创建消息消费者,指定该消息消费者只对ConType属性为TXT的消息感兴趣。
        MessageConsumer receiver = session.createConsumer(dest, "ConType='TXT'");
        //同步接收消息，如果没有接收到消息，该方法会阻塞线程
        TextMessage msg = (TextMessage) receiver.receive();
        System.out.println(msg);
        System.out.println("同步接收到的消息：" + msg.getText());
        //关闭资源
        session.close();
        conn.close();
    }

    //工具方法，用来获取命名服务的Context对象
    private Context getInitialContext() {
        // 参看(4)
    }

    public static void main(String[] args) throws Exception {
        PropertyConsumer consumer = new PropertyConsumer();
        consumer.receiveMessage();
    }
}

4. 消息的临时目的地(NetBeans创建java project: TempDestination)

MessageSender.java

package lee;

import javax.jms.*;
import javax.naming.*;
import java.util.*;

public class MessageSender {

    static final String HAD_RECEIVED = "OK";

    public void sendMessage() throws NamingException, JMSException, InterruptedException {
        //定义WebLogic默认连接工厂的JNDI
        final String CONNECTION_FACTORY_JNDI = "weblogic.jms.ConnectionFactory";
        //获取JNDI服务所需的Context
        Context ctx = getInitialContext();
        //通过JNDI查找获取连接工厂
        ConnectionFactory connFactory = (ConnectionFactory) ctx.lookup(CONNECTION_FACTORY_JNDI);
        //通过JNDI查找获取消息目的
        Destination dest = (Destination) ctx.lookup("MessageQueue");
        //连接工厂创建连接
        Connection conn = connFactory.createConnection();
        //JMS连接创建JMS会话
        Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
        //JMS会话创建消息生产者
        MessageProducer sender = session.createProducer(dest);
        //设置消息生产者生产出来的消息的传递模式、有效时间。
        sender.setDeliveryMode(DeliveryMode.PERSISTENT);
        sender.setTimeToLive(20000);
        //通过JMS会话创建一个文本消息
        TextMessage msg = session.createTextMessage();
        //设置消息内容
        msg.setText("Hello,是否受到消息，收到请回复！");
        //创建一个临时的消息目的
        TemporaryQueue tempDestination = session.createTemporaryQueue();
        System.out.println(tempDestination);
        //修改消息的消息头
        msg.setJMSReplyTo(tempDestination);
        //发送消息
        sender.send(msg);
        Thread.sleep(5000);
        //以JMS会话根据临时消息队列来创建队列浏览者
        QueueBrowser browser = session.createBrowser((javax.jms.Queue) tempDestination);
        //获取消息队列中所有消息
        Enumeration enumer = browser.getEnumeration();
        //列出消息队列中的所有消息
        while (enumer.hasMoreElements()) {
            TextMessage acMsg = (TextMessage) enumer.nextElement();
            if (acMsg.getText().equals(HAD_RECEIVED)) {
                System.out.println("对方已经收到消息!");
                break;
            }
        }
        //临时目的调用delete方法删除自己，释放资源。
        tempDestination.delete();
        //关闭资源
        session.close();
        conn.close();
    }

    //工具方法，用来获取命名服务的Context对象
    private Context getInitialContext() {
        // 参看(4)
    }

    public static void main(String[] args) throws Exception {
        MessageSender sender = new MessageSender();
        sender.sendMessage();
    }
}

MessageReceiver.java

package lee;

import javax.jms.*;
import javax.naming.*;
import java.util.*;

public class MessageReceiver {

    static final String HAD_RECEIVED = "OK";

    public void receiveMessage() throws JMSException, NamingException {
        //定义WebLogic默认连接工厂的JNDI
        final String CONNECTION_FACTORY_JNDI = "weblogic.jms.ConnectionFactory";
        //获取JNDI服务所需的Context
        Context ctx = getInitialContext();
        //通过JNDI查找获取连接工厂
        ConnectionFactory connFactory = (ConnectionFactory) ctx.lookup(CONNECTION_FACTORY_JNDI);
        //通过JNDI查找获取消息目的    
        Destination dest = (Destination) ctx.lookup("MessageQueue");
        //连接工厂创建连接
        Connection conn = connFactory.createConnection();
        //启动JMS连接，让它开始传输JMS消息
        conn.start();
        //JMS连接创建JMS会话
        Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
        //JMS会话创建消息消费者,指定该消息消费者只对优先级大于5的消息感兴趣。
        MessageConsumer receiver = session.createConsumer(dest);
        //同步接收消息，如果没有接收到消息，该方法会阻塞线程
        TextMessage msg = (TextMessage) receiver.receive();
        System.out.println(msg);
        System.out.println("同步接收到的消息：" + msg.getText());
        //获取指定消息的replyTo消息头的信息
        Destination replyTo = msg.getJMSReplyTo();
        System.out.println(replyTo);
        //创建发送到回复目的的消息生产者
        MessageProducer sender = session.createProducer(replyTo);
        TextMessage replyMsg = session.createTextMessage();
        replyMsg.setText(HAD_RECEIVED);
        sender.send(replyMsg);
        //关闭资源
        session.close();
        conn.close();
    }

    //工具方法，用来获取命名服务的Context对象
    private Context getInitialContext() {
        // 参看(4)
    }

    public static void main(String[] args) throws Exception {
        MessageReceiver receiver = new MessageReceiver();
        receiver.receiveMessage();
    }
}

5. 使用队列浏览器来查看消息(NetBeans创建java project: MessageBrowser)

MessageSender.java

package lee;

import javax.jms.*;
import javax.naming.*;
import java.util.Properties;

public class MessageSender {

    public void sendMessage() throws NamingException, JMSException {
        //定义WebLogic默认连接工厂的JNDI
        final String CONNECTION_FACTORY_JNDI = "weblogic.jms.ConnectionFactory";
        //获取JNDI服务所需的Context
        Context ctx = getInitialContext();
        //通过JNDI查找获取连接工厂
        ConnectionFactory connFactory = (ConnectionFactory) ctx.lookup(CONNECTION_FACTORY_JNDI);
        //通过JNDI查找获取消息目的
        Destination dest = (Destination) ctx.lookup("MessageQueue");
        //连接工厂创建连接
        Connection conn = connFactory.createConnection();
        //JMS连接创建JMS会话
        Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
        //JMS会话创建消息生产者
        MessageProducer sender = session.createProducer(dest);
        //设置消息生产者生产出来的消息的传递模式、有效时间。
        sender.setDeliveryMode(DeliveryMode.PERSISTENT);
        sender.setTimeToLive(20000);
        //通过JMS会话创建一个文本消息
        TextMessage msg = session.createTextMessage();
        //msg.setStringProperty("ConType","txt");
        //设置消息内容
        msg.setText("Hello");
        //发送消息
        sender.send(msg);
        msg.setText("Welcome to JMS");
        //再次发送消息
        sender.send(msg);
        //关闭资源
        session.close();
        conn.close();
    }

    //工具方法，用来获取命名服务的Context对象
    private Context getInitialContext() {
        // 参看(4)
    }

    public static void main(String[] args) throws Exception {
        MessageSender sender = new MessageSender();
        sender.sendMessage();
    }
}

MessageBrowser.java

package lee;

import javax.jms.*;
import javax.naming.*;
import java.util.*;

public class MessageBrowser {

    public void browseMessage() throws JMSException, NamingException {
        //定义WebLogic默认连接工厂的JNDI
        final String CONNECTION_FACTORY_JNDI = "weblogic.jms.ConnectionFactory";
        //获取JNDI服务所需的Context
        Context ctx = getInitialContext();
        //通过JNDI查找获取连接工厂
        ConnectionFactory connFactory = (ConnectionFactory) ctx.lookup(CONNECTION_FACTORY_JNDI);
        //通过JNDI查找获取消息目的    
        Destination dest = (Destination) ctx.lookup("MessageQueue");
        //连接工厂创建连接
        Connection conn = connFactory.createConnection();
        //启动JMS连接，让它开始传输JMS消息
        conn.start();
        //JMS连接创建JMS会话
        Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
        //以JMS会话根据消息队列来创建队列浏览者
        QueueBrowser browser = session.createBrowser((javax.jms.Queue) dest);
        //获取消息队列中所有消息
        Enumeration em = browser.getEnumeration();
        //列出消息队列中的所有消息
        while (em.hasMoreElements()) {
            TextMessage msg = (TextMessage) em.nextElement();
            System.out.println(msg.getText());
        }
        session.close();
        conn.close();
    }

    //工具方法，用来获取命名服务的Context对象
    private Context getInitialContext() {
        // 参看(4)
    }

    public static void main(String[] args) throws Exception {
        MessageBrowser browser = new MessageBrowser();
        browser.browseMessage();
    }
}