#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;    

}