CometDクライアントJava APIの使い方は？

Question

私のプロジェクトでは、pubsubとcometDサブスクライバを使用する必要があります。 私は2つのapplciationsのOracle Weblogicアプリケーションサーバーを使用します。 1人はpubsubsチャンネルにいくつかのメッセージを公開し、もう1人はチャンネルを購読してメッセージを表示します。 私のpubsubサーバもweblogicアプリケーションサーバ上にあり、xmlファイル（weblogic.xmlとweblogic-pubsub.xml）で構成されています。ここ は私のpubsubサーバが（のweblogic-pubsub.xml）設定されている方法です。

<wlps:channel> 
    <wlps:channel-pattern>/gip/**</wlps:channel-pattern> 
</wlps:channel> 

<wlps:channel-constraint> 
    <wlps:channel-resource-collection> 
     <wlps:channel-resource-name>all-permissions</wlps:channel-resource-name> 
     <wlps:description>Grant all permissions for everything by everyone</wlps:description> 
     <wlps:channel-pattern>/gip/*</wlps:channel-pattern> 
    </wlps:channel-resource-collection> 
</wlps:channel-constraint> 

そして、私の第二のアプリケーションがcometDのsubscirber JavaScriptのAPIとDojoツールキットでチャンネルにsusbscribeことができますので、それがうまく動作します。 これで、このJavascript APIのおかげで、サブスクリプションは私のWebアプリケーションのクライアント側で実行されます。ここで

は、サブスクリプションは、Dojoツールキットを使用してクライアント側（JavascriptのAPIを）どのように行われるかである。

//Initialize Dojo (CometD) for pubsub events 
dojo.require("dojo.io.script"); 
dojo.require("dojox.cometd"); 
dojo.require("dojox.cometd.callbackPollTransport"); 

dojo.addOnLoad(function() 
{ 
    console.log("on load dojo"); 
    dojox.cometd.init("/WebInterface/cometd", { 
    }); 
    dojox.cometd.subscribe("/gip/**", onEvent); 

    initMap(); 
}); 

このクライアント側実装がうまく機能したメッセージが到達したとき、のonEvent（）関数はよく発射されますpubsubチャネル。

今、サブスクリプションとメッセージ処理が行われましたサーバー側です。このため、私はCometDにpubsubチャンネルを購読してメッセージを処理できるクライアントJava APIも持っていることを理解しました。 しかし、私はそれをすることに成功していません。ここで

私はCometD 3ドキュメント（https://docs.cometd.org/current/reference/#_java_client）次のサーバー側のために行うことを試みたものを以下のようになります。

import com.vaadin.ui.CustomComponent; 
import java.util.HashMap; 
import java.util.Map; 
import org.cometd.bayeux.Channel; 
import org.cometd.bayeux.Message; 
import org.cometd.bayeux.client.ClientSession; 
import org.cometd.bayeux.client.ClientSessionChannel; 
import org.cometd.client.BayeuxClient; 
import org.cometd.client.transport.ClientTransport; 
import org.cometd.client.transport.LongPollingTransport; 
import org.eclipse.jetty.client.HttpClient; 

public class WireServerCometD extends CustomComponent { 

    private static final String CHANNEL = "/gip"; 
    private final ClientSessionChannel.MessageListener gipListener = new GIPListener(); 

    public WireServerCometD() { 
     System.out.println("Wire CometD constructor"); 
     setSizeFull(); 
     setWidth(50, Unit.PERCENTAGE); 
     setHeight(300, Unit.PIXELS); 
     addStyleName("customBackground"); 

     try { 
      // Create (and eventually set up) Jetty's HttpClient: 
      HttpClient httpClient = new HttpClient(); 
      // Here set up Jetty's HttpClient, for example: 

      // Prepare the transport 
      Map<String, Object> options = new HashMap<String, Object>(); 
      ClientTransport transport = new LongPollingTransport(options, httpClient); 

      // Create the BayeuxClient 
      ClientSession client = new BayeuxClient("http://localhost:8080/WebInterface/cometd", transport); 

      client.getChannel(CHANNEL).addListener(new ClientSessionChannel.MessageListener() { 
       public void onMessage(ClientSessionChannel channel, Message message) { 
        if (message.isSuccessful()) { 
         // Here handshake is successful 
         System.out.println("Handshake is successfull"); 
        } 
       } 
      }); 
      client.handshake(); 

     } catch (Exception ex) { 
      ex.printStackTrace(); 
     } 
    } 

    private static class GIPListener implements ClientSessionChannel.MessageListener { 

     public void onMessage(ClientSessionChannel channel, Message message) { 
      System.out.println("message received"); 
     } 
    } 

} 

これは、Vaadinフレームワークのコンポーネントである、チャネルサブスクリプションおよびメッセージリスナを試しに実行されますブロック。 コード行に次のエラーがあります。HttpClient httpClient = new HttpClient（）; ： SEVERE： java.lang.IncompatibleClassChangeError：ORG /日食/桟橋/クライアント/ HttpClientを

とのonMessage機能が解雇されることはありません...

あなたは私にいくつかの助けをもたらすことができますしてください？

は、すべての

Answer 1

まず、ありがとう、私は、WebLogicはCometDの非常に古いバージョン、またはCometD projectから公式のものと一致しません非常にカスタマイズしたものを出荷するかもしれないと思います。

dojox.cometd.callbackPollTransportは、CometDプロジェクトに存在していたものではなく、CometDが0.xだったとき、あるいは公式にリリースされなかったもの、またはWebLogicによって作成されたものだったかもしれません。

公式のCometD 3.xクライアントがWebLogicによって出荷される「CometD」を使用する可能性は非常に低いです。私はそれらが互換性があるとは思わない。

さらに、私はVaadinがあなたが上で書いたコンポーネントをJavaScriptで翻訳できるとは思わない。 CometDのバインドはJavaScriptで書かれていましたが、公式にCometDプロジェクトには入っていませんでした（牽引力がない、https://github.com/cometd/cometd/issues/63参照）ので、現在の状態はわかりません。

IncompatibleClassChangeErrorは、おそらく、JDK 7より古いJDKを使用しているためで、CometD 3.xはJDK 7以降でのみ動作します。

システム全体を再考する必要があります。

私は、サーバー（ないのWebLogicで出荷1）の公式CometDに固執することをお勧めし、あなたが本当に人々が過去にこれらのバインディングを書いたかを見てVaadin/GWTを使用する必要がある場合は、おそらくそれらのライブラリを使用できない場合は複製してください。

Vaadin/GWTバインディングとサーバー内の公式のCometDとJDK 7+がいったん完成したら、それはいいはずです。