设为首页 加入收藏

TOP

JMS服务器openJms入门
2014-11-19 00:27:36 】 浏览:3321
Tags:JMS 服务器 openJms 入门

  首先可以到网站上下载最新的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();


  }


  }


  }


  执行程序发


送消息,然后打开JMS控制台,用 admin 命令启动管理平台,点击菜单Actions-Connections-online,出现界面如下:


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


】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇计算机二级辅导:悟透JavaScript(4) 下一篇计算机二级辅导:JS日期时间函数

最新文章

热门文章

Hot 文章

Python

C 语言

C++基础

大数据基础

linux编程基础

C/C++面试题目