Java Vertx Eventbus桥，客户端具有角度

Question

我已经在我的客户端（Angular）实现了VERTX EventBus Bridge，并且可以进行一些扩展。我的意思是有时我会从我的Java Vertx应用程序中获取发送消息，但有时我会遇到以下错误。有人可以帮我调试还是告诉我为什么我会遇到这个错误。由于某种原因，我有一种感觉，客户没有注册。

> ERROR Error: INVALID_STATE_ERR
>     at EventBus.registerHandler (vertx-eventbus.js:279:13)
>     at SafeSubscriber._next (core.service.ts:83:16)
>     at SafeSubscriber.__tryOrUnsub (Subscriber.ts:265:10)
>     at SafeSubscriber.next (Subscriber.ts:207:14)
>     at Subscriber._next (Subscriber.ts:139:22)
>     at Subscriber.next (Subscriber.ts:99:12)
>     at FilterSubscriber._next (UnsubscriptionError.ts:101:24)
>     at FilterSubscriber.next (Subscriber.ts:99:12)
>     at BehaviorSubject._subscribe (BehaviorSubject.ts:27:18)
>     at BehaviorSubject._trySubscribe (Observable.ts:238:19)

错误中的代码指向我的Angular Code IE EventBus.RegisterHandler中的第83行。

hostJobProgressSession(){
    console.log('Inside hostJobProgressSession!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!')
    console.log(this.eventBusService.getEventBus());
    this.eventBusService.getEventBus().subscribe(eventBus => {
      eventBus.registerHandler('update.job.onclient', (error, message) => {
        console.log('Inside registerHandler() -- received a message from server !! : ' + JSON.stringify(message.body));
        this.progressValue.next(message.body);

        if(error)
        {
          console.log('ERROR'+error)
            
      });
    })
  }

感谢您的帮助！

Answer 1

不知道它是否有所不同，但是理想情况下，您应该在eb.onopen上注册处理程序，如下所示：

import EventBus from 'vertx3-eventbus-client';

const eb = new EventBus("http://localhost:8080/eventbus");

eb.onopen = () => {
  eb.registerHandler('update.job.onclient', function(error, message) {
    console.log('received a message: ' + JSON.stringify(message));
  });
}
eb.onclose = (param) => {
  console.log('closed', param)
}

export default eb;

在服务器端，您需要bridgeoptions。 sockjshandler（以及可能的CORS处理程序）

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

BridgeOptions opts = new BridgeOptions().addOutboundPermitted(
      new PermittedOptions().setAddress("update.job.onclient"));

SockJSHandler ebHandler = SockJSHandler.create(vertx).bridge(opts);
router.route("/eventbus/*").handler(ebHandler);
...
vertx.createHttpServer().requestHandler(router::accept).listen(8080);