使用Thrift0.9.1实现跨语言调用Golang、Php、Python、Java

Go 前端之家
前端之家收集整理的这篇文章主要介绍了使用Thrift0.9.1实现跨语言调用Golang、Php、Python、Java，前端之家小编觉得挺不错的，现在分享给大家，也给大家做个参考。

http://www.aboutyun.com/thread-8916-1-1.html

一、什么是Thrift

　　Thrift是一种可伸缩的跨语言服务的发展软件框架。它结合了功能强大的软件堆栈的代码生成引擎，以建设服务。
　　Thrift是facebook开发的，07年4月开放源代码，08年5月进入apache孵化器。创造Thrift是为了解决facebook系统中各系统间大数据量的传 输通信以及系统之间语言环境不同需要跨平台的特性。所以thrift可以支持多种程序语言，例如:C++,Java,Python,PHP,Ruby,Erlang,Perl,Haskell,C#,Cocoa,JavaScript,Node.js,Smalltalk,and OCaml. (目前0.9.1版本已经开始支持golang语言)在多种不同的语言之间通信thrift可以作为二进制的高性能的通讯中间件，支持数据(对象)序列化和多种类型的RPC服务。
　　Thrift允许你定义一个简单的定义文件中的数据类型和服务接口。以作为输入文件，编译器生成代码用来方便地生成RPC客户端和服务器通信的无缝跨编程语言。简而言之，开发者只需准备一份thrift脚本，通过thrift code generator（像gcc那样输入一个命令）就能生成所要求的开发语言代码。

　　类似Thrift的工具，还有Avro、protocol buffer,但相对于Thrift来讲，都没有Thrift支持全面和使用广泛。

1) thrift内部框架一瞥
　　按照官方文档给出的整体框架，Thrift自下到上可以分为4层：
+-------------------------------------------+
| Server |-- 服务器进程调度
| (single-threaded,event-driven etc) |
+-------------------------------------------+
| Processor |-- RPC接口处理函数分发，IDL定义接口的实现将挂接到这里面
| (compiler generated) |
+-------------------------------------------+
| Protocol |-- 协议
| (JSON,compact etc) |
+-------------------------------------------+
| Transport |-- 网络传输
| (raw TCP,HTTP etc) |
+-------------------------------------------+

　　Thrift实际上是实现了C/S模式，通过代码生成工具将接口定义文件生成服务器端和客户端代码（可以为不同语言），从而实现服务端和客户端跨语言的支持。用户在Thirft描述文件中声明自己的服务，这些服务经过编译后会生成相应语言的代码文件，然后用户实现服务（客户端调用服务，服务器端提服务）便可以了。其中protocol（协议层,定义数据传输格式，可以为二进制或者XML等）和transport（传输层，定义数据传输方式，可以为TCP/IP传输，内存共享或者文件共享等）被用作运行时库。

2)支持的数据传输格式、数据传输方式和服务模型
　　　　（a）支持的传输格式
　　　　　　TBinaryProtocol – 二进制格式.
　　　　　　TCompactProtocol – 压缩格式
　　　　　　TJSONProtocol – JSON格式
　　　　　　TSimpleJSONProtocol –提供JSON只写协议,生成的文件很容易通过脚本语言解析。
　　　　　　TDebugProtocol – 使用易懂的可读的文本格式，以便于debug
　　　　（b） 支持的数据传输方式
　　　　　　TSocket -阻塞式socker
　　　　　　TFramedTransport – 以frame为单位进行传输，非阻塞式服务中使用。
　　　　　　TFileTransport – 以文件形式进行传输。
　　　　　　TMemoryTransport – 将内存用于I/O. java实现时内部实际使用了简单的ByteArrayOutputStream。
　　　　　　TZlibTransport – 使用zlib进行压缩， 与其他传输方式联合使用。当前无java实现。
　　　　（c）支持的服务模型
　　　　　　TSimpleServer – 简单的单线程服务模型，常用于测试
　　　　　　TThreadPoolServer – 多线程服务模型，使用标准的阻塞式IO。
　　　　　　TNonblockingServer – 多线程服务模型，使用非阻塞式IO（需使用TFramedTransport数据传输方式）

　　　　3) Thrift IDL
　　Thrift定义一套IDL（Interface Definition Language）用于描述接口，通常后缀名为.thrift，通过thrift程序把.thrift文件导出成各种不一样的代码的协议定义。IDL支持的类型可以参考这里： http://thrift.apache.org/docs/types

二、Thrift的官方网站在哪里？
　　 http://thrift.apache.org/


三、在哪里下载？需要哪些组件的支持？
　　Thrift的官方下载地址在这里： http://www.apache.org/dyn/closer ... thrift-0.9.1.tar.gz
　　(现在官网打包后的0.9.1版本在make的时候会出各种问题，后文会介绍不建议使用官网提供的0.9.1包)

