JMS初探

JMS（Java Message Service，Java消息服务）是一组Java应用程序接口(Java API)，它提供创建、发送、接收、读取消息的服务。由Sun公司和它的合作伙伴设计的JMS API定义了一组公共的应用程序接口和相应语法，使得Java程序能够和其他消息组件进行通信。

JMS 使您能够通过消息收发服务（有时称为消息中介程序或路由器）从一个 JMS 客户机向另一个 JMS 客户机发送消息。消息是 JMS 中的一种类型对象，由两部分组成：报头和消息主体。报头由路由信息以及有关该消息的元数据组成。消息主体则携带着应用程序的数据或有效负载。根据有效负载的类型来划分，可以将消息分为几种类型，它们分别携带：简单文本 (TextMessage)、可序列化的对象 (ObjectMessage)、属性集合 (MapMessage)、字节流 (BytesMessage)、原始值流 (StreamMessage)，还有无有效负载的消息 (Message)。

消息收发系统是异步的，也就是说，JMS 客户机可以发送消息而不必等待回应。比较可知，这完全不同于基于 RPC 的（基于远程过程的）系统，如 EJB 1.1、CORBA 和 Java RMI 的引用实现。在 RPC 中，客户机调用服务器上某个分布式对象的一个方法。在方法调用返回之前，该客户机被阻塞；该客户机在可以执行下一条指令之前，必须等待方法调用结束。在 JMS 中，客户机将消息发送给一个虚拟通道（主题或队列），而其它 JMS 客户机则预订或监听这个虚拟通道。当 JMS 客户机发送消息时，它并不等待回应。它执行发送操作，然后继续执行下一条指令。消息可能最终转发到一个或许多个客户机，这些客户机都不需要作出回应。

JMS的通用接口集合以异步方式发送或接收消息。异步方式接收消息显然是使用间断网络连接的客户机，诸如移动电话和PDA的最好的选择。另外， JMS采用一种宽松结合方式整合企业系统的方法，其主要的目的就是创建能够使用跨平台数据信息的、可移植的企业级应用程序，而把开发人力解放出来。

Java消息服务支持两种消息模型：Point-to-Point消息(P2P)和发布订阅消息（Publish Subscribe messaging，简称Pub/Sub）。JMS规范并不要求供应商同时支持这两种消息模型，但开发者应该熟悉这两种消息模型的优势与缺点。

P2P消息模型是在点对点之间传递消息时使用。如果应用程序开发者希望每一条消息都能够被处理，那么应该使用P2P消息模型。与Pub/Sub消息模型不同，P2P消息总是能够被传送到指定的位置。

Pub/Sub模型在一到多的消息广播时使用。如果一定程度的消息传递的不可靠性可以被接受的话，那么应用程序开发者也可以使用Pub/Sub消息模型。换句话说，它适用于所有的消息消费程序并不要求能够收到所有的信息或者消息消费程序并不想接收到任何消息的情况。ConnectionFactory ：被管理的对象，由客户端使用，用来创建一个连接。

ConnectionFactory ：被管理的对象，由客户端使用，用来创建一个连接。
Connection：一个到JMS消息系统提供者的活动连接。
Destination ：一个被管理对象，封装了消息目的地的标识。
Session - a single：一个用来发送和接收消息的单独的线程上下文
MessageProducer ：一个由Session对象创建的，用来发送消息的到目的地的对象。
MessageConsumer KNOWLEDGE是WebLogic JMS 提供的。
------------------------------------------------------------------------------------------------------

1. JMS基本概念
JMS(Java Message Service)是访问企业消息系统的标准API,它便于消息系
统中的Java应用程序进行消息交换,并且通过提供标准的产生、发送、接收消息的接口简化企业应用的开发。

