假设您的 ReadProcessor 需要使用 JDBC 插入记录,或者您需要通过 JAXWS 调用与 SOAP 层集成。
使用 Lagom 异步(设计使然)平台处理同步呼叫的最佳方法是什么?
与提供处理阻塞调用的专用可能性的 vert.x 相比,Lagom 似乎没有提供这样的集成功能。
根据他们的文档(例如 JDBC),必须创建自己的处理机制,这些机制在内部创建要运行的线程。
因此,答案是"自己动手":创建执行器、可运行对象/可调用对象,并使用 Futures 围绕您的阻塞调用创建自己的非阻塞包装器。