这是背景: 我们有一个集群(3个(不同的服务部署在各种容器(如Tomcat,TomEE,JBoss(等。 每个服务都做一件事。就像一个服务管理一个公共数据库,并提供 REST 服务来 CRUD 数据库一样。一个服务将一些数据放入 JMS 队列,另一个服务从队列中读取并更新数据库。 有一个客户端应用程序对其中一个服务进行 REST 服务调用,从而在数据库中创建行,将该行推送到队列等。
问:我们需要实现客户端应用,以便我们知道在任何给定时间点进行处理。如何在 RcJava 2/Java 9 中实现这一点?
首先,您需要确定 RxJava 2 中的哪些功能对您有益。
- 异步源之间的协调。由于您有 a( 来自一端的事件驱动请求,以及 b( 另一端的网络查询,因此到目前为止这很合适。
- 管理数据流,从一个或多个源转换和组合。您没有说明这是必需的。
其次,您需要确定 RxJava 2 不提供的内容:
- 网络连接。这是由您现有的库提供的。
- 数据库管理。同样,这在现有解决方案中提供。
现在,您必须决定,考虑到学习新图书馆的前期成本,这些基础加起来是否可以从中受益。