JBoss集群中建立JMS集群服務
JMS集群的意義在于提升系統(tǒng)在處理消息時的并發(fā)能力，建立這樣的集群，有三個步驟：
1.配置JMS消息持久化所使用的數(shù)據(jù)庫
2.配置分布式的jndi環(huán)境
3.配置分布式JMS集群
在JBoss集群中，系統(tǒng)采用hibernate的方式來保存消息，所以能夠兼容hibernate支持的所有數(shù)據(jù)庫。JBoss默認采用 hsql，在我們的例子中，將使用oracle 9.2。首先需要配置連接到數(shù)據(jù)庫的jndi數(shù)據(jù)源。方法是把doc\examples\jca下的 oracle-ds.xml文件拷貝到server\all\farm下，并且修改其中的參數(shù)，保證數(shù)據(jù)庫能夠正確連接。JBoss集群啟動后，該文件能夠通過JBoss的farm服務，自動拷貝到其他集群節(jié)點，并且自動部署。假設jndi數(shù)據(jù)源的名稱為：GlobalDS將 doc\examples\JMS下的oracle-jdbc3-service.xml文件拷貝到server\all\deploy- hasingleton\JMS目錄下，并且刪除該目錄下的hsqldb-jdbc2-service.xml。修改oracle-jdbc3- service.xml，在56行左右指定name的值為數(shù)據(jù)源的名字：GlobalDS。這樣系統(tǒng)會使用該數(shù)據(jù)源來保存JMS消息。使用如下命令啟動 boss: run ?c all.啟動完成后，正常情況下會發(fā)現(xiàn)oracle數(shù)據(jù)庫中多出了三張表：
1、JMS_message_log 該表用于保存所有未處理的點對點消息，表結構是：
Messageid 消息id
Destination 目的地
Txid 事務id
Txop 消息操作類型(a為新增，d為刪除)
Messageblob 消息內(nèi)容
2、JMS_REFERENCE_LOG 用于保存所有未處理的topic消息，表結構是：
Messageid
Destination
Txid
Txop
Messageblob
Redelivered 消息是否被重發(fā)
3、JMS_TRANSACTION_LOG 用于保存處理消息過程中的一些重要的事務
需要注意的是，JBoss3.2之后就不在支持以文件形式保存消息，雖然這樣最會比數(shù)據(jù)庫操作快一倍以上。JBoss官方的解釋是，使用文件會讓系統(tǒng)不可靠。客戶端在發(fā)送JMS消息的時候，首先需要向app server查詢jndi，在JBoss集群中，jndi是作為一個分布式的 singleton出現(xiàn)的。每個節(jié)點除了有自己的jndi環(huán)境以外，整個JBoss集群還具有一些全局的jndi，客戶端在進行jndi查詢的時候，只需要向這個全局的jndi進行查詢，JBoss集群如果在全局jndi中找不到對應的jndi對象，就會按次序向每個節(jié)點詢問，看他們的本地jndi中是否有匹配的對象，如果有則返回給客戶，如果所有的節(jié)點都沒有，則拋出異常。所有以all方式啟動的JBoss，都會打開1100端口，這個端口是全局 jndi的入口，所有節(jié)點都是如此。
分布式的jndi有的節(jié)點有主次的區(qū)別，第一個啟動的JBoss是主服務器，它會保存所有的全局 jndi，其他的節(jié)點如果收到客戶查詢jndi的請求后，都會向主服務器請求數(shù)據(jù)。如果主服務器不幸down掉，那么次節(jié)點會發(fā)現(xiàn)這個變化，然后啟動自己的jndi環(huán)境，取代主服務器提供服務。
下面是配置JMS集群的jndi，打開server\all\deploy-hasingleton\JMS下的JBossmq-destinations-service.xml文件，增加一個名為test的destination，如下：
|
為了預防主服務器down了之后丟失該jndi，所以最好在每個節(jié)點都進行這個配置。
在JBoss的默認配置下，是不支持消息bean的集群的，要達到這個目的，必須下載一個jar包才能實現(xiàn)。得到這個jar文件后，將它命名為cdot-JBossx.jar，文件放到server\all\deploy\jms下。下面編寫消息bean，它的功能很簡單，接收到來自test隊列的消息后，打印消息id.
|
【編輯推薦】
