vertx.io (3.0.0) websocket not working



使用Vertx。我正在尝试使web服务器通过websocket与客户端通信。

下面是如何在Xtend (Java)中创建Vertx websocket

val sockJSHandler = SockJSHandler.create(vertx);
val options = new BridgeOptions() => [
    inboundPermitted = #[new PermittedOptions() => [
        addressRegex = '/*'
    ]]
    outboundPermitted = #[new PermittedOptions() => [
        addressRegex = '/*'
    ]]
]
sockJSHandler.bridge(options, [ be |
    println(be.type)
    if (be.type == "SEND") {
        println(be.rawMessage.getString("address"));
        bus.send(be.rawMessage.getString("address"), be.rawMessage.getJsonObject("body"), [handler | 
            println(handler.result.body);
            if(handler.succeeded){
                handler.result.reply(handler.result.body);
                be.complete(true);
            } else {
                be.complete(false)
            }
            return
        ]);
    } else {
        be.complete(true);
        return 
    }

我的问题是,websocket从来没有收到来自服务器的响应。当我查看开发人员工具中的网络选项卡时,请求仍然悬而未决。代码通过true到达if(handler.succeeded)

我错过了什么?

在当前的情况下,正则表达式是不好的,它应该是.*而不是/*

val options = new BridgeOptions() => [
   inboundPermitted = #[new PermittedOptions() => [
        addressRegex = '.*'
    ]]
    outboundPermitted = #[new PermittedOptions() => [
        addressRegex = '.*'
    ]]
]

这就解决了问题。

注意vertxbus-2.1.js收到一个错误,但没有做任何处理。

相关内容

  • 没有找到相关文章

最新更新