soapserver.c

linux, gsoap, thread pool, example. 使用gsoap和一个自己开发的线程池监听并处理soap请求的示例代码

#include "soapH.h" 
#include <pthread.h> 

#include <iostream>
#include <string>
#include "SoapDaemon.h"
using namespace std;

#define BACKLOG (100) // Max. request backlog 
#define MAX_THR (10) // Size of thread pool 
#define MAX_QUEUE (1000) // Max. size of request queue 
SOAP_SOCKET queue[MAX_QUEUE]; // The global request queue of sockets 
int head = 0, tail = 0; // Queue head and tail 
void *process_queue(void*); 
int enqueue(SOAP_SOCKET); 
SOAP_SOCKET dequeue(); 
pthread_mutex_t queue_cs; 
pthread_cond_t queue_cv; 
SoapDaemon soapd;

int main(int argc, char **argv) 
{ 
	struct soap soap; 
	soap_init(&soap); 
	struct soap *soap_thr[MAX_THR]; // each thread needs a runtime environment 
	pthread_t tid[MAX_THR]; 
	int port = 0;//atoi(argv[1]); // first command-line arg is port 
	if(argc<2)
	{
		port = 18000;//atoi(argv[1]); // first command-line arg is port 
	}
	else
	{
		port = atoi(argv[1]);
	}
	SOAP_SOCKET m, s; 
	int i; 
	m = soap_bind(&soap, NULL, port, BACKLOG); 
	if (!soap_valid_socket(m)) 
	exit(1); 
	fprintf(stderr, "Socket connection successful %d\n", m); 
	pthread_mutex_init(&queue_cs, NULL); 
	pthread_cond_init(&queue_cv, NULL); 
	for (i = 0; i < MAX_THR; i++) 
	{ 
		soap_thr[i] = soap_copy(&soap); 
		fprintf(stderr, "Starting thread %d\n", i); 
		pthread_create(&tid[i], NULL, (void*(*)(void*))process_queue, (void*)soap_thr[i]); 
	} 
	for (;;) 
	{ 
		s = soap_accept(&soap); 
		if (!soap_valid_socket(s)) 
		{ 
			if (soap.errnum) 
			{ 
				soap_print_fault(&soap, stderr); 
				continue; // retry 
			} 
			else
			{ 
				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); 
		fprintf(stderr, "accept socket %d connection from IP %d.%d.%d.%d\n", s, (soap.ip >> 24)&0xFF, (soap.ip >> 16)&0xFF, (soap.ip >> 8)&0xFF, soap.ip&0xFF); 
		while (enqueue(s) == SOAP_EOM) 
		sleep(1); 
	} 
	for (i = 0; i < MAX_THR; i++) 
	{ 
		while (enqueue(SOAP_INVALID_SOCKET) == SOAP_EOM) 
		sleep(1); 
	} 
	for (i = 0; i < MAX_THR; i++) 
	{ 
		fprintf(stderr, "Waiting for thread %d to terminate... ", i); 
		pthread_join(tid[i], NULL); 
		fprintf(stderr, "terminated\n"); 
		soap_done(soap_thr[i]); 
		free(soap_thr[i]); 
	} 
	pthread_mutex_destroy(&queue_cs); 
	pthread_cond_destroy(&queue_cv); 

	soap_done(&soap); 
	return 0; 
} 
void *process_queue(void *soap) 
{ 
	struct soap *tsoap = (struct soap*)soap; 
	for (;;) 
	{ 
		tsoap->socket = dequeue(); 
		fprintf(stderr, "Thread %d served socket %d. \n", head-tail,tsoap->socket); 
		if (!soap_valid_socket(tsoap->socket)) 
		break; 
		soap_serve(tsoap); 
		soap_destroy(tsoap); 
		soap_end(tsoap); 
	} 
	return NULL; 
} 
int enqueue(SOAP_SOCKET sock) 
{ 
	int status = SOAP_OK; 
	int next; 
	pthread_mutex_lock(&queue_cs); 
	next = tail + 1; 
	if (next >= MAX_QUEUE) 
	next = 0; 
	if (next == head) 
	status = SOAP_EOM;   //to end of maxinum of pool
	else
	{ 
		queue[tail] = sock; 
		tail = next; 
	} 
	pthread_cond_signal(&queue_cv); 
	pthread_mutex_unlock(&queue_cs); 
	return status; 
} 
SOAP_SOCKET dequeue() 
{ 
	SOAP_SOCKET sock; 
	pthread_mutex_lock(&queue_cs); 
	while (head == tail)       pthread_cond_wait(&queue_cv, &queue_cs); 
	sock = queue[head++]; 
	if (head >= MAX_QUEUE) 
	head = 0; 
	pthread_mutex_unlock(&queue_cs); 
	return sock; 
} 

SOAP_FMAC5 int SOAP_FMAC6 ns1__Request(struct soap* sins, ArrayOf_USCORExsd_USCOREstring *in0, struct ns1__RequestResponse &_param_1)
{
	try{
		//your bussiness logical codes.
	}
	catch(...)
	{
		cout<<"*******count problem**************"<<endl;
	}
	return 0;
}