JMS - 异步消息的使者

核心提示： Subscriber： Contextcontext=newInitialContext();TopicConnectionFactorytopicConnectionFactory=(TopicConnectionFactory)context.lookup("TopicConnec

Subscriber：　　

　　　　　　Context　context　=　new　InitialContext();
　　　　　　TopicConnectionFactory　topicConnectionFactory　=　(TopicConnectionFactory)　context.lookup("TopicConnectionFactoryTest");
　　　　　　TopicConnection　topicConnection　=　topicConnectionFactory.createTopicConnection();
　　　　　　TopicSession　topicSession　=　topicConnection.createTopicSession(false,　Session.AUTO_ACKNOWLEDGE);
　　　　　　Topic　topic　=　(Topic)　context.lookup("TopicTest");
　　　　　　TopicSubscriber　topicSubscriber　=　topicSession.createSubscriber(topic,　null,　true);
　　　　　　topicConnection.start();
　　　　　　TextMessage　inMessage　=　(TextMessage)　topicSubscriber.receive();
　　　　　　System.out.println("SUBSCRIBER　THREAD:　Reading　message:　"+　inMessage.getText());
　　　　　　topicConnection.close();

以上是对P2P和pub/sub两种模式最简单的实现，对于JMS的基本使用来说足够了，对比以上两种模式的实现，我们不难发现一些共同点：都是通过 QueueConnectionFactory/TopicConnectionFactory来生成QueueConnection /TopicConnection的实例，QueueConnection/TopicConnection用来建立和JMS的连接并生成会话实例 QueueSession/TopicSession，QueueSender的send方法和TopicPublisher的publish方法发送消息到Destination。 QueueReceiver和TopicSubscriber直接使用父接口MessageConsumer中定义的方法receive、 recieveNoWait等方法来接收消息。

如果你想在main方法中运行这些程序，你需要先在Application Server中配置ConnectionFactory和Destination的JNDI，可参考我的上篇文章《Standalone Client Lookup JNDI from the GlassFish》。

同样，我们可以采用Message Driven Bean（MDB）作为JMS消息的receiver，sender将消息发送到MDB所监听的目的地，EJB容器会调用MDB的onMessage方法去接收消息。以这种方式去实现JMS，应该更J2EE点。

JMS的实现就是如此的简单，但简单并不代表简陋，JMS还拥有众多的特性，以帮助你在实现中达到更多的目的，同时，还有很多的JMS provider能够更加简化您的JMS应用，比如ActiveMQ，更多的精彩需要你自己的发掘。