Vertx事件总线无法将消息发送到不同的verticle

Question

我对Vertx很陌生，但我对测试它与Spring的集成很感兴趣。我使用Spring Boot来提升项目，并部署了两个顶点。我希望他们使用事件总线相互通信，但失败了。这就是我所做的：

>

在主应用程序中：

@SpringBootApplication公共类MySpringVertxApplication{@Autowired MyRestAPIServer MyRestAPIServer；@Autowired MyRestAPIVerticle MyRestAPIVerticle；

public static void main(String[] args) {
SpringApplication.run(MySpringVertxApplication.class, args);
}

@PostConstruct
public void deployVerticles(){
System.out.println("deploying...");

Vertx.vertx().deployVerticle(MyRestAPIVerticle);
Vertx.vertx().deployVerticle(myRestAPIServer);
}

}

在apirticle中：

@Component公共类MyRestAPIVerette扩展抽象版本{

public static final String ALL_ACCOUNT_LISTING = "com.example.ALL_ACCOUNT_LISTING";

@Autowired
AccountService accountService;

EventBus eventBus;

@Override
public void start() throws Exception {
super.start();

eventBus = vertx.eventBus();
MessageConsumer<String> consumer = eventBus.consumer(MyRestAPIVerticle.ALL_ACCOUNT_LISTING);
consumer.handler(message -> {
    System.out.println("I have received a message: " + message.body());
    message.reply("Pretty Good");
  });
consumer.completionHandler(res -> {
    if (res.succeeded()) {
      System.out.println("The handler registration has reached all nodes");
    } else {
      System.out.println("Registration failed!");
    }
  });
}

}

最后服务器版本：

@服务公共类MyRestAPIServer扩展了AbstractVerticle{

HttpServer server;
HttpServerResponse response;

EventBus eventBus;
@Override
public void start() throws Exception {

server = vertx.createHttpServer();
Router router = Router.router(vertx);

eventBus = vertx.eventBus();

router.route("/page1").handler(rc -> {
    response = rc.response();
    response.setChunked(true);

    eventBus.send(MyRestAPIVerticle.ALL_ACCOUNT_LISTING, 
        "Yay! Someone kicked a ball",
        ar->{
        if(ar.succeeded()){
            System.out.println("Response is :"+ar.result().body());
        }
        }
        );

});

server.requestHandler(router::accept).listen(9999);

}

但在我启动它并访问/page1之后，消息根本无法从ServerVerticle发送到apverticle。若我将事件总线使用者移动到和发送方相同的垂直位置，那个么就可以接收事件。

在两条垂直线之间发送信息有什么问题吗？我怎样才能让它工作？

提前谢谢。

Answer 1

Vertx事件总线不会像您正在尝试的那样在不同的Vertx实例之间共享（但是集群Vert.x应用程序可以做到这一点）。在您的情况下，将其更改为使用单个顶点。在您的MySpringVertxApplication中，有下面这样的x个实例。

Vertx vertx = Vertx.vertx();
vertx.deployVerticle(MyRestAPIVerticle.class.getName());
vertx.deployVerticle(MyRestAPIServer.class.getName());

Answer 2

您在单独的vertx实例中部署了它们：

Vertx.vertx().deployVerticle(MyRestAPIVerticle);
Vertx.vertx().deployVerticle(myRestAPIServer);

试试这个：

Vertx vertx = Vertx.vertx();
vertx.deployVerticle(MyRestAPIVerticle);
vertx.deployVerticle(myRestAPIServer);