使用gSOAP开发实例(2) 股票信息服务端程序

landuochong 发表于 2011-12-21 08:44

转载：http://blog.csdn.net/yui/archive/2010/07/19/5747433.aspx 电信provisioning系统中，常常需要与远程服务器实时交换一些数据，以完成用户的请求。由于简单对象访问协议（Simple Object Access Protocol, SOAP）的流行，许多涉及到第三方的应用，我们一般都比较乐意使用SOAP来开发。不过，由于可能涉及到公司的机密，本系列教程的开发实例尽量采用在网上已经公开的Web Service资源。
 
上文已经交待了gSOAP在Linux环境下的编译方法和客户端的实例程序，本文继续讲解其服务端程序的开发。由于不可能获得真正的数据库内容，我们设定的目标是，所有返回的内容都是客户端传入的股票代码。
 
首先，在gsoap-2.7/gsoap/wsdl/下创建一个stock_server目录
-bash-3.2$ mkdir -p stock_server
 
改变当前路径为stock_server
-bash-3.2$ cd stock_server
 
仍然使用wsdl2h生成基于纯C代码的stock.h
-bash-3.2$ ../wsdl2h -c -o stock.h http://webservice.webxml.com.cn/WebServices/ChinaStockWebService.asmx?wsdl
 
然后，生成服务端存根程序，并且不生成xml文件和soapServerLib.c
-bash-3.2$ ../../bin/linux386/soapcpp2 -S -L -x stock.h
 
**  The gSOAP code generator for C and C++, soapcpp2 release 2.7.17
**  Copyright (C) 2000-2010, Robert van Engelen, Genivia Inc.
**  All Rights Reserved. This product is provided "as is", without any warranty.
**  The soapcpp2 tool is released under one of the following three licenses:
**  GPL, the gSOAP public license, or the commercial license by Genivia Inc.
 
Saving soapStub.h annotated copy of the input declarations
Saving soapH.h interface declarations
Saving soapC.c XML serializers
Saving soapServer.c server request dispatcher
Using ns2 service name: ChinaStockWebServiceSoap
Using ns2 service style: document
Using ns2 service encoding: literal
Using ns2 service location: http://webservice.webxml.com.cn/WebServices/ChinaStockWebService.asmx
Using ns2 schema namespace: http://WebXml.com.cn/ChinaStockWebServiceSoap
Saving ChinaStockWebServiceSoap.nsmap namespace mapping table
Using ns3 service name: ChinaStockWebServiceSoap12
Using ns3 service style: document
Using ns3 service encoding: literal
Using ns3 service location: http://webservice.webxml.com.cn/WebServices/ChinaStockWebService.asmx
Using ns3 schema namespace: http://WebXml.com.cn/ChinaStockWebServiceSoap12
Saving ChinaStockWebServiceSoap12.nsmap namespace mapping table
 
Compilation successful
 
<span style="font-family: 宋体; font-size: 12pt; mso-ascii-font-family: 'Courier New'; mso-hansi-font-family: 'Times New Roman'; mso-bidi-font-family: 'Courier New'; mso-ansi-language: EN-US; mso-fareast-language: ZH-CN; mso-bidi-language: AR-SA;">服务端的主程序稍微比客户端复杂些，因为还要处理客户端的其他请求，至少要有其函数体，否则编译时会报错。

