Chinaunix首页 | 论坛 | 博客
  • 博客访问: 17721741
  • 博文数量: 7460
  • 博客积分: 10434
  • 博客等级: 上将
  • 技术积分: 78178
  • 用 户 组: 普通用户
  • 注册时间: 2008-03-02 22:54
文章分类

全部博文(7460)

文章存档

2011年(1)

2009年(669)

2008年(6790)

分类:

2008-04-14 21:35:26

 假设有10个网站,分布在各地,它们的库存要同步,而不支持远程连接。
  
    我们要实时地取得服务器的库存数,可以通过很多种,我所知道的有以下几种:
  
     ·CURL方式
  
     ·SOCKET方式
  
     ·PHP5中的SOAP方式
  
    以下分别给出示例来实现它:
  
    CURL方式
  
    client.php
  
  <?php
  $psecode = ’NDE005’;
  $website = ’’;
  $amt = 1;
  $pwd = 123456;
  $ch = curl_init();
  $curl_url = "" . $website .
  "&pwd=" . $pwd . "&action=check&pseid=" . $psecode .
  "&amt=" . $amt;
  curl_setopt($ch, CURLOPT_URL, $curl_url);
  curl_setopt($ch, CURLOPT_POST, 1);
  curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);//不直接输出,返回到变量
  $curl_result = curl_exec($ch);
  $result = explode(’,’, $curl_result);
  curl_close($ch);
  print_r($result);
  ?>
  
    服务器端只需按一定的格式输出,然后客户端按此格式接收就可以了如:
  
  echo "OK," . $fpsecode . "," . $fbalance ;//以逗号分隔
  
    SOCKET方式
  
    这个要借助第三方类库HttpClient,可以到这里下载:http://scripts.incutio.com/httpclient/
  
  <?php
  require_once ’class/HttpClient.php’;
  $params = array(’web’ => ’’,
  ’pwd’ => ’123456’,
  ’action’ => ’check’,
  ’pseid’ => ’NDE005’,
  ’amt’ => 1);
  $pageContents = HttpClient::quickPost(’’, $params);
  $result = explode(’,’, $pageContents);
  print_r($result);
  ?>
  
    PHP5中的SOAP方式
  
    server.php
  
  <?php
  function getQuote($fpsecode) {
  global $dbh;
  $result = array();
  try {
  $query = "SELECT fprice, fcansale, fbalance, fbaltip FROM tblbalance where upper(trim(fpsecode)) = :psecode limit 1";
  $stmt = $dbh->prepare($query);
  $stmt->execute(array(’:psecode’ => strtoupper(trim($fpsecode))));
  $stmt->bindColumn(’fprice’, $fprice);
  $stmt->bindColumn(’fcansale’, $fcansale);
  $stmt->bindColumn(’fbalance’, $fbalance);
  $stmt->bindColumn(’fbaltip’, $fbaltip);
  while($row = $stmt->fetch(PDO_FETCH_BOUND)) {
  //
  }
  } catch (PDOException $e) {
  echo $e->getMessage();
  }
  return $fprice; //你可以返回一个数组
  }
  
  $dsn = ’pgsql:host=192.168.*.* port=5432 dbname=db user=123456 password=123456’;
  try {
  $dbh = new PDO($dsn);
  } catch (PDOException $e) {
  die(’Connection failed: ’ . $e->getMessage());
  }
  ini_set("soap.wsdl_cache_enabled", "0"); // disabling WSDL cache
  $server = new SoapServer("stockquote.wsdl"); //配置文件
  $server->addFunction("getQuote");
  $server->handle();
  ?>
  
    stockquote.wsdl
  
  <?xml version =’1.0’ encoding =’UTF-8’ ?>
  <definitions name=’StockQuote’
  targetNamespace=’’
  xmlns:tns=’ ’
  xmlns:soap=’’
  xmlns:xsd=’’
  xmlns:soapenc=’’
  xmlns:wsdl=’’
  xmlns=’’>
  
  <message name=’getQuoteRequest’>
  <part name=’symbol’ type=’xsd:string’/>
  </message>
  <message name=’getQuoteResponse’>
  <part name=’Result’ type=’xsd:float’/>
  </message>
  
  <portType name=’StockQuotePortType’>
  <operation name=’getQuote’>
  <input message=’tns:getQuoteRequest’/>
  <output message=’tns:getQuoteResponse’/>
  </operation>
  </portType>
  
  <binding name=’StockQuoteBinding’ type=’tns:StockQuotePortType’>
  <soap:binding style=’rpc’
  transport=’’/>
  <operation name=’getQuote’>
  <soap:operation soapAction=’urn:xmethods-delayed-quotes#getQuote’/>
  <input>
  <soap:body use=’encoded’ namespace=’urn:xmethods-delayed-quotes’
  encodingStyle=’’/>
  </input>
  <output>
  <soap:body use=’encoded’ namespace=’urn:xmethods-delayed-quotes’
  encodingStyle=’’/>
  </output>
  </operation>
  </binding>
  
  <service name=’StockQuoteService’>
  <port name=’StockQuotePort’ binding=’StockQuoteBinding’>
  <soap:address location=’’/>
  </port>
  </service>
  </definitions>
  
  client.php
  
  <?php
  $client = new SoapClient("stockquote.wsdl");
  $result = $client->getQuote("nde005");
  print_r($result);
  ?>
阅读(377) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~