基于TCP协议的套接字编程

套接字

套接字有两种，分别是基于文件型和基于网络型

• 基于文件类型的套接字家族：AF_UNIX，unix一切皆文件，基于文件的套接字调用的就是底层的文件系统来取数据，两个套接字进程运行在同一机器，可以通过访问同一文件系统间接完成通信
• 基于网络类型的套接字家族：AF_INET

套接字工作流程

服务器端先初始化Socket，然后与端口绑定(bind)，对端口进行监听(listen)，调用accept阻塞，等待用户端连接。在这时如果有个客户端初始化一个Socket，然后连接服务器(connect)，如果连接成功，这时客户端与服务器端的连接就建立了。客户端发送数据请求，服务器端接收请求并处理请求，然后把回应数据发送给客户端，客户端读取数据，最后关闭连接

基于TCP协议的套接字编程（简单）

服务端

import socket# 创建符合TCP协议的服务端
server = socket.socket(socket.AF_INET,socket.SOCK_STREAM)  # TCP协议称为流失协议，UDP称为数据报协议SOCK_DGRAM# 绑定端口
server.bind(('127.0.0.1', 8000))  # 127.0.0.1代表本地# 对端口进行监听
server.listen(5)  # 半连接池，限制的是请求书# 等待客户端连接
print('start....')
conn, client_addr = server.accept()
print('conn: ', conn)
print('client_addr: ', client_addr)# 收到消息
data = conn.recv(1024)  # 限制最大接收的字节数
print('来自客户端的数据: ', data)# 回消息
conn.send(data.upper())  # 将数据变大写# 关闭连接
conn.close()# 关闭服务器
server.close()

客户端

import socket# 创建符合TCP协议的客户端
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)# 连接服务端端口
client.connect(('127.0.0.1', 8000))# 发送消息
client.send('hello'.encode('utf8'))# 接收服务端返回的消息
data = client.recv(1024)
print('来自服务端的数据：', data)# 关闭客户端
client.close()

基于TCP协议的套接字编程（循环）

服务端

import socket# 创建符合TCP协议的服务端
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)# 绑定端口
server.bind(('127.0.0.1', 8000))# 对端口进行监听
server.listen(5)# 等待客户端连接
print('start...')# 链接循环
while True:conn, client_addr = server.accept()# 通信循环while True:try:# 接收消息data = conn.recv(1024)print('来自客户端的数据：', data)# 回消息conn.send(data)except ConnectionResetError:  # 捕捉客户端与服务端关闭连接break

客户端1

import socket# 创建符合TCP协议的客户端
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)# 连接服务端端口
client.connect(('127.0.0.1', 8000))while True:# 发送消息msg = input('please enter msg>>>')client.send(msg.encode('utf8'))# 接收消息data = client.recv(1024)print('来自服务端的数据：', data.upper())

客户端2

import socket# 创建符合TCP协议的客户端
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)# 连接服务端端口
client.connect(('127.0.0.1', 8000))while True:# 发送消息msg = input('please enter msg>>>')client.send(msg.encode('utf8'))# 接收消息data = client.recv(1024)print('来自服务端的数据：', data.upper())

在服务器连接客户端1时，虽然能监听客户端2，但不能给客户端2返回消息，将客户端1关闭后即断开连接，给客户端2返回数据