c++ - DCOM:如何在客户端崩溃时关闭服务器中的连接？

Question

我有一个比较老的项目:DCOM客户端和服务器，都是C++\ATL，只有Windows平台。一切正常:本地和远程客户端连接到服务器并同时工作，没有任何问题。

但是当远程客户端崩溃或被任务管理器或“taskkill”命令或电源关闭时被杀死 - 我遇到了问题。我的服务器对客户端崩溃一无所知，并尝试向所有客户端(也已经崩溃)发送新事件。结果我有暂停(服务器无法向已经崩溃的客户端发送数据)并且它的持续时间与崩溃的远程客户端的数量成正比。 5 次崩溃的客户端暂停时间太长以至于服务器完全停止。

我知道 DCOM“ping”机制(DCOM 应该断开在 6 分钟静默后不响应“每 2 分钟 ping”的客户端)。实际上，在挂起 6 分钟后，我有一小段时间可以正常工作，但随后服务器又回到“暂停”状态。

我能用这些做什么？如何使 DCOM“ping”工作正常？如果我将实现自己的“ping”代码，是否可以手动断开旧的 DCOM 客户端连接？怎么做？

Answer 1

我不确定 DCOM ping 系统，但您的一个选择是简单地将通知转移到一个单独的线程池。这将有助于减轻阻塞客户端数量较少的影响 - 当然，当客户端数量过多时，您就会开始遇到问题。

做到这一点的简单方法是使用 QueueUserWorkItem - 这将在应用程序的系统线程池上调用传递的回调。假设您使用的是 MTA，这就是您需要做的所有事情:

static InfoStruct {
    IRemoteHost *pRemote;
    BSTR someData;
};

static DWORD WINAPI InvokeClientAsync(LPVOID lpInfo) {
  CoInitializeEx(COINIT_MULTITHREADED);

  InfoStruct *is = (InfoStruct *)lpInfo;
  is->pRemote->notify(someData);
  is->pRemote->Release();
  SysFreeString(is->someData);
  delete is;

  CoUninitialize();
  return 0;
}

void InvokeClient(IRemoteHost *pRemote, BSTR someData) {

  InfoStruct *is = new InfoStruct;
  is->pRemote = pRemote;
  pRemote->AddRef();

  is->someData = SysAllocString(someData);
  QueueUserWorkItem(InvokeClientAsync, (LPVOID)is, WT_EXECUTELONGFUNCTION);
}

如果您的主线程在 STA 中，这只会稍微复杂一些；你只需要使用 CoMarshalInterThreadInterfaceInStream和 CoGetInterfaceAndReleaseStream在公寓之间传递接口(interface)指针:

static InfoStruct {
    IStream *pMarshalledRemote;
    BSTR someData;
};

static DWORD WINAPI InvokeClientAsync(LPVOID lpInfo) {
  CoInitializeEx(COINIT_MULTITHREADED); // can be STA as well

  InfoStruct *is = (InfoStruct *)lpInfo;
  IRemoteHost *pRemote;
  CoGetInterfaceAndReleaseStream(is->pMarshalledRemote, __uuidof(IRemoteHost), (LPVOID *)&pRemote);

  pRemote->notify(someData);
  pRemote->Release();
  SysFreeString(is->someData);
  delete is;

  CoUninitialize();

  return 0;
}

void InvokeClient(IRemoteHost *pRemote, BSTR someData) {
  InfoStruct *is = new InfoStruct;
  CoMarshalInterThreadInterfaceInStream(__uuidof(IRemoteHost), pRemote, &is->pMarshalledRemote);

  is->someData = SysAllocString(someData);
  QueueUserWorkItem(InvokeClientAsync, (LPVOID)is, WT_EXECUTELONGFUNCTION);
}

请注意，为清楚起见，错误检查已被省略 - 您当然希望对所有调用进行错误检查 - 特别是，您希望检查 RPC_S_SERVER_UNAVAILABLE 和其他此类网络错误，并删除冒犯客户。

您可能需要考虑的一些更复杂的变体包括确保每个客户端一次只有一个请求正在运行(从而进一步减少卡住客户端的影响)以及在 MTA 中缓存编码接口(interface)指针(如果您的主线程是一个 STA)- 因为我相信 CoMarshalInterThreadInterfaceInStream 可能会执行网络请求，所以您最好在知道客户端已连接时提前处理它，而不是冒阻塞主线程的风险。