文章目录
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_user,remove_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 m服务器托管网atch_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位
服务器托管,北京服务器托管,服务器租用 http://www.fwqtg.net
相关推荐: RustRover 中最常见的 Rust 编译器错误(上)| 技术解析
Rust 编译器相当挑剔, 如果它对输入的源代码不满意,可能会发出 400 多种不同的错误(而且每个月都在增加!)。有些错误极其罕见,另一些则每天都困绕着 Rust 开发者。在这个博文系列中,我们将介绍开发者在 RustRover(JetBrains 推出的专…