- thrift是什么？
- thrift通信的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 { i32 add_user(1: User user, 2: string 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 match_service
// 定义一个User对象
struct User {
1: i32 id,
2: string name,
3: i32 score
}
// 定义交互的接口
service Match {
i32 add_user(1: User user, 2: string 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位
