转------ms 的两种模式，p2p ,publish/substrib
来自：http://blog.csdn.net/jixiuffff/archive/2010/07/30/5776057.aspx
p2p 点对点模式， 也就是一对一，服务端发送一条消息到Destination 即Queue
虽然可能有n个客户端在队列中侦听消息，但只有一个可以读取到消息，之后消息将不存在，其他人没法读取
publish/substrib 则可以理解为一对多，
1、P2P模型
在P2P模型中，有下列概念：消息队列(Queue)、发送者(Sender)、接收者(Receiver)。每个消息都被发送到一个特定的队 列，接收者从队列中获取消息。队列保留着消息，直到它们被消费或超时 。
?每个消息只有一个消费者 (Consumer)（即一旦被消费，消息就不再在消息队列中）
?发送者和接收者之间在时间上没有依赖性 ，也就是说当发送者发送了消息之后，不管接收者有没有正在运行，它不会影响到消息被发送到队列。
?接收者在成功接收消息之后需向队列应答成功
如果你希望发送的每个消息都应该被成功处理 的话，那么你需要P2P模型。
适用场合：想让接收者进行且只进行一次处理
组件之间进行同步通信
2 在Pub/Sub模型中，有下列概念： 主题（Topic）、发布者（Publisher）、订阅者（Subscriber）。客户端将消息发送到主题。多个发布者将消息发送到Topic，系统 将这些消息传递给多个订阅者。
?每个消息可以有多个消费者
? 发布者和订阅者之间有时间上的依赖性 。针对某个主题(Topic)的订阅者，它必须创建一个订阅之后，才能消费发布者的消息，而且，为了消费消息，订阅者 必须保持运行的状态。
当然，为了缓和这种严格的时间相关性，JMS允许订阅者创建一个可持久化的订阅。这样，即使订阅者没有被激活（运行），它也能接收到发布者的消 息。
如果你希望发送的消息可以不被做任何处理、或者被一个消费者处理、或者可以被多个消费者处理 的话，那么可以采用Pub/Sub模型（也就是说发布者不关心有多少侦听者）。
关于时间 的依赖性
二种模型的实现结果：
对于p2p 模型的每个消息只能有一个消费者 如果我们定义二个消息接受者的Bean那么只能有一端会接收到消息。当你把部署在Jboss中的消息接收Bean去掉以后，然后发送消息 此时消息在队列中，一旦你重新部署他会立刻就接收到刚刚发送的消息 所以它没有时间的依赖性，
pub/sub 模型可以有多个消费者 在这个模型中如果我们定义多个接收消息的Bean当我们在客户端发送消息的时候二个bean都会接收到消息，所以他有多个消费者 但是如果你把Jboss部署中的消息接收bean去掉之后，发送消息。然后在重新部署，那么消息也无法接收到 ，所以说他有时间的依赖性。
=========================================================
p2p 的两种消息处理模式 ：同步，异步
JMS P2P编程
在JMS P2P通信方式中，发送程序将消息放入一个队列，根据通信要求，发送程序可以要求一个应答信息（请求-应答模式 ），也可以不要求立即获得应答（发送-遗忘 模式）。如果需要应答信息，发送程序通过消息头的JMSReplayTo 域向消息的接收程序声明应答信息应当放入哪一个本地队列。
在请求-应答模式中，发送程序可以按照两种方式操作。一种称为伪同步方式，发送程序在等待应答消息时会被阻塞；另一种是异步方式，发送程序发送消息后不被 阻塞，可以照常执行其他处理任务，它可以在以后适当的时机检查队列，查看有没有它希望得到的应答信息。下面的代码片断显示了JMS程序发送消息的过程。
pub/sub方式 ：
概念：topic,publisher,subscriber,主题，发布者，订阅者三个角色。主题和订阅者是一对多关系，一个主题可以被多个订阅者订 阅。当发布者向某个主题发送一条消息时，所有的订阅者都会收到。
如何理解订阅的概念呢，个人理解，分两种情况：
一、 创建一个订阅者时使用session.createDurableSubscriber(topic, clientId )方法创建为持久型订阅者时，该topic和clientId的订阅关系将被保存在服务器上，即产生了订阅关系。这样clientId这个id的订阅者将 在离线的时候，也不会丢失消息。这个订阅关系也可以理解为被持久化在jms服务器上了，使用jmx的监视控制台（我使用的activeMq），可以看到有 一个Subscription的节点，下面有你订阅主题时给定的客户端名字。可以使用unsubscribe 方法 取消订阅关系。
二、 创建一个非持久化方式的订阅者时，只有在客户端订阅者连接到jms服务器时，订阅关系成立，订阅者离线时，订阅关系即取消，不会保存在服务器上，这也是非 持久化方式订阅者不能离线接收消息的原因吧。默认为广播方式，在没有订阅者连接到服务器时，发送的消息将丢失，不会保存在服务器。
subSession.createConsumer(destination);
subSession.createSubscriber(topic);
subSession.createDurableSubscriber(topic, name); //name 是 一个jms 用来区别定阅者的id
取消定阅
subscriber.close();
session.unsubscribe(name); //只对持久定阅，
