Java中Akka事件总线(EventBus)的示例
需要一些如何在Java中（而非Scala）使用Akka提供的EventBus的建议。网站上的文档似乎不完整：http://doc.akka.io/docs/akka/2.0.1/java/event-bus.html 据我所了解，应该创建actor来对特定的消息做出反应，例如： final...
可以将REST与消息传递结合在微服务中吗？
我们有一个基于微服务架构的应用程序第一个版本。我们使用REST进行内部和外部通信。 现在，我们想要从CP切换到AP（CAP定理），并使用消息总线来实现微服务之间的通信。有很多关于如何基于Kafka、RabbitMQ等创建事件总线的信息。但是我找不到关于REST和消息传递组合的最佳实践。例如，...
多个应用程序和容器共享的事件总线以及用于反应堆的容器
我想知道如何使用Spring Boot和Reactor，让多个应用程序（每个应用程序在自己的Spring Boot容器中运行）使用一个独立容器中运行的共享EventBus。 这是一个具有多个应用程序的微服务环境，每个应用程序都是专门的，并且应该按事件链调用。 这种情况是否可能？ 以下是代表此场...
Vertx IllegalArgumentException: 没有适用于该类型的消息编解码器 - 如何为自定义类型创建消费者
我有一个垂直线程，创建了一个事件总线消费者，如下所示： public void start() { vertx.eventBus().consumer(ADDRESS_REQUEST, this::handleRequestMessage); } ...
Greenbot Eventbus 3.0: onEvent、onEventMainThread、onEventBackgroundThread和onEventAsync之间有什么区别?
我对在Greenrobot's EventBus 3.0中使用onEvent、onEventMainThread、onEventBackgroundThread和onEventAsync有点困惑。 从我在文档中看到的： onEvent与ThreadMode.POSTING（默认）一起使用...
EventBus 3.0中的registerSticky已被弃用
无法使用registerSticky(this)替换register(this)方法 @Override public void onStart() { super.onStart(); EventBus.getDefault().register(this); } 我已...
使用Otto事件总线注入而不是使用静态单例的优势
在我的Android应用程序中，我使用Otto作为事件总线和Dagger用于依赖注入。 在Otto的用户指南和许多博客文章中，建议使用注入来获取一个总线单例。我已经这样做了一段时间，但最近我越来越怀疑注入总线是否比使用简单的静态单例有任何优势。 通过注入，我必须注入每个自定义视图或View...
在Android中使用greenrobot EventBus发布事件
通过使用EventBus，在Android中需要在一个Activity中发布事件（MyEvent），并在另一个Activity中接收该事件。 我尝试了greenrobot EventBus性能测试项目，但不知道如何操作。 我在ActivitySubscriber中尝试过。 MyEvent e...
Akka的事件总线是否保证消息顺序？
我想保持事件进入总线的顺序。 例如，如果事件1然后事件2被输入到总线中，则订阅的参与者将按照那个顺序得到它们。 问题是这样的顺序是否有保证，在集群和单节点参与者系统上都是如此。
如何在EventBus中使用“调用类型”
我正在使用EventBus来通知Activity/Fragment当我从服务器获取响应时。到目前为止，一切都很顺利，但是当我在同一个Fragment或Activity中消耗两个网络调用时，问题就出现了。问题是相同的方法onEvent(String response)会接收来自服务器的两个响应。...