　　Thrift的安装依赖，以及相关语言支持所需要的库，以下是来自官方文档的介绍：
　　　　Basic requirements
　　　　　　A relatively POSIX-compliant *NIX system
　　　　　　　　Cygwin or MinGW can be used on Windows
　　　　　　g++ 4.2
　　　　　　boost 1.53.0
　　　　　　Runtime libraries for lex and yacc might be needed for the compiler.
　　　　Requirements for building from source
　　　　　　GNU build tools:
　　　　　　　　autoconf 2.65
　　　　　　　　automake 1.9
　　　　　　　　libtool 1.5.24
　　　　　　pkg-config autoconf macros (pkg.m4)
　　　　　　lex and yacc (developed primarily with flex and bison)
　　　　　　libssl-dev
　　　　Language requirements
　　　　These are only required if you choose to build the libraries for the given language
　　　　　　C++
　　　　　　　　Boost 1.53.0
　　　　　　　　libevent (optional,to build the nonblocking server)
　　　　　　　　zlib (optional)
　　　　　　Java
　　　　　　　　Java 1.7
　　　　　　　　Apache Ant
　　　　　　C#: Mono 1.2.4 (and pkg-config to detect it) or Visual Studio 2005+
　　　　　　Python 2.6 (including header files for extension modules)
　　　　　　PHP 5.0 (optionally including header files for extension modules)
　　　　　　Ruby 1.8
　　　　　　　　bundler gem
　　　　　　Erlang R12 (R11 works but not recommended)
　　　　　　Perl 5
　　　　　　　　Bit::Vector
　　　　　　　　Class::Accessor

四、如何安装？
1) 安装依赖插件

  1. root@m1:/home/hadoop#sudo apt-get install libboost-dev libboost-test-dev libboost-program-options-dev libevent-dev automake libtool flex bison pkg-config g++ libssl-dev
复制代码

2) 安装最新版PHP5(因为后文会使用PHP来测试客户端与Golang服务端的交互)
  1. #先添加PHPkey
  2. root@m2:/home/hadoop/thrift-git# add-apt-repository ppa:ondrej/PHP5
  3. You are about to add the following PPA to your system:
  4. This branch follows latest PHP packages as maintained by me & rest of the Debian pkg-PHP team.

  6. You can get more information about the packages at https://sury.org

  8. If you need to stay with PHP 5.4 you can use the oldstable PHP repository:

  10. ppa:ondrej/PHP5-oldstable

  12. BUGS&FEATURES: This PPA now has a issue tracker: https://deb.sury.org/pages/bugreporting.html

  14. PLEASE READ: If you like my work and want to give me a little motivation,please consider donating: https://deb.sury.org/pages/donate.html
  15. More info: https://launchpad.net/~ondrej/+archive/ubuntu/PHP5
  16. Press [ENTER] to continue or ctrl-c to cancel adding it

  18. gpg: 钥匙环‘/tmp/tmpZ7PZIy/secring.gpg’已建立
  19. gpg: 钥匙环‘/tmp/tmpZ7PZIy/pubring.gpg’已建立
  20. gpg: 下载密钥‘E5267A6C’，从 hkp 服务器 keyserver.ubuntu.com
  21. gpg: /tmp/tmpZ7PZIy/trustdb.gpg：建立了信任度数据库
  22. gpg: 密钥 E5267A6C：公钥“Launchpad PPA for Ondřej Sury”已导入
  23. gpg: 合计被处理的数量：1
  24. gpg: 已导入：1(RSA: 1)
  25. OK
  26. root@m2:/home/hadoop/thrift-git# apt-get update
  27. root@m1:/home/hadoop/thrift-git# apt-get install PHP5-dev PHP5-cli PHPunit
复制代码

3) 下载thirft0.9.1版本
  1. root@m2:/home/hadoop# git clone https://github.com/apache/thrift.git thrift-git
  2. Cloning into 'thrift-git'...
  3. remote: Counting objects: 37193,done.
  4. remote: Compressing objects: 100% (216/216),done.
  5. remote: Total 37193 (delta 319),reused 407 (delta 272)
  6. Receiving objects: 100% (37193/37193),9.62 MiB | 50 KiB/s,done.
  7. Resolving deltas: 100% (25794/25794),done.

  9. root@m1:/home/hadoop#cd thrift-git
  10. root@m2:/home/hadoop/thrift-git# git checkout -b 0.9.1
  11. Switched to a new branch '0.9.1'
复制代码

4) 编译安装
  1. root@m1:/home/hadoop/thrift-git#./bootstrap.sh
  2. root@m1:/home/hadoop/thrift-git# ./configure --enable-thrift_protocol

  4. #下面是截取部分运行成功后的信息
  5. thrift 0.9.1

  7. Building C++ Library ......... : yes
  8. Building C (GLib) Library .... : yes
  9. Building Java Library ........ : no
  10. Building C# Library .......... : no
  11. Building Python Library ...... : yes
  12. Building Ruby Library ........ : no
  13. Building Haskell Library ..... : no
  14. Building Perl Library ........ : no
  15. Building PHP Library ......... : yes
  16. Building Erlang Library ...... : no
  17. Building Go Library .......... : no
  18. Building D Library ........... : no

  20. C++ Library:
  21. Build TZlibTransport ...... : yes
  22. Build TNonblockingServer .. : yes
  23. Build TQTcpServer (Qt) .... : no

  25. Python Library:
  26. Using Python .............. : /usr/bin/python

  28. PHP Library:
  29. Using PHP-config .......... : /usr/bin/PHP-config

  31. If something is missing that you think should be present,
  32. please skim the output of configure to find the missing
  33. component.Details are present in config.log.
