многопоточные сервисы gSOAP - PullRequest
Новая
       14

многопоточные сервисы gSOAP

2 голосов
/ 07 апреля 2011

Есть ли способ для компилятора заглушки / скелета генерировать многопоточные сервисы (т. Е. Порождать поток для каждого запроса или пул потоков), или мне нужно вручную добавлять soap_copy (), pthread_create () ...

Я знаю, что - согласно FAQ и руководству пользователя 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;
}

Любая подсказка?

1 Ответ

3 голосов
/ 25 апреля 2011

Возможно, это не прямое обращение с вашим конкретным запросом, но оно настолько близко, насколько я могу найти ... (вырезано из 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;
}

Примечание: код не ожидает потоков, присоединяющихся к основному потоку после завершения программы.

В той же области документа, на которую есть ссылка в приведенной выше ссылке, имеется дополнительная информация о потоках. Это может, по крайней мере, обеспечить отправную точку в вашем поиске решения.

С уважением, Райкер

...