日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

JMS集群的意義在于提升系統(tǒng)在處理消息時(shí)的并發(fā)能力，建立這樣的集群，有三個(gè)步驟：
1.配置JMS消息持久化所使用的數(shù)據(jù)庫
2.配置分布式的jndi環(huán)境
3.配置分布式JMS集群

在JBoss集群中，系統(tǒng)采用hibernate的方式來保存消息，所以能夠兼容hibernate支持的所有數(shù)據(jù)庫。JBoss默認(rèn)采用 hsql，在我們的例子中，將使用oracle 9.2。首先需要配置連接到數(shù)據(jù)庫的jndi數(shù)據(jù)源。方法是把doc\examples\jca下的 oracle-ds.xml文件拷貝到server\all\farm下，并且修改其中的參數(shù)，保證數(shù)據(jù)庫能夠正確連接。JBoss集群?jiǎn)?dòng)后，該文件能夠通過JBoss的farm服務(wù)，自動(dòng)拷貝到其他集群節(jié)點(diǎn)，并且自動(dòng)部署。假設(shè)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)會(huì)使用該數(shù)據(jù)源來保存JMS消息。使用如下命令啟動(dòng) boss:    run ?c all.啟動(dòng)完成后，正常情況下會(huì)發(fā)現(xiàn)oracle數(shù)據(jù)庫中多出了三張表：
1、JMS_message_log        該表用于保存所有未處理的點(diǎn)對(duì)點(diǎn)消息，表結(jié)構(gòu)是：
        Messageid         消息id
        Destination        目的地
        Txid            事務(wù)id
        Txop            消息操作類型(a為新增，d為刪除)
        Messageblob        消息內(nèi)容
2、JMS_REFERENCE_LOG    用于保存所有未處理的topic消息，表結(jié)構(gòu)是：
        Messageid
        Destination
        Txid
        Txop
        Messageblob
        Redelivered        消息是否被重發(fā)
3、JMS_TRANSACTION_LOG    用于保存處理消息過程中的一些重要的事務(wù)

需要注意的是，JBoss3.2之后就不在支持以文件形式保存消息，雖然這樣最會(huì)比數(shù)據(jù)庫操作快一倍以上。JBoss官方的解釋是，使用文件會(huì)讓系統(tǒng)不可靠。客戶端在發(fā)送JMS消息的時(shí)候，首先需要向app server查詢jndi，在JBoss集群中，jndi是作為一個(gè)分布式的 singleton出現(xiàn)的。每個(gè)節(jié)點(diǎn)除了有自己的jndi環(huán)境以外，整個(gè)JBoss集群還具有一些全局的jndi，客戶端在進(jìn)行jndi查詢的時(shí)候，只需要向這個(gè)全局的jndi進(jìn)行查詢，JBoss集群如果在全局jndi中找不到對(duì)應(yīng)的jndi對(duì)象，就會(huì)按次序向每個(gè)節(jié)點(diǎn)詢問，看他們的本地jndi中是否有匹配的對(duì)象，如果有則返回給客戶，如果所有的節(jié)點(diǎn)都沒有，則拋出異常。所有以all方式啟動(dòng)的JBoss，都會(huì)打開1100端口，這個(gè)端口是全局 jndi的入口，所有節(jié)點(diǎn)都是如此。

分布式的jndi有的節(jié)點(diǎn)有主次的區(qū)別，第一個(gè)啟動(dòng)的JBoss是主服務(wù)器，它會(huì)保存所有的全局 jndi，其他的節(jié)點(diǎn)如果收到客戶查詢jndi的請(qǐng)求后，都會(huì)向主服務(wù)器請(qǐng)求數(shù)據(jù)。如果主服務(wù)器不幸down掉，那么次節(jié)點(diǎn)會(huì)發(fā)現(xiàn)這個(gè)變化，然后啟動(dòng)自己的jndi環(huán)境，取代主服務(wù)器提供服務(wù)。

下面是配置JMS集群的jndi，打開server\all\deploy-hasingleton\JMS下的JBossmq-destinations-service.xml文件，增加一個(gè)名為test的destination，如下：

1.  code="org.jboss.mq.server.jmx.Queue" 
2.      name="jboss.mq.destination:service=Queue,name=test"> 
3.      optional-attribute-name="DestinationManager">jboss.mq:service=DestinationManager depends> 
4.    mbean> 

為了預(yù)防主服務(wù)器down了之后丟失該jndi，所以最好在每個(gè)節(jié)點(diǎn)都進(jìn)行這個(gè)配置。

在JBoss的默認(rèn)配置下，是不支持消息bean的集群的，要達(dá)到這個(gè)目的，必須下載一個(gè)jar包才能實(shí)現(xiàn)。得到這個(gè)jar文件后，將它命名為cdot-JBossx.jar，文件放到server\all\deploy\jms下。下面編寫消息bean，它的功能很簡(jiǎn)單，接收到來自test隊(duì)列的消息后，打印消息id.

1. public class TestJmsBean  
2.     implements MessageDrivenBean, MessageListener {  
3.   MessageDrivenContext messageDrivenContext;  
4.   public void ejbCreate() {  
5.     System.out.println("消息bean創(chuàng)建");  
6.   }  
8.   public void ejbRemove() {  
9.   }  
11.   public void onMessage(Message msg) {  
12.     try  
13.     {  
14.       System.out.println(msg.getJMSMessageID());  
15.     }catch(Exception e)  
16.     {  
17.       e.printStackTrace();  
18.     }  
19.   }  
21.   public void setMessageDrivenContext(MessageDrivenContext
22.  messageDrivenContext) {  
23.     this.messageDrivenContext = messageDrivenContext;  
24.   }  
25. } 

【編輯推薦】

1. 在JBOSS下發(fā)布Web程序
2. 如何解決JBoss和log4j沖突
3. JBoss集群配置代碼實(shí)例
4. JBoss下載與JBoss安裝
5. 淺談如何讓Netbeans 6.5支持Jboss 5.0 GA