消息传递和 Java 消息服务(JMS)

消息传递和 Java 消息服务(JMS)

消息传递系统用于构建高可靠、可伸缩及灵活的分布式应用程序。本文从大体上讨论了消息传递系统，简要叙述了它们的特性及类型，然后描述开发人员如何可以使用 Java 消息服务(Java Message Service ，JMS) 编写基于消息的应用程序。

正如许多以前在同步、可靠性、可伸缩性和安全性方面的未知问题一样，分布式应用程序潜在的问题也是不断增长的。一种解决方案是建立在松散耦合组件基础上的消息传递系统，这些组件之间通过消息进行通信。

Java 消息服务提供了一致的 API 集合，让开发人员可以访问许多消息传递系统产品的公共特性。

什么是消息传递系统？
从它的本质上讲，消息传递系统允许不同的非耦合应用程序以异步方式进行可靠通信。消息传递系统体系结构一般用各个组件间的点对点关系代替客户端/服务器模型，其中每个点可以发送消息到其他点，或从其他点接收消息。

相对于更加传统的分布式计算模型，消息传递系统提供了许多强大的优势。首先，它们倡议在消息消费者和消息生产者之间进行“松散耦合”。在生产者和消费者之间存在着高级匿名：对于消息消费者，它不关心 谁 产生消息，在网络上生产者在 哪里，或者消息是 何时 产生的。

这使得可以构建动态、可靠和灵活的系统，由此可以修改子应用程序的整体组合，而不会影响到系统的其余部分。 消息传递系统的其他优势包括高可伸缩性（商业实现鼓吹可以支持好几万个客户端，以及支持每秒进行好几万个操作）、容易集成到异构网络以及由于减少了单点故障而提高了可靠性。

由于消息传递系统固有的可靠性和可伸缩性，所以它们用于解决许多商业和计算科学问题。例如，它们是这样的一些不同的应用程序的基础：工作流、网络管理、通信服务（通过 IP 的语音、有声邮件、寻呼机和电子邮件）、客户服务、天气预报和供应链管理等系统。此外，消息传递系统是无价的，因为它作为“glue”（胶水）把完全不同的系统联系在一起，使之能够合并和获取消息。

消息系统类型
通常使用两种消息传递系统模型。

发布/订阅
发布/订阅 (pub/sub) 消息传递系统支持事件驱动模型，在这种模型中，信息消费者和生产者参与消息的传输。生产者“发布”事件，而消费者“订阅”感兴趣的事件并消费事件。生产者把消息把与特定主题关联起来，然后消息传递系统根据消费者所注册的感兴趣主题，把消息路由给消费者。

点对点
在点对点消息传递系统中，消息是被路由到各个消费者的，该消费者维护“传入”消息队列。消息传递应用程序发送消息到指定队列，然后客户端从队列中检索消息。 供应商经常会支持点对点模型或发布/订阅消息传递模型，或者同时支持这两种模型。

既然已经从大体上认识了消息系统，现在让我们来看一下 Java 开发人员是如何可以利用它们的能力的。

Java 消息服务
Java 消息服务是 J2EE (Java 2 EntERPrise Edition) 套件的一部分，它提供了标准 API，Java 开发人员可以使用这些 API 来访问企业消息系统的共同特性。JMS 支持发布/订阅和点对点模型，并允许创建由任意 Java 对象组成的消息类型。

设计目标
JMS 的基本设计目标是为了提供一组一致的接口，消息传递系统客户端可以独立地使用这些接口，而不必关心基础消息系统的提供商。 这样，客户端应用程序不仅可以跨计算机体系结构和操作系统进行移植，而且也可以跨消息传递产品进行移植。写到 JMS 的客户端应用程序将正常工作，而不用在所有符合 JMS 的消息传递系统上做修改（这可以与组件所运行的基础中间件上的 Enterprise Java Beans 组件的独立性进行比较）。

JMS 也设计成：

最小化消息传递系统提供商为其产品实现 JMS API 所需的工作量。
提供了普通消息传递系统的大多数功能。
许多消息系统提供商已经为它们的产品实现了 JMS，允许 Java 访问它们系统的功能。

JMS 客户端可以使用 Java 设施
由于 JMS 客户端是基于 Java 的，因此它们可以利用现有的 Java API，比如：用于数据库访问的 JDBC、JavaBeans 组件模型、用于命名服务的 JNDI、用于客户端事务控制的 JTA 或用于企业应用程序服务的任何 J2SE 和 J2EE API。

JMS 细节
现在，我们从消息开始，来看一下使用 JMS 构建消息传递系统客户端的细节。

什么是消息？
在消息传递系统中，应用程序之间的通信点是消息本身，因此使用 JMS 的开发人员必须理解消息。

尽管消息传递系统之间消息定义区别甚大，但 JMS 提供了统一的方式用于描述和访问消息。JMS 消息由三部分组成：

消息标题
用于消息标识。例如，标题用于确定指定的消息是否适合于“订阅者”。
属性
用于特定于应用程序、特定于提供商及可选的标题字段。
消息体
保存消息的内容。支持几种格式，其中包括：TextMessages——用于包装简单的 String; 和 ObjectMessages——用于包装任意的 Java 对象（它们必须是可序列化的）。也支持其他的格式。
TextMessages
TextMessage 用于包装简单的 String 对象。在只传递字符串的情形下，这是有用的。期望许多消息传递系统将以 XML 为基础，TextMessages 是它们的自然容器。

创建 TextMessage 对象是简单的，如下面两行代码所指出的那样：

TextMessage message =
session.createMessage();
message.setText("hello world");

（在下一节，我们将看到 session 对象）。

以这种方式创建的 TextMessage 准备发布到消息传递系统中。

标签：

版权申明：本站文章部分自网络，如有侵权，请联系：west999com@outlook.com
特别注意：本站所有转载文章言论不代表本站观点，本站所提供的摄影照片，插画，设计作品，如需使用，请与原作者联系，版权归原作者所有