cometd bayeux 客户端无法获得订阅确认？

Question

实际上，我正在使用文档 https://docs.cometd.org/current/reference/ 中显示的 maven jetty run 在我的本地运行 cometd-demo 服务器，并尝试在 broadcast channel 中订阅和发布某些内容。使用如下所示的 Groovy 脚本，

ClientSessionChannel.MessageListener mylistener = new Mylistener();  

def myurl = "http://localhost:8080/cometd/"

MyHttpClient httpClient = new MyHttpClient();

httpClient.start()

Map<String, Object> options = new HashMap<String, Object>();

ClientTransport transport = new LongPollingTransport(options, httpClient);

BayeuxClient client = new BayeuxClient(myurl, transport)

println 'client started on URL : '+ client.getURL()


client.handshake ( new ClientSessionChannel.MessageListener() {

    public void onMessage(ClientSessionChannel channel, Message message) {
        if (message.isSuccessful()) {   
            println 'Handshake Message : ' + message 
        }
    }
})

boolean handshakecheck = client.waitFor(1000, BayeuxClient.State.CONNECTED);

println 'Handshake check : '+ handshakecheck

    client.batch( new Runnable() {

        public void run() {

            client.getChannel("/foo/hello").subscribe(

                    new ClientSessionChannel.MessageListener() {

                        public void onMessage(ClientSessionChannel channel,
                                              Message message) {
                                println "subscribed : "+ message
                        }
                    })
        }

    });

程序输出：

client started on URL : http://localhost:8080/cometd/
Handshake Message : [minimumVersion:1.0, clientId:fv0ozxw8cb5e11vtlwpacm7afp, supportedConnectionTypes:[websocket, long-polling, callback-polling], advice:[reconnect:retry, interval:0, maxInterval:10000, timeout:20000], channel:/meta/handshake, id:1, version:1.0, successful:true]
Handshake check : true

在这里我无法获得代码中的subscribed 消息。但在服务器日志中打印如下图，

2018-02-12 20:30:32,687 qtp2069584894-17 [ INFO][examples.CometDDemoServlet] Monitored Subscribe from fv0ozxw8cb5e11vtlwpacm7afp,last=0,expire=0 for /foo/hello

更新 1： 我也无法使用callback 方法订阅，我收到的消息为[channel:/meta/subscribe, id:4, subscription:/foo/hello, error:403:denied_by_not_granting:create_denied, successful:false]。我不知道我做错了什么？我只是按照文档步骤操作。提前致谢。

Answer 1

只要在频道/foo/hello 上发布消息，就会调用您传递给subscribe(...) 方法的ClientSessionChannel.MessageListener。

您的程序永远不会在该通道上发布消息，因此永远不会调用侦听器，因此永远不会在您的代码中打印 subscribed。

您需要仔细检查您要使用的 subscribe() 方法的版本，因为有 2 个版本。

single parameter version 带有一个监听器，而two parameter version 带有一个监听器和一个回调。

从您的代码中猜测，您希望 subscribed 日志行位于 callback 中而不是侦听器中，因此您只需更改代码以使用 @987654331 的两个参数版本@方法。

另外，请注意，如果 JVM 在您的 groovy 脚本结束时退出，那么该客户端将消失并且永远不会收到任何消息。