复制代码

如果在安装Thrift时，不需要支持的扩展，可以在使用./configure的时候带上以下参数
  1. ./configure --without-PHP --without-ruby --without-haskell --without-python --without-perl
复制代码

继续安装这个时间会长一点
  1. root@m2:/home/hadoop/thrift-git# make
  2. root@m2:/home/hadoop/thrift-git# make install
复制代码

我们可以看到thrift已经安装完成,当前版本是0.9.1
  1. root@m1:/home/hadoop/thrift-git# thrift -version
  2. Thrift version 0.9.1
复制代码


五、Golang、Java、Python、PHP之间通过Thrift实现跨语言调用
　　在写代码之前，我们先来配置Thrift的协议库IDL文件：
  1. root@m1:/home/hadoop/thrift-git/tutorial# vi idoall.org.thrift
  2. namespace go idoall.org.demo
  3. namespace java idoall.org.demo
  4. namespace PHP idoall.org.demo
  5. namespacepy idoall.org.demo

  7. struct Student{
  8. 1: i32 sid,
  9. 2: string sname,
  10. 3: bool ssex=0,
  11. 4: i16 sage,
  12. }

  14. const map<string,string> MAPCONSTANT = {'hello':'world','goodnight':'moon'}

  16. service idoallThrift {
  17. list<string> CallBack(1:i64 callTime,2:string name,3:map<string,string> paramMap),
  18. void put(1: Student s),
  19. }
复制代码

编译IDL文件，生成相关代码
  1. root@m1:/home/hadoop/thrift-git/tutorial# thrift -r --gen go idoall.org.thrift
  2. root@m1:/home/hadoop/thrift-git/tutorial# thrift -r --gen py idoall.org.thrift
  3. root@m1:/home/hadoop/thrift-git/tutorial# thrift -r --gen PHP idoall.org.thrift
  4. root@m1:/home/hadoop/thrift-git/tutorial# thrift -r --gen java idoall.org.thrift
复制代码

如果编译IDL的PHP包要生成server端代码，和其他语言不太一样，可以使用thrift --help查看使用说明，需要加上server选项，如下：
  1. root@m1:/home/hadoop/thrift-git/tutorial# thrift -r --gen PHP:server idoall.org.thrift
复制代码

1) Golang 客户端和服务端的实现及交互
Golang1.3的安装，请参考这篇文章《 ubuntu12.04 64bit基于源码安装golang1.3》，默认使用apt-get安装不是最新版。

#安装golang的Thrift包：


  1. root@m1:/home/hadoop/thrift-git/tutorial# go get git.apache.org/thrift.git/lib/go/thrift
复制代码

#将Thrift生成的开发库也复制到GOPATH中
  1. root@m1:/home/hadoop/thrift-git/tutorial# cp -r /home/hadoop/thrift-git/tutorial/gen-go/idoall $GOPATH/src
复制代码

#编写go server端代码（后面的代码，我们都放在/home/hadoop/thrift_demo目录中进行演示）
  1. root@m1:/home/hadoop# mkdir thrift_demo
  2. root@m1:/home/hadoop# cd thrift_demo/
  3. root@m1:/home/hadoop/thrift_demo# vi s.go
复制代码
  1. package main

  3. import (
  4. "idoall/org/demo"
  5. "fmt"
  6. "git.apache.org/thrift.git/lib/go/thrift"
  7. "os"
  8. )

  10. const (
  11. NetworkAddr = "0.0.0.0:10086"
  12. )

  14. type idoallThrift struct {
  15. }

  17. func (this *idoallThrift) CallBack(callTime int64,name string,paramMap map[string]string) (r []string,err error) {
  18. fmt.Println("-->from client Call:",callTime,name,paramMap)
  19. r = append(r,"key:"+paramMap["a"]+" value:"+paramMap["b"])
  20. return
  21. }

  23. func (this *idoallThrift) Put(s *demo.Student) (err error){
  24. fmt.Printf("Stduent--->id: %d\tname:%s\tsex:%t\tage:%d\n",s.Sid,s.Sname,s.Ssex,s.Sage)
  25. return nil
  26. }

  28. func main() {
  29. transportFactory := thrift.NewTFramedTransportFactory(thrift.NewTTransportFactory())
  30. protocolFactory := thrift.NewTBinaryProtocolFactoryDefault()
  31. //protocolFactory := thrift.NewTCompactProtocolFactory()

  33. serverTransport,err := thrift.NewTServerSocket(NetworkAddr)
  34. if err != nil {
  35. fmt.Println("Error!",err)
  36. os.Exit(1)
  37. }

  39. handler := &idoallThrift{}
  40. processor := demo.NewIdoallThriftProcessor(handler)

  42. server := thrift.NewTSimpleServer4(processor,serverTransport,transportFactory,protocolFactory)
  43. fmt.Println("thrift server in",NetworkAddr)
  44. server.Serve()
  45. }
