当从webservice接收到信息的时候，消息生产者producer立刻把收到的消息放入到jms里面，消费者cusomer这时要设置一个监听，当生产者发送消息时，只要消息被发出来，消费者就会接收到消息，然后进行相应的操作。

在tomcat里面，要进行配置。

首先在tomcat安装目录里面，对conf/context.xml进行配置，加入以下代码：

<Resourcename="jms/FailoverConnectionFactory"auth="Container"type="org.apache.activemq.ActiveMQConnectionFactory"description="JMS Connection Factory"factory="org.apache.activemq.jndi.JNDIReferenceFactory"brokerURL="failover:(tcp://localhost:61616)?initialReconnectDelay=100&amp;maxReconnectAttempts=5"brokerName="localhost"useEmbeddedBroker="false"/><Resourcename="jms/NormalConnectionFactory"auth="Container"type="org.apache.activemq.ActiveMQConnectionFactory"description="JMS Connection Factory"factory="org.apache.activemq.jndi.JNDIReferenceFactory"brokerURL="tcp://localhost:61616"brokerName="localhost"useEmbeddedBroker="false"/><Resourcename="jms/topic/MyTopic"auth="Container"type="org.apache.activemq.command.ActiveMQTopic"factory="org.apache.activemq.jndi.JNDIReferenceFactory"physicalName="MY.TEST.FOO"/><Resourcename="jms/queue/MyQueue"auth="Container"type="org.apache.activemq.command.ActiveMQQueue"factory="org.apache.activemq.jndi.JNDIReferenceFactory"physicalName="MY.TEST.FOO.QUEUE"/> 

具体也不晓得这个是做什么的，看上去貌似是配置jndi的，我没用jndi的方式，加上这个，也正常运行。所以还是加上吧。

然后在web.xml里面，加入监听的类，这个类是自己写的。

  <!--添加jms监听--><servlet><servlet-name>jms-listener</servlet-name><servlet-class>com.message.JMSListener</servlet-class><load-on-startup>1</load-on-startup></servlet>

然后就建立这个类：

packagecom.message;importjavax.jms.Connection;importjavax.jms.ConnectionFactory;importjavax.jms.Destination;importjavax.jms.JMSException;importjavax.jms.Message;importjavax.jms.MessageConsumer;importjavax.jms.MessageListener;importjavax.jms.ObjectMessage;importjavax.jms.Session;importjavax.servlet.http.HttpServlet;importorg.apache.activemq.ActiveMQConnection;importorg.apache.activemq.ActiveMQConnectionFactory;importorg.apache.log4j.Logger;public class JMSListener extends HttpServlet implementsMessageListener {/****/private static final long serialVersionUID = -8455543162505698971L;private Logger logger=Logger.getLogger(JMSListener.class);ConnectionFactory connectionFactory;Connection connection=null;Session session;Destination destination;MessageConsumer consumer;inti;publicJMSListener(){String url= "tcp://localhost:61616";String queue="NewNocPacket";connectionFactory= newActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER,ActiveMQConnection.DEFAULT_PASSWORD, url);try{connection=connectionFactory.createConnection();session= connection.createSession(false,Session.AUTO_ACKNOWLEDGE);destination=session.createQueue(queue);consumer=session.createConsumer(destination);consumer.setMessageListener(this);connection.start();}catch(JMSException e) {//TODO Auto-generated catch blocklogger.error("===========cusumer create error");e.printStackTrace();}}@Overridepublic voidonMessage(Message message) {//TODO Auto-generated method stubObjectMessage msg=(ObjectMessage) message;try{logger.info("=========hello ===========");i++;}catch(JMSException e) {//TODO Auto-generated catch block
e.printStackTrace();}}}

原理大概是这样，上面代码不要照抄的。

然后就ok了，部署一下项目，建立一个消息的发送者，消息到达后，监听就会自动执行，打印出onmessage里面的话。