service Sleep {

    // oneway表示该方法没有任何返回值,返回值类型必须为void

    // 客户端调用后不等待服务器响应，直接返回

    // 服务器端收到请求，执行相关业务逻辑后，不返回任何返回值

    oneway void sleep(1: i32 seconds)

}

# -*- coding: utf-8 -*-

import time

import thriftpy

from thriftpy.rpc import make_server

# 根据sleep.thrift文件，在内存中动态构建一个名为"sleep_thriftpy"的module

# 该module中包含了名为Sleep的一个object

sleep_thrift = thriftpy.load("sleep.thrift", module_name="sleep_thrift")

# 官方代码中该Class名称为Dispatcher

# 修改为Sleep只是为了方便读者和sleep.thrift文件中的Sleep服务相对应

class Sleep(object):

    # 该方法对应sleep.thrift文件中的oneway void sleep(1: i32 seconds)

    def sleep(self, seconds):

        print("I'm going to sleep %d seconds" % seconds)

        time.sleep(seconds)

        print("Sleep over!")

def main():

    # 创建一个服务，在127.0.0.1的6000端口进行监听

    # 将class Sleep和module sleep_thrift中名为Sleep的Object绑定

    server = make_server(sleep_thrift.Sleep, Sleep(),

                         '127.0.0.1', 6000)

    print("serving...")

    # 启动服务

    server.serve()

if __name__ == '__main__':

    main()

# -*- coding: utf-8 -*-

import thriftpy

from thriftpy.rpc import make_client

# 根据sleep.thrift文件，动态生成一个名为"sleep_thriftpy"的module

# 该module中包含了名为Sleep的一个object

sleep_thrift = thriftpy.load("sleep.thrift", module_name="sleep_thrift")

def main():

    # 创建一个客户端，该客户端连接127.0.0.1的6000端口

    # 并将该客户端和服务器端的Sleep服务进行绑定

    client = make_client(sleep_thrift.Sleep, '127.0.0.1', 6000)

    # 绑定完成后即可直接调用服务器端相应的方法

    client.sleep(1)

if __name__ == '__main__':

    main()

serving…

I’m going to sleep 1 seconds

Sleep over!