复制代码

#编写go client端代码
  1. root@m1:/home/hadoop/thrift_demo# vi c.go
  2. package main

  4. import (
  5. "idoall/org/demo"
  6. "fmt"
  7. "git.apache.org/thrift.git/lib/go/thrift"
  8. "net"
  9. "os"
  10. "time"
  11. "strconv"
  12. )

  14. const (
  15. HOST = "127.0.0.1"
  16. PORT = "10086"
  17. )

  19. func main() {
  20. startTime := currentTimeMillis()

  22. transportFactory := thrift.NewTFramedTransportFactory(thrift.NewTTransportFactory())
  23. protocolFactory := thrift.NewTBinaryProtocolFactoryDefault()

  25. transport,err := thrift.NewTSocket(net.JoinHostPort(HOST,PORT))
  26. if err != nil {
  27. fmt.Fprintln(os.Stderr,"error resolving address:",err)
  28. os.Exit(1)
  29. }

  31. useTransport := transportFactory.GetTransport(transport)
  32. client := demo.NewIdoallThriftClientFactory(useTransport,protocolFactory)
  33. if err := transport.Open(); err != nil {
  34. fmt.Fprintln(os.Stderr,"Error opening socket to "+HOST+":"+PORT," ",err)
  35. os.Exit(1)
  36. }
  37. defer transport.Close()

  39. for i := 0; i < 5; i++ {
  40. paramMap := make(map[string]string)
  41. paramMap["a"] = "idoall"
  42. paramMap["b"] = "org"+strconv.Itoa(i+1)
  43. r1,_ := client.CallBack(time.Now().UnixNano() / 1000000,"go client",paramMap)
  44. fmt.Println("GOClient Call->",r1)
  45. }

  47. model := demo.Student{11,"student-idoall-go",true,20}
  48. client.Put(&model)
  49. endTime := currentTimeMillis()
  50. fmt.Printf( "本次调用用时:%d-%d=%d毫秒\n",endTime,startTime,(endTime - startTime))

  52. }

  54. func currentTimeMillis() int64 {
  55. return time.Now().UnixNano() / 1000000
  56. }
复制代码

#运行go服务端(可以看到服务端已经在监听本机的10086端口)
  1. root@m1:/home/hadoop/thrift_demo# go run s.go
  2. thrift server in 0.0.0.0:10086
复制代码

#运行go客户端
  1. root@m1:/home/hadoop/thrift_demo# go run c.go
  2. GOClient Call-> [key:idoall value:org1]
  3. GOClient Call-> [key:idoall value:org2]
  4. GOClient Call-> [key:idoall value:org3]
  5. GOClient Call-> [key:idoall value:org4]
  6. GOClient Call-> [key:idoall value:org5]
  7. 本次调用用时:1408267333489-1408267333486=3毫秒
  8. root@m1:/home/hadoop/thrift_demo#
复制代码

#查看go服务端，可以看到数据的交互
  1. root@m1:/home/hadoop/thrift_demo# go run s.go
  2. thrift server in 0.0.0.0:10086
  3. -->from client Call: 1408267333487 go client map[a:idoall b:org1]
  4. -->from client Call: 1408267333487 go client map[a:idoall b:org2]
  5. -->from client Call: 1408267333488 go client map[b:org3 a:idoall]
  6. -->from client Call: 1408267333488 go client map[a:idoall b:org4]
  7. -->from client Call: 1408267333488 go client map[a:idoall b:org5]
  8. Stduent--->id: 11 name:student-idoall-gosex:true age:20
复制代码

2) python 客户端的实现与golang 服务端的交互
#将python用到的Thrift包复制到thrift_demo里面

  1. root@m1:/home/hadoop/thrift_demo# cp -r /home/hadoop/thrift-git/lib/py/build /home/hadoop/thrift_demo/libpy
  2. root@m1:/home/hadoop/thrift_demo# cp -r /home/hadoop/thrift-git/tutorial/gen-py /home/hadoop/thrift_demo/gen-py
复制代码

#编写python client代码
  1. root@m1:/home/hadoop/thrift_demo# vi c.py
  2. #!/usr/bin/env python
  3. # -*- coding: utf-8 -*-
  4. import sys,glob,time,datetime
  5. sys.path.append('gen-py')
  6. sys.path.insert(0,glob.glob('libpy/lib.*')[0])

  8. from idoall.org.demo import idoallThrift
  9. from idoall.org.demo.ttypes import *

  11. from thrift import Thrift
  12. from thrift.transport import TSocket
  13. from thrift.transport import TTransport
  14. from thrift.protocol import TBinaryProtocol

  16. try:
  17. startTime = time.time()*1000
  18. # Make socket
  19. transport = TSocket.TSocket('127.0.0.1',10086)

  21. # Framed is critical. Raw sockets are very slow
  22. transport = TTransport.TFramedTransport(transport)

  24. # Wrap in a protocol
  25. protocol = TBinaryProtocol.TBinaryProtocol(transport)

  27. # Create a client to use the protocol encoder
  28. client = idoallThrift.Client(protocol)

  30. # Connect!
  31. transport.open()

  33. for i in range(1,6):
  34. r = client.CallBack(time.time()*1000,"python client",{"a":"idoall","b":"org"+str(i)})
  35. print "PythonClient Call->%s" %(r)

  37. u1 = Student()
  38. u1.sid=111
  39. u1.sname='student-idoall-python'
  40. u1.ssex=False
  41. u1.sage=200
  42. client.put(u1)

  44. endTime = time.time()*1000

  46. print "本次调用用时:%d-%d=%d毫秒" %(endTime,(endTime - startTime))
  47. # Close!
  48. transport.close()

  50. except Thrift.TException,tx:
  51. print 'ERROR:%s' % (tx.message)
