Python - 【socket】客户端client重连处理简单示例Demo（一）

一. 前言

在Python中，使用socket进行网络通信时，如果连接断开，可以通过以下步骤实现重连处理

二. 示例代码

1. 定义一个函数，用于建立socket连接

import socketdef connect_socket(host, port):while True:try:# 建立socket连接sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)sock.connect((host, port))print('Socket connected')return sockexcept socket.error as e:print('Socket error:', e)time.sleep(5)

这个函数使用一个while循环，不断地尝试建立socket连接，如果出现socket.error异常，则打印异常信息并等待5秒钟重试。当连接成功时，函数会返回一个连接套接字。

2. 在主程序中使用连接函数

在主程序中，可以使用上述定义的连接函数来建立socket连接。如果连接断开，程序会自动进行重连，如下所示：

def main():host = 'example.com'port = 8888sock = connect_socket(host, port)# 循环处理数据while True:try:# 从socket中读取数据data = sock.recv(1024)# 处理数据...except socket.error as e:print('Socket error:', e)sock = connect_socket(host, port)

在这个程序中，先通过连接函数来建立socket连接，并将连接套接字保存在变量sock中。然后进入一个无限循环中，从socket中读取数据并进行处理。一旦出现socket.error异常，就说明连接已经断开，此时程序会调用连接函数来进行重连。重连成功后，程序会继续读取数据。

3. 完整代码：

import socket
import timedef connect_socket(host, port):while True:try:# 建立socket连接sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)sock.connect((host, port))print('Socket connected')return sockexcept socket.error as e:print('Socket client reconnect =====> {}, Socket error:{}'.format('5s', e))time.sleep(5)def main(host, port):sock = connect_socket(host, port)# 循环处理数据while True:try:# 从socket中读取数据data = sock.recv(1024)# 处理数据...except socket.error as e:print('Socket recv data error:', e)sock = connect_socket(host, port)if __name__ == '__main__':host = '127.0.0.1'port = 8080# connect_socket(host, port)main(host, port)