有关 Vert.x 事件总线的问题

Question

我是Vert.x.中活动巴士的新手https://vertx.io/docs/vertx-core/java/，描述如下：

尽最大努力交付

Vert.x尽最大努力传递消息，并且不会有意识地丢弃它们。这称为尽力而为的交付。

如果您的应用程序关心丢失的消息，您应该将您的处理程序编码为等幂，并将您的发送程序编码为在恢复后重试。

我的系统不希望丢失任何消息，所以我必须了解事件总线并决定是否使用Vert. x。以下是我的问题：

>

丢失事件总线消息的典型情况是什么？

假设一个场景，生产者很快，消费者很慢。制片人能察觉到它并放慢发送速度吗？如何处理这种情况？

假设另一个场景，消费者注册了事件总线，然后由于某种原因消费者不工作，这时，生产者发送返回异常吗？还是生产者不知道消费者身份继续发？这种情况怎么处理？

事件循环线程是否负责为事件总线传递消息？

事件总线有缓冲消息的队列吗？如果有，默认情况下大小有多大？

Answer 1

默认情况下，事件总线缓冲区为每个消费者保存1000个事件，并且可以更改限制。

这意味着，“慢”的消费者可以再等待1000条消息，然后才会丢弃新的传入消息。我认为这很好，因此EB可以被认为是非常安全和无损的。

当消息即将开始丢失时，您应该扩大您的缓慢消费者垂直度。

通常情况下，消息在vert之外丢失的概率。x事件总线远大于集群节点之间的事件总线。与您的“专用”网络的本地连接相比，任何外部互联网连接都不太稳定。

如果使用者由于某种原因无法访问，vert.x 可以通知有关消息传递的信息：

vertx.eventBus().request( 'some.addr', 'some payload' ){ AsyncResult ar ->
  if( ar.succeded() )
    println 'ok'
  else 
    println "Error : ${ar.cause()}"
} 

如果由于消费者不在场而导致交付失败，您将获得适当的例外