开源JMS服务器－openJms 介绍（一）

本文介绍开源的JMS服务器openJms，及怎样使用openJms来构建系统之间健全、高度可用的通讯，从而简化企业级应用的开发。 openJms符合SUN的JMS API 1.0.2规范，支持消息队列，还支持消息传递的发布/订阅模式，本文先就系统服务的搭建及JMS的非结构化消息发送和接收进行说明。

JMS 有五种消息类型。三种结构化或半结构化的消息类型（MapMessage、ObjectMessage 和 StreamMessage）以及两种非结构化的或自由格式的消息类型（TextMessage 和 BytesMessage）。而这里虽然我们只对非结构化消息进行说明，但非结构化的消息格式却能够更好地进行交互操作，因为它们在消息上很少利用结构，在此基础上与XML再进行结合，将能方便的进行更好的扩展，XML相关简化操作参考《Jaxb来实现Java-XML的转换》。

下面具体来介绍服务器搭建，在http://openjms.sourceforge.net/downloads.html下载openJms，解压后可以直接使用，在 \openjms-0.7.6.1\bin 里，有openJms的运行脚本，执行 startup 启动，弹出一个新的窗口，服务就运行在新窗口内，shutdown 为停止命令：

服务运行后，就可以开始使用JMS服务了，至此服务搭建完毕，简单得不能再简单了。

下面是消息发送和接收的开发，开发中需要的jar包在\openjms-0.7.6.1\lib里可以找到：
openjms-0.7.6.1.jar
jms-1.0.2a.jar
exolabcore-0.3.7.jar
commons-logging-1.0.3.jar

把上面的类包加入到项目中，下面是消息发送服务的代码：

package javayou.demo.openjms;
import java.util.*;
import javax.jms.*;
import javax.naming.*;
/**
* @author Liang.xf 2004-12-24
* For openJms 演示, Message 发送
* www.javayou.com
*/
public class QueueSend {
    public static void main(String[] args) {
        try {
            //取得JNDI上下文和连接
            Hashtable properties = new Hashtable();
            properties.put(
                Context.INITIAL_CONTEXT_FACTORY,
                "org.exolab.jms.jndi.InitialContextFactory");
            //openJms默认的端口是1099
            properties.put(Context.PROVIDER_URL,
                 "rmi://localhost:1099/");
            Context context = new InitialContext(properties);

            //获得JMS信息连接队列工厂
            QueueConnectionFactory queueConnectionFactory =
                (QueueConnectionFactory) context.lookup(
                    "JmsQueueConnectionFactory");
            //获得JMS信息连接队列
            QueueConnection queueConnection =
                queueConnectionFactory.createQueueConnection();
            //产生队列Session，设置事务为false，自动应答消息接收
            QueueSession queueSession =
                queueConnection.createQueueSession(
                    false,
                    Session.AUTO_ACKNOWLEDGE);

            //获得默认内建在JMS里的队列之一：queue1
            Queue queue = (Queue) context.lookup("queue1");
            //产生JMS队列发送器
            QueueSender queueSender =
                queueSession.createSender(queue);
            //发送数据到JMS
            TextMessage message = queueSession.createTextMessage();
            message.setText("Hello, I'm openJms.");
            queueSender.send(message);

            System.out.println(
                ""信息写入JMS服务器队列");

            //以下做清除工作，代码略
            // ... ...
                      
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

执行程序发送消息，然后打开JMS控制台，用 admin 命令启动管理平台，点击菜单Actions－Connections－online，出现界面如下：

可以看到JSM默认的队列queue1里已经有1条消息了，而其他的队列还是空着的。

下面我们来看看消息接收服务的代码：

package javayou.demo.openjms;
import java.util.*;
import javax.jms.*;
import javax.naming.*;
/**
* @author Liang.xf 2004-12-24
* For openJms 演示, Message接收
* www.javayou.com
*/
public class QueueReceiveSynchronous {
    public static void main(String[] args) {
        try {
            //取得JNDI上下文和连接
            Hashtable properties = new Hashtable();
            properties.put(
                Context.INITIAL_CONTEXT_FACTORY,
                "org.exolab.jms.jndi.InitialContextFactory");
            properties.put(Context.PROVIDER_URL,
                "rmi://localhost:1099/");
            Context context = new InitialContext(properties);

            //获得JMS信息连接队列工厂
            QueueConnectionFactory queueConnectionFactory =
                (QueueConnectionFactory) context.lookup(
                    "JmsQueueConnectionFactory");

            //获得JMS信息连接队列
            QueueConnection queueConnection =
                queueConnectionFactory.createQueueConnection();

            //启动接收队列线程
            queueConnection.start();
            //产生队列Session，设置事务为false，自动应答消息接收
            QueueSession queueSession =
                queueConnection.createQueueSession(
                    false,
                    Session.AUTO_ACKNOWLEDGE);
            //获得默认内建在JMS里的队列之一：queue1
            Queue queue = (Queue) context.lookup("queue1");
            //产生JMS队列接收器
            QueueReceiver queueReceiver =
                queueSession.createReceiver(queue);
            //通过同步的方法接收消息
            Message message = queueReceiver.receive();
            String messageText = null;
            if (message instanceof TextMessage)
                messageText = ((TextMessage) message).                        
                    getText();
            System.out.println(messageText);
            //以下做清除工作，代码略
            // ... ...
          
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

编译后运行接收信息服务，可以看到接收到并打印之前发送的消息，再看看控制台，发现queue1的消息队列变为0，消息已被读取，消息发送和接收到此结束。

下一篇再继续讲述另外的内容：openJms的消息发布和定购。