`
junier
  • 浏览: 76379 次
  • 性别: Icon_minigender_1
  • 来自: 郑州
社区版块
存档分类
最新评论
阅读更多
当前,CORBA、DCOM、RMI等RPC中间件技术已广泛应用于各个领域。但是面对规模和复杂度都越来越高的分布式系统,这些技术也显示出其局限性:(1)同步通信:客户发出调用后,必须等待服务对象完成处理并返回结果后才能继续执行;(2)客户和服务对象的生命周期紧密耦合:客户进程和服务对象进程都必须正常运行;如果由于服务对象崩溃或者网络故障导致客户的请求不可达,客户会接收到异常;(3)点对点通信:客户的一次调用只发送给某个单独的目标对象。
   面向消息的中间件(Message Oriented Middleware,MOM)较好的解决了以上问题。发送者将消息发送给消息服务器,消息服务器将消息存放在若干队列中,在合适的时候再将消息转发给接收者。这种模式下,发送和接收是异步的,发送者无需等待;二者的生命周期未必相同:发送消息的时候接收者不一定运行,接收消息的时候发送者也不一定运行;一对多通信:对于一个消息可以有多个接收者。
   已有的MOM系统包括IBM的MQSeries、Microsoft的MSMQ和BEA的MessageQ等。由于没有一个通用的标准,这些系统很难实现互操作和无缝连接。Java Message Service(JMS)是SUN提出的旨在统一各种MOM系统接口的规范,它包含点对点(Point to Point,PTP)和发布/订阅(Publish/Subscribe,pub/sub)两种消息模型,提供可靠消息传输、事务和消息过滤等机制。


1.JMS
   JAVA 消息服务(JMS)定义了Java 中访问消息中间件的接口。JMS 只是接口,并没有给予实现,实现JMS 接口的消息中间件称为JMS Provider,iLink实现了JMS接口,用户可以通过使用JMS接口,在iLink中进行JMS编程。 iLink支持JMS1.0.2版本。

2.JMS接口描述
   JMS 支持两种消息类型PTP 和Pub/Sub,分别称作:PTP Domain 和Pub/Sub Domain,这两种接口都继承统一的JMS父接口,JMS 主要接口如下所示:
MS父接口
PTP
Pub/Sub

ConnectionFactory
QueueConnectionFactory
TopicConnectionFactory

Connection
QueueConnection
TopicConnection

Destination
Queue
Topic

Session
QueueSession
TopicSession

MessageProducer
QueueSender
TopicPublisher

MessageConsumer
QueueReceiver,QueueBrowser
TopicSubscriber


                    
   ConnectionFactory :连接工厂,JMS 用它创建连接
   Connection :JMS 客户端到JMS Provider 的连接
   Destination :消息的目的地
   Session: 一个发送或接收消息的线程
   MessageProducer: 由Session 对象创建的用来发送消息的对象
   MessageConsumer: 由Session 对象创建的用来接收消息的对象

3.JMS消息模型
JMS 消息由以下几部分组成:消息头,属性,消息体。
  
3.1 消息头(Header) - 消息头包含消息的识别信息和路由信息,消息头包含一些标准的属性如:JMSDestination,JMSMessageID 等。
消息头
  由谁设置

JMSDestination
send 或 publish 方法

JMSDeliveryMode
send 或 publish 方法

JMSExpiration
send 或 publish 方法

JMSPriority
send 或 publish 方法

JMSMessageID
send 或 publish 方法

JMSTimestamp
send 或 publish 方法

JMSCorrelationID
客户

JMSReplyTo
客户

JMSType
客户

JMSRedelivered
JMS Provider


      
3.2 属性(Properties) - 除了消息头中定义好的标准属性外,JMS 提供一种机制增加新属性到消息头中,这种新属性包含以下几种:
   1. 应用需要用到的属性;
   2. 消息头中原有的一些可选属性;
   3. JMS Provider 需要用到的属性。
   标准的JMS 消息头包含以下属性:
JMSDestination
消息发送的目的地

JMSDeliveryMode
传递模式, 有两种模式: PERSISTENT 和NON_PERSISTENT,PERSISTENT 表示该消息一定要被送到目的地,否则会导致应用错误。NON_PERSISTENT 表示偶然丢失该消息是被允许的,这两种模式使开发者可以在消息传递的可靠性和吞吐量之间找到平衡点。

JMSMessageID
唯一识别每个消息的标识,由JMS Provider 产生。

JMSTimestamp
一个消息被提交给JMS Provider 到消息被发出的时间。

JMSCorrelationID
用来连接到另外一个消息,典型的应用是在回复消息中连接到原消息。

JMSReplyTo
提供本消息回复消息的目的地址

JMSRedelivered
如果一个客户端收到一个设置了JMSRedelivered 属性的消息,则表示可能该客户端曾经在早些时候收到过该消息,但并没有签收(acknowledged)。

JMSType
消息类型的识别符。

JMSExpiration
消息过期时间,等于QueueSender 的send 方法中的timeToLive 值或TopicPublisher 的publish 方法中的timeToLive 值加上发送时刻的GMT 时间值。如果timeToLive值等于零,则JMSExpiration 被设为零,表示该消息永不过期。如果发送后,在消息过期时间之后消息还没有被发送到目的地,则该消息被清除。

JMSPriority
消息优先级,从0-9 十个级别,0-4 是普通消息,5-9 是加急消息。JMS 不要求JMS Provider 严格按照这十个优先级发送消息,但必须保证加急消息要先于普通消息到达。



3.3 消息体(Body) - JMS API 定义了5种消息体格式,也叫消息类型,你可以使用不同形式发送接收数据并可以兼容现有的消息格式,下面描述这5种类型:
消息类型
消息体

TextMessage
java.lang.String对象,如xml文件内容

MapMessage
名/值对的集合,名是String对象,值类型可以是Java任何基本类型

BytesMessage
字节流

StreamMessage
Java中的输入输出流

ObjectMessage
Java中的可序列化对象

Message
没有消息体,只有消息头和属性



下例演示创建并发送一个TextMessage到一个队列:
TextMessage message = queueSession.createTextMessage();
message.setText(msg_text); // msg_text is a String
queueSender.send(message);

下例演示接收消息并转换为合适的消息类型:
Message m = queueReceiver.receive();
if (m instanceof TextMessage) {
TextMessage message = (TextMessage) m;
System.out.println("Reading message: " + message.getText());
} else {
// Handle error
}

4. 消息的同步异步接收
   消息的同步接收是指客户端主动去接收消息,JMS 客户端可以采用MessageConsumer 的receive方法去接收下一个消息。
   消息的异步接收是指当消息到达时,主动通知客户端。JMS 客户端可以通过注册一个实 现MessageListener 接口的对象到MessageConsumer,这样,每当消息到达时,JMS Provider 会调用MessageListener中的onMessage 方法。


5. PTP模型
PTP(Point-to-Point)模型是基于队列的,发送方发消息到队列,接收方从队列接收消息,队列的存在使得消息的异步传输成为可能。和邮件系统中的邮箱一样,队列可以包含各种消息,JMS Provider 提供工具管理队列的创建、删除。JMS PTP 模型定义了客户端如何向队列发送消息,从队列接收消息,浏览队列中的消息。
   下面描述JMS PTP 模型中的主要概念和对象:
名称
描述

Queue
由JMS Provider 管理,队列由队列名识别,客户端可以通过JNDI 接口用队列名得到一个队列对象。

TemporaryQueue
由QueueConnection 创建,而且只能由创建它的QueueConnection 使用。

QueueConnectionFactory
客户端用QueueConnectionFactory 创建QueueConnection 对象。

QueueConnection
一个到JMS PTP provider 的连接,客户端可以用QueueConnection 创建QueueSession 来发送和接收消息。

QueueSession
提供一些方法创建QueueReceiver 、QueueSender、QueueBrowser 和TemporaryQueue。如果在QueueSession 关闭时,有一些消息已经被收到,但还没有被签收(acknowledged),那么,当接收者下次连接到相同的队列时,这些消息还会被再次接收。

QueueReceiver
客户端用QueueReceiver 接收队列中的消息,如果用户在QueueReceiver 中设定了消息选择条件,那么不符合条件的消息会留在队列中,不会被接收到。

QueueSender
客户端用QueueSender 发送消息到队列。

QueueBrowser
客户端可以QueueBrowser 浏览队列中的消息,但不会收走消息。

QueueRequestor
JMS 提供QueueRequestor 类简化消息的收发过程。QueueRequestor 的构造函数有两个参数:QueueSession 和queue,QueueRequestor 通过创建一个临时队列来完成最终的收发消息请求。

可靠性(Reliability)
队列可以长久地保存消息直到接收者收到消息。接收者不需要因为担心消息会丢失而时刻和队列保持激活的连接状态,充分体现了异步传输模式的优势。


 

6. PUB/SUB模型
JMS Pub/Sub 模型定义了如何向一个内容节点发布和订阅消息,这些节点被称作主题(topic)。
   主题可以被认为是消息的传输中介,发布者(publisher)发布消息到主题,订阅者(subscribe) 从主题订阅消息。主题使得消息订阅者和消息发布者保持互相独立,不需要接触即可保证消息的传送。
   下面描述JMS Pub/Sub 模型中的主要概念和对象:
名称
描述

订阅(subscription)
消息订阅分为非持久订阅(non-durable subscription)和持久订阅(durable subscrip-tion),非持久订阅只有当客户端处于激活状态,也就是和JMS Provider 保持连接状态才能收到发送到某个主题的消息,而当客户端处于离线状态,这个时间段发到主题的消息将会丢失,永远不会收到。持久订阅时,客户端向JMS 注册一个识别自己身份的ID,当这个客户端处于离线时,JMS Provider 会为这个ID 保存所有发送到主题的消息,当客户再次连接到JMS Provider时,会根据自己的ID 得到所有当自己处于离线时发送到主题的消息。

Topic
主题由JMS Provider 管理,主题由主题名识别,客户端可以通过JNDI 接口用主题名得到一个主题对象。JMS 没有给出主题的组织和层次结构的定义,由JMS Provider 自己定义。

TemporaryTopic
临时主题由TopicConnection 创建,而且只能由创建它的TopicConnection 使用。临时主题不能提供持久订阅功能。

TopicConnectionFactory
客户端用TopicConnectionFactory 创建TopicConnection 对象。

TopicConnection
TopicConnection 是一个到JMS Pub/Sub provider 的连接,客户端可以用TopicConnection创建TopicSession 来发布和订阅消息。

TopicSession
TopicSession 提供一些方法创建TopicPublisher、TopicSubscriber、TemporaryTopic 。它还提供unsubscribe 方法取消消息的持久订阅。

TopicPublisher
客户端用TopicPublisher 发布消息到主题。

TopicSubscriber
客户端用TopicSubscriber 接收发布到主题上的消息。可以在TopicSubscriber 中设置消息过滤功能,这样,不符合要求的消息不会被接收。

Durable TopicSubscriber
如果一个客户端需要持久订阅消息,可以使用Durable TopicSubscriber,TopSession 提供一个方法createDurableSubscriber创建Durable TopicSubscriber 对象。

恢复和重新派送(Recovery and Redelivery)
非持久订阅状态下,不能恢复或重新派送一个未签收的消息。只有持久订阅才能恢复或重新派送一个未签收的消息。

TopicRequestor
JMS 提供TopicRequestor 类简化消息的收发过程。TopicRequestor 的构造函数有两个参数:TopicSession 和topic。TopicRequestor 通过创建一个临时主题来完成最终的发布和接收消息请求。

可靠性(Reliability)
当所有的消息必须被接收,则用持久订阅模式。当丢失消息能够被容忍,则用非持久订阅模式。

    
 
7. 开发JMS的步骤
   广义上说,一个JMS 应用是几个JMS 客户端交换消息,开发JMS 客户端应用由以下几步构成:
用JNDI 得到ConnectionFactory 对象;
用JNDI 得到目标队列或主题对象,即Destination 对象;
用ConnectionFactory 创建Connection 对象;
用Connection 对象创建一个或多个JMS Session;
用Session 和Destination 创建MessageProducer 和MessageConsumer;
通知Connection 开始传递消息。

更详细的信息请参考 Java Message Specification.
分享到:
评论

相关推荐

    消息中间件和JMS消息服务.rar

    消息中间件通常支持多种协议和消息格式,如Advanced Message Queuing Protocol (AMQP)、Message Queuing Telemetry Transport (MQTT) 和Simple Object Access Protocol (SOAP)等。通过消息中间件,系统可以异步处理...

    消息中间件和JMS原理

    【消息中间件和JMS原理】是分布式系统中重要的组件,它们主要解决了传统RPC(Remote Procedure Call)中间件存在的性能、健壮性和可扩展性的不足。RPC中间件如CORBA、DCOM、RMI,虽然方便了跨网络的函数调用,但其...

    消息中间件和jms消息服务

    JMS消息由消息头、属性和消息体三部分组成。消息头包含了识别和路由信息,如JMSDestination、JMSMessageID等,这些由发送方或JMS Provider设置。属性允许用户自定义额外的信息,而消息体则承载实际的数据内容。 在...

    消息中间件和JMS消息服务.pdf

    3. **JMS消息结构**:JMS消息主要包括消息头、属性和消息体三个部分。 - **消息头**:包含消息的识别信息和路由信息。 - `JMSDestination`:消息发送的目的地。 - `JMSDeliveryMode`:指定消息是否需要持久化。 ...

    消息中间件原理及JMS简介

    Java消息服务(JMS)是SUN及其合作伙伴提出的一种规范,旨在统一各种消息中间件系统的接口,为Java开发者提供了一种标准的方式来访问和操作消息队列。JMS允许应用程序创建、发送、接收和读取消息,同时确保消息的...

    消息中间件与JMS.pdf

    Java消息服务(JMS)是由Sun Microsystems提出的一种消息中间件接口规范,旨在统一不同消息中间件系统的接口,提高应用程序的可移植性和互操作性。 #### 四、JMS介绍 **4.1 JMS简介** JMS是Java平台上的消息中间件...

    基于JMS的消息中间件的实现-论文.zip

    《基于JMS的消息中间件的实现》这篇论文深入探讨了如何在JMX(Java ...通过阅读和研究论文中的内容,开发者不仅可以掌握JMS和JMX的基本原理,还能学习到如何在实际项目中应用这些技术,以提升系统的可维护性和可靠性。

    消息中间件在分布式系统中的作用介绍

    通过消息传递和消息排队模型,消息中间件可以在分布式环境下扩展进程间的通信,支持应用程序或组件之间进行可靠的异步通信,从而降低系统间的耦合度,提高系统的可扩展性和可用性。 在分布式系统中,消息中间件的...

    java中间件之jms

    JMS消息由消息头、消息属性和消息体三部分组成: **1.3.1 消息头** 消息头包含消息的识别信息和路由信息,具体属性如下: - **JMSDestination**:消息发送的目的地,自动分配。 - **JMSDeliveryMode**:传送模式...

    JMS+activeMQ消息中间件

    综上所述,这个例子提供了一个全面的实践,涵盖了Spring MVC、JMS和ActiveMQ的集成,帮助开发者理解如何在实际项目中使用消息中间件实现异步处理和解耦。通过学习这个示例,你可以了解到如何在Spring MVC环境中配置...

    activemq中间件视频 jms规范

    JMS的核心概念包括生产者、消费者、消息和消息队列/主题。生产者创建消息并发送到队列或主题,而消费者则从这些队列或主题中接收消息。JMS支持两种消息模型:点对点(Queue)和发布/订阅(Topic)。点对点模型中,每...

    从 0 开始带你成为消息中间件实战高手.rar

    消息中间件是现代分布式系统中不可或缺的组件,它在系统之间提供可靠的数据传输服务,确保数据的高效、安全和解耦。本教程旨在帮助你从零基础开始,逐步成长为消息中间件的实战高手。我们将深入探讨消息中间件的核心...

    基于JMS的消息中间件的实现-论文

    《基于JMX框架的JMS服务器的设计和实现》是一篇探讨如何利用JMX(Java Management Extensions)技术构建符合JMS(Java Message Service)规范的消息中间件的硕士研究生毕业论文。该论文作者为陈冬,导师为周华研究员...

    分布式消息中间件实践_倪炜(著)

    分布式消息中间件是现代软件架构中的重要组成部分,特别是在微服务和大数据处理场景中,它们扮演着数据通信的关键角色。本书《分布式消息中间件实践_倪炜(著)》深入探讨了四种主流的消息队列(Message Queue,MQ)...

    Java消息中间件JMS,ActiveMQ.zip

    Java消息中间件JMS,ActiveMQ

    JMS中间件ActiveMQ介绍

    ActiveMQ 是Apache基金会维护的一款开源消息中间件,它实现了JMS 规范,并提供了丰富的特性和功能。ActiveMQ 可以帮助应用程序在不同的系统之间进行通信,实现消息的异步传输。 - **关键特点**: - **可移植性**:...

    JMS优秀硕士学位论文(六)-基于JMS的消息中间件的研究与实现

    内容为基于JMS的消息中间件的研究与实现,格式为CAJ,页数为54

    TIBCO_RV__VS__IBM_MQ和JMS消息中间件的对比分析

    ### TIBCO Rendezvous (TIBCO RV) 与 IBM MQ 及 JMS 消息中间件的对比分析 #### TIBCO Rendezvous 技术简介 TIBCO Rendezvous(简称TIBCO RV)是一款强大的中间件产品,它通过一系列专有的技术,实现了异构系统...

    activemq消息中间件的使用demo,以及spring集合jms实现消息发送和处理。

    ActiveMQ是Apache软件基金会开发的一款开源消息中间件,它遵循Java消息服务(JMS)标准,提供高效、可靠的异步消息传递。在分布式系统中,消息中间件扮演着至关重要的角色,它允许不同组件之间通过解耦的方式进行...

    TongLINK/Q消息中间件(说明)

    该中间件提供了多种消息传递模式,包括点对点、发布/订阅、路由和集群等,适用于不同的应用场景。其主要功能包括高级的队列、消息处理机制以及丰富的管理工具,旨在确保消息能够安全、可靠地传输。 #### 二、产品...

Global site tag (gtag.js) - Google Analytics