<span style="font-family: 宋体; font-size: 12pt; mso-ascii-font-family: 'Courier New'; mso-hansi-font-family: 'Times New Roman'; mso-bidi-font-family: 'Courier New'; mso-ansi-language: EN-US; mso-fareast-language: ZH-CN; mso-bidi-language: AR-SA;"><div class="dp-highlighter"><div class="bar"><div class="tools"><a href="http://blog.csdn.net/yui/archive/2010/07/19/5747433.aspx#">view plain</a><a href="http://blog.csdn.net/yui/archive/2010/07/19/5747433.aspx#">copy to clipboard</a><a href="http://blog.csdn.net/yui/archive/2010/07/19/5747433.aspx#">print</a><a href="http://blog.csdn.net/yui/archive/2010/07/19/5747433.aspx#">?</a></div></div><ol class="dp-cpp" start="1"><li class="alt">#include "soapH.h"  </li><li class="">#include "ChinaStockWebServiceSoap12.nsmap"  </li><li class="alt">  </li><li class="">int main(int argc, char **argv) {  </li><li class="alt">    if ( argc != 2 ) {  </li><li class="">        printf("Usage: %s port\n", argv);  </li><li class="alt">        exit(-1);  </li><li class="">    }  </li><li class="alt">    int port = atol(argv);  </li><li class="">  </li><li class="alt">    struct soap soap;  </li><li class="">    soap_init(&soap);  </li><li class="alt">    int m, s;  </li><li class="">    if ( (m = soap_bind(&soap, NULL, port, 100)) < 0 ) {  </li><li class="alt">        soap_print_fault(&soap, stderr);  </li><li class="">    }  </li><li class="alt">    else {  </li><li class="">        printf("Socket connect successfully: master socket = %d\n", m);  </li><li class="alt">        int i = 0;  </li><li class="">        while ( 1 ) {  </li><li class="alt">            if ( (s = soap_accept(&soap)) < 0 ) {  </li><li class="">                soap_print_fault(&soap, stderr);  </li><li class="alt">                break;  </li><li class="">            }  </li><li class="alt">            printf("Connection %d accepted from IP = %d.%d.%d.%d, slave socket = %d\n", ++i, (soap.ip >> 24) & 0xff, (soap.ip >> 16) & 0xff, (soap.ip >> 8) & 0xff, soap.ip & 0xff, s);  </li><li class="">            if ( soap_serve(&soap) != SOAP_OK ) {  </li><li class="alt">                soap_print_fault(&soap, stderr);  </li><li class="">                break;  </li><li class="alt">            }  </li><li class="">            soap_end(&soap);  </li><li class="alt">        }  </li><li class="">    }  </li><li class="alt">    soap_done(&soap);  </li><li class="">}  </li><li class="alt">  </li><li class="">int __ns3__getStockInfoByCode(  </li><li class="alt">    struct soap *soap,  </li><li class="">    struct _ns1__getStockInfoByCode *request,  </li><li class="alt">    struct _ns1__getStockInfoByCodeResponse *response) {  </li><li class="">    int element_counter = 25;  </li><li class="alt">    response->getStockInfoByCodeResult = (struct ns1__ArrayOfString *) malloc(sizeof(struct ns1__ArrayOfString));  </li><li class="">    response->getStockInfoByCodeResult->__sizestring = element_counter;  </li><li class="alt">    response->getStockInfoByCodeResult->string = (char **) malloc(sizeof(char *) * element_counter);  </li><li class="">    int i = 0;  </li><li class="alt">    for ( i = 0; i < element_counter; i++ ) {  </li><li class="">        response->getStockInfoByCodeResult->string = (char *) malloc(sizeof(char) * 32);  </li><li class="alt">        strcpy(response->getStockInfoByCodeResult->string, request->theStockCode);  </li><li class="">    }  </li><li class="alt">    return SOAP_OK;  </li><li class="">}  </li><li class="alt">  </li><li class="">int __ns3__getStockImage_USCOREkByteByCode(  </li><li class="alt">    struct soap *soap,  </li><li class="">    struct _ns1__getStockImage_USCOREkByteByCode *request,  </li><li class="alt">    struct _ns1__getStockImage_USCOREkByteByCodeResponse *response) {  </li><li class="">    return SOAP_OK;  </li><li class="alt">}  </li><li class="">  </li><li class="alt">int __ns3__getStockImage_USCOREkByCode(  </li><li class="">    struct soap *soap,  </li><li class="alt">    struct _ns1__getStockImage_USCOREkByCode *request,  </li><li class="">    struct _ns1__getStockImage_USCOREkByCodeResponse *response) {  </li><li class="alt">    return SOAP_OK;  </li><li class="">}  </li><li class="alt">  </li><li class="">int __ns3__getStockImageByteByCode(  </li><li class="alt">    struct soap *soap,  </li><li class="">    struct _ns1__getStockImageByteByCode *request,  </li><li class="alt">    struct _ns1__getStockImageByteByCodeResponse *response) {  </li><li class="">    return SOAP_OK;  </li><li class="alt">}  </li><li class="">  </li><li class="alt">int __ns3__getStockImageByCode(  </li><li class="">    struct soap *soap,  </li><li class="alt">    struct _ns1__getStockImageByCode *request,  </li><li class="">    struct _ns1__getStockImageByCodeResponse *response) {  </li><li class="alt">    return SOAP_OK;  </li><li class="">}  </li><li class="alt">  </li><li class="">int __ns2__getStockInfoByCode(  </li><li class="alt">    struct soap *soap,  </li><li class="">    struct _ns1__getStockInfoByCode *request,  </li><li class="alt">    struct _ns1__getStockInfoByCodeResponse *response) {  </li><li class="">    int element_counter = 25;  </li><li class="alt">    response->getStockInfoByCodeResult = (struct ns1__ArrayOfString *) malloc(sizeof(struct ns1__ArrayOfString));  </li><li class="">    response->getStockInfoByCodeResult->__sizestring = element_counter;  </li><li class="alt">    response->getStockInfoByCodeResult->string = (char **) malloc(sizeof(char *) * element_counter);  </li><li class="">    int i = 0;  </li><li class="alt">    for ( i = 0; i < element_counter; i++ ) {  </li><li class="">        response->getStockInfoByCodeResult->string = (char *) malloc(sizeof(char) * 32);  </li><li class="alt">        strcpy(response->getStockInfoByCodeResult->string, request->theStockCode);  </li><li class="">    }  </li><li class="alt">    return SOAP_OK;  </li><li class="">}  </li><li class="alt">  </li><li class="">int __ns2__getStockImage_USCOREkByteByCode(  </li><li class="alt">    struct soap *soap,  </li><li class="">    struct _ns1__getStockImage_USCOREkByteByCode *request,  </li><li class="alt">    struct _ns1__getStockImage_USCOREkByteByCodeResponse *response) {  </li><li class="">    return SOAP_OK;  </li><li class="alt">}  </li><li class="">  </li><li class="alt">int __ns2__getStockImage_USCOREkByCode(  </li><li class="">    struct soap *soap,  </li><li class="alt">    struct _ns1__getStockImage_USCOREkByCode *request,  </li><li class="">    struct _ns1__getStockImage_USCOREkByCodeResponse *response) {  </li><li class="alt">    return SOAP_OK;  </li><li class="">}  </li><li class="alt">  </li><li class="">int __ns2__getStockImageByteByCode(  </li><li class="alt">    struct soap *soap,  </li><li class="">    struct _ns1__getStockImageByteByCode *request,  </li><li class="alt">    struct _ns1__getStockImageByteByCodeResponse *response) {  </li><li class="">    return SOAP_OK;  </li><li class="alt">}  </li><li class="">  </li><li class="alt">int __ns2__getStockImageByCode(  </li><li class="">    struct soap *soap,  </li><li class="alt">    struct _ns1__getStockImageByCode *request,  </li><li class="">    struct _ns1__getStockImageByCodeResponse *response) {  </li><li class="alt">    return SOAP_OK;  </li><li class="">}  </li></ol></div> 