2. JMS基本功能
JMS 是用于和面向消息的中间件相互通信的应用程序接口。它既支持点对点(point-to-point)的域，又支持发布/订阅 (publish/subscribe)类型的域，并且提供对下列类型的支持：经认可的消息传递,事务型消息的传递，一致性消息和具有持久性的订阅者支持。JMS还提供了另一种方式来对您的应用与旧的后台系统相集成。
3. WebLogic JMS Server介绍
WebLogic Server8.1符合JAVA规范,并通过Sun Microsystems J2EE 1.3认
证. 作为WebLogic的一部分,当然WebLogic JMS Server也完全遵从JMS规范,还支持集群,并可以应用于实际企业系统.下图是WebLogic JMS Server体系结构.图中可以看到WebLogic JMS Server主要组件有: WebLogic JMS servers(用于消息通信),Java客户端,JNDI(用于域名查找), 后备存储(用于持久消息存储,基于文件或者JDBC数据库).

二. WebLogic JMS特性
1. 消息通信模型
JMS 支持两种消息通信模型：点到点（point-to-point）（PTP）模型和发布/订阅（Pub/Sub）模型。除了下列不同之外，这两种消息通信模型非常地相似：
PTP 模型规定了一个消息只能有一个接收者;Pub/Sub 模型允许一个消息可以有多个接收者。
2. 消息组成
消息传递系统的中心就是消息。
一条 Message 分为三个组成部分：
· 头（header）是个标准字段集，客户机和供应商都用它来标识和路由消息。
· 属性（property）支持把可选头字段添加到消息。如果您的应用程序需要不使用标准头字段对消息编目和分类，您就可以添加一个属性到消息以实现这个编目和分类。提供 set<Type>Property(...) 和 get<Type>Property(...) 方法以设置和获取各种 Java 类型的属性，包括 Object。JMS 定义了一个供应商选择提供的标准属性集。
· 消息的主体（body）包含要发送给接收应用程序的内容。每个消息接口特定于它所支持的内容类型。
JMS 为不同类型的内容提供了它们各自的消息类型，但是所有消息都派生自 Message 接口。
· StreamMessage：包含 Java 基本数值流，用标准流操作来顺序的填充和读取。
· MapMessage：包含一组名/值对；名称为 string 类型，而值为 Java 的基本类型。
· TextMessage：包含一个 String。
· ObjectMessage：包含一个 Serializable Java 对象；能使用 JDK 的集合类。
· BytesMessage：包含未解释字节流: 编码主体以匹配现存的消息格式。
· XMLMessage: 包含XML内容。扩展TextMessage,XMLMessage 类型的使用，使得消息过滤非常便利。
3. 消息确认模式
非事务性会话中，应用程序创建的会话有5 种确认模式,而在事务性会话中，确认模式被忽略。
五种确认模式说明:
· AUTO_ACKNOWLEDGE：自动确认模式。一旦接收方应用程序的方法调用从处理消息处返回，会话对象就会确认消息的接收。
· CLIENT_ACKNOWLEDGE：客户端确认模式。会话对象依赖于应用程序对被接收的消息调用一个acknowledge()方法。一旦这个方法被调用，会话会确认最后一次确认之后所有接收到的消息。这种模式允许应用程序以一个调用来接收，处理并确认一批消息。注意：在管理控制台中，如果连接工厂的 Acknowledge Policy（确认方针）属性被设置为"Previous"（提前），但是你希望为一个给定的会话确认所有接收到的消息，那么就用最后一条消息来调用 acknowledge()方法。
· DUPS_OK_ACKNOWLEDGE：允许副本的确认模式。一旦接收方应用程序的方法调用从处理消息处返回，会话对象就会确认消息的接收；而且允许重复确认。在需要考虑资源使用时，这种模式非常有效。注意：如果你的应用程序无法处理重复的消息的话，你应该避免使用这种模式。如果发送消息的初始化尝试失败，那么重复的消息可以被重新发送。
· NO_ACKNOWLEDGE：不确认模式。不确认收到的消息是需要的。消息发送给一个NO_ACKNOWLEDGE 会话后，它们会被WebLogic 服务器立即删除。在这种模式下，将无法重新获得已接收的消息，而且可能导致下面的结果：1. 消息可能丢失；和（或者）另一种情况：2. 如果发送消息的初始化尝试失败，会出现重复消息被发送的情况。
· MULTICAST_NO_ACKNOWLEDGE：IP组播下的不确认模式，同样无需确认。发送给一个 MULTICAST_NO_ACKNOWLEDGE会话的消息， 会共享之前所述的NO_ACKNOWLEDGE 确认模式一样的特征。这种模式支持希望通过IP 组播方式进行消息通信的应用程序，而且无需依赖会话确认提供的服务质量。注意：如果你的应用程序无法处理消息的丢失或者重复，那么你应该避免使用这种模式。如果发送消息的初始化尝试失败的话，重复的消息可能会被再次发送。
注：在上表的5 种确认模式中，AUTO_ACKNOWLEDGE ，DUPS_OK_ACKNOWLEDGE 和
CLIENT_ACKNOWLEDGE 是JMS 规范定义的，NO_ACKNOWLEDGE 和MULTICAST_NO_ACKNOWLEDGE是WebLogic JMS 提供的。




