【IT168 技术】 首先可以到网站上下载最新的openjms版本，然后启动bin下的startup.bat就启动服务了，然后可以启动admin.bat进入管理界面(非必要步骤)，然后分别运行samples下的basic例子就可以看到效果了，当然以前有篇文章介绍的不错，可以参考一下，不过时间上比较老了，做为参考还是可以的。
本文介绍开源的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.*;
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();
}
}
}
执行程序发
