开发者社区> 科技小先锋> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

python thrift 服务端与客户端使用

简介:
+关注继续查看

一、简介

   thrift是一个软件框架,用来进行可扩展且跨语言的服务的开发。它结合了功能强大的软件堆栈和代码生成引擎,以构建在 C++, Java, Python, PHP, Ruby, Erlang, Perl, Haskell, C#, Cocoa, JavaScript, Node.js, Smalltalk, and OCaml 这些编程语言间无缝结合的、高效的服务。

二、安装

    1.下载地址    

1
http://www.apache.org/dyn/closer.cgi?path=/thrift/0.9.2/thrift-0.9.2.tar.gz

    2.安装

1
2
3
4
5
6
7
8
9
10
11
[root@localhost ~]# yum -y groupinstall "Development Tools"
[root@localhost ~]# yum -y install libevent-devel zlib-devel openssl-devel autoconf automake
[root@localhost ~]#  wget http://ftp.gnu.org/gnu/bison/bison-2.5.1.tar.gz 
[root@localhost ~]# tar xf bison-2.5.1.tar.gz
[root@localhost ~]# cd bison-2.5.1
[root@localhost ~]# ./configure --prefix=/usr
[root@localhost ~]# make
[root@localhost ~]# make install
[root@localhost ~]# tar xf thrift-0.9.2.tar.gz 
[root@localhost ~]# cd thrift-0.9.2
[root@localhost thrift-0.9.2]# ./configure -with-lua=no

    3.安装python插件

1
pip install thrift

三、准备服务器端

    1.编辑接口文件 helloworld.thrift:

1
2
3
4
service HelloWorld {
    string ping(),
    string say(1:string msg)
}

    2.编辑 server.py

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
#!/usr/bin/env python 
import socket
import sys
sys.path.append('./gen-py'
from helloworld import HelloWorld 
from helloworld.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 ping(self):   
         return "pong"   
     def say(self, msg):
        ret = "Received: " + msg    
      print ret    
      return ret
#创建服务端
handler = HelloWorldHandler()
processor = HelloWorld.Processor(handler)
#监听端口
transport = TSocket.TServerSocket("localhost", 9090)
#选择传输层
tfactory = TTransport.TBufferedTransportFactory()
#选择传输协议
pfactory = TBinaryProtocol.TBinaryProtocolFactory()
#创建服务端 
server = TServer.TSimpleServer(processor, transport, tfactory, pfactory) 
print "Starting thrift server in python..."
server.serve()
print "done!"

四、准备客户端

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
#!/usr/bin/env python
 
import sys
sys.path.append('./gen-py')
 
from helloworld import HelloWorld #引入客户端类
 
from thrift import Thrift 
from thrift.transport import TSocket
from thrift.transport import TTransport
from thrift.protocol import TBinaryProtocol
 
try:
  #建立socket
  transport = TSocket.TSocket('localhost', 9090)
  #选择传输层,这块要和服务端的设置一致
  transport = TTransport.TBufferedTransport(transport)
  #选择传输协议,这个也要和服务端保持一致,否则无法通信
  protocol = TBinaryProtocol.TBinaryProtocol(transport)
  #创建客户端
  client = HelloWorld.Client(protocol)
  transport.open()
 
  print "client - ping"
  print "server - " + client.ping()
 
  print "client - say"
  msg = client.say("Hello!")
  print "server - " + msg
  #关闭传输
  transport.close()
#捕获异常
except Thrift.TException, ex:
  print "%s" % (ex.message)

ps:亲测通过,吐槽一下,这东西以前都没有听说过,就要拿来开发,还要只是用客户端



本文转自wangfeng7399 51CTO博客,原文链接:http://blog.51cto.com/wangfeng7399/1696108,如需转载请自行联系原作者


版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
python+socket服务端和客户端
python+socket服务端和客户端
0 0
python实现ftp服务端和客户端
python实现ftp服务端和客户端
0 0
python——通过socket实现服务端和客户端的通信
python——通过socket实现服务端和客户端的通信
0 0
python实现两台不同主机之间进行通信(客户端和服务端)——Socket
通过Python进行Socket网络编程 (做一个聊天程序) 可以实现在不同的主机(电脑)之间进行通话。
0 0
Python网络编程——TCP服务端多线程
TCP服务端与多个客户端同时建立套接字,需要一个线程维护一个客户端。
0 0
Python网络编程——TCP服务端程序开发
TCP服务端,需要与客户端建立连接,接收并处理客户端传输来的数据。
0 0
Python 技术篇-requests发送post请求传文件给flask服务端报405、400问题解决方法
Python 技术篇-requests发送post请求传文件给flask服务端报405、400问题解决方法
0 0
Python 套接字-判断socket服务端有没有关闭的方法实例演示,查看socket运行状态
Python 套接字-判断socket服务端有没有关闭的方法实例演示,查看socket运行状态
0 0
twisted:基于python的twisted框架编写一个客户端和服务端的对话聊天空间
twisted:基于python的twisted框架编写一个客户端和服务端的对话聊天空间
0 0
Python socket 实现服务端和客户端数据传输(TCP)
服务器端 import socket #创建一个socket对象 socket_server = socket.socket(socket.AF_INET, socket.SOCK_STREAM) host = "127.
1382 0
文章
问答
文章排行榜
最热
最新
相关电子书
更多
给运维工程师的Python实战课
立即下载
Python 脚本速查手册
立即下载
ACE 区域技术发展峰会:Flink Python Table API入门及实践
立即下载