Thrift-简单实用

摘要：安装作用跨语言调用，打破不同语言之间的隔阂。跨项目调用，微服务的么么哒。示例前提版本的版本版本版本说明该示例包含三种语言。

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...等语言，使之它们之间无缝结合、高效服务。

brew install thrift

跨语言调用，打破不同语言之间的隔阂。
跨项目调用，微服务的么么哒。

thrift版本：

Go的版本、Php版本、Python版本：

该示例包含python,php,go三种语言。（java暂无）

进入目录

cd /Users/birjemin/Developer/Php/study-php

编写HelloThrift.thrift

vim HelloThrift.thrift

内容如下：

namespace php HelloThrift {
  string SayHello(1:string username)
}

加载thrift-php库

composer require apache/thrift

生成php版本的thrift相关文件

cd /Users/birjemin/Developer/Php/study-php
thrift -r --gen php:server HelloThrift.thrift

这时目录中生成了一个叫做gen-php的目录。

建立Server.php文件

registerDefinition("HelloThrift",$GEN_DIR);
$loader->register();

class HelloHandler implements HelloThriftHelloServiceIf
{
    public function SayHello($username)
    {
        return "Php-Server: " . $username;
    }
}

$handler   = new HelloHandler();
$processor = new HelloThriftHelloServiceProcessor($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文件

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 HelloThriftHelloServiceClient($protocol);
$transport->open();
echo $client->SayHello("Php-Client");
$transport->close();

测试

php Client.php --http

加载thrift-python3模块（只测试python3,python2就不测试了）

pip3 install thrift

生成python3版本的thrift相关文件

thrift -r --gen py HelloThrift.thrift

这时目录中生成了一个叫做gen-py的目录。

建立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()

测试

开一个新窗口，运行下面命令：

python3 Server.php

加载go的thrift模块

go get git.apache.org/thrift.git/lib/go/thrift

生成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)
}

测试

开一个新窗口，运行下面命令：

go run Server.go

开启两个窗口，保证server开启

go run Server.go # localhost:9092
python3 Server.py # localhost:9091

php调用go-server、py-server

php Client.php localhost:9091
php Client.php localhost:9092

python3调用go-server、py-server

python3 Client.py localhost:9091
python3 Client.py localhost:9092

go调用go-server、py-server

go run Client.go localhost:9091
go run Client.go localhost:9092

没有测试php的socket，go、python3的http，可以花时间做一下

代码纯属组装，没有深刻了解其中原理，后期打算写一篇理论篇和封装类库篇

https://studygolang.com/articles/1120

https://www.cnblogs.com/qufo/p/5607653.html

https://www.cnblogs.com/lovemdx/archive/2012/11/22/2782180.html

https://github.com/yuxel/thrift-examples

http://thrift.apache.org/