JMS学习心得（一）

学习中的一些心得记录
p2p方式：

概念：queue，QueueSender，QueueReceiver，队列，消息发送者，消息接收者三个角色。发送者向队列中加入消息，接收者从队列取出消息，队列中的消息接收一条少一条，如果有多个接收者连接到队列，一条消息只能被一个接收者取走。

一、
消息发送方式默认不设置的时候是  DeliveryMode.PERSISTENT
方式，也就是持久化方式。该常量值为2。这种方式消息不会丢失，会保存在服务器上。就是说消息发送后，即使你关闭jms服务器（比如用activeMQ，
关闭服务器程序），然后服务重新启动后，这条消息仍然是存在的，而其他使用NON_PERSISTENT方式的消息就丢失了。我想大多数情况下啊我们需要
的是PERSISTENT方式吧！

DeliveryMode.NON_PERSISTENT 常量值为1

DeliveryMode.PERSISTENT 常量值为2

int a = msgp0.getDeliveryMode();

        //msgp0.setDeliveryMode(DeliveryMode.PERSISTENT);

二、消息的消费者接收消息可以采用两种方式：

1、consumer.receive() 或 consumer.receive(int timeout)；

2、注册一个MessageListener。

采用第一种方式，即同步方式，遇到receive方法就会阻塞，消息的接收者会一直等待下去，直到有消息到达，或者超时。该方式调用一次方法只接收一条消息。

采用第二种方式，即异步方式，程序会一直监听，只要有消息就会响应onMessage方法，当执行
conn.close()方法时会结束监听器。
MessageConsumer comsumer 
=
 session.createConsumer(queue);

comsumer.setMessageListener(
new
 MessageListener(){

            @Override

            
public
 
void
 onMessage(Message m) {

                TextMessage textMsg 
=
 (TextMessage) m;

                
try
 {

                    System.out.println(textMsg.getText());

                } 
catch
 (JMSException e) {

                    e.printStackTrace();

                }

            }

           

        });

测试发现
conn.close()
方法对这两种方式有些不同，对于监听器方式，只要close方法执行，监听就会终止，估计监听是以后台线程方式执行的。而对于recive接收方式，只要
receive方法只要调用一次，就必须等到有消息到达才会执行下面的语句，是阻塞的方式，即使后面的conn.close()不会执行到。

参考：http://www.cnblogs.com/iloveu/archive/2009/06/10/1500714.html

pub/sub方式
：

概念：topic,publisher,subscriber,主题，发布者，订阅者三个角色。主题和订阅者是一对多关系，一个主题可以被多个订阅者订阅。当发布者向某个主题发送一条消息时，所有的订阅者都会收到。

如何理解订阅的概念呢，个人理解，分两种情况：

一、
创建一个订阅者时使用session.createDurableSubscriber(topic, clientId
)方法创建为持久型订阅者时，该topic和clientId的订阅关系将被保存在服务器上，即产生了订阅关系。这样clientId这个id的订阅者将
在离线的时候，也不会丢失消息。这个订阅关系也可以理解为被持久化在jms服务器上了，使用jmx的监视控制台（我使用的activeMq），可以看到有
一个Subscription的节点，下面有你订阅主题时给定的客户端名字。可以使用unsubscribe
方法
取消订阅关系。

二、
创建一个非持久化方式的订阅者时，只有在客户端订阅者连接到jms服务器时，订阅关系成立，订阅者离线时，订阅关系即取消，不会保存在服务器上，这也是非
持久化方式订阅者不能离线接收消息的原因吧。默认为广播方式，在没有订阅者连接到服务器时，发送的消息将丢失，不会保存在服务器。

对jms规范的理解：

jms
规范是sun提出的java的消息服务统一的api接口规范，规范、标准的好处就不用说了，java能走到今天，规范标准的制定可以说有很大的功劳吧。所
有提供java消息服务的软件提供者都必须针对这个接口实现。我们编写jms程序时，基本可以做到只针对接口编程，不用考虑是那个厂家实现，这是我们的代
码有了很大的灵活行，不绑定某个具体厂商。只要你的代码写的够好，完全可以不修改代码就直接部署到不同厂商的jms服务器上。

举个例子：编写一个基于ActiveMQ的jms程序时有这样的代码：

ActiveMQConnectionFactory factory = new
 ActiveMQConnectionFactory("vm://localhost"
);

...

Queue queue = new
 ActiveMQQueue("testQueue"
); 

等，这样就在代码里绑死了ActiveMQ的api。要做到厂商无关性，应该使用jndi来取得工厂对象以及队列资源。

比如：

ConnectionFactory cf = (ConnectionFactory) ctx.lookup("connectionFactory");

...

Destination dest = (Queue) ctx.lookup("MyQueue");

注意接口也尽量使用jms的大的接口。当然这里需要提供jndi服务支持，ActiveMQ本身提供jndi服务，只要在classpath中有一个jndi.properties文件，在配置文件中对资源做一些配置就可以了

比如：

java.naming.factory.initial = org.apache.activemq.jndi.ActiveMQInitialContextFactory

connectionFactoryNames = connectionFactory, queueConnectionFactory, topicConnectionFactry

queue.MyQueue = zmQueue

topic.MyTopic = zmTopic

等。

对jms规范1.1的一些理解:

JMS 1.0.2 定义了两种类型的消息传递域（它们是相互独立的），即点对点和发布／订阅。JMS 的最新版本，即版本 1.1，JMS 统一了这两个域。如下图：有了 JMS 1.1，客户机就不再必须专门针对这个或那个域进行实现了。

JMS 公共	PTP 域	Pub/Sub 域
ConnectionFactory	QueueConnectionFactory	TopicConnectionFactory
Connection	QueueConnection	TopicConnection
Destination	Queue	Topic
Session	QueueSession	TopicSession
MessageProducer	QueueSender	TopicPublisher
MessageConsumer	QueueReceiver	TopicSubscriber

参考：http://www.ibm.com/developerworks/cn/java/j-jms11/index.html

就是说，只使用JMS公共域的接口就可以完成jms程序编写。所以推荐尽量使用大的接口，增加代码的灵活性。

比如，写pub/sub方式的消息程序也可以这样：

        Context ctx = new InitialContext();

        ConnectionFactory factory = (ConnectionFactory) ctx

                .lookup("connectionFactory");

        Connection connection = factory.createConnection();

        connection.start();

        // 创建一个Topic

        Destination topic = (Destination) ctx.lookup("MyTopic");

        Session session = connection.createSession(false,

                Session.AUTO_ACKNOWLEDGE);

        MessageConsumer comsumer3 = session.createConsumer(topic);

        Message msg = comsumer3.receive();