6

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

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

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

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

4

4 回答 4

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在公寓之间传递接口指针：

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 中的编组接口指针（如果您的主线程是STA） - 因为我相信可能会执行网络请求，所以理想情况下，当您知道CoMarshalInterThreadInterfaceInStream客户端已连接时，您最好提前处理它，而不是冒着阻塞主线程的风险。

于 2011-01-25T15:15:04.810 回答
0

您可以实现自己的 ping 机制，以便您的客户端不时调用服务器的 ping 方法。您已经在服务器端为您的客户端维护了某种容器。在该地图中，用最后一次 ping 的时间戳标记每个客户端。然后在向该客户端发送事件之前检查客户端是否处于活动状态。您可以自定义何时停止发送事件的策略，可能基于时间或错过的 ping 次数或事件类型或其他一些因素。您可能不需要担心删除客户端 - 可以等到 DCOM 意识到特定客户端已死。此方案可能无法完全消除问题，因为客户端可能会在需要发送事件之前死亡，但您可以通过调整 ping 周期来完全控制可能存在的此类客户端的数量。

于 2011-05-29T20:28:49.767 回答
0

使用 DCOM 建立一个名为管道的通知。使用管道可以更好地处理断开连接。听众（几乎）立即响应消息。例如服务器-> 客户端（你的管道名称是什么？）。Client->Server 以包含机器的名称响应。客户端创建命名管道并监听。服务器立即或在需要时打开管道。

于 2011-02-27T21:45:09.880 回答
0

一种解决方案是消除事件——让客户端查询服务器是否有任何感兴趣的东西。

于 2011-01-25T14:48:10.427 回答