JGroups是Bela Ban的用于可靠消息交換的軟件，該軟件高度可配置，可以使用TCP或UDP作為傳輸協議。 基本上，您在多個客戶端上運行JGroup，它們構成一個集群，它們可以在集群內發送和接收消息。

JGroups由JBoss Infinispan內部使用。 但是，與JGroups不同，Infinispan添加了分布式緩存語義（復制/分布式模式，條目無效，事務行為，Map訪問API等）。它甚至允許您將集群用作計算網格。

依次使用Infinispan提供JBoss AS 7集群功能。 因此，這意味著底層JGroups子系統可以并且使用標準JBoss AS 7 Standalone * .xml文件進行配置。 您可以從Java EE組件（例如EJB）訪問Infinispan緩存，而不會出現此處所述的任何問題。

但是，在某些情況下，您只想使用基礎JGroups消息傳遞而不是Infinispan為您提供的所有緩存語義。 這是事情變得越來越復雜的地方。 您始終可以直接使用JGroups，并將其配置存儲為應用程序本地資源。 是否違反或違反Java EE規范可能會引起爭議，Java EE規范規定應用程序不應管理低級連接，生成線程，打開套接字等。應用服務器-它還使我們可以使用一個配置文件，而不是將其分布在多個位置。 因此，問題是– 如何從我們的EJB應用程序訪問JGroups子系統？ 整個解決方案涉及幾個步驟，下面將對其進行描述。 如果要檢查整個工作項目， 請查看我的JGroups AS7 Github項目 。

1.編寫自定義JBoss AS 7服務激活器

該激活器（ JGroupsChannelServiceActivator.java ）將做兩件事：

• 使用JBoss協議配置創建實際的JGroups通道，
• 將新創建的JGroups通道綁定到JNDI。

第一部分在JGroupsChannelServiceActivator#createChannel(-) 。 我不知道ServiceActivator或JBoss AS 7模塊的其他內部組件，但從中您可以看到：

InjectedValue<ChannelFactory> channelFactory = new InjectedValue<>(); ServiceName serviceName = ChannelFactoryService.getServiceName(STACK_NAME); ChannelService channelService = new ChannelService(CHANNEL_NAME, channelFactory);target.addService(channelServiceName, channelService).addDependency(serviceName, ChannelFactory.class, channelFactory).install();

似乎它會創建一個新服務（ ChannelService ），并讓JBoss MSC在安裝過程中自動注入其依賴的ChannelFactory 。 ChannelFactory將使用UDP協議棧。 第二部分在JGroupsChannelServiceActivator#bindChannelToJNDI(-)完成， JGroupsChannelServiceActivator#bindChannelToJNDI(-)新創建的Channel實例綁定到用戶定義位置下的JNDI。 在我們的例子中是java:jboss/channel/myChannel 。

2.注冊激活器

現在，我們需要告訴JBoss AS 7調用我們的自定義激活器。 使用標準化的JDK ServiceLoader API完成 。 簡而言之，這意味著我們需要提供一個帶有我們激活器類完全限定名稱的META-INF/services/org.jboss.msc.service.ServiceActivator文件。 看一下這個例子 。

3.將必需的模塊添加到我們的應用程序

好的，所以我們有一個應該做魔術的活化劑。 如果我們嘗試這樣部署它，我們將獲得一堆ClassNotFoundException 。 這是因為JBoss模塊。 我們的應用程序未包含所有這些JBoss工件，例如JGroups，ServiceActivator API和與JNDI相關的類。 我們不想用這些庫弄亂我們的應用程序–我們只想定義JBoss AS 7本身提供的模塊依賴性。 我們在META-INF/jboss-deployment-structure.xml 。 請注意，我們可以在MANIFEST.MF Dependencies：部分中執行此操作，但是Intellij IDEA似乎無法與Maven生成的MANIFEST.MF一起使用 ：

<?xml version='1.0' encoding='UTF-8'?> <jboss-deployment-structure><deployment><dependencies><module name='org.jgroups'/><module name='org.jboss.as.naming'/><module name='org.jboss.as.clustering.jgroups'/></dependencies></deployment> </jboss-deployment-structure>

訪問JChannel，ChannelService等需要JGroups模塊。JNDI綁定代碼需要命名模塊。

4.使用JGroups Channel開發EJB

JGroupsSampleDataProducer是一個Singleton EJB，它顯示了如何訪問JGroups通道。 由于具有JNDI綁定，因此相當簡單。 我們可以使用：

@Resource(lookup = 'java:jboss/channel/myChannel') private JChannel channel;

在那里。 該EJB注冊一個計時器，該計時器每2秒被調用一次，并發送一些隨機的String消息。

注意，我們不必顯式啟動JChannel 。 我們只是注入并直接使用它。 看一下步驟1中在我們的激活器中使用的ChannelService 。它的啟動方法如下：

@Override protected void start() throws Exception {(...)if (this.channel.getProtocolStack().findProtocol(STATE_TRANSFER.class, STATE.class, STATE_SOCK.class) != null) {this.channel.connect(this.id, null, STATE_TRANSFER_TIMEOUT);} else {this.channel.connect(this.id);}

因此， 該服務將自動連接到我們的頻道 。 除了使用ChannelService我們還可以開發自己的服務，該服務將負責啟動和停止我們的頻道，或者甚至可以將此責任移交給頻道的實際用戶。

5.部署EJB-JAR

現在，我們準備將應用程序部署到JBoss AS 7服務器。 這里最重要的部分是確保我們的服務器將以適當的配置運行，這意味著已定義了JGroups協議棧。 使用<subsystem xmlns='urn:jboss:domain:jgroups:1.1'> 。 我正在使用JBoss AS 7.1.1和standalone-full-ha.xml配置。

**注意：**因為Intellij IDEA不允許您像Eclipse一樣輕松地更改JBoss AS的配置文件，所以我們需要使用VM選項來指定它： -Djboss.server.default.config=standalone-full-ha.xml 。

我們還需要確保JGroups將使用IPv4 （有時會選擇IPv6，這可能會導致某些奇怪而又難以解決的問題。）為此，請在服務器配置中添加-Djava.net.preferIPv4Stack=true選項。

6.運行客戶端應用程序

您可以在此處找到一個相當簡單的客戶端代碼。 它只是使用指定的配置文件連接到JGroups集群。 請注意，對于服務器和客戶端，應將多播端口號和地址設置為相同的值。 另外，請記住在運行客戶端時添加-Djava.net.preferIPv4Stack=true VM選項。 希望本教程對您有所幫助，并且可以節省一些配置時間。 十分感謝貝拉班了很多重要的建議和保羅·費拉羅指著我初步認識論壇主題（像這樣或這樣就類似的問題之一）。

參考：在Piotr Nowicki主頁博客上，我們的JCG合作伙伴 Piotr Nowicki 直接從JBoss AS 7組件直接使用JGroups 。

翻譯自: https://www.javacodegeeks.com/2013/03/using-jgroups-directly-from-jboss-as-7-component.html

總結

以上是生活随笔為你收集整理的直接从JBoss AS 7组件使用JGroups的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。