PHP程序与服务器端通讯方法小结
2024年02月22日
假设有10个网站，分布在各地，它们的库存要同步，而数据库不支持远程连接。我们要实时地取得服务器的库存数，可以通过很多种方法，我所知道的有以下几种：
·CURL方式
·SOCKET方式
·PHP5中的SOAP方式
以下分别给出示例来实现它：
CURL方式
client.php
＜?php
$psecode=’NDE005’;
$website=’www.abc.com’;
$amt=1;
$pwd=123456;
$ch=curl_init();
$curl_url="http://ics1.server.com/index.php?web=".$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’=＞’www.abc.com’,
’pwd’=＞’123456’,
’action’=＞’check’,
’pseid’=＞’NDE005’,
’amt’=＞1);
$pageContents=HttpClient::quickPost(’http://ics.server.com/index.php’,$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=’http://example.org/StockQuote’
xmlns:tns=’http://example.org/StockQuote’
xmlns:soap=’http://schemas.xmlsoap.org/wsdl/soap/’
xmlns:xsd=’http://www.w3.org/2001/XMLSchema’
xmlns:soapenc=’http://schemas.xmlsoap.org/soap/encoding/’
xmlns:wsdl=’http://schemas.xmlsoap.org/wsdl/’
xmlns=’http://schemas.xmlsoap.org/wsdl/’＞
＜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=’http://schemas.xmlsoap.org/soap/http’/＞
＜operation name=’getQuote’＞
＜soap:operation soapAction=’urn:xmethods-delayed-quotes#getQuote’/＞
＜input＞
＜soap:body use=’encoded’namespace=’urn:xmethods-delayed-quotes’
encodingStyle=’http://schemas.xmlsoap.org/soap/encoding/’/＞
＜/input＞
＜output＞
＜soap:body use=’encoded’namespace=’urn:xmethods-delayed-quotes’
encodingStyle=’http://schemas.xmlsoap.org/soap/encoding/’/＞
＜/output＞
＜/operation＞
＜/binding＞
＜service name=’StockQuoteService’＞
＜port name=’StockQuotePort’binding=’StockQuoteBinding’＞
＜soap:address location=’http://192.168.3.9/php5/server.php’/＞
＜/port＞
＜/service＞
＜/definitions＞
client.php
＜?php
$client=new SoapClient("stockquote.wsdl");
$result=$client-＞getQuote("nde005");
print_r($result);
?＞
