当前位置: 首页 > 知识库问答 >
问题:

使用Vertx“IAsyncResult”和“EventBus消费者”的区别

罗源
2023-03-14

请有人向我解释一下这两种方法的区别:

vertx.evenbus().consumer("test", message -> {
  ..........
});
vertx.evenbus().send("test", res->{
...........
});

以及:

public void test(Handler<AsyncResult<JsonObject>> resultHandler){
..........
}

test(res->{
..........
})

共有1个答案

高明辉
2023-03-14

在垂直方向。x eventbus允许您快速构建分布式应用程序,而无需知道其他服务在哪里运行,还允许您通过添加更多侦听公共地址的垂直链接来扩展。

当你使用第一段代码时,你实际上是在问vert。x以在集群上的任何位置定位一个节点(可能与调用者相同),该节点可以处理特定类型的消息。

在第二个片段中,如果您喜欢本地操作,您将定义一个处理程序或回调,例如从文件中读取JSON对象后该做什么。

 类似资料:
  • Flink kafka消费者有两种类型的消费者,例如: 这两个消费者层次结构扩展了相同的类。我想知道维护编号类背后的设计决策是什么?我们什么时候应该使用其中一种? 我注意到带有数字后缀的类有更多的特性(例如ratelimiting)。 https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka

  • 我有代码: 处理消费者异常的最佳方法是什么?现在,如果异常引发,它将被吞没。。。

  • 假设我有一个名为“MyTopic”的主题,它有3个分区P0、P1和P2。这些分区中的每一个都有一个leader,并且本主题的数据(消息)分布在这些分区中。 1.Producer将始终根据代理上的负载以循环方式写到分区的领导者。对吗? 2.制作人如何认识隔断的首领?

  • 给定以下设置: Kafkav0.11.0.0 3个经纪人 2个主题,每个主题有2个分区,复制因子为3 2个消费者组,每个主题一个 3个包含使用者的服务器 服务器包含两个使用者,每个主题一个,这样: null null null 消费者-B1被分配到topic-1分区-1 消费者-C1被分配到topic-1分区-0 消费者-A1没有分配给分区 这似乎正如我们所料。由于分区计数为2,我们只有两个活动消

  • 是否有一种方法以编程方式访问和打印使用者滞后偏移,或者说使用者读取的最后一条记录的偏移与某个生产者写入该使用者分区的最后一条记录的偏移之间的位置差。 要知道我的最终目标是将这个值发送到prometheus进行监视,我应该在上面添加哪些语句来得到滞后偏移值?

  • 本文向大家介绍Kafka 新旧消费者的区别相关面试题,主要包含被问及Kafka 新旧消费者的区别时的应答技巧和注意事项,需要的朋友参考一下 旧的 Kafka 消费者 API 主要包括:SimpleConsumer(简单消费者) 和 ZookeeperConsumerConnectir(高级消费者)。SimpleConsumer 名字看起来是简单消费者,但是其实用起来很不简单,可以使用它从特定的分区