?http://xiangtui.iteye.com/blog/978674

?

什么是JMS？

JMS即java消息服務(wù)，JMS通過消息的形式來降低組件之間的耦合度。

JMS由兩部分組成消息發(fā)送者 和消息監(jiān)聽者 。

?

JMS的運(yùn)用場景？

?? 用戶系統(tǒng)負(fù)責(zé)維護(hù)用戶信息，文檔系統(tǒng)負(fù)責(zé)維護(hù)文檔信息，但是當(dāng)用戶刪除的時候，需要將他所撰寫的文檔信息也刪除的時候，在用戶管理模塊調(diào)用文檔管理模塊的接口，會造成用戶模塊和業(yè)務(wù)模塊緊耦合。

???這個時候可以使用JMS技術(shù)來將緊耦合轉(zhuǎn)化為松耦合，具體做法是用戶系統(tǒng)在刪除，修改用戶的時候往JMS服務(wù)器發(fā)送更新消息，又業(yè)務(wù)系統(tǒng)監(jiān)聽這些消息，然后按照自己的業(yè)務(wù)邏輯來進(jìn)行相應(yīng)的處理。

?? 即組件A做了一件事情往消息服務(wù)器上發(fā)送了一個通知，組件B監(jiān)聽到了消息，處理自己的業(yè)務(wù)邏輯。

?

詳細(xì)步驟：

1：配置消息服務(wù)器：配置JMS需要兩個對象connectionFactory和?destination。

connectionFactory使用jboss自帶的TopicConnectionFactory。

destination可以使用自定義的。

kiral-jms-service.xml?? 注意：文件名稱一定要是-service.xml結(jié)尾。這個文件放在部署目錄下。

?

xml 代碼

?

<!---->< xml ? version = "1.0" ? encoding = "UTF-8" ?> ??

< server > ??

?? < mbean ? code = "org.jboss.mq.server.jmx.Topic" ??

????? name = "jboss.mq.destination:service=Topic,name=kiralJms" > ??

???? < depends ? optional-attribute-name = "DestinationManager" > jboss.mq:service = DestinationManager depends > ??

???? < depends ? optional-attribute-name = "SecurityManager" > jboss.mq:service = SecurityManager depends > ??

???? < attribute ? name = "SecurityConf" > ??

?????? < security > ??

???????? < role ? name = "guest" ? read = "true" ? write = "true" /> ??

???????? < role ? name = "publisher" ? read = "true" ? write = "true" ? create = "false" /> ??

???????? < role ? name = "durpublisher" ? read = "true" ? write = "true" ? create = "true" /> ??

?????? security > ??

???? attribute > ??

?? mbean > ??

? server > ???

2：配置發(fā)送消息端

bean-jms.xml

xml 代碼

<!---->xml ? version = "1.0" ? encoding = "GB2312" ?> ?

< beans > ??

???? < bean ? id = "jmsConnectionFactory" ??

???????? class = "org.springframework.jndi.JndiObjectFactoryBean" > ??

???????? < property ? name = "jndiName" > ??

???????????? < value > TopicConnectionFactory value > ??

???????? property > ??

???? bean > ??

???? ??

???? < bean ? id = "destination" ??

???????? class = "org.springframework.jndi.JndiObjectFactoryBean" > ??

???????? < property ? name = "jndiName" > ??

???????????? < value > topic/kiralJms value > ??

???????? property > ??

???? bean > ??

??

???? <!----> ??

???? < bean ? id = "jmsTemplate" ??

???????? class = "org.springframework.jms.core.JmsTemplate" > ??

???????? < property ? name = "connectionFactory" > ??

???????????? < bean ??

???????????????? class = "org.springframework.jms.connection.SingleConnectionFactory" > ??

???????????????? < property ? name = "targetConnectionFactory" ??

???????????????????? ref = "jmsConnectionFactory" ? /> ??

???????????? bean > ??

???????? property > ??

???? bean > ??

??

???? <!----> ?<!---->?

???? < bean ? id = "messageProducer" ??

???????? class = "jms.MessageProducer" > ??

