使用GlassFish实现JMS消息传递 - 编程入门网

GlassFish 通过提供一个完全集成的 JMS 提供器为 JMS 消息传递提供巨大支持。Java Message Service API 通过将 Sun Java System Message Queue 软件集成到 GlassFish，并提供透明的 JMS 消息 传递支持得以实现。

GlassFish 支持两种 JMS 资源: 连接工厂和目的地资源。

连接工厂是一种由 JMS 客户机使用用于创建 JMS 提供器连接的对象。连接工厂有 3 种类型：

连接工厂: 由点到点以及发布 —— 订阅消息传递模式使用。

队列连接工厂: 由点到点消息传递模式使用。

主题连接工厂: 由发布 —— 订阅消息传递模式使用。

目的地是一个对象，JMS 消息生成器使用这个对象以便将消息邮寄到该对象；它也是一种资源，JMS 消息使用者使用来自该资源的消息。支持目的地的类型有：

队列: 队列是点到点通信的目的地。

主题: 主题是发布 —— 订阅通信的目的地。

下列内容是 GlassFish 支持的一些 JMS 连接功能。

连接池

GlassFish 服务器自动汇集 JMS 连接。用户可以使用 GlassFish 管理控制台或 asadmin 命令设置连 接池属性。在创建连接工厂时配置连接池细节。由 GlassFish 支持的一些连接池参数有：

连接池的初始值和最小值: 在连接池中指示初始连接的数量。这也是给连接池设置的最小连接数量。

连接池最大值: 在连接池中指示可用连接的最大数量。

连接池重新调整的数量: 当连接池达到空闲超时时，应该移除的连接数量。

空闲超时: 在连接池中连接可以保持空闲的最长时间。

最大等待时间: 在发送连接超时以前系统等待的最长时间。

运行失败行为: 在发生运行失败的情况下，连接可能被中断然后重新连接。

事务支持: 事务支持的级别。支持事务的类型有“本地事务”、“XA 事务”和“没有事务”。

连接验证: 如果选择了该属性，将连接传递到应用程序之前要对其进行验证。

连接故障转移

如果连接丢失，该功能启用应用程序服务器重新连接到消息代理。如果启用重新连接并且无法连接初 始消息代理，那么应用程序服务器将尝试重新连接另一个可用代理。用户可以配置重试数量和重试之间的 时间间隔。

访问应用程序中的 JMS 资源

在 GlassFish 中, 可以以两种方式访问连接工厂和目的地： 使用 Java 命名和目录接口（Java Naming and Directory InterfaceTM，JNDI)查找或使用注释。

JNDI 查找

JMS 客户机使用 JNDI API 查找连接工厂和消息目的地。

InitialContext jndi = new InitialContext(); // Lookup queue connection factory QueueConnectionFactory qFactory = (QueueConnectionFactory)jndi. 　　　　　　　　 lookup("webTrackerConnFactory"); // Lookup queue Queue queue = (Queue)jndi.lookup("webTrackerQueue");

使用GlassFish实现JMS消息传递(3)

注释

在 Java SE 5.0 中介绍过注释，它是编程的声明性样式。注释与元标记一样，可以应用于类、构造函 数、方法、变量等等。

注释 @Resource 用于查找连接工厂和目的地。在 Web 应用程序中，如果注释放在变量上，那么 servlet 容器将注入请求的资源；也就是，注释变量将在为请求提供服务之前使用适当的值进行预先填充 。

@Resource(name="connFactory", mappedName="webTrackerConnFactory") private QueueConnectionFactory qFactory; @Resource(name="jmsQueue", mappedName="webTrackerQueue") private Queue queue;

使消息传递正常运行

迄今为止，我们已经讨论了如何将 JMS 和 MDB 一起运行来实施异步消息传递。我们也了解了 GlassFish 的功能和它提供的

凌众科技专业提供服务器租用、服务器托管、企业邮局、虚拟主机等服务，公司网站：http://www.lingzhong.cn 为了给广大客户了解更多的技术信息，本技术文章收集来源于网络,凌众科技尊重文章作者的版权，如果有涉及你的版权有必要删除你的文章，请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息，谢谢!