有没有办法让 stub /骨架编译器生成线程服务(即通过为每个请求生成一个线程或通过线程池),或者我是否必须手动添加soap_copy()、pthread_create() ...
我知道——根据常见问题解答和用户指南 7.2.4——gSOAP 是线程安全的并且支持多线程服务。然而,使用soapcpp2 -i标志我最终得到
int DummyService::run(int port)
{
if (soap_valid_socket(bind(NULL, port, 100)))
{
for (;;)
{
if (!soap_valid_socket(accept()))
return this->error;
(void)serve();
soap_destroy(this);
soap_end(this);
}
}
else
return this->error;
return SOAP_OK;
}
有什么提示吗?
最佳答案
这可能不是对您的具体请求的直接处理,但它是我能找到的最接近的...(从 http://www.cs.fsu.edu/~engelen/soapdoc2.html#sec:mt 剪辑)
以下示例说明了如何使用线程通过在单独的线程中处理新请求来提高服务质量:
#include "soapH.h"
#include < pthread.h >
#define BACKLOG (100) // Max. request backlog
int main(int argc, char **argv)
{
struct soap soap;
soap_init(&soap);
if (argc < 2) // no args: assume this is a CGI application
{
soap_serve(&soap); // serve request, one thread, CGI style
soap_destroy(&soap); // dealloc C++ data
soap_end(&soap); // dealloc data and clean up
}
else
{
soap.send_timeout = 60; // 60 seconds
soap.recv_timeout = 60; // 60 seconds
soap.accept_timeout = 3600; // server stops after 1 hour of inactivity
soap.max_keep_alive = 100; // max keep-alive sequence
void *process_request(void*);
struct soap *tsoap;
pthread_t tid;
int port = atoi(argv[1]); // first command-line arg is port
SOAP_SOCKET m, s;
m = soap_bind(&soap, NULL, port, BACKLOG);
if (!soap_valid_socket(m))
exit(1);
fprintf(stderr, "Socket connection successful %d\n", m);
for (;;)
{
s = soap_accept(&soap);
if (!soap_valid_socket(s))
{
if (soap.errnum)
{
soap_print_fault(&soap, stderr);
exit(1);
}
fprintf(stderr, "server timed out\n");
break;
}
fprintf(stderr, "Thread %d accepts socket %d connection from IP %d.%d.%d.%d\n", i, s, (soap.ip >> 24)&0xFF, (soap.ip >> 16)&0xFF, (soap.ip >> 8)&0xFF, soap.ip&0xFF);
tsoap = soap_copy(&soap); // make a safe copy
if (!tsoap)
break;
pthread_create(&tid, NULL, (void*(*)(void*))process_request, (void*)tsoap);
}
}
soap_done(&soap); // detach soap struct
return 0;
}
void *process_request(void *soap)
{
pthread_detach(pthread_self());
soap_serve((struct soap*)soap);
soap_destroy((struct soap*)soap); // dealloc C++ data
soap_end((struct soap*)soap); // dealloc data and clean up
soap_done((struct soap*)soap); // detach soap struct
free(soap);
return NULL;
}
注意:程序终止时代码不会等待线程加入主线程。
上面链接中引用的文档的同一区域中有其他线程信息。它至少可以为您寻找解决方案提供一个起点。
关于multithreading - 多线程 gSOAP 服务,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/5579693/