0

我正在使用 gsoap 在 C++ 中创建一个肥皂服务器。消息通过用 Java 编写的总线进行路由。服务器和总线都是多线程的。一切正常,一次通过系统发送一条消息。如果我启动 3 个客户端,每个客户端都尽可能快地发送消息,那么对于大约 3500 条消息来说一切都很好。然后我开始定期收到“一次只允许一个套接字连接”。gsoap 代码中的错误。典型的 4000 条消息中约有 3950 条通过 OK。在最后 500 次发送中发生所有 50 次失败。

  1. 为什么这些错误会在多次发送后出现,而不是在发送开始时出现?发送速率不会增加。

  2. 它在说什么?我找不到该错误的任何解释,我也不清楚它的含义。

  3. 有人成功地多线程了一个 gsoap 应用程序吗?

这是我的服务器代码。

long WINAPI threadGO(soap *x);

int main(int argc, char* argv[])
{
HANDLE thread1;
int m, s; /* master and slave sockets */
struct soap *soap = soap_new();
if (argc < 2)
soap_serve(soap); /* serve as CGI application */
else
{ 
  m = soap_bind(soap, NULL, atoi(argv[1]), 100); 
  if (m < 0)
  { 
      soap_print_fault(soap, stderr);
      exit(-1);
  }
  fprintf(stderr, "Socket connection successful: master socket = %d\n", m);
  for (;;)
  {
     s = soap_accept(soap);
     thread1 =    CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)threadGO,soap_copy(soap),0,NULL);
  }
}
soap_done(soap);
free(soap);
return 0;
}

long WINAPI threadGO(soap *x)
{
soap_serve(x);
soap_end(x);
return 0

;
}
4

1 回答 1

1

我相信您在 threadGO 中存在资源泄漏。

用 复制soap 结构后soap_copy(),我认为需要通过调用以下所有内容来释放它:

soap_destroy(x);
soap_end(x);
soap_free(x);

具体来说,丢失的调用soap_done()(调用 from soap_free())调用soap_closesock(),它关闭了套接字。

于 2008-09-20T04:40:47.977 回答