php soap wsdl 实例

service.php(服务器端):

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
<?php

//设置不缓存wsdl
ini_set("soap.wsdl_cache_enabled","0");

class Service {
public function conn() {
$con = mysql_connect('localhost', 'root', '密码');
if (!con) {
die('Could not connect: ' . mysql_error());
}
return $con;
}

public function insertQueue($emails) {
$emails = unserialize($emails);
if (empty($emails)) {
return false;
}
$fields = array(
'server_id',
'mailer_id',
'campaign_id',
'receiver_email',
'subject',
'message',
'headers',
'parameters',
'status',
'data');
$insertSql = "INSERT INTO queue (" . implode(',', $fields) . ") VALUES ";
$valueStr = '';
foreach ($emails as $email) {
if (!empty($email)) {
$valueStr .= "('',{$email['mailer_id']},{$email['campaign_id']},'{$email['receiver_email']}','{$email['subject']}','{$email['message']}','{$email['headers']}','{$email['parameters']}','{$email['status']}','{$email['data']}'),";
}
}

if (empty($valueStr)) {
return false;
}
$valueStr = substr($valueStr, 0, strlen($valueStr) - 1);
$insertSql .= $valueStr;
error_reporting(E_ALL);
ini_set('display_errors', '1');
try {
// return true;
$con = self::conn();
mysql_select_db('database', $con);
mysql_query($insertSql);
mysql_close($con);
return true;
} catch (Exception $e) {
return $e -> getMessage();
exit();
}
}

}
//生成wsdl文件
// include("SoapDiscovery.class.php");
// $disco = new SoapDiscovery('Service', 'soap'); //第一个参数是类名(生成的wsdl文件就是以它来命名的),即Service类,第二个参数是服务的名字(这个可以随便写)。
// $disco->getWSDL();
// die;
$soapServer = new SoapServer('Service.wsdl', array('soap_version' => SOAP_1_2));

$soapServer -> setClass("Service");
//注册Service类的所有方法
$soapServer -> handle();
//处理请求
?>

用service.php生成wsdl文件。
注意:需取消service.php中的注释行.
生成后再注释掉。
如果另外创建文件create_wsdl.php文件来创建的话.在多次soap后会出现Forbidden的错误.

client.php(客户端):

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
<?php
error_reporting(E_ALL);
ini_set('display_errors', '1');
ini_set('soap.wsdl_cache_enabled', "0");
exec('rm /tmp/* -rf');
//关闭wsdl缓存
try {
$emails = array();
$email['server_id'] = '';
$email['mailer_id'] = '11';
$email['campaign_id'] = '112';
$email['sender_name'] = 'hongzhao.zou';
$email['sender_email'] = 'hongzhao.zou@fenzsoft.com';
$email['receiver_name'] = 'zouhongzhao';
$email['receiver_email'] = 'zouhongzhao@126.com';
$email['content'] = 'aaaaaaaaaaaaaadddddddddddddddd';
$email['content_alt'] = 'cccccccccccccccccc';
$email['status'] = '0';
array_push($emails,$email);
$soap = new SoapClient("http://xxxx.com/service.php?wsdl");
$resurt = $soap -> insertQueue(serialize($emails));
if($resurt){
echo 'success !';
}
// echo $soap -> Add(28, 2);
// echo $soap -> __soapCall('Add', array(28, 2));
//或这样调用
} catch (Exception $e) {
print $e -> getMessage();
exit();
}
?>

附:wsdl的生成类 SoapDiscovery.class.php

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
<?php

/**
* Copyright (c) 2005, Braulio Jos Solano Rojas
* All rights reserved.
* 生成wsdl文件
* Redistribution and use in source and binary forms, with or without modification, are
* permitted provided that the following conditions are met:
*
* Redistributions of source code must retain the above copyright notice, this list of
* conditions and the following disclaimer.
* Redistributions in binary form must reproduce the above copyright notice, this list of
* conditions and the following disclaimer in the documentation and/or other materials
* provided with the distribution.
* Neither the name of the Solsoft de Costa Rica S.A. nor the names of its contributors may
* be used to endorse or promote products derived from this software without specific
* prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND
* CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES,
* INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
* MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
* DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR
* CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
* NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
* CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR
* OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE,
* EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*
*
* @version $Id$
* @copyright 2005
*/