<span style="font-family: 宋体; font-size: 12pt; mso-ascii-font-family: 'Courier New'; mso-hansi-font-family: 'Times New Roman'; mso-bidi-font-family: 'Courier New'; mso-ansi-language: EN-US; mso-fareast-language: ZH-CN; mso-bidi-language: AR-SA;">
值得注意的是，如果项目中存在多个name space，最好把全部name space的相关方法都进行编码，否则可能出现意想不到的错误：客户端明明是调用ns3的方法，但是服务端却使用了ns2的方法来提供服务。这一点我也比较费解，可能与wsdl本身的写法有关。
 
上述服务端程序的编译命令是
gcc -O2 -o stock_server stock_server.c soapC.c soapServer.c ../../stdsoap2.c -I../.. -L../.. -lgsoap
 
<span style="font-family: 宋体; font-size: 12pt; mso-ascii-font-family: 'Courier New'; mso-hansi-font-family: 'Times New Roman'; mso-bidi-font-family: 'Courier New'; mso-ansi-language: EN-US; mso-fareast-language: ZH-CN; mso-bidi-language: AR-SA;">同时，要把上文的客户端程序修改一下，支持指定的end point<span style="font-family: 宋体; font-size: 12pt; mso-ascii-font-family: 'Courier New'; mso-hansi-font-family: 'Times New Roman'; mso-bidi-font-family: 'Courier New'; mso-ansi-language: EN-US; mso-fareast-language: ZH-CN; mso-bidi-language: AR-SA;">，不指定end point<span style="font-family: 宋体; font-size: 12pt; mso-ascii-font-family: 'Courier New'; mso-hansi-font-family: 'Times New Roman'; mso-bidi-font-family: 'Courier New'; mso-ansi-language: EN-US; mso-fareast-language: ZH-CN; mso-bidi-language: AR-SA;">再取默认的end point

