使用pear::soap创建web服务的步骤

2. class FruitQuoteService
3. {
4. public $__dispatch_map = array();
5. public $__typedef = array();
6. public function FruitQuoteService()
7. {
8. $this->__dispatch_map['getQuote'] = array(
9. "in" => array("category" => "string"),
10. "out" => array("quote" => "int")
11. );
12. $this->__dispatch_map['getFruit'] = array(
13. "in" => array(),
14. "out" => array("fruitSummary" => "{urn:FruitQuoteService}fruitStruct")
15. );
17. $this->__typedef['fruitStruct'] = array(
18. 'category'=>'string', 'amount' => 'int'
19. );
20. }
22. public function getQuote($category)
23. {
24. switch ($category)
25. {
26. case 'apple':
27. $quote = 10;
28. break;
29. case 'orange':
30. $quote = 12;
31. break;
32. case 'banana':
33. $quote = 20;
34. break;
35. default:
36. $quote = 0;
37. break;
38. }
39. return $quote;
40. }//end funtion
42. public function getFruit()
43. {
44. $list = array(
45. array("apple", 100),
46. array("orange", 500),
47. array("banana", 260)
48. );
49. return $list;
50. }//end funtion
51. }//end class
52. ?>

复制代码

第二步：创建server.php 这个程序将接收并处理客户端的请求

2. require_once("FruitQuoteService.php");
3. require_once("SOAP/Server.php");
4. $fruitQuote = new FruitQuoteService();
5. $server = new Soap_Server();
6. $server->addObjectMap($fruitQuote, "http://www.xxx.com");
7. if (isset($_SERVER['REQUEST_METHOD']) && $_SERVER['REQUEST_METHOD']=='POST')
8. {
9. $server->service($GLOBALS['HTTP_RAW_POST_DATA']);
10. } else
11. {
12. require_once 'SOAP/Disco.php';
13. $disco = new SOAP_DISCO_Server($server,'FruitQuoteService');
14. header("Content-type: text/xml");
15. if (isset($_SERVER['QUERY_STRING']) && strcasecmp($_SERVER['QUERY_STRING'],'wsdl')==0) {
16. echo $disco->getWSDL();
17. } else {
18. echo $disco->getDISCO();
19. }
20. }
21. exit;
22. ?>

复制代码

现在可以通过http://www.shangyong.com/ws/server.php?wsdl 查看wsdl文档。

DISCO:一项微软用来发布和发现Web服务的技术,定义了一个从给定的url获取web服务描述的简单的HTTP GET机制

第三步：创建web服务客户端代码

3. require_once('SOAP/Client.php');
4. //这个名称空间必须和server.php中定义的一致
5. $options = array('namespace' => 'http://www.xxx.com',
6. 'trace' => 1); //为1表示可以通过__get_wire获取soap消息，默认是0
7. $client = new SOAP_client("http://www.shangyong.com/ws/server.php");
8. $params = array();
9. $response = $client->call("getFruit", $params, $options);
10. //print_r($client->__get_wire()); //输出 soap消息
11. if (PEAR::isError($response)) {
12. echo 'Error: ' . $response->getMessage() . "
    \n";
13. } else {
14. print_r($response) . "\n";
15. }
16. $params = array("name" => "orange");
17. $response = $client->call("getQuote", $params, $options);
18. if (PEAR::isError($response)) {
19. echo 'Error: ' . $response->getMessage() . "
    \n";
20. } else {
21. echo $response . "\n\n";
22. }
23. exit;
24. ?>

复制代码

客户端代码2

3. require_once('SOAP/Client.php');
4. /**
5. * 所有的服务内容，如：命名空间、UEL, 参数名等都可以从wsdl文件获取
6. */
7. $wsdl = new SOAP_WSDL("http://www.shangyong.com/ws/server.php?wsdl");
8. /**
9. * 从wsdl生成一个proxy对象，这个对象包含wsdl文档中定义的所有操作的方法。
10. * 可以通过proxy对象直接调用函数
11. * 优点：易于用户使用
12. */
13. $client = $wsdl->getProxy();
14. $response = $client->getQuote("apple");
15. if (PEAR::isError($response)) {
16. echo 'Error: ' . $response->getMessage() . "
    \n";
17. } else {
18. echo $response . "\n\n";
19. }
20. $response = $client->getFruit();
21. if (PEAR::isError($response)) {
22. echo 'Error: ' . $response->getMessage() . "
    \n";
23. } else {
24. print_r($response) . "\n";
25. }
26. exit;
27. ?>

复制代码