???????? < property ? name = "template" ? ref = "jmsTemplate" ? /> ??

???????? < property ? name = "destination" ? ref = "destination" ? /> ??

???? bean > ??

beans > ??

?

java 代碼

import ?javax.jms.Destination; ??

import ?javax.jms.JMSException; ??

import ?javax.jms.Message; ??

import ?javax.jms.Session; ??

??

import ?org.springframework.jms.core.JmsTemplate; ??

import ?org.springframework.jms.core.MessageCreator; ??

??

/*********************************************************** ?

?*?消息發(fā)送者 ?

?*? ?

?*?@作者：kiral ?

?*?@日期：2007-7-3 ?

?**********************************************************/ ??

public ? class ?MessageProducer?{ ??

??

???? public ? void ?send( final ?String?message)?{ ??

????????template.send(destination,? new ?MessageCreator()?{ ??

???????????? public ?Message?createMessage(Session?session)? throws ?JMSException?{ ??

????????????????Message?m?=?session.createTextMessage(message); ??

???????????????? return ?m; ??

????????????} ??

????????}); ??

????} ??

??

???? private ?JmsTemplate?template; ??

??

???? private ?Destination?destination; ??

??

???? public ? void ?setDestination(Destination?destination)?{ ??

???????? this .destination?=?destination; ??

????} ??

??

???? public ? void ?setTemplate(JmsTemplate?template)?{ ??

???????? this .template?=?template; ??

????} ??

??

}??

發(fā)送方調(diào)用send方法發(fā)送消息。

?

3：配置消息接收者

xml 代碼

<!----> < xml ? version = "1.0" ? encoding = "UTF-8" ?> ??

<!----> ??

< beans > ??

???? < bean ? id = "jmsConnectionFactory" ??

???????? class = "org.springframework.jndi.JndiObjectFactoryBean" > ??

???????? < property ? name = "jndiName" > ??

???????????? < value > TopicConnectionFactory value > ??

???????? property > ??

????< bean > ??

???? < bean ? id = "destination" ??

???????? class = "org.springframework.jndi.JndiObjectFactoryBean" > ??

???????? < property ? name = "jndiName" > ??

???????????? < value > topic/kiralJms value > ??

???????? property > ??

????< bean > ??

??

???? <!----> ??

???? < bean ? id = "messageListener" ??

???????? class = "jms.MessageConsumer" > ??

???????? < property ? name = "worksheetService" ? ref = "worksheetService" > property > ??

????< bean > ??

??

???? <!----> ??

???? < bean ? id = "listenerContainer" ??

???????? class = "org.springframework.jms.listener.DefaultMessageListenerContainer" > ??

???????? < property ? name = "connectionFactory" ? ref = "jmsConnectionFactory" ? /> ??

???????? < property ? name = "destination" ? ref = "destination" ? /> ??

???????? < property ? name = "messageListener" ? ref = "messageListener" ? /> ??

????< bean > ??

< beans > ??

?

java 代碼

import ?javax.jms.Message; ??

import ?javax.jms.MessageListener; ??

??

import org.kiral.flow.service.WorksheetService; ??

??

/******************************************************************************* ?

?*?消息接收者 ?

?*? ?

?*?@作者：kiral ?

?*?@日期：2007-7-3 ?

?******************************************************************************/ ??

public ? class ?MessageConsumer? implements ?MessageListener?{ ??

??

???? private ?WorksheetService?worksheetService; ??

??

???? public ?WorksheetService?getWorksheetService()?{ ??

???????? return ?worksheetService; ??

????} ??

??

???? public ? void ?setWorksheetService(WorksheetService?worksheetService)?{ ??

???????? this .worksheetService?=?worksheetService; ??

????} ??

??

???? public ? void ?onMessage(Message?message)?{ ??

????????System.out.println(message); ??

????????worksheetService.updateRole(); ??

????} ??

??

}??

接受方一旦接收到消息，就會打印在控制臺。

總結(jié)

以上是生活随笔為你收集整理的在Spring中使用JMS的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。