<div class="dp-highlighter"><div class="bar"><div class="tools"><a href="http://blog.csdn.net/yui/archive/2010/07/19/5747433.aspx#">view plain</a><a href="http://blog.csdn.net/yui/archive/2010/07/19/5747433.aspx#">copy to clipboard</a><a href="http://blog.csdn.net/yui/archive/2010/07/19/5747433.aspx#">print</a><a href="http://blog.csdn.net/yui/archive/2010/07/19/5747433.aspx#">?</a></div></div><ol class="dp-cpp" start="1"><li class="alt">#include "soapH.h"  </li><li class="">#include "ChinaStockWebServiceSoap12.nsmap"  </li><li class="alt">  </li><li class="">int main(int argc, char **argv) {  </li><li class="alt">    if ( argc != 2 && argc != 3 ) {  </li><li class="">        printf("Usage: %s stock_code \n", argv);  </li><li class="alt">        exit(-1);  </li><li class="">    }  </li><li class="alt">  </li><li class="">    struct soap soap;  </li><li class="alt">    soap_init(&soap);  </li><li class="">    soap_set_mode(&soap, SOAP_C_UTFSTRING);  </li><li class="alt">    struct _ns1__getStockInfoByCode request;  </li><li class="">    struct _ns1__getStockInfoByCodeResponse response;  </li><li class="alt">  </li><li class="">    request.theStockCode = argv;  </li><li class="alt">    char *endpoint = NULL;  </li><li class="">    if ( argc == 3 )  </li><li class="alt">        endpoint = argv;  </li><li class="">    if ( soap_call___ns3__getStockInfoByCode(&soap, endpoint, NULL, &request, &response) == SOAP_OK ) {  </li><li class="alt">        int element_counter = response.getStockInfoByCodeResult->__sizestring;  </li><li class="">        int i = 0;  </li><li class="alt">        for ( i = 0; i < element_counter; i++ ) {  </li><li class="">            switch ( i ) {  </li><li class="alt">                case 0  : printf("Stock code        : "); break;  </li><li class="">                case 1  : printf("Stock name        : "); break;  </li><li class="alt">                case 2  : printf("Timestamp         : "); break;  </li><li class="">                case 3  : printf("Latest price      : "); break;  </li><li class="alt">                case 4  : printf("Closing price T-1 : "); break;  </li><li class="">                case 5  : printf("Opening price     : "); break;  </li><li class="alt">                case 6  : printf("Ups and downs     : "); break;  </li><li class="">                case 7  : printf("Mininum price     : "); break;  </li><li class="alt">                case 8  : printf("Maxinum price     : "); break;  </li><li class="">                case 9  : printf("Amount of up/down : "); break;  </li><li class="alt">                case 10 : printf("Trading volume    : "); break;  </li><li class="">                case 11 : printf("Trading amount    : "); break;  </li><li class="alt">                case 12 : printf("Buy price         : "); break;  </li><li class="">                case 13 : printf("Sell price        : "); break;  </li><li class="alt">                case 14 : printf("Agency trans      : "); break;  </li><li class="">                case 15 : printf("Buy  1            : "); break;  </li><li class="alt">                case 16 : printf("Buy  2            : "); break;  </li><li class="">                case 17 : printf("Buy  3            : "); break;  </li><li class="alt">                case 18 : printf("Buy  4            : "); break;  </li><li class="">                case 19 : printf("Buy  5            : "); break;  </li><li class="alt">                case 20 : printf("Sell 1            : "); break;  </li><li class="">                case 21 : printf("Sell 2            : "); break;  </li><li class="alt">                case 22 : printf("Sell 3            : "); break;  </li><li class="">                case 23 : printf("Sell 4            : "); break;  </li><li class="alt">                case 24 : printf("Sell 5            : "); break;  </li><li class="">                default : break;  </li><li class="alt">            }  </li><li class="">            printf("%s\n", response.getStockInfoByCodeResult->string);  </li><li class="alt">        }  </li><li class="">    }  </li><li class="alt">    else {  </li><li class="">        soap_print_fault(&soap, stderr);  </li><li class="alt">    }  </li><li class="">  </li><li class="alt">    soap_destroy(&soap);  </li><li class="">    soap_end(&soap);  </li><li class="alt">    soap_done(&soap);  </li><li class="">    return 0;  </li><li class="alt">}  </li></ol></div> 


使服务端程序在某一高位端口下运行，比如
-bash-3.2$ ./stock_server 6883
Socket connect successfully: master socket = 3
 
另起一个窗口执行客户端程序，并且指定end point
-bash-3.2$ ./stock sh600000 http://localhost:6883
Stock code        : sh600000
Stock name        : sh600000
Timestamp         : sh600000
Latest price      : sh600000
Closing price T-1 : sh600000
Opening price     : sh600000
Ups and downs     : sh600000
Mininum price     : sh600000
Maxinum price     : sh600000
Amount of up/down : sh600000
Trading volume    : sh600000
Trading amount    : sh600000
Buy price         : sh600000
Sell price        : sh600000
Agency trans      : sh600000
Buy  1            : sh600000
Buy  2            : sh600000
Buy  3            : sh600000
Buy  4            : sh600000
Buy  5            : sh600000
Sell 1            : sh600000
Sell 2            : sh600000
Sell 3            : sh600000
Sell 4            : sh600000
Sell 5            : sh600000
 
成功！

页: [1]

Chinaunix's Archiver

使用gSOAP开发实例(2) 股票信息服务端程序