Spring 配置整合 jms Tibco EMS

左手的ㄟ右手 2022-09-21 13:07 158阅读 0赞

原文地址：http://blog.csdn.net/shimly2010/article/details/9748223

参考文档：   
[http://haohaoxuexi.iteye.com/blog/1893038][http_haohaoxuexi.iteye.com_blog_1893038]  
[http://www.blogjava.net/chenhui7502/archive/2011/08/28/357457.html][http_www.blogjava.net_chenhui7502_archive_2011_08_28_357457.html]

网上大都是关于[spring][]和Apache整合的文章，很少有使用Tibco EMS的。都是遵循Spring JMS 标准，参考了这两篇文章后，做了一个demo跑Tibco EMS。可以运行。  
1. Import jar 包

2. 配置文件

**\[html\]** [view plain][] [copy][view plain]

1.  **<?****xml** version="1.0" encoding="UTF-8"**?>**  
2.  **<****beans** xmlns="http://www.springframework.org/schema/beans"  
3.      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"  
4.      xmlns:tx="http://www.springframework.org/schema/tx" xmlns:context="http://www.springframework.org/schema/context"  
5.      xmlns:mongo="http://www.springframework.org/schema/data/mongo"  
6.      xsi:schemaLocation="  
7.      http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd  
8.      http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.1.xsd  
9.      http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.1.xsd  
10.     http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd  
11.     http://www.springframework.org/schema/data/mongo http://www.springframework.org/schema/data/mongo/spring-mongo-1.0.xsd  
12.     "**>**  
13.     **<****bean** id="targetConnectionFactory" class="com.tibco.tibjms.TibjmsConnectionFactory"**>**    
14.         **<****property** name="serverUrl" value="tcp://localhost:1234"**/>**    
15.     **</****bean****>**     
16.     **<****bean** id="connectionFactory" class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter"**>**    
17.         **<****property** name="targetConnectionFactory" ref="targetConnectionFactory"**/>**    
18.         **<****property** name="username" value="username" **/>**  
19.         **<****property** name="password" value="password" **/>**  
20.     **</****bean****>**   
21.     **<****bean** id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"**>**    
22.         **<****property** name="connectionFactory" ref="connectionFactory"**/>**    
23.     **</****bean****>**    
24.       
25.     **<****bean** id="queueDestination" class="com.tibco.tibjms.TibjmsQueue"**>**    
26.         **<****constructor-arg****>**    
27.             **<****value****>**queue.name**</****value****>**    
28.         **</****constructor-arg****>**    
29.     **</****bean****>**   
30.        
31.     **<****bean** id="consumerMessageListener" class="euc.demo.emsqueue.ConsumerMessageListener"**/>**         
32.      
33.     **<****bean** id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer"**>**    
34.         **<****property** name="connectionFactory" ref="connectionFactory" **/>**    
35.         **<****property** name="destination" ref="queueDestination" **/>**    
36.         **<****property** name="messageListener" ref="consumerMessageListener" **/>**    
37.     **</****bean****>**    
38.   
39. **</****beans****>**

3. Send Message的类

**\[java\]** [view plain][] [copy][view plain]

1.  **package** euc.demo.emsqueue;  
2.    
3.  **import** javax.annotation.Resource;  
4.  **import** javax.jms.Destination;  
5.  **import** javax.jms.JMSException;  
6.  **import** javax.jms.Message;  
7.  **import** javax.jms.Session;  
8.  **import** javax.jms.StreamMessage;  
9.    
10. **import** org.springframework.jms.core.JmsTemplate;  
11. **import** org.springframework.jms.core.MessageCreator;  
12. **import** org.springframework.stereotype.Component;  
13.   
14.   
15. @Component  
16. **public** **class** SendEmsQueueMessage \{  
17.     **private** JmsTemplate jmsTemplate;     
18.       
19.      **public** **void** sendTextMessage(Destination destination, **final** String message) \{     
20.             System.out.println("The producer send a message：" + message);     
21.             jmsTemplate.send(destination, **new** MessageCreator() \{     
22.                 **public** Message createMessage(Session session) **throws** JMSException \{     
23.                     **return** session.createTextMessage(message);     
24.                 \}     
25.             \});     
26.         \}      
27.   
28.      **public** **void** sendStreamMessage(Destination destination, **final** **byte**\[\] content)\{  
29.             System.out.println("The producer send a message：" + **new** String(content));     
30.             jmsTemplate.send(destination, **new** MessageCreator() \{     
31.                 **public** Message createMessage(Session session) **throws** JMSException \{     
32.                     StreamMessage message = session.createStreamMessage();  
33.                     message.setIntProperty("length", content.length);  
34.                     message.writeBytes(content);  
35.                     **return** message;  
36.                 \}     
37.             \});    
38.      \}  
39.     
40.     **public** JmsTemplate getJmsTemplate() \{     
41.         **return** jmsTemplate;     
42.     \}      
43.     
44.     @Resource    
45.     **public** **void** setJmsTemplate(JmsTemplate jmsTemplate) \{     
46.         **this**.jmsTemplate = jmsTemplate;     
47.     \}     
48.   
49. \}

4. 接收message的类

**\[java\]** [view plain][] [copy][view plain]

1.  **package** euc.demo.emsqueue;  
2.    
3.  **import** javax.jms.JMSException;  
4.  **import** javax.jms.Message;  
5.  **import** javax.jms.MessageListener;  
6.  **import** javax.jms.StreamMessage;  
7.  **import** javax.jms.TextMessage;  
8.        
9.  **public** **class** ConsumerMessageListener **implements** MessageListener \{     
10.       
11.     **public** **void** onMessage(Message message) \{        
12.           
13.         **if** (message **instanceof** javax.jms.TextMessage) \{  
14.             TextMessage textMsg = (TextMessage) message;    
15.             **try** \{  
16.                 System.out.println("The receiver received a message:" + textMsg.getText());  
17.             \} **catch** (JMSException e) \{  
18.                 e.printStackTrace();  
19.             \}   
20.         \}  
21.         **else** **if**(message **instanceof** javax.jms.StreamMessage)\{  
22.             StreamMessage streamMsg = (StreamMessage)message;  
23.             **try** \{  
24.                 **int** length = message.getIntProperty("length");  
25.                 **byte**\[\] content = **new** **byte**\[length\];  
26.                 **if**(streamMsg.readBytes(content)>0)  
27.                 \{  
28.                     String str = **new** String(content);  
29.                     System.out.println("The message length is:" + length);  
30.                     System.out.println("The receiver received a message:" + str);  
31.                 \}  
32.             \} **catch** (JMSException e) \{  
33.                 e.printStackTrace();  
34.             \}  
35.         \}   
36.     \}     
37.       
38. \}

5. 测试

**\[java\]** [view plain][] [copy][view plain]

1.  **public** **static** **void** testEmsQueue() \{  
2.          ApplicationContext ac = **new** ClassPathXmlApplicationContext(  
3.                  "spring-config.xml");  
4.          SendEmsQueueMessage sendEmsQueueMessage = (SendEmsQueueMessage) ac.getBean("sendEmsQueueMessage");  
5.          Destination destination = (Destination) ac.getBean("queueDestination");  
6.            
7.          String str = "<?xmlversion=\\"1.0\\"encoding=\\"UTF-8>";  
8.  //      sendEmsQueueMessage.sendTextMessage(destination,"Text message");  
9.          sendEmsQueueMessage.sendStreamMessage(destination, str.getBytes());  
10.     \}  
11.   
12.     **public** **static** **void** main(String\[\] args) \{  
13.         testEmsQueue();

[http_haohaoxuexi.iteye.com_blog_1893038]: http://haohaoxuexi.iteye.com/blog/1893038
[http_www.blogjava.net_chenhui7502_archive_2011_08_28_357457.html]: http://www.blogjava.net/chenhui7502/archive/2011/08/28/357457.html
[spring]: http://lib.csdn.net/base/17
[view plain]: http://blog.csdn.net/shimly2010/article/details/9748223#