acwing linux 基础课第六讲 thrift

2023-12-22 06:50:25

文章目录

1.thrift是什么?

2.thrift通信的3个步骤

3.本课作业

这节课讲解thrift

thrift是什么?

thrift是一个跨语言的RPC(Remote Procedure Call)框架,用于远程通信。

通常来说,一个应用系统(System),可能会由多个服务(Service)组成,多个服务(Service)可能会部署在多台服务器(Server)上。而这些服务之间可能需要进行通信,这时就需要网络通信的参与了,而RPC框架,就是把网络通信的细节给封装和隐藏起来,只暴露一些简单的接口,使得不同服务之间的远程调用变得简单,并提升了开发效率。

官网:https://thrift.apache.org/

thrift通信的3个步骤

定义接口

定义server

定义client

QuickStart => 官网教程

首先在服务器上安装thrift环境(略过)

接着

编写一个.thrift文件,这个文件是对接口的定义,比如编写一个match.thrift,定义如下的添加/删除用户的接口

?
// match.thrift

namespace cpp match_service



struct User {

??? 1: i32 id,

??? 2: string name,

??? 3: i32 score

}



service Match {



??? /**

???? * user: 添加的用户信息

???? * info: 附加信息

???? * 在匹配池中添加一个名用户

???? */

??? i32 add_user(1: User user, 2: string info),



??? /**

???? * user: 删除的用户信息

???? * info: 附加信息

???? * 从匹配池中删除一名用户

???? */

??? i32 remove_user(1: User user, 2: string info),

}

?

运行thrift命令,对上一步定义的接口,生成源代码

比如,针对如上定义的接口,生成RPC需要的代码(C++),只需执行命令

thrift -r --gen cpp match.thrift

就会得到如下的文件

如果想要生成Java代码,则执行命令

thrift -r --gen java match.thrift

则得到

生成的代码里既包含了服务端的代码,也包含了客户端的代码,按需要进行删减和保留即可。

本课作业

本节课的作业:实现3个模块

游戏模块

匹配模块

数据存储模块(已实现)

3个模块之间会进行通信

游戏模块可以通过RPC,调用匹配模块的add_user,remove_user方法,来将一个玩家添加到匹配池里,或从匹配池里移除。

而匹配模块,负责将当前匹配池里的玩家,进行匹配,每当成功匹配了2个玩家,匹配模块就药把匹配的结果,保存到数据存储模块中。

即,我们定义3个接口,分别是add_userremove_user,save_result,前2个接口我们称为match服务,后1个接口我们称为save服务。

则,匹配模块是match服务的server,游戏模块是match服务的client,数据存储模块是save服务的server,匹配模块是save服务的client。

我们用thrift定义好接口后,需要在各自模块上生成server端和client端的RPC代码。

在AC Terminal上创建一个文件夹

thrift_lesson,再创建2个子文件夹game_system,,match_system。分别表示2个模块。再创建一个文件夹thrift_api,存放定义的接口,先来定义游戏模块和匹配模块之间的交互接口,创建一个文件,名为match.thrift,在里面按照thrift的语法,定义好接口

namespace cpp match_service



// 定义一个User对象

struct User {

? 1: i32 id,

? 2: string name,

? 3: i32 score

}



// 定义交互的接口

service Match {

??? /**

???? * user: 添加的用户

???? * info: 额外信息

???? * 在匹配池中添加一个用户

??? **/

??? i32 add_user(1: User user, 2: string info),

???

??? /**

???? * user: 删除的用户

???? * info: 额外信息

???? * 从匹配池中删除一个用户

??? **/

??? i32 remove_user(1: User user, 2: string info),

}

正文:随后,通过如下命令,自动生成一份C++版本的thrift服务端代码:

thrift -r --gen cpp match.thrift

可以看到在当前目录下生成了一堆文件

我们把其中的Match_server.skeleton.cpp拷贝一份,重命名为main.cpp然后对其内容进行一些修改。

编译,编译全部的cpp文件

g++ -c main.cpp match_server/*.cpp

编译了多少个cpp文件,就会生成多少个.o文件,下一步将这些.o文件链接起来即可

链接(需要加thrift的动态链接库)

g++ *.o -o main -lthrift

随后,便可以通过 ./main 来运行匹配模块了。

随后,我们编写游戏模块,用python3进行编写,它是上面定义的2个函数add_user和remove_user的客户端。

thrift -r --gen py match.thrift

生成的是服务端的代码,我们需要从thrift官网上找到客户端代码的例子,直接拷贝过来,然后略加修改即可。

from match_client.match import Match

from match_client.match.ttypes import User



from thrift import Thrift

from thrift.transport import TSocket

from thrift.transport import TTransport

from thrift.protocol import TBinaryProtocol

from sys import stdin



def operate(op, user_id, username, score):

??? # Make socket

??? transport = TSocket.TSocket('localhost', 9090)



??? # Buffering is critical. Raw sockets are very slow

??? transport = TTransport.TBufferedTransport(transport)



??? # Wrap in a protocol

??? protocol = TBinaryProtocol.TBinaryProtocol(transport)



??? # Create a client to use the protocol encoder

??? client = Match.Client(protocol)

???????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????

??? # Connect!

??? transport.open()

??? user = User(user_id, username, score)

??? if op == "add":

??????? client.add_user(user, "")

??? elif op == "remove":

??????? client.remove_user(user, "")

??? # Close!

??? transport.close()



def main():

??? for line in stdin:

??????? op, user_id, username, score = line.split(' ')

??????? operate(op, int(user_id), username, int(score))



if __name__ == "__main__":

??? main()

随后,修改match服务端的代码。实现匹配机制,使用多线程。

修改好match服务端的代码后,先重新编译一下main.cpp然后重新链接

g++ -c main.cpp

g++ *.o -o main -lthrift -pthread

然后,最后一步实现将匹配结果保存到数据存储服务器上。针对save.thrift生成对应的的代码,然后略加修改即可。

注:生成密码的md5sum

md5sum 敲回车,然后输入自己的密码

然后敲回车,然后按Ctrl + D,就会生成一个 md5,拷贝前8位

文章来源:https://blog.csdn.net/m0_74202561/article/details/135124654
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。