#include "soapH.h"
#include "wsddapi.h"
#include <stdio.h>
#include <sys/types.h> /* See NOTES */
#include <sys/socket.h>
#include <unistd.h>
#include <errno.h>
extern int GetListenPort();
void* main_probe(void* arg)
{
int m, s;
struct ip_mreq mcast;
struct soap soap;
soap_init2(&soap, SOAP_IO_UDP | SOAP_IO_FLUSH, SOAP_IO_UDP|SOAP_IO_FLUSH);
soap_set_namespaces(&soap, namespaces);
soap_set_mode(&soap, SOAP_C_UTFSTRING);//客户端接收支持中文
soap.bind_flags = SO_REUSEADDR;
soap.connect_timeout = 10;
soap.recv_timeout = 5;
soap.send_timeout = 5;
soap_register_plugin(&soap, soap_wsa);
// 打开调试信息,需 1）、首先gsoap安装时，在./configure --prefix=/usr/local/gsoap --enable-debug
// 2）、在/usr/local/gsoap/include/sdtsoap2.h文件中开启#define DEBUG
//soap_set_recv_logfile(&soap, "./log/recv.xml");
//soap_set_sent_logfile(&soap, "./log/send.xml");
//soap_set_test_logfile(&soap, "./log/test.log");
if(!soap_valid_socket(soap_bind(&soap, NULL, 3702, 16)))
{
soap_print_fault(&soap, stderr);
exit(1);
}
mcast.imr_multiaddr.s_addr = inet_addr("239.255.255.250");
mcast.imr_interface.s_addr = inet_addr("0.0.0.0");
if(setsockopt(soap.master, IPPROTO_IP, IP_ADD_MEMBERSHIP, (char*)&mcast, sizeof(mcast)) < 0)
{
printf("setsockopt error!\n");
return 0;
}
//成功绑定之后，便开始监听
for (;;) {
//监听直到有连接请求
soap_wsdd_listen(&soap, 0);
soap_destroy(&soap);
soap_end(&soap);
fprintf(stderr, "Socket connection successful: slave socket = %d\n", s);
}
soap_done(&soap);
return (void*)0;
}
int http_get(struct soap *soap)
{
/*
The callback is required to produce a response to the request in textual form, such as a
Web page or a SOAP/XML response. This method does not work with CGI.
*/
{
soap->http_content = "text/xml"; //HTTP header with text /xml content
char szContent[100] = {0};
sprintf(szContent, "welcome to use webservice!");
sprintf(soap->tmpbuf, szContent);
soap_send_raw(soap, soap->tmpbuf, strlen(szContent));
}
soap_end_send(soap);
return SOAP_OK;
}
int main(int argc, char **argv)
{
int m, s;
struct soap thesoap;
pthread_t thrProbe;
pthread_create(&thrProbe,NULL,main_probe,NULL);
soap_init(&thesoap);
soap_set_namespaces(&thesoap, namespaces);
#ifdef DEBUG
printf("debug mode\n");
#else
printf("release mode\n");
#endif
thesoap.fget = http_get;
if (argc < 0) {
printf("usage: %s <server_port> \n", argv[0]);
exit(1);
} else {
// LOAD_CFGFILE(root);
int port = GetListenPort();//8085;//root["port"].asInt();
m = soap_bind(&thesoap, NULL, port, 100);
if (m < 0) {
soap_print_fault(&thesoap, stderr);
exit(-1);
}
fprintf(stderr, "Socket connection successful: master socket = %d\n", m);
for (;;) {
s = soap_accept(&thesoap);
if (s < 0) {
soap_print_fault(&thesoap, stderr);
exit(-1);
}
// fprintf(stderr, "Socket connection successful: slave socket = %d\n", s);
soap_serve(&thesoap);
soap_end(&thesoap);
// fprintf(stderr, " soap_end socket = %d\n", s);
}
}
return 0;
}