# 1. 创建 socket 对象       socket.socket()
# 2. 和服务器建立连接         socket对象.connect()
# 3. 发送数据给服务器         socket对象.send()
# 4. 客户端接收服务器发送的信息 socket对象.recv()
# 5. 关闭连接                socket对象.close()
# (3. 4 可以重复进行)

str: 使用引号引起来的就是字符串
bytes: 二进制类型的数据
str  --> bytes str.encode(编码类型)
bytes--> str   bytes.decode(编码类型)

import socket
# 1. 创建 socket 对象
# socket.AF_INET 表示 ipv4 AF_INET6 表示 ipv6
# socket.SOCK_STREAM 表示 tcp协议
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 2. 和服务器建立连接(参数是元组)
client_socket.connect(('192.168.1.5', 8080))
print('和服务器建立连接成功')
# 3. 发送数据给服务器
# 3.1 准备数据(bytes)
send_info = '你好服务器'.encode()
# 3.2 发送数据
client_socket.send(send_info)
# 4. 客户端接收服务器发送的信息,参数表示一次接收多少字节
buf = client_socket.recv(4096)
try:print(f'接收到: {buf.decode()}')
except UnicodeError:print(f'接收到: {buf.decode("gbk")}')
# 5. 关闭连接
client_socket.close()

和服务器建立连接成功
接收到: 你好

# 1. 创建 socket 对象
# 2. 绑定 IP 和端口
# 3. 设置监听, 将主动套接字变为被动套接字
# 4. 等待客户端链接阻塞等待
# 5. 接收客户端的信息
# 6. 给客户端发送信息
# 7. 关闭套接字

import socket
# 1. 创建 socket 对象
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 2. 绑定 IP 和端口(参数是元组)
server_socket.bind(('', 9999)) # IP 地址为空表示绑定的是王机中任意一个ip
# 3. 设置监听, 将主动套接字变为被动套接字,参数表示最多允许多少客户端同时请求服务器(不包括已经连接成功的)
server_socket.listen(128)
# 4. 等待客户端链接阻塞等待
print('等待客户端连接')
# 返回值是元组类型(用于通信socket，客户端的 IP 和端口
new_socket, ip_port = server_socket.accept()
print(f'客户端 {ip_port} 上线')
# 5. 接收客户端的信息
buf = new_socket.recv(4096)
print(f'接收到: {buf.decode()}')
# 6. 给客户端发送信息
new_socket.send('信息收到'.encode())
# 7. 关闭套接字
new_socket.close()
server_socket.close()

等待客户端连接
客户端 ('192.168.1.5', 65439) 上线
接收到: 你好服务器

# 参数1 level,设置哪个级别的socket, socket.SOL_SOCKET当前的socket(固定写法)
# 参数2 option, 设置什么内容, socket.SO_REUSEADDR 端口复用
# 参数3 将内容设置为什么值, True
server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, True)

# buf: 字符串(容器)都可以直接作为 bool 类型进行判断,当容器中元素的个数为 0, 是 False, 其余是 True
if len(buf) == 0:pass
if buf:  # if not buf:pass

import socket
import threadingdef handle_client_request(new_socket, ip_port):while True:buf = new_socket.recv(4096)if buf:try:print(f'接收到: {buf.decode()}')new_socket.send('信息收到'.encode())except UnicodeDecodeError:print(f'接收到: {buf.decode("gbk")}')new_socket.send('信息收到'.encode("gbk"))else:print(f'{ip_port} 下线')breaknew_socket.close()if __name__ == '__main__':# 1. 创建 socket 对象server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)# 设置端口复用server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, True)# 2. 绑定server_socket.bind(('', 9999))# 3. 设置监听server_socket.listen(128)# 4. 循环等待客户端链接阻塞等待print('等待客户端连接')while True:# 返回值是元组类型，（用于通信socket，客户端的Lio和端口port】，拆包new_socket, ip_port = server_socket.accept()print(f'客户端 {ip_port} 上线')sub_thread = threading.Thread(target=handle_client_request, args=(new_socket, ip_port))sub_thread.start()