「Weblogic学习」Weblogic知识要点之JMS发布与订阅实例演示

互联网的时代，喜欢她就关注她，然后我们就能收到她的动态。你想知道这是什么原理，怎么实现的吗？JMS订阅与发布功能就能揭开这层神秘的面纱，一起看看吧……

每一个消息可以有多个消费者。

向某个话题订阅的客户程序只能收到那些在它订阅之后发布的消息。为了接收到消息， 订阅者必须保持活动状态。因此，发布者和订阅者之间存在时间上的依赖关系。JMS API在一定程度上放宽了对这种依赖关系的要求，允许创建持久性订阅（Durable Subscription）。有了持久性订阅，当订阅者不活动时发送的消息也能接收到。

下面的实例是非持久性订阅：

① Commons.java 公有类

② TopicProducer.java 主题发布类

package com.lession.day1024.topic;
import java.util.Date;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicPublisher;
import javax.jms.TopicSession;
import javax.naming.Context;
import com.lession.day1024.Commons;
public class TopicProducer
{
private TextMessage msg;
private TopicPublisher producer;
//private MessageProducer producer;
public TopicProducer() throws Exception
{
this("topic");
}
public TopicProducer(String jndiName)
throws Exception
{
Context context = Commons.getInitialContext();
TopicConnectionFactory factory = (TopicConnectionFactory) context.lookup(Commons.TOPICCONNECTION_FACTORY_JNDI);
TopicConnection connection = factory.createTopicConnection();
connection.start();
//创建一个Topic
Topic topic = (Topic) context.lookup("topic");
TopicSession session = connection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
producer = session.createPublisher(topic);
//producer = session.createProducer(topic);
msg = session.createTextMessage();
}
public void sendMessage(String str)
throws Exception
{
msg.setText(str);
producer.send(msg);
}
public static void main(String[] args)
{
try
{
TopicProducer topic = new TopicProducer("topic");
for (int i = 0; i < 3; i++)
{
topic.sendMessage("Hello Topic" + i + "," + new Date().toString());
}
System.out.println("消息发送完成");
}
catch (Exception e)
{
e.printStackTrace();
}
}
}

③ SyncTopicReceive.java同步接收

package com.lession.day1024.topic;
import javax.jms.Message;
import javax.jms.TextMessage;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicSession;
import javax.jms.TopicSubscriber;
import javax.naming.Context;
import com.lession.day1024.Commons;
public class SyncTopicReceive
{
private TopicSubscriber subscriber;
//private MessageConsumer subscriber;
public SyncTopicReceive()
throws Exception
{
this("topic");
}
public SyncTopicReceive(String jndiName)
throws Exception
{
Context context = Commons.getInitialContext();
TopicConnectionFactory factory = (TopicConnectionFactory)context.lookup(Commons.TOPICCONNECTION_FACTORY_JNDI);
TopicConnection conn = factory.createTopicConnection();
TopicSession session = conn.createTopicSession(false, TopicSession.AUTO_ACKNOWLEDGE);
Topic messageTopic = (Topic)context.lookup(jndiName);
subscriber = session.createSubscriber(messageTopic);
//subscriber = session.createConsumer(messageTopic);
conn.start();
}
public boolean receiveMessage() throws Exception
{
Message msg = subscriber.receive();
if(null != msg)
{
String msgText = "";
if (msg instanceof TextMessage)
{
msgText = ((TextMessage)msg).getText();
}
else
{
msgText = msg.toString();
}
System.out.println("The message:" + msgText);
return true;
}
return false;
}
public static void main(String[] args) throws Exception{
SyncTopicReceive receiver = new SyncTopicReceive("topic");
while(receiver.receiveMessage());
System.out.println("finish");
}
}

运行结果：

1）我先运行一个接收 SyncTopicReceive.java，然后运行 TopicProducer.java，可以看到刚刚发布的消息，已经被接收

2） 我再运行一个接收SyncTopicReceive.java（有两个了），然后运行 TopicProducer.java。请根据截图时间对比接收到的消息内容。

由两次运行的结果，我们可以知道：只有订阅者是活动状态，发布者发布的消息才能被接收到；每条消息都可以被正在运行的订阅者接收。

发布/订阅模型的特点：

? 每个消息都可以有多个（0，1，……）订阅者

每条消息可以有多个消费者，如果报纸和杂志一样，谁订阅了谁都可以获得。

? 订阅者只能消费他们订阅之后出版的消息

这就要求订阅者必须先订阅，生产者再发布。即订阅者必须先运行，再等待生产者的运行，这和点对点类型有所差异。

? 订阅者必须保持为活动状态才能使用这些消息

即订阅者必须保持活动状态等待发布者发布的消息，如果订阅者在发布者发布消息之后才运行，则不能获得先前发布者发布的消息。