Python实现TCP通信的示例代码

Python  /  管理员 发布于 7年前   204

使用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 import socketimport timeMaxBytes=1024*1024 server = socket.socket(socket.AF_INET,socket.SOCK_STREAM)server.settimeout(60)host = '127.0.0.1'#host = socket.gethostname()port = 11223server.bind((host, port))    # 绑定端口 server.listen(1)           # 监听try:  client,addr = server.accept()     # 等待客户端连接  print(addr," 连接上了")  while True:    data = client.recv(MaxBytes)    if not data:      print('数据为空，我要退出了')      break    localTime = time.asctime( time.localtime(time.time()))    print(localTime,' 接收到数据字节数:',len(data))    print(data.decode())    client.send(data)except BaseException as e:  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 import socketimport timeMaxBytes=1024*1024host ='127.0.0.1'port = 11223client = socket.socket(socket.AF_INET,socket.SOCK_STREAM)client.settimeout(30)client.connect((host,port))while True:  inputData=input();     #等待输入数据  if(inputData=="quit"):    print("我要退出了，再见")    break  sendBytes = client.send(inputData.encode())  if sendBytes<=0:    break;  recvData = client.recv(MaxBytes)  if not recvData:    print('接收数据为空，我要退出了')    break  localTime = time.asctime( time.localtime(time.time()))  print(localTime, ' 接收到数据字节数:',len(recvData))  print(recvData.decode())client.close()print("我已经退出了，后会无期")

以上客户端连接成功后等待用户输入，然后将输入信息发送到服务端，服务端将数据原样返回给客户端，如果客户端输入quit就会跳出循环并关闭socket，这时服务端recv会返回空从而跳出循环并关闭socket。希望对大家的学习有所帮助，也希望大家多多支持。