Vertx事件总线访问_denied

Vertx event bus access_denied

本文关键字：denied 访问 总线 事件 Vertx      更新时间：2023-09-26

我有一个java vertx服务器和一个JavaScript客户端。我想在下面创建一个事件总线两次，但vertx响应：连接时收到错误：access_denied

Javascript代码：

var eventBus = new vertx.EventBus("http://localhost:8989/eventbus");
eventBus.onopen = function () {
console.log("Event bus connected !");
console.log(eventBus);
eventBus.registerHandler("http://localhost:8989/eventbus/news-feed", function (message) {
    console.log("registred" + message.body());
});

Java代码：

SockJSHandler bridge = SockJSHandler.create(vertx).bridge(new BridgeOptions());
router.route("/eventbus/*").handler(bridge);
router.route().handler(StaticHandler.create());// otherwise serve static pages
HttpServer httpServer = vertx.createHttpServer();
httpServer.requestHandler(router::accept);
httpServer.listen(Servers.SERVER_PORT);
vertx.setPeriodic(1000, event -> {
vertx.eventBus().publish("news-feed", "{'"c'":'"df'"}");

你有主意吗？

问候

您需要在BridgeOptions:中设置权限

BridgeOptions options = new BridgeOptions()
.addInboundPermitted(new PermittedOptions().setAddress("news-feed"))
.addOutboundPermitted(new PermittedOptions().setAddress("news-feed"));

此外，您的Javascript代码无法注册整个地址：

eventBus.registerHandler("news-feed", ...

.addOutboundPermitted(new PermittedOptions().setAddress("news-feed"));

是必需的，并且

 eb.registerHandler('news-feed', function(error, message) {
      console.log('received a message: ' + JSON.stringify(message));});

回调函数有两个参数是必需的

相关文章：