-------------------------------------------------------------------------------------------------------------------------------------
配置了一上午，终于把这个小jms实例调通了
1.在weblogc控制台下面新建连接工厂(myjmsfactory)、服务器(myjmsserver)、目标queue(myjmsqueue)、目标topic(myjmstopic).其他配置均按照默认配置。
2.编写小应用
queue初始化init

java 代码

String jndi_factory = "weblogic.jndi.WLInitialContextFactory";
String provider_url = "t3://localhost:7001";
String jms_factory = "myjmsfactory";
String queuename = "myjmsqueue";
String user = "weblogic";
ring password = "weblogic";

Hashtable env = new Hashtable();
env.put(Context.INITIAL_CONTEXT_FACTORY, jndi_factory);
env.put(Context.PROVIDER_URL, provider_url);
env.put(Context.SECURITY_PRINCIPAL, user);
env.put(Context.SECURITY_CREDENTIALS, password);
InitialContext ctx=null;

ctx = new InitialContext(env);//初始化上下文
this.confactory = (QueueConnectionFactory)ctx.lookup(jms_factory);
this.jmsCon=this.confactory.createQueueConnection();
this.queue = (Queue)ctx.lookup(queuename);

queue接收

java 代码

/** 开启一个会话来创建一个消息消费者，异步监听到来的消息。*/
QueueSession session=jmsCon.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
QueueReceiver queueReceiver = session.createReceiver(this.queue);
MessageListenerForOrgMsg msgListener=new MessageListenerForOrgMsg();
queueReceiver.setMessageListener(msgListener);

queue发送

java 代码

QueueSession session = this.jmsCon.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
    QueueSender queueSender = session.createSender(queue);
    Message textMsg=session.createTextMessage();
    textMsg.setStringProperty("deptId", deptId);
    textMsg.setStringProperty("deptName", deptName);
    queueSender.send(textMsg);
session.close();

topic初始化init

java 代码

    String jndi_factory = "weblogic.jndi.WLInitialContextFactory";
    String provider_url = "t3://localhost:7001";
    String jms_factory = "myjmsfactory";
    String queuename = "myjmstopic";
    String user = "weblogic";
  String password = "weblogic";

    Hashtable env = new Hashtable();
    env.put(Context.INITIAL_CONTEXT_FACTORY, jndi_factory);
    env.put(Context.PROVIDER_URL, provider_url);
    env.put(Context.SECURITY_PRINCIPAL, user);
env.put(Context.SECURITY_CREDENTIALS, password);
    InitialContext ctx=null;

    try
    {
        ctx = new InitialContext(env);//初始化上下文
        this.confactory = (TopicConnectionFactory)ctx.lookup(jms_factory);
        this.jmsCon=this.confactory.createTopicConnection();
        this.queue = (Topic)ctx.lookup(queuename);
    }

topic接收

java 代码

/** 开启一个会话来创建一个消息消费者，异步监听到来的消息。*/
TopicSession session=jmsCon.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
TopicSubscriber queueReceiver = session.createSubscriber(this.queue);
MessageListenerForOrgMsg msgListener=new MessageListenerForOrgMsg();
queueReceiver.setMessageListener(msgListener);

topic发送

java 代码

TopicSession session = this.jmsCon.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
    TopicPublisher queueSender = session.createPublisher(queue);
    Message textMsg=session.createTextMessage();
    textMsg.setStringProperty("deptId", deptId);
    textMsg.setStringProperty("deptName", deptName);
    queueSender.publish(textMsg);
session.close();