The Apache Thrift software framework, for scalable cross-language services development, combines a software stack with a code generation engine to build services that work efficiently and seamlessly between C++, Java, Python, PHP, Ruby, Erlang, Perl, Haskell, C#, Cocoa, JavaScript, Node.js, Smalltalk, OCaml and Delphi and other languages.
Apache Thrift是一個軟件框架,用來進行可擴展跨語言的服務開發,結合了軟件堆棧和代碼生成引擎,用來構建C++,Java,Python...等語言,使之它們之間無縫結合、高效服務。php
brew install thrift
跨語言調用,打破不一樣語言之間的隔閡。
跨項目調用,微服務的麼麼噠。
該示例包含python,php,go三種語言。(java暫無)html
cd /Users/birjemin/Developer/Php/study-php
vim HelloThrift.thrift
內容以下:java
namespace php HelloThrift { string SayHello(1:string username) }
composer require apache/thrift
cd /Users/birjemin/Developer/Php/study-php thrift -r --gen php:server HelloThrift.thrift
這時目錄中生成了一個叫作gen-php
的目錄。python
Server.php
文件<?php /** * Created by PhpStorm. * User: birjemin * Date: 22/02/2018 * Time: 3:59 PM */ namespace HelloThrift\php; require_once 'vendor/autoload.php'; use Thrift\ClassLoader\ThriftClassLoader; use Thrift\Protocol\TBinaryProtocol; use Thrift\Transport\TPhpStream; use Thrift\Transport\TBufferedTransport; $GEN_DIR = realpath(dirname(__FILE__)).'/gen-php'; $loader = new ThriftClassLoader(); $loader->registerDefinition('HelloThrift',$GEN_DIR); $loader->register(); class HelloHandler implements \HelloThrift\HelloServiceIf { public function SayHello($username) { return "Php-Server: " . $username; } } $handler = new HelloHandler(); $processor = new \HelloThrift\HelloServiceProcessor($handler); $transport = new TBufferedTransport(new TPhpStream(TPhpStream::MODE_R | TPhpStream::MODE_W)); $protocol = new TBinaryProtocol($transport,true,true); $transport->open(); $processor->process($protocol,$protocol); $transport->close();
Client.php
文件<?php /** * Created by PhpStorm. * User: birjemin * Date: 22/02/2018 * Time: 4:00 PM */ namespace HelloThrift\php; require_once 'vendor/autoload.php'; use Thrift\ClassLoader\ThriftClassLoader; use Thrift\Protocol\TBinaryProtocol; use Thrift\Transport\TSocket; use Thrift\Transport\THttpClient; use Thrift\Transport\TBufferedTransport; use Thrift\Exception\TException; $GEN_DIR = realpath(dirname(__FILE__)).'/gen-php'; $loader = new ThriftClassLoader(); $loader->registerDefinition('HelloThrift', $GEN_DIR); $loader->register(); if (array_search('--http',$argv)) { $socket = new THttpClient('local.study-php.com', 80,'/Server.php'); } else { $host = explode(":", $argv[1]); $socket = new TSocket($host[0], $host[1]); } $transport = new TBufferedTransport($socket,1024,1024); $protocol = new TBinaryProtocol($transport); $client = new \HelloThrift\HelloServiceClient($protocol); $transport->open(); echo $client->SayHello("Php-Client"); $transport->close();
php Client.php --http
pip3 install thrift
thrift -r --gen py HelloThrift.thrift
這時目錄中生成了一個叫作gen-py
的目錄。git
Server.py
文件#!/usr/bin/python3 # -*- coding: UTF-8 -*- import sys sys.path.append('./gen-py') from HelloThrift import HelloService from HelloThrift.ttypes import * from thrift.transport import TSocket from thrift.transport import TTransport from thrift.protocol import TBinaryProtocol from thrift.server import TServer class HelloWorldHandler: def __init__(self): self.log = {} def SayHello(self, user_name = ""): return "Python-Server: " + user_name handler = HelloWorldHandler() processor = HelloService.Processor(handler) transport = TSocket.TServerSocket('localhost', 9091) tfactory = TTransport.TBufferedTransportFactory() pfactory = TBinaryProtocol.TBinaryProtocolFactory() server = TServer.TSimpleServer(processor, transport, tfactory, pfactory) server.serve()
Client.py
文件#!/usr/bin/python3 # -*- coding: UTF-8 -*- import sys sys.path.append('./gen-py') from HelloThrift import HelloService from HelloThrift.ttypes import * from HelloThrift.constants import * from thrift.transport import TSocket from thrift.transport import TTransport from thrift.protocol import TBinaryProtocol host = sys.argv[1].split(':') transport = TSocket.TSocket(host[0], host[1]) transport = TTransport.TBufferedTransport(transport) protocol = TBinaryProtocol.TBinaryProtocol(transport) client = HelloService.Client(protocol) transport.open() msg = client.SayHello('Python-Client') print(msg) transport.close()
開一個新窗口,運行下面命令:github
python3 Server.php
go get git.apache.org/thrift.git/lib/go/thrift
thrift -r --gen go HelloThrift.thrift
Server.go
文件package main import ( "./gen-go/hellothrift" "git.apache.org/thrift.git/lib/go/thrift" "context" ) const ( NET_WORK_ADDR = "localhost:9092" ) type HelloServiceTmpl struct { } func (this *HelloServiceTmpl) SayHello(ctx context.Context, str string) (s string, err error) { return "Go-Server:" + str, nil } func main() { transportFactory := thrift.NewTTransportFactory() protocolFactory := thrift.NewTBinaryProtocolFactoryDefault() transportFactory = thrift.NewTBufferedTransportFactory(8192) transport, _ := thrift.NewTServerSocket(NET_WORK_ADDR) handler := &HelloServiceTmpl{} processor := hellothrift.NewHelloServiceProcessor(handler) server := thrift.NewTSimpleServer4(processor, transport, transportFactory, protocolFactory) server.Serve() }
Client.go
文件package main import ( "./gen-go/hellothrift" "git.apache.org/thrift.git/lib/go/thrift" "fmt" "context" "os" ) func main() { var transport thrift.TTransport args := os.Args protocolFactory := thrift.NewTBinaryProtocolFactoryDefault() transport, _ = thrift.NewTSocket(args[1]) transportFactory := thrift.NewTBufferedTransportFactory(8192) transport, _ = transportFactory.GetTransport(transport) //defer transport.Close() transport.Open() client := hellothrift.NewHelloServiceClientFactory(transport, protocolFactory) str, _ := client.SayHello(context.Background(), "Go-Client") fmt.Println(str) }
開一個新窗口,運行下面命令:golang
go run Server.go
go run Server.go # localhost:9092 python3 Server.py # localhost:9091
php Client.php localhost:9091 php Client.php localhost:9092
python3 Client.py localhost:9091 python3 Client.py localhost:9092
go run Client.go localhost:9091 go run Client.go localhost:9092