复制代码

#运行go服务端
  1. root@m1:/home/hadoop/thrift_demo# go run s.go
  2. thrift server in 0.0.0.0:10086
复制代码

#运行python客户端
  1. root@m1:/home/hadoop/thrift_demo# python c.py
  2. PythonClient Call->['key:idoall value:org1']
  3. PythonClient Call->['key:idoall value:org2']
  4. PythonClient Call->['key:idoall value:org3']
  5. PythonClient Call->['key:idoall value:org4']
  6. PythonClient Call->['key:idoall value:org5']
  7. 本次调用用时:1408268651648-1408268651646=2毫秒
  8. root@m1:/home/hadoop/thrift_demo#
复制代码

#查看go服务端，可以看到数据的交互
  1. root@m1:/home/hadoop/thrift_demo# go run s.go
  2. thrift server in 0.0.0.0:10086
  3. -->from client Call: 1408268651646 python client map[b:org1 a:idoall]
  4. -->from client Call: 1408268651646 python client map[a:idoall b:org2]
  5. -->from client Call: 1408268651647 python client map[a:idoall b:org3]
  6. -->from client Call: 1408268651647 python client map[a:idoall b:org4]
  7. -->from client Call: 1408268651647 python client map[a:idoall b:org5]
  8. Stduent--->id: 111 name:student-idoall-python sex:false age:200
复制代码

3) PHP 客户端的实现与golang 服务端的交互
#编译PHP的Thrift扩展

  1. root@m1:/home/hadoop/thrift_demo# cd /home/hadoop/thrift-git/lib/PHP/src/ext/thrift_protocol
  2. root@m1:/home/hadoop/thrift-git/lib/PHP/src/ext/thrift_protocol# ls
  3. acinclude.m4 build config.h.inconfig.nice configure include ltmain.sh Makefile.global mkinstalldirs PHP_thrift_protocol.h thrift_protocol.la
  4. aclocal.m4 config.guessconfig.log config.statusconfigure.ininstall-shMakefile Makefile.objectsmodules PHP_thrift_protocol.lo
  5. autom4te.cacheconfig.h config.m4 config.sub config.w32 libtool Makefile.fragmentsmissing PHP_thrift_protocol.cpprun-tests.PHP
  6. root@m1:/home/hadoop/thrift-git/lib/PHP/src/ext/thrift_protocol# PHPize
  7. Configuring for:
  8. PHP Api Version: 20121113
  9. Zend Module Api No: 20121212
  10. Zend Extension Api No: 220121212
  11. root@m1:/home/hadoop/thrift-git/lib/PHP/src/ext/thrift_protocol# ./configure
  12. ##以下只给出部分输出信息
  13. checking for grep that handles long lines and -e... /bin/grep
  14. checking for egrep... /bin/grep -E
  15. checking for a sed that does not truncate output... /bin/sed
  16. checking for cc… cc
  17. …
  18. …
  19. config.status: creating config.h
  20. config.status: config.h is unchanged
  21. config.status: executing libtool commands
  22. #执行make命令后，我们可以看到扩展文件放到了/usr/lib/PHP5/20121212/目录
  23. root@m1:/home/hadoop/thrift-git/lib/PHP/src/ext/thrift_protocol# make && make install

  25. Build complete.
  26. Don't forget to run 'make test'.

  28. Installing shared extensions: /usr/lib/PHP5/20121212/
复制代码

#让PHP支持thrift,编辑PHP.ini文件，搜索extension_dir，然后在下面加上extension=thrift_protocol.so，保存退出。
  1. root@m1:/home/hadoop/thrift-git/lib/PHP/src/ext/thrift_protocol# vi /etc/PHP5/fpm/PHP.ini
  2. ; Directory in which the loadable extensions (modules) reside.
  3. ; http://PHP.net/extension-dir
  4. ; extension_dir = "./"
  5. ; On windows:
  6. ; extension_dir = "ext"
  7. extension=thrift_protocol.so
复制代码

#重启PHP5-fpm
  1. root@m1:/home/hadoop/thrift-git/lib/PHP/src/ext/thrift_protocol# service PHP5-fpm restart
  2. PHP5-fpm stop/waiting
  3. PHP5-fpm start/running,process 16522
  4. root@m1:/home/hadoop/thrift-git/lib/PHP/src/ext/thrift_protocol#
