加入收藏 收藏网站 设为首页 设为首页
招生考试网
学历类| 阳光高考 研 究 生 自学考试 成人高考 专 升 本 中考会考 外语类| 四 六 级 职称英语 商务英语 公共英语 日语能力
资格类| 公 务 员 报 关 员 银行从业 司法考试 导 游 证 教师资格 财会类| 会 计 证 经 济 师 会计职称 注册会计 税 务 师
工程类| 一级建造 二级建造 造 价 师 造 价 员 咨 询 师 监 理 师 医学类| 卫生资格 执业医师 执业药师 执业护士 国际护士
计算机| 等级考试 软件水平 应用能力 其它类| 书画等级 美国高考 驾 驶 员 书法等级 少儿英语 报 检 员 单 证 员 出国留学
 招生考试网 - 计算机等级考试 - 考试辅导 - 正文

 
JMS服务器openJms入门
来源:fjzsksw.com 2009-11-26 编辑:yangmeiling 【字体:小 大】

首先可以到网站上下载最新的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条消息了,而其他的队列还是空着的。



 
  • 上一个文章:

  • 下一个文章:
  • 网站版权与免责声明
    ①由于各方面情况的不断调整与变化,本网所提供的相关信息请以权威部门公布的正式信息为准.
    ②本网转载的文/图等稿件出于非商业性目的,如转载稿涉及版权等问题,请在两周内来电联系.
    最新文章
    热门文章

    报名考试
    全国 | 黑龙江 | 吉林 | 辽宁 | 内蒙古
    青海 | 宁夏 | 甘肃 | 新疆 | 陕西
    西藏 | 北京 | 天津 | 河北 | 山东
    江苏 | 安徽 | 河南 | 上海 | 浙江
    福建 | 广东 | 山西 | 湖南 | 湖北
    江西 | 广西 | 海南 | 云南 | 贵州
    四川 | 重庆
    分省高校计算机考试
    黑龙江 | 吉林 | 辽宁 | 内蒙古 | 河北
    北京 | 天津 | 新疆 | 甘肃 | 宁夏
    青海 | 陕西 | 山西 | 河南 | 山东
    江苏 | 安徽 | 浙江 | 福建 | 广东
    海南 | 广西 | 江西 | 湖北 | 湖南
    四川 | 上海 | 重庆 | 贵州 | 云南
    西藏
    成绩查询
    报考指南
    试题答案
    模拟试题
    考试辅导
    计算机一级 | 计算机二级 | 计算机三级 | 计算机四级
    经验交流
    高校计算机