使用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
收到一个错误,但没有做任何处理。