复制代码

#将PHP用到的Thrift包复制到thrift_demo里面
  1. root@m1:/home/hadoop/thrift-git/lib/PHP/src/ext/thrift_protocol# mkdir -p /home/hadoop/thrift_demo/libPHP/
  2. root@m1:/home/hadoop/thrift-git/lib/PHP/src/ext/thrift_protocol# cp -r /home/hadoop/thrift-git/lib/PHP/src/* /home/hadoop/thrift_demo/libPHP/
  3. root@m1:/home/hadoop/thrift-git/lib/PHP/src/ext/thrift_protocol# cp -r /home/hadoop/thrift-git/lib/PHP/lib/Thrift /home/hadoop/thrift_demo/libPHP
  4. root@m1:/home/hadoop/thrift-git/lib/PHP/src/ext/thrift_protocol# cp -r /home/hadoop/thrift-git/tutorial/gen-PHP /home/hadoop/thrift_demo/gen-PHP
  5. root@m1:/home/hadoop/thrift-git/lib/PHP/src/ext/thrift_protocol# cd /home/hadoop/thrift_demo
复制代码

#编写PHP client端代码
  1. root@m1:/home/hadoop/thrift_demo# vi c.PHP
  2. <?PHP

  4. $startTime = getMillisecond();
  5. $GLOBALS['THRIFT_ROOT'] = './libPHP'; # 指定库目录，可以是绝对路径或是相对路径
  6. require_once $GLOBALS['THRIFT_ROOT'].'/Thrift/ClassLoader/ThriftClassLoader.PHP';

  8. use Thrift\ClassLoader\ThriftClassLoader;
  9. use Thrift\Protocol\TBinaryProtocol;
  10. use Thrift\Transport\TSocket;
  11. use Thrift\Transport\TSocketPool;
  12. use Thrift\Transport\TFramedTransport;
  13. use Thrift\Transport\TBufferedTransport;

  15. $GEN_DIR = realpath(dirname(__FILE__)).'/gen-PHP';

  17. $loader = new ThriftClassLoader();
  18. $loader->registerNamespace('Thrift',$GLOBALS['THRIFT_ROOT']); # 加载thrift
  19. $loader->registerDefinition('idoall\org\demo',$GEN_DIR); # 加载自己写的thrift文件编译的类文件和数据定义
  20. $loader->register();

  22. $socket = new TSocket('127.0.0.1',10086); # 建立socket
  23. $socket->setDebug(TRUE);
  24. $framedSocket = new TFramedTransport($socket); #这个要和服务器使用的一致
  25. $transport = $framedSocket;
  26. $protocol = new TBinaryProtocol($transport); # 这里也要和服务器使用的协议一致
  27. $transport->open();

  29. $client= new \idoall\org\demo\idoallThriftClient($protocol);# 构造客户端

  31. for($i=1;$i<6;$i++)
  32. {
  33. $item = array();
  34. $item["a"] = "idoall";
  35. $item["b"] = "org"+$i;
  36. $result = $client->CallBack(getMillisecond(),"PHP client",$item); # 对服务器发起rpc调用
  37. echo "PHPClient Call->".implode('',$result)."\n";
  38. }

  40. $s = new \idoall\org\demo\Student();
  41. $s->sid=1111;
  42. $s->sname="student-idoall-PHP";
  43. $s->ssex = false;
  44. $s->sage = 2000;
  45. $client->put($s);
  46. $endTime = getMillisecond();

  48. echo "本次调用用时:".$endTime."-".$startTime."=".($endTime-$startTime)."毫秒\n";

  50. function getMillisecond() {
  51. list($t1,$t2) = explode(' ',microtime());
  52. return (float)sprintf('%.0f',(floatval($t1) + floatval($t2)) * 1000);
  53. }

  55. $transport->close(); # 关闭链接
复制代码

#运行go服务端
  1. root@m1:/home/hadoop/thrift_demo# go run s.go
  2. thrift server in 0.0.0.0:10086
复制代码

#运行PHP客户端
  1. root@m1:/home/hadoop/thrift_demo# PHP c.PHP
  2. PHPClient Call->key:idoall value:1
  3. PHPClient Call->key:idoall value:2
  4. PHPClient Call->key:idoall value:3
  5. PHPClient Call->key:idoall value:4
  6. PHPClient Call->key:idoall value:5
  7. 本次调用用时:1408268739277-1408268739269=8毫秒
复制代码
#查看go服务端，可以看到数据的交互
  1. root@m1:/home/hadoop/thrift_demo# go run s.go
  2. thrift server in 0.0.0.0:10086
  3. -->from client Call: 1408268739272 PHP client map[a:idoall b:1]
  4. -->from client Call: 1408268739273 PHP client map[a:idoall b:2]
  5. -->from client Call: 1408268739274 PHP client map[a:idoall b:3]
  6. -->from client Call: 1408268739275 PHP client map[a:idoall b:4]
  7. -->from client Call: 1408268739275 PHP client map[a:idoall b:5]
  8. Stduent--->id: 1111 name:student-idoall-PHP sex:false age:2000
