Spring3.2.3整合MQ-WS_MQ_V7.5

记录给需要帮助的人~

step ：1 pom.xml

Java代码  

1. <spring-framework.version>3.2.3.RELEASE</spring-framework.version>
2. <mq.version>7.5.0.3</mq.version>
3. <dependency>
4. <groupId>com.ibm.mq</groupId>
5. <artifactId>com.ibm.mqjms</artifactId>
6. <version>${mq.version}</version>
7. </dependency>
8. <dependency>
9. <groupId>com.ibm.mq</groupId>
10. <artifactId>com.ibm.mq.jmqi</artifactId>
11. <version>${mq.version}</version>
12. </dependency>
13. <dependency>
14. <groupId>com.ibm.mq</groupId>
15. <artifactId>connector</artifactId>
16. <version>${mq.version}</version>
17. </dependency>
18. <dependency>
19. <groupId>com.ibm.mq</groupId>
20. <artifactId>providerutil</artifactId>
21. <version>${mq.version}</version>
22. </dependency>
23. <dependency>
24. <groupId>com.ibm.mq</groupId>
25. <artifactId>com.ibm.mq.commonservices</artifactId>
26. <version>${mq.version}</version>
27. </dependency>
28. <dependency>
29. <groupId>com.ibm.mq</groupId>
30. <artifactId>com.ibm.mq.defaultconfig</artifactId>
31. <version>${mq.version}</version>
32. </dependency>
33. <dependency>
34. <groupId>com.ibm.mq</groupId>
35. <artifactId>dhbcore</artifactId>
36. <version>${mq.version}</version>
37. </dependency>
38. <dependency>
39. <groupId>com.ibm.mq</groupId>
40. <artifactId>com.ibm.mq.headers</artifactId>
41. <version>${mq.version}</version>
42. </dependency>
43. <dependency>
44. <groupId>com.ibm.mq</groupId>
45. <artifactId>com.ibm.mq.pcf</artifactId>
46. <version>${mq.version}</version>
47. </dependency>
48. <dependency>
49. <groupId>javax.jms</groupId>
50. <artifactId>jms-api</artifactId>
51. <version>1.1-rev-1</version>
52. </dependency>
53. <dependency>
54. <groupId>org.springframework</groupId>
55. <artifactId>spring-jms</artifactId>
56. <version>${spring-framework.version}</version>
57. </dependency>

step：2 connectionFactory , DefaultMessageListenerContainer 连接与监听

Java代码  

1. @Configuration
2. // MQ连接信息的配置文件
3. @PropertySource("file:${ic.assistant.config.path}/ic-assistant.properties")
4. public class MqConfig{
5. @Autowired
6. private Environment env;
7. /**
8. * 连接MQ
9. */
10. @Bean
11. public ConnectionFactory connectionFactory() throws JMSException{
12. MQConnectionFactory cf = new MQConnectionFactory();
13. cf.setHostName(env.getRequiredProperty("ic.mq.host"));
14. cf.setPort(Integer.parseInt(env.getRequiredProperty("ic.mq.port")));
15. cf.setQueueManager(env.getRequiredProperty("ic.mq.queue.manager"));
16. cf.setChannel(env.getRequiredProperty("ic.mq.channel"));
17. cf.setTransportType(1);
18. return cf;
19. }
20. /**
21. * 获得MQ方法监听器
22. */
23. @Bean
24. public MessageListener eventListener(){
25. return new SynListener();
26. }
27. /**
28. *  配置连接，以及监听的序列，以及需要监听的方法
29. */
30. @Bean
31. public DefaultMessageListenerContainer messageListenerContainer() throws JMSException{
32. DefaultMessageListenerContainer mc = new DefaultMessageListenerContainer();
33. mc.setConnectionFactory(connectionFactory());
34. mc.setDestinationName("queue:///"+env.getRequiredProperty("ic.mq.queue"));
35. mc.setMessageListener(eventListener());
36. mc.setConcurrentConsumers(1);
37. mc.setMaxConcurrentConsumers(2);
38. return mc;
39. }

step：3 实现MessageListener接口，重写onMessage方法

Java代码  

1. public class SynListener implements MessageListener {
2. public void onMessage(Message message) {
3. if (message instanceof TextMessage) {
4. String msgContext;
5. try {
6. msgContext = ((TextMessage) message).getText();
7. if(msgContext.indexOf(FinalManager.SBC) >= 0){
8. synMsgService.saveSubc(msgContext);
9. } else if (msgContext.indexOf(FinalManager.SBD) >= 0) {
10. synMsgService.saveSubd(msgContext);
11. }
12. } catch (JMSException e) {
13. }
14. }
15. }
16. }

step：4 启动服务自动监听MQ

》》源码地址获取

springmvc + mybatis整合详细，及遇到的问题请参看以下资料：

参考资料：

http://www.springmvc,net/detail/6074493.html

http://my.spring.net/wangbiglei/blog/489583

http://my.springmvc.net/wangbiglei/blog/489604