OpenJMS特性及使用.docx

OpenJMS是一个开源的Java Message Service API 1.0.2 规范的实现,它包含有以下特性：*. 它既支持点到点（point-to-point）（PTP）模型和发布/订阅（Pub/Sub）模型。*. 支持同步与异步消息发送*. JDBC持久性管理使用数据库表来存储消息*. 可视化管理界面。*. Applet支持。*. 能够与Jakarta Tomcat这样的Servlet容器结合。*. 支持RMI, TCP, HTTP 与SSL协议。*. 客户端验证*. 提供可靠消息传输、事务和消息过滤介绍服务器搭建，在/downloads.html下载openJms，解压后可以直接使用，在 openjms-0.7.7-beta-1\bin 里，有openJms的运行脚本，执行 startup 启动，弹出一个新的窗口，服务就运行在新窗口内，shutdown 为停止命令：服务运行后，就可以开始使用JMS服务了，至此服务搭建完毕，简单得不能再简单了。下面是消息发送和接收的开发，开发中需要的jar包在openjms-0.7.7-beta-1\lib里可以找到：openjms-0.7.7-beta-1.jarjms-1.1.jarcommons-logging-1.0.4.jar把上面的类包加入到项目中，下面是消息发送服务的代码：/*** @author qianli 2011-12-26* For openJms 演示, Message 发送*/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 ??????????? UserBean ub = new UserBean();??????????? ub.setUsername(weida);??????????? ub.setPassword(111);??????????? ObjectMessage me