thrift php服务器端开发

WBOY
Freigeben: 2016-06-20 12:49:56
Original
1341 Leute haben es durchsucht

在前文(Thrift的java和php数据交互)中只介绍了java作服务器端,但是“php是最好的语言”,自然少了php开发的thrift服务器端。

使用的业务例子,还是以前文的登录和注册为例


服务器端由php代码编写,客户端由php和java编写。

PhpMulServer.php (注意需要使用apache或其它web服务器来运行,由于thrift自身没有提供负载均衡,可考虑用LVS、HAProxy、 Nginx等等对HTTP请求做负载均衡处理)

<?phpnamespace com\penngo;error_reporting(E_ALL);require_once __DIR__.'/../lib/Thrift/ClassLoader/ThriftClassLoader.php';use Thrift\ClassLoader\ThriftClassLoader;$GEN_DIR = realpath(dirname(__FILE__).'/..').'/gen-php';$loader = new ThriftClassLoader();$loader->registerNamespace('Thrift', __DIR__ . '/../lib');$loader->registerDefinition('com', $GEN_DIR);$loader->register();if (php_sapi_name() == 'cli') {  ini_set("display_errors", "stderr");}use Thrift\Protocol\TBinaryProtocol;use Thrift\Transport\TPhpStream;use Thrift\Transport\TBufferedTransport;use Thrift\TMultiplexedProcessor;use com\penngo\User;class RegisterServiceHandler implements \com\penngo\RegisterServiceIf {    public function createUser($name, $psw){        $user = new User();        $user->id = 2;        $user->name = $name;        $user->password = $psw;        return $user;    }};class LoginServiceHandler implements \com\penngo\LoginServiceIf {    public function login($name, $psw){        $user = new User();        if($name == 'penngo' && $psw == '123'){            $user->id = 1;            $user->name = 'penngo';        }        return $user;    }};header('Content-Type', 'application/x-thrift');if (php_sapi_name() == 'cli') {  echo "\r\n";}$transport = new TBufferedTransport(new TPhpStream(TPhpStream::MODE_R | TPhpStream::MODE_W));$protocol = new TBinaryProtocol($transport, true, true);$tMultiplexedProcessor = new TMultiplexedProcessor();$handler = new LoginServiceHandler();$loginServiceProcessor = new LoginServiceProcessor($handler);$tMultiplexedProcessor->registerProcessor("LoginService", $loginServiceProcessor);$registerService = new RegisterServiceHandler();$registerServiceProcessor = new RegisterServiceProcessor($registerService);$tMultiplexedProcessor->registerProcessor("RegisterService", $registerServiceProcessor);$transport->open();$tMultiplexedProcessor->process($protocol, $protocol);$transport->close();
Nach dem Login kopieren


php客户端调用

PhpMulClient.php

<?phpnamespace com\penngo;error_reporting(E_ALL);require_once __DIR__.'/../lib/Thrift/ClassLoader/ThriftClassLoader.php';use Thrift\ClassLoader\ThriftClassLoader;$GEN_DIR = realpath(dirname(__FILE__).'/..').'/gen-php';$loader = new ThriftClassLoader();$loader->registerNamespace('Thrift', __DIR__ . '/../lib');$loader->registerDefinition('com', $GEN_DIR);$loader->register();use Thrift\Protocol\TBinaryProtocol;use Thrift\Protocol\TMultiplexedProtocol;use Thrift\Transport\THttpClient;use Thrift\Transport\TBufferedTransport;use Thrift\Exception\TException;try {$socket = new THttpClient('localhost', 80, '/thrift/penngo/PhpMulServer.php');//   $socket = new THttpClient('localhost', 8090, '/thrift/penngo/PhpMulServer.php');  $transport = new TBufferedTransport($socket);  $protocol = new TBinaryProtocol($transport);  $loginProtocol = new TMultiplexedProtocol($protocol, 'LoginService');  $loginService = new LoginServiceClient($loginProtocol);  $user = $loginService->login('penngo', '123');  var_dump($user);  $registerProtocol = new TMultiplexedProtocol($protocol, 'RegisterService');  $registerService = new RegisterServiceClient($registerProtocol);  $user = $registerService->createUser('penngo', '123');  var_dump($user);//   $transport->close();} catch (TException $tx) {  print 'TException: '.$tx->getMessage()."\n";}?>
Nach dem Login kopieren


java客户端

HttpClient.java

package com.penngo.main;import org.apache.thrift.*;import org.apache.thrift.protocol.*;import org.apache.thrift.transport.*;import com.penngo.LoginService;import com.penngo.RegisterService;import com.penngo.User;public class HttpClient {	public static void main(String[] args) {		try {			THttpClient transport = new THttpClient("http://localhost:80/thrift/penngo/PhpMulServer.php");			TProtocol protocol = new TBinaryProtocol(transport);			TMultiplexedProtocol mp1 = new TMultiplexedProtocol(protocol,					"LoginService");			LoginService.Client loginClient = new LoginService.Client(mp1);			TMultiplexedProtocol mp2 = new TMultiplexedProtocol(protocol,					"RegisterService");			RegisterService.Client registerClient = new RegisterService.Client(					mp2);//			transport.open();			User user = loginClient.login("penngo", "123");			if (user != null) {				System.out.println("登录成功:" + user.getId() + " "						+ user.getName());			} else {				System.out.println("登录失败");			}			User user2 = registerClient.createUser("test", "123");			if (user2 != null) {				System.out.println("创建用户成功:" + user2.getId() + " "						+ user2.getName());			} else {				System.out.println("创建用户失败");			}//			transport.close();		} catch (TException x) {			x.printStackTrace();		}	}}
Nach dem Login kopieren


Verwandte Etiketten:
Quelle:php.cn
Erklärung dieser Website
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn
Beliebte Tutorials
Mehr>
Neueste Downloads
Mehr>
Web-Effekte
Quellcode der Website
Website-Materialien
Frontend-Vorlage
Über uns Haftungsausschluss Sitemap
Chinesische PHP-Website:Online-PHP-Schulung für das Gemeinwohl,Helfen Sie PHP-Lernenden, sich schnell weiterzuentwickeln!