/**
* SoapDiscovery Class that provides Web Service Definition Language (WSDL).
*
* @package SoapDiscovery
* @author Braulio Jos Solano Rojas
* @copyright Copyright (c) 2005 Braulio Jos Solano Rojas
* @version $Id$
* @access public
**/
class SoapDiscovery {
private $class_name = '';
private $service_name = '';

/**
* SoapDiscovery::__construct() SoapDiscovery class Constructor.
*
* @param string $class_name
* @param string $service_name
**/
public function __construct($class_name = '', $service_name = '') {
$this->class_name = $class_name;
$this->service_name = $service_name;
}

/**
* SoapDiscovery::getWSDL() Returns the WSDL of a class if the class is instantiable.
*
* @return string
**/
public function getWSDL() {
if (empty($this->service_name)) {
throw new Exception('No service name.');
}
$headerWSDL = "<?xml version=\"1.0\" ?>\n";
$headerWSDL.= "<definitions name=\"$this->service_name\" targetNamespace=\"urn:$this->service_name\" xmlns:wsdl=\"http://schemas.xmlsoap.org/wsdl/\" xmlns:soap=\"http://schemas.xmlsoap.org/wsdl/soap/\" xmlns:tns=\"urn:$this->service_name\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" xmlns:SOAP-ENC=\"http://schemas.xmlsoap.org/soap/encoding/\" xmlns=\"http://schemas.xmlsoap.org/wsdl/\">\n";
$headerWSDL.= "<types xmlns=\"http://schemas.xmlsoap.org/wsdl/\" />\n";

if (empty($this->class_name)) {
throw new Exception('No class name.');
}

$class = new ReflectionClass($this->class_name);

if (!$class->isInstantiable()) {
throw new Exception('Class is not instantiable.');
}

$methods = $class->getMethods();

$portTypeWSDL = '<portType name="'.$this->service_name.'Port">';
$bindingWSDL = '<binding name="'.$this->service_name.'Binding" type="tns:'.$this->service_name."Port\">\n<soap:binding style=\"rpc\" transport=\"http://schemas.xmlsoap.org/soap/http\" />\n";

$url=str_replace("distribute.php","",$_SERVER['PHP_SELF']).str_replace("?wsdl","",$_SERVER['REQUEST_URI']);

$serviceWSDL = '<service name="'.$this->service_name."\">\n<documentation />\n<port name=\"".$this->service_name.'Port" binding="tns:'.$this->service_name."Binding\"><soap:address location=\"http://".$_SERVER['SERVER_NAME'].':'.$_SERVER['SERVER_PORT'].$url."\" />\n</port>\n</service>\n";
$messageWSDL = '';
foreach ($methods as $method) {
if ($method->isPublic() && !$method->isConstructor()) {
$portTypeWSDL.= '<operation name="'.$method->getName()."\">\n".'<input message="tns:'.$method->getName()."Request\" />\n<output message=\"tns:".$method->getName()."Response\" />\n</operation>\n";
$bindingWSDL.= '<operation name="'.$method->getName()."\">\n".'<soap:operation soapAction="urn:'.$this->service_name.'#'.$this->class_name.'#'.$method->getName()."\" />\n<input><soap:body use=\"encoded\" namespace=\"urn:$this->service_name\" encodingStyle=\"http://schemas.xmlsoap.org/soap/encoding/\" />\n</input>\n<output>\n<soap:body use=\"encoded\" namespace=\"urn:$this->service_name\" encodingStyle=\"http://schemas.xmlsoap.org/soap/encoding/\" />\n</output>\n</operation>\n";
$messageWSDL.= '<message name="'.$method->getName()."Request\">\n";
$parameters = $method->getParameters();
foreach ($parameters as $parameter) {
$messageWSDL.= '<part name="'.$parameter->getName()."\" type=\"xsd:string\" />\n";
}
$messageWSDL.= "</message>\n";
$messageWSDL.= '<message name="'.$method->getName()."Response\">\n";
$messageWSDL.= '<part name="'.$method->getName()."\" />\n";
$messageWSDL.= "</message>\n";
}
}
$portTypeWSDL.= "</portType>\n";
$bindingWSDL.= "</binding>\n";
$fso = fopen($this->class_name . ".wsdl" , "w");
fwrite($fso, sprintf('%s%s%s%s%s%s', $headerWSDL, $portTypeWSDL, $bindingWSDL, $serviceWSDL, $messageWSDL, '</definitions>'));
// return sprintf('%s%s%s%s%s%s', $headerWSDL, $portTypeWSDL, $bindingWSDL, $serviceWSDL, $messageWSDL, '</definitions>');
}

/**
* SoapDiscovery::getDiscovery() Returns discovery of WSDL.
*
* @return string
**/
public function getDiscovery() {
return "<?xml version=\"1.0\" ?>\n<disco:discovery xmlns:disco=\"http://schemas.xmlsoap.org/disco/\" xmlns:scl=\"http://schemas.xmlsoap.org/disco/scl/\">\n<scl:contractRef ref=\"http://".$_SERVER['SERVER_NAME'].':'.$_SERVER['SERVER_PORT'].$_SERVER['PHP_SELF']."?wsdl\" />\n</disco:discovery>";
}
}

?>

坚持原创技术分享,您的支持将鼓励我继续创作!