复制代码

4) java 客户端的实现与golang 服务端的交互
#安装maven项目管理工具

  1. root@m1:/home/hadoop/thrift_demo# apt-get install maven
复制代码

#将java用到的Thrift包复制到thrift_demo里面
  1. root@m1:/home/hadoop/thrift_demo# cp -r /home/hadoop/thrift-git/tutorial/gen-java .
  2. root@m1:/home/hadoop/thrift_demo# cd gen-java
  3. root@m1:/home/hadoop/thrift_demo/gen-java# mkdir -p src/main/java
  4. root@m1:/home/hadoop/thrift_demo/gen-java# mkdir Meta-INF
  5. root@m1:/home/hadoop/thrift_demo/gen-java# mkdir lib
  6. root@m1:/home/hadoop/thrift_demo/gen-java# cp -r /home/hadoop/thrift-git/lib/java/build/libthrift-0.9.1.jar ./lib/
复制代码

#编写java client端代码
  1. root@m1:/home/hadoop/thrift_demo/gen-java# vi idoall/org/demo/c.java
  2. package idoall.org.demo;

  4. import java.util.HashMap;
  5. import java.util.List;
  6. import java.util.Map;

  8. import org.apache.thrift.TException;
  9. import org.apache.thrift.protocol.TBinaryProtocol;
  10. import org.apache.thrift.protocol.TProtocol;
  11. import org.apache.thrift.transport.TFramedTransport;
  12. import org.apache.thrift.transport.TSocket;
  13. import org.apache.thrift.transport.TTransport;
  14. import org.apache.thrift.transport.TTransportException;


  17. public class c {

  19. public static final String SERVER_IP = "m1";
  20. public static final int SERVER_PORT = 10086;
  21. public static final int TIMEOUT = 30000;

  23. /**
  24. * @param args
  25. */
  26. public static void main(String[] args) {

  28. long startTime=System.currentTimeMillis(); //获取开始时间
  29. TTransport transport = null;
  30. try {
  31. transport = new TFramedTransport(new TSocket(SERVER_IP,
  32. SERVER_PORT,TIMEOUT));
  33. // 协议要和服务端一致
  34. TProtocol protocol = new TBinaryProtocol(transport);
  35. idoallThrift.Client client = new idoallThrift.Client(
  36. protocol);
  37. transport.open();

  39. for(int i=1;i<6;i++)
  40. {
  41. Map<String,String> m = new HashMap<String,String>();
  42. m.put("a","idoall");
  43. m.put("b","org"+i);

  45. List<String> result = client.CallBack(System.currentTimeMillis(),"java client",m);
  46. System.out.println("JAVAClient Call->" + result);
  47. }

  49. Student s = new Student();
  50. s.sid=1111;
  51. s.sname="student-idoall-java";
  52. s.ssex = true;
  53. s.sage = 20000;
  54. client.put(s);
  55. long endTime = System.currentTimeMillis();
  56. System.out.println("本次调用用时:" + endTime + "-" + startTime + "=" + (endTime - startTime)+"毫秒");

  58. } catch (TTransportException e) {
  59. e.printStackTrace();
  60. } catch (TException e) {
  61. e.printStackTrace();
  62. } finally {
  63. if (null != transport) {
  64. transport.close();
  65. }
  66. }
  67. }
  68. }
复制代码

