副标题#e#
在差异系统之间互换信息的一大障碍是如安在准确互换和名目化数据方面取得一致。Java Message Service（ Java动静处事，简称JMS）通过提供一种与J2EE应用措施或传统系统交互的要领部门的办理了这个问题。
JMS的通用接口荟萃以异步方法发送或吸收动静。异步方法吸收动静显然是利用中断网络毗连的客户机，诸如移动电话和PDA的最好的选择。别的， JMS回收一种宽松团结方法整合企业系统的要领，其主要的目标就是建设可以或许利用跨平台数据信息的、可移植的企业级应用措施，而把开拓人力解放出来。
Java动静处事支持两种动静模子：Point-to-Point动静(P2P)和宣布订阅动静（Publish Subscribe messaging，简称Pub/Sub）。JMS类型并不要求供给商同时支持这两种动静模子，但开拓者应该熟悉这两种动静模子的优势与缺点。
P2P动静模子是在点对点之间通报动静时利用。假如应用措施开拓者但愿每一条动静都可以或许被处理惩罚，那么应该利用P2P动静模子。与Pub/Sub动静模子差异，P2P动静老是可以或许被传送到指定的位置。
Pub/Sub模子在一到多的动静广播时利用。假如必然水平的动静通报的不行靠性可以被接管的话，那么应用措施开拓者也可以利用Pub/Sub动静模子。换句话说，它合用于所有的动静消费措施并不要求可以或许收到所有的信息可能动静消费措施并不想吸收到任何动静的环境。
JMS通过答允建设耐久订阅来简化时间相关性，纵然动静预订者未激活也可以吸收到动静。另外，利用耐久订阅还可通过行列提供机动性和靠得住性，而仍然答允动静被发给很多的吸收者。
Topic Subscriber topic Subscriber =
topicSession.createDurableSubscriber(topic, subscriptionName);
Connection工具暗示了到两种动静模子中的任一种的动静系统的毗连。处事器端和客户机端工具要求打点建设的JMS毗连的状态。毗连是由Connection Factory建设的而且通过JNDI查寻定位。
//取得用于 P2P的 QueueConnectionFactory
QueueConnectionFactory = queueConnectionFactory( );
Context messaging = new InitialContext( );
QueueConnectionFactory = (QueueConnectionFactory)
Messaging.lookup(“QueueConnectionFactory”);
//取得用于 pub/sub的 TopicConnectionFactory
TopicConnectonFactory topicConnectionFactory;
Context messaging = new InitialContext();
topicConnectionFactory = (TopicConnectionFactory)
messaging.lookup(“TopicConnectionFactory”);
留意：用于P2P的代码和用于PublishSubscribe的代码很是相似。
假如session被标志为transactional的话，确认动静就通过确认和校正来自动地处理惩罚。假如session没有标志为 transactional，你有三个用于动静确认的选项。
· AUTO_ACKNOWLEDGE session将自动地确认收到一则动静。
· CLIENT_ACKNOWLEDGE 客户端措施将确认收到一则动静，挪用这则动静简直认要领。
· DUPS_OK_ACKNOWLEDGE 这个选项呼吁session“懒散的”确认动静通报，可以想到，这将导致动静提供者通报的一些复制动静大概会堕落。这种确认的方法只该当用于动静消费措施可以容忍潜在的副本动静存在的环境。
queueSession = queueConnection.createQueueSession(false, session.AUTO_ACKNOWLEDGE);//P2P
topicSession = topicConnection.createTopicSession(false, session.AUTO_ACKNOWLEDGE); //Pub-Sub
#p#副标题#e#
留意：在本例中，一个session目标从连结中建设，非值指出session是non-transactional的，而且 session将自动地确认收到一则动静。
JMS此刻有两种通报动静的方法。标志为NON_PERSISTENT的动静最多投递一次，而标志为PERSISTENT的动静将利用暂存后再转送的机理投递。假如一个JMS处事离线，那么耐久性动静不会丢失可是得比及这个处事规复联机时才会被通报。所以默认的动静通报方法长短耐久性的。纵然利用非耐久性动静大概低落内务和需要的存储器，而且这种通报方法只有当你不需要吸收所有的动静时才利用。
固然 JMS类型并不需要JMS供给商实现动静的优先级蹊径，可是它需要递送加速的动静优先于普通级此外动静。JMS界说了从0到9的优先级蹊径级别，0是最低的优先级而9则是最高的。更非凡的是0到4是正常优先级的变革幅度，而5到9是加速的优先级的变革幅度。举例来说：
topicPublisher.publish (message, DeliveryMode.PERSISTENT, 8, 10000); //Pub-Sub
或
queueSender.send(message, DeliveryMode.PERSISTENT, 8, 10000);//P2P
这个代码片段，有两种动静模子，映射递送方法是耐久的，优先级为加速型，保留周期是10000 (以毫秒怀抱 )。假如保留周期配置为零，这则动静将永远不会逾期。当动静需要时间限制不然将使其无效时，配置保留周期是有用的。
JMS界说了五种差异的动静正文名目，以及挪用的动静范例，答允你发送并吸收以一些差异形式的数据，提供现有动静名目标一些级此外兼容性。
· StreamMessage — Java原始值的数据流
· MapMessage–一套名称-值对
· TextMessage–一个字符串工具
· ObjectMessage–一个序列化的 Java工具
· BytesMessage–一个未表明字节的数据流
JMS应用措施接口提供用于建设每种范例动静和配置荷载的要领规如，为了在一个行列建设并发送一个TextMessage实例，你可以利用下列语句：
TextMessage message = queueSession.createTextMessage(); message.setText(textMsg);
#p#分页标题#e#
以异步方法吸收动静，需要建设一个动静监听器然后注册一个或多个利用MessageConsumer的JMS MessageListener接口。会话(主题或行列)认真发生某些动静，这些动静被传送到利用onMessage要领的监听者哪里。
import javax.jms.*;
public class ExampleListener implements MessageListener {
//把动静强制转化为TextMessage名目
public void onMessage(Message message) {
TextMessage textMsg = null;
// 打开并处理惩罚这段动静
}
}
当我们建设QueueReceiver和TopicSubscriber时，我们通报动静选择器字符串：
//P2P QueueReceiver
QueueReceiver receiver;
receiver = session.createReceiver(queue, selector);
//Pub-Sub TopicSubscriber
TopicSubscriber subscriber;
subscriber = session.createSubscriber(topic, selector);
为了启动动静的交付，岂论是Pub/Sub照旧P2P，都需要挪用start要领。
TopicConnection.start( ); //pub-sub
QueueConnection.start( ); //P2P
TopicConnection.start ( );// pub-sub
QueueConnection.start ( );// P2P
当一条动静被捕获时，这条动静做为一条必需被强制转化为适当动静范例的普通Message工具达到。这是一个被用来提取或打开动静内容的getter要领。下列代码片断利用StreamMessage范例。
private void unPackMessage (Message message) {
String eName;
String position;
double rate;
StreamMessage message;
Message = session.createStreamMessage( );
//留意下面的代码必需凭据我给出的顺序书写
message.writeString(eName);
message.writeString(position);
message.writeDouble(rate);
//实现处理惩罚动静的须要的措施逻辑
}
遏制动静的通报，无论是Pub/Sub照旧P2P，都挪用stop要领。
TopicConnection.start( ); //pub-sub
QueueConnection.start( ); //P2P
TopicConnection.start ( );// pub-sub
QueueConnection.start ( );// P2P
其他的J2EE组件–servlet或EJB–可以看成动静出产者；然而，它们大概只能同步操纵，这大概是因为它们的请求-应答的性质抉择的。固然XML今朝还不是被支持的动静范例，发送一个XML文件和建设一条文本范例动静以及把XML文件添加到动静的有效负载都一样简朴，都是以非专有的方法传送数据。值得留意的是，一些JMS供给厂商已经提供了可用的XML动静范例。可是利用非尺度的动静范例大概会呈现可移植性问题。
String reportData; //reportData内容为XML 文档
TextMessage message;
message = session.createTextMessage();
message.setText (reportData);
动静驱动组件(MDB)是一个当动静达到时被容器挪用的异步动静消费措施。和entity和session EJB差异，MDB没有当地和长途接口而且是匿名的；它们对付客户是不行见的。MDB是JMS系统的一部门，作为消费者实现处事器上的贸易逻辑措施。 一个客户措施大概通过利用JNDI定位一个与MDB相关联的JMS。 譬喻：
Context initialContext = new InitialContext();
Queue reportInfoQueue = (javax.jms.Queue)initialContext.lookup
(“java:comp/env/jms/reportInfoQueue”);
MDB是由Bean类和相应的XML陈设描写符构成。 Bean 类实现MessageDriveBean 接口：
import javax.ejb.*;
import jms.Message.*;
public interface MessageDriveBean {
public void ejbCreate();
public void ejbRemove();
public void setMessageDrivenContext(MessageDrivenContext ctx);
}
动静监听器接口：
import javax.jms.*;
public interface MessageListener {
public void onMessage( );
}
陈设描写符
＜!DOCTYPE ejb-jar PUBLIC "-//Sun Microsystems, Inc.//DTD Enterprise JavaBeans 2.0//EN" "http://java.sun.com/j2ee/dtds/ejb-jar_2_0.dtd"＞
＜ejb-jar＞
＜enterprise-beans＞
＜message-driven＞
＜ejb-name＞MDB＜/ejb-name＞
＜ejb-class＞MDB＜/ejb-class＞
＜transaction-type＞Container＜/transaction-type＞
＜message-driven-destination＞
＜jms-destination-type＞javax.jms.Queue＜/jms-destination-type＞
＜/message-driven-destination＞
＜security-identity＞
＜run-as-specified-identity＞
＜role-name＞everyone＜/role-name＞
＜/run-as-specified-identity＞
＜/security-identity＞
＜/message-driven＞
＜/enterprise-beans＞
＜/ejb-jar＞
既然我们此刻已经有了一些根基的JMS常识，那么我们可以利用JMS做什么呢？任何工作都可以。
#p#分页标题#e#
譬喻，别离用于销售、库存、客户处事和账目处理惩罚的系统。这些部分之间的系统很大概已经存在了很长时间，这些处理惩罚要求把事务移动到系统中去，这并不是一个小的事情。这就是动静处事合用的所在。
当售货员完成销售的时候，一条动静被发给库存系统；一旦订单动静发送给收发货人员，就可以凭据订单出货了。当订单乐成地发货，系统将通知顾主处事和管帐系统这个订单已经乐成的生意业务了。所有对应的每个子系统都自动地按照收到的动静举办更新。
JMS一般都不是用来整合一个系统，而是整合很多大概参加动静驱动情况的系统。JMS是一个用于开拓和集成企业应用措施的重要的东西。因为很多公司都有以前遗留下来的系统和新近开拓的系统综合起来的系统，动静的利用是整合整个企业的重要的步调。
