复习功课
第一篇地址
第二篇地址
第三篇地址
逐渐讲述回包
间接入正题，第三篇曾经提到了如何收到回包，以后这个主题网络编程都是讲 Tcp，协定申请形式自身会决定个性，咱们这里先讲和发包收包程序无关的。
Tcp 首先是一个双工的，意思就是客户端 C 端发消息给 S 端，S 端也能够发消息给客户端，传输协定数据类型外面传输在网卡那层都是二进制文件流。为啥是流而不是包能够回顾之前的，也能够抉择死记硬背。
那么 C 端是不是发给 S 端音讯，S 端肯定是要回复的呢，这个是未必的。因为在协定申请/传输方式还会传输协定数据类型，这个类型和业务是间接无关的，大体能够分为须要应答和不须要应答。不须要应答的最常见的就是心跳包。这里为啥要叫包而不是叫心跳流呢，只能说是一种通用的叫法。
当客户端链接上服务后，每隔约一段时间，往服务器固定传输一段信息，就和人的心电图一样，证实以后客户端是沉闷的。如果不沉闷服务器会把客户端对象断开（Tcp 挥手），这里不沉闷个别是指多少次没有收到，才会判断不沉闷。
断开的益处，这里能够这样记忆，每个 socket 链接是肯定有老本的，放弃链接状态也一样，每个 socket 做一些事会产生内存变动（这里不思考软件缓存，硬件的几级缓存），如果在把一些数据存储到数据库，就会把内存数据交换到数据库或者数据库缓存，交互过程也会产生内存碎片和数据库 IO 开销。只是是沉闷的，就会依据这个 socket 做得事件产生一系列的非用户态的一些开销，所以有必要剔除不沉闷的申请。
比方 30 分钟没有取得教训/多少分钟没有挪动（挪动也会产生挪动数据包，这个数据包会逐条同步给他四周的沉闷用户），而后就会进入挂机状态，这种其实也是相似把 fb 标记为了不沉闷 (leave = no alive)，不沉闷就只须要定期同步一次。
如果是齐全下线 (close)，这里撇开业务，齐全下线也会主动挂机获取教训。
以上次要缓缓开展客户端发了 3 次 100 个字节后期待几百 ms，然而服务器只回了一组包，这个是 Tcp 独有黏包的问题。
然而发现这样跨度有点大，例子比拟根底，会先来通过一个 Tcp 心跳的例子（分四，五章节）来缓缓往后延长，反正最终都会讲清楚的。
心跳学习和设计
写个例子来做一些直观性的推理和设计，例子也会联合之前的一些知识点。
心跳信息：json 字串 # 实战外面是一个 bytes 模式 这个 butes 会比拟小，只是为了让服务器计数客户端是沉闷的。
详解 服务器那边记录一个客户端连贯句柄的治理字典，链接的客户端对象在服务器那边会是一个"fd"，是否沉闷会是一个字段"status":"alive",""leave","close" 别离代表 沉闷，非沉闷暂离，敞开。
服务器那边进行开发设计，反对状态为一个双向的程序 ("alive"<-->"leave"<-->"close")
对于 status:"alive"状态条件 客户端来说是默认的，没在 socket.error 那层被拦挡掉，所以链接上了，链接上分为地址正确，写法正确，防火墙容许 (这里测试用不上这个)
须要服务器开发：
1.socket 服务器程序
2.惯例接管包
3.判断 4 个字节后的数据在反序列化 json.loads。服务器比客户端多一个 bind 后开启监听的性能，服务器反对多个客户端。
4.匹配性能。服务器收到客户端信息后会进行匹配，有一个游标（第 5 章实现该性能）。
游标比方设置为 3，阈值是 5，多少秒收到一次音讯就-1，多少秒没有收到音讯就 +1.阈值达到一次 5 计数一次，达到 3 次阈值，批改以后客户端链接治理字典为"leave"。达到阈值小于 3 次那么还是 alive。
5.会用一个 user 实例对象列表去治理增加模仿链接进来的客户端。每 10 秒加一个，客户端是模仿假的，端口号 +1。
须要客户端开发的：
1.socket client 程序
2.Json 发包 + 数据结构
3.距离每 10 秒发一次。
对于 status:"leave"状态：记录放弃 30 分钟（代码会写 30 秒）会到下个状态"close"，如果呈现心跳稳固屡次，没有触发到阈值 5，会回退到"alive"。
对于达到 status:"close"服务器会把客户端踢掉，在 user 的列表治理外面，服务器会存储客户端的 ip:端口。
心跳客户端前置
先写这个例子 只有"alive"状态条件，没有切换条件的。依据过来例子，咱们先须要定义一个网络层的数据结构，这次先不必 protobuff。
协定传输用 Tcp 应用通用性高的 struct，传输数据构造为 Json
Tcp 数据结构为包头 4 个字节，4 个字节为外面塞包体长度，那个整个包长度也就是 4 个字节（固定的）+ 包头 4 个字节的取值（动静的包体长度）。
Json C2S {"ip":传递本地 Ip，"status"：下面讲的状态应用默认的,"pid":用于客户端治理本人的} pid 这里次要用于本人杀本人过程。
这里须要补一个常识，第三章未讲完的，就是如果 4 个字节包头长度 + 客户端传递对象是如何写的
# ip_add给服务器的地址ip_addr = socket.gethostbyname(socket.gethostname())# 客户端本地本人治理本人用的pidpid = os.getpid()# 状态切换用的列表，列表有序的，通过idx作为状态机索引，默认是alivestatus = ["alive", "leave", "close"]idx = 0data = {'ip': ip_addr, 'status': status[idx], 'pid': pid}# data的长度，这里有str只是为了上面+应用，int->str不影响上面后果pack_len = str(len(data))print(pack_len) # 输入为3# i是4个字节 +pack_len struct.calcsize是看fmt区域的client_len = struct.calcsize("!i" + pack_len + 's')print(client_len) # 输入为4+3留神看正文，动静计算长度就这么进去了，然而留神了，struct.pack 压包动态化是面向包头外面有几个对象，如果只有一个对象传入 json 输入应该是这样的
本次代码对于压包实例
buffer = json.dumps(data)print(len(buffer))packet_head = struct.pack("!i",len(buffer))buffer_client = packet_head+buffer.encode("utf-8")print(buffer_client) # b'\x00\x00\x008{"ip": "192.168.1.105", "status": "alive", "pid": 26464}'心跳客户端
只蕴含和服务器进行通信，发送 Tcp-stuct，Json，把 json 数据做为心跳包发送了，留神理论心跳确实会是固定的数据，但不会传入这个。
服务器只是解析字符串那样去判断心跳是哪个客户端发的。状态切换性能下个文章再写。
import datetimeimport socket, sys, osimport time, json,structclass HeartBeatClient: interval = 10 #心跳发送距离 def __init__(self, addr: tuple): try: self.client = socket.socket(socket.AF_INET, socket.SOCK_STREAM) self.client.connect(addr) except socket.error as e: print("Error creating socket: %s" % e) sys.exit() def encode_json(self, conn,data:dict): """发包""" buffer = json.dumps(data) print(f"以后客户端收回去包长度{len(buffer)}") packet_head = struct.pack("!i", len(buffer)) conn.send(packet_head + buffer.encode("utf-8")) def loop_client(self, conn: socket.socket): """ 循环客户端 :param conn: :return: """ status = ["alive", "leave", "close"] #状态列表有序 idx = 0 #状态索引 while True: ip_addr = socket.gethostbyname(socket.gethostname()) pid = os.getpid() data = {"ip": ip_addr, "status": status[idx], "pid": pid} buffer = json.dumps(data) try: self.encode_json(conn,buffer) except socket.error: print("client send failed") break else: now =datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S") print({"time":now,"fd":os.getpid(),"status":status[idx]}) time.sleep(self.interval) self.client_close(conn) def client_close(self,conn): if conn: conn.close()if __name__ == '__main__': client = HeartBeatClient(("127.0.0.1", 14000)) client.loop_client(client.client)加固 strcut 传递应用的例子，倡议手敲代码。
心跳服务器
次要是对应这次客户端编写的心跳服务器性能，留神调式是先启动服务器，在启动客户端文件。
为了模仿 fd_port 自增 1,等于好多个客户端连贯入，这里如果不相熟 Threading 的，须要略微自学下。
import socketimport jsonfrom threading import Threadimport astclass HeartBeatServer: def __init__(self, addr: tuple, max: int): self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) self.sock.bind(addr) # 最大反对max个链接数 self.sock.listen(max) self.user = [] def encode_buffer(self, conn: socket.socket, data: str or bytes or dict): """ 发送数据 :param conn: 客户端链接到服务器的句柄 :param data: 数据 :return: """ if isinstance(data, str): data = data.encode("utf-8") elif isinstance(data, dict): data = str(data).encode("utf-8") conn.send(str(data).encode("utf-8")) def match_data(self,recv)->bool: """ 匹配反序列化后的数据 :param recv: :return: """ if isinstance(recv,dict): return recv.get("ip") and recv.get("status") def loop_thread(self, conn: socket.socket, fd_port: int): """ 服务器是只判断客户端的包头是否非法。 :return: """ head_len = 4 self.user.append("192.168.1.105:88888") idx = 1 while True: try: # 不停收包 data = conn.recv(1024 * 4) if len(data) > head_len: recv = json.loads(data[4:]) recv = ast.literal_eval(recv) if not self.match_data(recv): # pop()列表丢进来并且返回丢出的数据，默认是最初一个 print(f"client fd addr:{self.user.pop()} Connected over!") break # 为了模仿fd_port自增1,等于好多个客户端连贯入 self.user.append(f"{recv.get('ip')}:{fd_port + idx}") print(f"以后服务器治理用户-->{self.user}") else: print(f"client fd addr:{self.user[-1]}数据不非法") except socket.error: print(f"client fd addr:{self.user.pop()} Connected over!") break else: idx += 1 conn.close() def start(self): """ 服务启动 :return: """ while True: conn, addr = self.sock.accept() t = Thread(target=self.loop_thread, args=(conn, addr[1])) t.start()if __name__ == '__main__': server = HeartBeatServer(("127.0.0.1", 14000), 100) server.start()这里有一个重要概念
这里为啥不能用 self.sock 是因为 self.sock 是服务器自身的句柄
conn 是服务器收到客户端对象的句柄，所以这个 conn 才是被治理的，当客户端断开时，在服务器通过 conn 进行挥手
如果是 self.sock 服务就敞开了。
结尾
第五章也写了一部分草稿中
本文首发于TesterHome社区，作者是资深游戏测试开发工程师陈子昂。用 Python 写网络编程共四篇，明天分享的是第四篇。原文链接：https://testerhome.com/topics/29411
以上是明天的分享，你学废了吗~
想学习更多干货常识和前沿技术？
想结识测试行业大咖和业界精英？
欢送关注2022 MTSC大会（第十届中国互联网测试开发大会）
业界对MTSC大会的评估：落地、求实、有深度、重分享
中国互联网测试开发大会 Testing Summit China，是由TesterHome发动的软件测试开发行业技术会议。还有个别名：Make Testing Super Cool！
MTSC大会以软件品质保障体系和测试研发技术交换为次要目标，始于 2015 年，已胜利举办了九届。共有 1000+ 家企业，10000+ 测试工程师、测试经理、CTO 参会，受到了全行业的宽泛关注，是中国互联网质量保证行业的顶级会议。
为了保障议题品质，每年都会提前半年进行议题征集，再通过历时数月的审核，最终确定在大会分享的议题。MTSC 2022的议题还在征集中，诚邀各位资深测试技术专家、品质治理经理和测试新秀们自荐/举荐议题！
提交议题形式
间接点击 https://www.wjx.top/vj/wZwCju... 进入投递入口，依照格局进行填写并提交即可，欢送自荐/举荐议题。
议题截止工夫
为便于评审组有更充沛工夫进行评审及与讲师进行沟通优化，为宽广参会者出现更好的议题，议题投稿（可无 PPT，有纲要等议题信息介绍即可）投递截止工夫提前为：2022年3月30日
议题征集评比流程
总体流程：案例提交 > 初审核定 > PPT提交 > 确认议题 > 会议演讲
总体工夫节点：
案例提交 >> 3 月 30 日
初审核定 >> 4 月 15 日
ppt 提交 >> 5 月 15 日
议题确认 >> 5 月 30 日
会议演讲 >> 7 月 22~23 日
分享讲师福利
- 锤炼演讲能力，加强集体品牌
- 取得和业内专家面对面交换的机会，博采众长
- 晋升公司品牌，给本人的团队减少吸引力
- 获取收费的大会门票和材料：
每位讲师都会获赠 1 张大会门票，大会后续的PPT和视频都会第一工夫给到讲师 - 当地讲师由MTSC大会组委会承当差旅费用
MTSC 2022早鸟票已轻轻开售，点击理解详情。