#配置jar包的MANIFEST文件
  1. root@m1:/home/hadoop/thrift_demo/gen-java# vi Meta-INF/MANIFEST.MF
  2. Manifest-Version: 1.0
  3. Main-Class: idoall.org.demo.c
  4. Class-Path: lib/**.jar
复制代码

#制作Maven的描述文件pom.xml
  1. root@m1:/home/hadoop/thrift_demo/gen-java# vi pom.xml
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3. xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  4. <modelVersion>4.0.0</modelVersion>
  5. <groupId>idoall.org.demo</groupId>
  6. <artifactId>idoall.org.demo</artifactId>
  7. <version>0.0.1-SNAPSHOT</version>
  8. <packaging>jar</packaging>
  9. <name>idoall.org.demo</name>
  10. <url>http://maven.apache.org</url>
  11. <properties>
  12. <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  13. </properties>
  14. <dependencies>
  15. <dependency>
  16. <groupId>junit</groupId>
  17. <artifactId>junit</artifactId>
  18. <version>3.8.1</version>
  19. <scope>test</scope>
  20. </dependency>
  21. <dependency>
  22. <groupId>org.apache.thrift</groupId>
  23. <artifactId>libthrift</artifactId>
  24. <version>0.9.1</version>
  25. </dependency>
  26. <dependency>
  27. <groupId>org.slf4j</groupId>
  28. <artifactId>slf4j-log4j12</artifactId>
  29. <version>1.5.8</version>
  30. </dependency>
  31. </dependencies>
  32. <build>
  33. <plugins>
  34. <plugin>
  35. <artifactId>maven-assembly-plugin</artifactId>
  36. <configuration>
  37. <archive>
  38. <manifest>
  39. <mainClass>idoall.org.demo.c</mainClass>
  40. </manifest>
  41. </archive>
  42. <descriptorRefs>
  43. <descriptorRef>jar-with-dependencies</descriptorRef>
  44. </descriptorRefs>
  45. </configuration>
  46. </plugin>

  48. <plugin>
  49. <groupId>org.apache.maven.plugins</groupId>
  50. <artifactId>maven-compiler-plugin</artifactId>
  51. <configuration>
  52. <source>1.6</source>
  53. <target>1.6</target>
  54. </configuration>
  55. </plugin>
  56. </plugins>
  57. </build>
  58. </project>
复制代码

#使用maven工具，将相关依赖打包到当前目录的target目录中，并生成idoall.org.demo-0.0.1-SNAPSHOT-jar-with-dependencies.jar
  1. root@m1:/home/hadoop/thrift_demo/gen-java# mv idoall src/main/java/
  2. root@m1:/home/hadoop/thrift_demo/gen-java# mvn assembly:assembly
  3. #以下只给出部分提示信息
  4. [INFO] ------------------------------------------------------------------------
  5. [INFO] BUILD SUCCESS
  6. [INFO] ------------------------------------------------------------------------
  7. [INFO] Total time: 7.618s
  8. [INFO] Finished at: Sun Aug 17 09:36:48 CST 2014
  9. [INFO] Final Memory: 12M/29M
  10. [INFO] ------------------------------------------------------------------------
复制代码

#运行go服务端
  1. root@m1:/home/hadoop/thrift_demo# go run s.go
  2. thrift server in 0.0.0.0:10086
复制代码

#运行打包后的java客户端
  1. root@m1:/home/hadoop/thrift_demo/gen-java# java -jar target/idoall.org.demo-0.0.1-SNAPSHOT-jar-with-dependencies.jar
  2. JAVAClient Call->[key:idoall value:org1]
  3. JAVAClient Call->[key:idoall value:org2]
  4. JAVAClient Call->[key:idoall value:org3]
  5. JAVAClient Call->[key:idoall value:org4]
  6. JAVAClient Call->[key:idoall value:org5]
  7. 本次调用用时:1408268973582-1408268973477=105毫秒
复制代码

#查看go服务端，可以看到数据的交互
  1. root@m1:/home/hadoop/thrift_demo# go run s.go
  2. thrift server in 0.0.0.0:10086
  3. -->from client Call: 1408268973547 java client map[a:idoall b:org1]
  4. -->from client Call: 1408268973568 java client map[b:org2 a:idoall]
  5. -->from client Call: 1408268973568 java client map[b:org3 a:idoall]
  6. -->from client Call: 1408268973568 java client map[b:org4 a:idoall]
  7. -->from client Call: 1408268973569 java client map[b:org5 a:idoall]
  8. Stduent--->id: 1111 name:student-idoall-java sex:true age:20000
复制代码

猜你在找的Go相关文章

golang简单实现jwt验证(beego、xorm、jwt)
程序目录结构 简单实现，用户登录后返回一个jwt的token，下次请求带上token请求用户信息接...
【工程实践】利用go语言写一个简单的Pow样例
本篇博客的主要内容是用go写一个简单的Proof-of-Work共识机制，不涉及到网络通信环节，只是...
【工程实践】go语言实现MerkleTree
简介 默克尔树（MerkleTree）是一种典型的二叉树结构，其主要特点为： 最下面的叶节点包含...
第九章 goroutine
接下来学习并发编程, 并发编程是go语言最有特色的地方, go对并发编程是原生支持. goroutin...
第十一章 运用广度优先搜索走迷宫
先普及一下, 什么是广度优先搜索 广度优先搜索类似于树的层次遍历。从图中的某一顶点出发，...
第十三章 go实现分布式网络爬虫---单机版爬虫
爬虫的分类 网络爬虫分为两类 1. 通用爬虫: 类似于baidu, google. 他们会把大量的数据挖下...
第十章 channel select 总结
感觉channel在理解起来还有点费劲的, 尤其是select的使用, 既要可以读数据, 又要可以写数据...
第十五章 并发版爬虫第二版 -- 完结
并发版爬虫, 在上一篇单机版爬虫的基础上演变而来 这里只有并发引擎的代码, 基本的解析器代...
第八章--性能优化--pprof详细研究
接着上次的博客:&#160;https://www.cnblogs.com/ITPower/articles/12315637.html ppro...
第八章 测试与性能调优--生成文档和测试示例代码
java也可以生成文档, 就像一个手册一样, 可以用来查看方法, 接口, 下面我们给go项目生成文...
PHPJavaJava SEPythonC#C&C++RubyVBasp.NetGoPerlnettyDjangoDelphiJsp.NET CoreSpringFlaskSpringbootSpringMVCLuaLaravelMybatisAspGroovyThinkPHPYiiswoole
文件时间pythonm相等性PHP Warning时间问题问题解决pcntl_signal采样点wav模块动态文本调用频率限制对外暴露多个访问请求更新数据表模型结构type()方法比较速度手写体sobel算子保存模型Image类nn.Conv2dpytorch1.0kaggleDCGAN交并比range()用法打印模型反卷积卷积