java - 异步网络服务流

Question

我需要一些框架来帮助我通过 http 进行异步流式传输。它可能看起来像 SOAP WS 或其他东西。我不知道我是否正确命名它，所以这是我需要的:

ServerA 想通过 http 向远程 ServerB 发出请求。该请求包含任意信息。它的结果将包含多个相同类型的记录。其中一些是立即可用的，其他的则稍后可用。 ServerA 希望尽快获得可用结果，而不是等到所有结果都可用。在现实世界中，ServerB 将搜索不同的数据源，其中一些比其他的响应更快。

我可以想到 3 种解决方案。首先ServerA生成request的随机id，进行SOAP请求

void ServerB.startSearch(id, request); 

即会立即返回，然后A周期性调用

Result[] ServerB.areThereAnyNewResults(id);

因此 ServerA 轮询 ServerB 以获得新的结果。我称这种方法为轮询。它涉及从A到B建立的多个连接。另一种解决方案是在ServerA端暴露接收服务，如

ServerA.acceptResults(String id, Result[] newResults); 

然后打电话

ServerB.startSearch(id, request, serverAReceivingServiceEndpoindAddress);

因此，当新结果可用时，ServerB 将新结果推送到 ServerA.acceptResults()。我称之为插入。它涉及从A到B建立的1个连接和从B到A建立的多个连接。

另一种选择是在单个响应内通过同一 http channel 流式传输结果。

A 执行 http 调用(我不知道它是否可以是 SOAP 或其他东西)，B 开始搜索，当新结果可用时，它通过 http 流发送它们并刷新它，因此它们可能可用立即在A侧。在所有结果可用之前，它不会关闭 http 连接。它只涉及从 A 到 B 的单一连接，这就是我更愿意使用它的原因。我称之为流媒体。我知道如果某些代理正在缓冲响应内容，它可能无法工作。

所以，我的问题是是否有任何解决方案可以为我完成大部分工作。我想做的是在 A 端调用这样的代码

Service s = new RemoteAsyncService("http://serverb.com/serviceEndpoint", RemoteAsyncService.STREAMING); 
// or RemoteAsyncService.POLLING, or RemoteAsyncService.PUSHING
Request r = new Request(...);
Callback callback = new Callback(){
 void newResults(Result[] result){...}
 // e should be null if finished correctly
 void requestFinished(RemoteException e){...}
}
s.search(request, callback);

并在ServerB端实现

public ServiceImpl implements Service{
  void search(Request r, Callback c){
   // perform search, call c.newResult() when new results are available
  }
}

剩下的由框架来处理，包括连接断开时重新建立连接，如果因为缓冲代理而无法进行流式处理，则转为轮询/推送，当 ServerB 完成工作或抛出异常时调用 callback.requestFinished()，等等。可能它还应该以某种标准方式处理身份验证。

那么，是否有任何解决方案可以抽象化完成通信的方式，并且在可能的情况下能够进行流式传输？

如果没有，您认为将其实现为开源有用吗？ :)

Answer 1

您所说的听起来像是 COMET 服务。您可以在此处阅读维基百科条目:

Comet (programming)

不确定如何在 Java 中实现类似的东西，但在 .NET 中，您可以为 WCF 服务使用双工契约(Contract)。您可以在此处阅读有关如何访问该服务类型并与之通信的更多信息:

How to: Access Services with a Duplex Contract