初手配置Tomcat6.0 + ActiveMq5.1 + Spring2.5.doc

这个用了很多的时间都搞得成功，参考了不同的书籍，最后都成功了，在这里我把我的心得在这里写写 首先，下载ActiveMq5.1，大家可以在官方网站下载：当大家下载解压后，就将文件夹的的包到web project下的lib文件夹里，需要拷贝的以下图的包(j2ee和jre除外)activemq-all-5.2.0.jar commons-pool-1.4.jar log4j-1.2.14.jar spring-beans-2.5.5.jar spring-context-2.5.5.jar spring-core-2.5.5.jar spring-jms-2.5.5.jar spring-tx-2.5.5.jar spring-web-2.5.5.jar spring-webmvc-2.5.5.jar xbean-spring-3.4.jar好了，现在开始写配置文件了。在src文件夹下新建一spring配置文件名为：applicationContext.xml。其代码如下： Xml代码 1. 2. 7. 8. 10. 11. 12. 13. 15. 16. 17. 18. 20. 21. 22. 23. 24. 25. 26. 27. 28. 29. 31. 32. 33. 34. 35. 36. 37. 这里中，其中就有一个地方花了我很多时间找资料。这里是用了ActiveMq的方式来配置Spring的配置文件，其中引入了xsd的文件。Xml代码 1. 8. 9. . 10. 11. . 由于面的配置文件中使用了jndi，所以也得在Tomcat目录下的conf/context.xml配置,需加入Xml代码 1. 8. 9. 在这里我分别配置了jmsConnectionFactory和jms点对点 之后，就由消息生产者的代码Java代码 1. packagemessage; 2. 3. importjavax.jms.JMSException; 4. importjavax.jms.Message; 5. importjavax.jms.Session; 6. 7. importorg.springframework.jms.core.JmsTemplate; 8. importorg.springframework.jms.core.MessageCreator; 9. 10. 11. publicclassSender 12. 13. privateJmsTemplatejmsTemplate; 14. 15. publicvoidsetJmsTemplate(JmsTemplatejmsTemplate) 16. this.jmsTemplate=jmsTemplate; 17. 18. 19. publicvoidsend(finalStringtext) 20. System.out.println(-Send:+text); 21. jmsTemplate.send(newMessageCreator() 22. 23. publicMessagecreateMessage(Sessionarg0)throwsJMSException 24. /TODOAuto-generatedmethodstub 25. returnarg0.createTextMessage(text); 26. 27. 28. ); 29. 30. 31. package message;import javax.jms.JMSException;import javax.jms.Message;import javax.jms.Session;import org.springframework.jms.core.JmsTemplate;import org.springframework.jms.core.MessageCreator;public class Sender private JmsTemplate jmsTemplate;public void setJmsTemplate(JmsTemplate jmsTemplate) this.jmsTemplate = jmsTemplate;public void send(final String text)System.out.println(-Send:+text);jmsTemplate.send(new MessageCreator()public Message createMessage(Session arg0) throws JMSException / TODO Auto-generated method stubreturn arg0.createTextMessage(text);); 消息接收者Java代码 1. packagemessage; 2. 3. importjavax.jms.JMSException; 4. importjavax.jms.Message; 5. importjavax.jms.MessageListener; 6. importjavax.jms.TextMessage; 7. 8. publicclassReceiverimplementsMessageListener 9. 10. publicvoidonMessage(Messagemessage) 11. if(messageinstanceofTextMessage) 12. TextMessagetext=(TextMessage)message; 13. 14. try 15. System.out.println(Receive:+text.getText(); 16. catch(JMSExceptione) 17. /TODOAuto-generatedcatchblock 18. e.printStackTrace(); 19. 20. 21. 22. 23. package message;import javax.jms.JMSException;import javax.jms.Message;import javax.jms.MessageListener;import javax.jms.TextMessage;public class Receiver implements MessageListener public void onMessage(Message message) if (message instanceof TextMessage) TextMessage text = (TextMessage) message;try S