CometD 中的实现

Question

我是 CometD 的新手，在响应/请求模型的情况下，是否有任何简单的示例来实现服务通道模型。我看过 cometd.org，但没有这样的例子说明如果我发布到任何频道，如何发回响应。

这是客户端

alert("channel published1");
    dojox.cometd.publish('/service/getlist');   
    alert("channel published");
    dojox.cometd.subscribe('/service/getlist', function(message) {
        alert(message);
    });

这是服务器端“ConfigurationServlet”

bayeux.createIfAbsent("/service/getlist", new ConfigurableServerChannel.Initializer() {

        //new EchoService(bayeux);
        @Override
        public void configureChannel(ConfigurableServerChannel channel) {
            /*channel.setPersistent(true);
            GetListChannelListener channelListner = new GetOrderListChannelListener();
            channel.addListener(channelListner);*/
            new EchoService(bayeux);
        }
    });

回声服务

public class EchoService extends AbstractService{
public EchoService(BayeuxServer bayeuxServer)                                 
{
    super(bayeuxServer, "getlist");                                              
    addService("/service/getlist", "processEcho");                                       
}

public void processEcho(ServerSession remote,Map<String, Object> data)
{       
    try{
    System.out.println("Start Process Echo");
    getBayeux().getChannel("/service/getlist").publish(getServerSession(), "Hello", null);
    System.out.println("End Process Echo");
    }catch(Exception exp){
        exp.printStackTrace();
    }
    //remote.deliver(getServerSession(), "/service/getlist", data, null);                  
}

}

Answer 1

http://cometd.org 有你需要的一切。

为了构建一个非常简单的示例（带有 Javascript 客户端的 Web 应用程序），您需要特别阅读：

• This 客户端
• This 用于服务器端（配置）
• This 用于服务器端（代码）。在此菜单中，您可能希望首先使用第一个和第三个要点：Inherited Services 用于响应输入消息的代码，以及 Server Services Integration 用于通过配置 servlet 设置 Bayeux 服务器。

在我链接的页面中有所有必要的代码，只需复制并粘贴即可。以防万一，回来提出更具体的问题。

---

已编辑

查看您的代码后，我发现对于服务配置，您需要从 here 复制 ConfigurationServlet 类的代码，对于 EchoService 类，您需要修改 processEcho 方法，如下所示：

remote.deliver(getServerSession(), "/echo", data, null);

data 是一个定义为 here 解释的 HashMap（第一个示例）。

在客户端，我会在发布您的请求之前订阅频道（我不确定它是否也适用于您的方式）