Python实现TCP通信的示例代码
使用socket实现tcp通信，需导入socket模块
1、服务端
主要步骤：
（1）创建socket：socket.socket(family=AF_INET,type=SOCK_STREAM,proto=0,fileno=None)
family：AF_INET,AF_INET6,AF_UNIX,AF_CAN,AF_PACKET, AF_RDS
type：SOCK_STREAM,SOCK_DGRAM,SOCK_RAW,或者其他SOCK_*
proto：一般使用默认值0
fileno：一般使用默认值
（2）绑定IP和端口号：socket.bind(address)
address：使用(host,port)元组即可
（3）监听：socket.listen([backlog])
backlog：就理解为最大连接数
（4）接受连接：socket.accept()
返回(conn,address)元组，分别是已连接客户端的socket对象和地址
（5）发送/接受数据：socket.recv(bufsize[,flags])/socket.send(bytes[,flags])
bufsize：接收的数据最大字节数
bytes：需要发送的数据字节数
（6）关闭连接：socket.close()
#!/usr/bin/python
#-*-coding:UTF-8-*-
#文件名：tcpserver.py
importsocket
importtime
MaxBytes=1024*1024
server=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
server.settimeout(60)
host='127.0.0.1'
#host=socket.gethostname()
port=11223
server.bind((host,port))#绑定端口
server.listen(1)#监听
try:
client,addr=server.accept()#等待客户端连接
print(addr,"连接上了")
whileTrue:
data=client.recv(MaxBytes)
ifnotdata:
print('数据为空，我要退出了')
break
localTime=time.asctime(time.localtime(time.time()))
print(localTime,'接收到数据字节数:',len(data))
print(data.decode())
client.send(data)
exceptBaseExceptionase:
print("出现异常：")
print(repr(e))
finally:
server.close()#关闭连接
print("我已经退出了，后会无期")
这个实例没有创建其他线程，也只接收一个客户端的连接；为了能手动结束或自动结束accept和recv的阻塞，设置了超时60秒，并将主体部分放入到try语句中；将socket的关闭放到finally块中，可以防止程序异常退出，而导致没有调用close函数。
2、客户端
主要步骤：
（1）创建socket：socket.socket(family=AF_INET,type=SOCK_STREAM,proto=0,fileno=None)
（2）连接：socket.connect(address)
address：使用(host,port)元组即可
（3）发送/接受数据：socket.recv(bufsize[,flags])/socket.send(bytes[,flags])
（4）关闭连接：socket.close()
#!/usr/bin/python
#-*-coding:UTF-8-*-
#文件名：tcpclient.py
importsocket
importtime
MaxBytes=1024*1024
host='127.0.0.1'
port=11223
client=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
client.settimeout(30)
client.connect((host,port))
whileTrue:
inputData=input();#等待输入数据
if(inputData=="quit"):
print("我要退出了，再见")
break
sendBytes=client.send(inputData.encode())
ifsendBytes<=0:
break;
recvData=client.recv(MaxBytes)
ifnotrecvData:
print('接收数据为空，我要退出了')
break
localTime=time.asctime(time.localtime(time.time()))
print(localTime,'接收到数据字节数:',len(recvData))
print(recvData.decode())
client.close()
print("我已经退出了，后会无期")
以上客户端连接成功后等待用户输入，然后将输入信息发送到服务端，服务端将数据原样返回给客户端，如果客户端输入quit就会跳出循环并关闭socket，这时服务端recv会返回空从而跳出循环并关闭socket。希望对大家的学习有所帮助，也希望大家多多支持毛票票。