JMS集群的意义在于提升系统在处理消息时的并发能力，建立这样的集群，有三个步骤：

　　1.配置JMS消息持久化所使用的数据库

　　2.配置分布式的jndi环境

　　3.配置分布式JMS集群

　　在JBoss集群中，系统采用Hibernate的方式来保存消息，所以能够兼容hibernate支持的所有数据库。JBoss默认采用 hsql，在我们的例子中，将使用Oracle 9.2。首先需要配置连接到数据库的jndi数据源。方法是把docexamplesjca下的 oracle-ds.XML文件拷贝到serverallfarm下，并且修改其中的参数，保证数据库能够正确连接。JBoss集群启动后，该文件能够通过JBoss的farm服务，自动拷贝到其他集群节点，并且自动部署。假设jndi数据源的名称为：GlobalDS将 docexamplesJMS下的oracle-JDBC3-service.xml文件拷贝到serveralldeploy- hasingletonJMS目录下，并且删除该目录下的hsqldb-jdbc2-service.xml。修改oracle-jdbc3- service.xml，在56行左右指定name的值为数据源的名字：GlobalDS。这样系统会使用该数据源来保存JMS消息。使用如下命令启动 boss:　　　 run ?c all.启动完成后，正常情况下会发现oracle数据库中多出了三张表：

　　1、JMS_message_log　　　　　　　 该表用于保存所有未处理的点对点消息，表结构是：

　　Messageid　　　　　　　　 消息id

　　Destination　　　　　　　 目的地

　　Txid　　　　　　　　　　　 事务id

　　Txop　　　　　　　　　　　 消息操作类型(a为新增，d为删除)

　　Messageblob　　　　　　　 消息内容

　　2、JMS_REFERENCE_LOG　　　 用于保存所有未处理的topic消息，表结构是：

　　Messageid

　　Destination

　　Txid

　　Txop

　　Messageblob

　　Redelivered　　　　　　　 消息是否被重发

　　3、JMS_TRANSACTION_LOG　　　 用于保存处理消息过程中的一些重要的事务

　　需要注意的是，JBoss3.2之后就不在支持以文件形式保存消息，虽然这样最会比数据库操作快一倍以上。JBoss官方的解释是，使用文件会让系统不可靠。客户端在发送JMS消息的时候，首先需要向app server查询jndi，在JBoss集群中，jndi是作为一个分布式的 singleton出现的。每个节点除了有自己的jndi环境以外，整个JBoss集群还具有一些全局的jndi，客户端在进行jndi查询的时候，只需要向这个全局的jndi进行查询，JBoss集群如果在全局jndi中找不到对应的jndi对象，就会按次序向每个节点询问，看他们的本地jndi中是否有匹配的对象，如果有则返回给客户，如果所有的节点都没有，则抛出异常。所有以all方式启动的JBoss，都会打开1100端口，这个端口是全局 jndi的入口，所有节点都是如此。

　　分布式的jndi有的节点有主次的区别，第一个启动的JBoss是主服务器，它会保存所有的全局 jndi，其他的节点如果收到客户查询jndi的请求后，都会向主服务器请求数据。如果主服务器不幸down掉，那么次节点会发现这个变化，然后启动自己的jndi环境，取代主服务器提供服务。

　　下面是配置JMS集群的jndi，打开serveralldeploy-hasingletonJMS下的JBossmq-destinations-service.xml文件，增加一个名为test的destination，如下：

<mbean　code="org.jboss.mq.server.jmx.Queue"　
　　　　　name="jboss.mq.destination:service=Queue,name=test">　
　　　　<depends　optional-attribute-name="DestinationManager">jboss.mq:service=DestinationManagerdepends>　
　　mbean>　

　　为了预防主服务器down了之后丢失该jndi，所以最好在每个节点都进行这个配置。

　　在JBoss的默认配置下，是不支持消息bean的集群的，要达到这个目的，必须下载一个jar包才能实现。得到这个jar文件后，将它命名为cdot-JBossx.jar，文件放到serveralldeployjms下。下面编写消息bean，它的功能很简单，接收到来自test队列的消息后，打印消息id.

public　class　TestJmsBean 　
　　　　implements　MessageDrivenBean,　MessageListener　{ 　
　　MessageDrivenContext　messageDrivenContext; 　
　　public　void　EJBCreate()　{ 　
　　　　System.out.println("消息bean创建"); 　
　　} 　

　　public　void　ejbRemove()　{ 　
　　} 　

　　public　void　onMessage(Message　msg)　{ 　
　　　　try 　
　　　　{ 　
　　　　　　System.out.println(msg.getJMSMessageID()); 　
　　　　}catch(Exception　e) 　
　　　　{ 　
　　　　　　e.printStackTrace(); 　
　　　　} 　
　　} 　

　　public　void　setMessageDrivenContext(MessageDrivenContext
　messageDrivenContext)　{ 　
　　　　this.messageDrivenContext　=　messageDrivenContext; 　
　　} 　
}　

(责任编辑：admin)