Java 9/RxJava 2 中的 REST 可观察服务和远程订户客户端示例



这是背景: 我们有一个集群(3个(不同的服务部署在各种容器(如Tomcat,TomEE,JBoss(等。 每个服务都做一件事。就像一个服务管理一个公共数据库,并提供 REST 服务来 CRUD 数据库一样。一个服务将一些数据放入 JMS 队列,另一个服务从队列中读取并更新数据库。 有一个客户端应用程序对其中一个服务进行 REST 服务调用,从而在数据库中创建行,将该行推送到队列等。

:我们需要实现客户端应用,以便我们知道在任何给定时间点进行处理。如何在 RcJava 2/Java 9 中实现这一点?

首先,您需要确定 RxJava 2 中的哪些功能对您有益。

  • 异步源之间的协调。由于您有 a( 来自一端的事件驱动请求,以及 b( 另一端的网络查询,因此到目前为止这很合适。
  • 管理数据流,从一个或多个源转换和组合。您没有说明这是必需的。

其次,您需要确定 RxJava 2 不提供的内容:

  • 网络连接。这是由您现有的库提供的。
  • 数据库管理。同样,这在现有解决方案中提供。

现在,您必须决定,考虑到学习新图书馆的前期成本,这些基础加起来是否可以从中受益。

最新更新