#!/usr/bin/env python
# -*- coding:utf8 -*-
"""服务端"""
import socket #导入模块
"""设置多个对象，绑定不同端口"""
k1 = socket.socket() #创建对象
k1.bind(('127.0.0.1', 9991)) #绑定服务端IP和端口
k1.listen() #监听IP和端口

k2 = socket.socket() #创建对象
k2.bind(('127.0.0.1', 9992)) #绑定服务端IP和端口
k2.listen() #监听IP和端口

k3 = socket.socket() #创建对象
k3.bind(('127.0.0.1', 9993)) #绑定服务端IP和端口
k3.listen() #监听IP和端口
"""将多个对象组合成列表"""
lib = [k1, k2, k3]"""使用自动监听模块"""
import select #导入自动监听多个端口模块
while True:#select()自动监听列表里的socket对象（文件描述符），一旦监听的对象，谁发生了变化（有用户请求），# 就将发生变化对象的客户端连接地址赋值给第一个变量a，第一个变量接收的列表，列表里的每一个元素，就是一个端口的用户连接地址#如果是多个端口在同时连接客户端，那么列表元素就是多个元素a, b, c = select.select(lib, [], [], 1)for k in a: #循环出select()获取到的列表类型客户端连接地址d, e = k.accept() #将循环到的每一个客户端连接地址等待通讯，阻塞d.sendall(bytes("欢迎访问", encoding="utf-8")) #向连接的客户端发送一条消息

#!/usr/bin/env python
# -*- coding:utf8 -*-
"""创建客户端"""
import socket #导入模块
z = socket.socket() #创建socket对象
b = z.connect(('127.0.0.1', 9991,))#连接服务端，在客户端绑定服务端IP和端口

f = z.recv(1024) #客户端接收服务端sendall()发来的信息，1024表示最大接收1024字节
f2 = str(f, encoding='utf-8') #将接收到的服务端字节信息转换成字符串
print(f2) #打印出服务端发来的信息

#!/usr/bin/env python
# -*- coding:utf8 -*-
"""创建客户端"""
import socket #导入模块
z = socket.socket() #创建socket对象
b = z.connect(('127.0.0.1', 9992,))#连接服务端，在客户端绑定服务端IP和端口

f = z.recv(1024) #客户端接收服务端sendall()发来的信息，1024表示最大接收1024字节
f2 = str(f, encoding='utf-8') #将接收到的服务端字节信息转换成字符串
print(f2) #打印出服务端发来的信息

#!/usr/bin/env python
# -*- coding:utf8 -*-
"""服务端"""
import socket #导入模块
k1 = socket.socket() #创建对象
k1.bind(('127.0.0.1', 9991)) #绑定服务端IP和端口
k1.listen() #监听IP和端口
lib = [k1]"""使用自动监听模块"""
import select #导入自动监听多个端口模块
while True:#select()自动监听列表里的socket对象（文件描述符），一旦监听的对象，谁发生了变化（有用户请求），# 就将发生变化对象的客户端连接地址赋值给第一个变量a，第一个变量接收的列表，列表里的每一个元素，就是一个端口的用户连接地址#如果是多个端口在同时连接客户端，那么列表元素就是多个元素a, b, c = select.select(lib, [], [], 1)print("正在监听的socket对象 %d" % len(lib)) #监听的对象有多少个print(a) #监听发生变化的有哪些for k in a: #循环出select()获取到的列表类型客户端连接地址if k == k1: #判断循环到的连接地址等于socket对象，说明有新用户连接d, e = k.accept() #等待请求，获取客户端通讯地址lib.append(d) #将客户端通讯地址追加到列表，传入select()监听通讯变化d.sendall(bytes("你好", encoding="utf-8"))else: #如果不是连接信息，说明是通讯信息try: #监控代码是否出现异常，如果客户端关闭了就会出现异常，没出现异常执行里面的代码fd = k.recv(1024)f = str(fd, encoding="utf-8")g = f + "好"k.sendall(bytes(g, encoding="utf-8"))except Exception as ex: #出现异常将当前通讯对象移除列表，select不在监听lib.remove(k)

#!/usr/bin/env python
# -*- coding:utf8 -*-
"""创建客户端"""
import socket #导入模块
z = socket.socket() #创建socket对象
b = z.connect(('127.0.0.1', 9991,))#连接服务端，在客户端绑定服务端IP和端口
while True:f = z.recv(1024) #客户端接收服务端sendall()发来的信息，1024表示最大接收1024字节f2 = str(f, encoding='utf-8') #将接收到的服务端字节信息转换成字符串print(f2) #打印出服务端发来的信息a = input("输入要发送的信息")z.sendall(bytes(a, encoding="utf-8"))

#!/usr/bin/env python
# -*- coding:utf8 -*-
"""服务端实现读写分离"""
import socket #导入模块
k1 = socket.socket() #创建对象
k1.bind(('127.0.0.1', 9991)) #绑定服务端IP和端口
k1.listen() #监听IP和端口

lib = [k1] #监听的客户连接地址或，客户通讯地址,传给select第一个参数
lib2 = [] #接收客户端通讯地址，传给select第二个参数
jilu = {} #接收字典，里面是客户端发通讯内容的用户通讯地址(键)和通讯内容(值)"""使用自动监听模块"""
import select #导入自动监听多个端口模块
while True:#select()自动监听列表里的socket对象（文件描述符），一旦监听的对象，谁发生了变化（有用户请求），# 就将发生变化对象的客户端连接地址赋值给第一个变量a，第一个变量接收的列表，列表里的每一个元素，就是一个端口的用户连接地址#如果是多个端口在同时连接客户端，那么列表元素就是多个元素a, b, c = select.select(lib, lib2, lib, 1)print("正在监听的socket对象 %d" % len(lib)) #监听的对象有多少个print(a) #监听发生变化的有哪些"""循环判断链接地址或通讯地址，获取客户端通讯信息以及内容"""for k in a: #循环出select()获取到的列表类型客户端连接地址if k == k1: #判断循环到的连接地址等于socket对象，说明有新用户连接d, e = k.accept() #等待请求，获取客户端通讯地址lib.append(d) #将客户端通讯地址追加到列表，传入select()监听通讯变化jilu[d] = [] #将连接用户通讯地址添加到字典为键，值为空列表else: #如果不是连接信息，说明是通讯信息try: #监控代码是否异常fd = k.recv(1024) #获取客户端发的信息except Exception as e: #如果异常将此通讯地址移除列表，停止监听lib.remove(k) #通讯地址移除列表else:fd2 = str(fd, encoding="utf-8") #接收客户端发的信息转换成字符串jilu[k].append(fd2) # 将客户端转换的字符串追加到，字典里当前客户键的，列表里为值lib2.append(k) #将当前客户通讯地址，添加到select第二个参数列表里"""向客户端发信息"""for km in b: #循环select第二个参数列表里的通讯用户jkd = jilu[km][0] #通过通讯用户拿到字典里对应的通讯内容del jilu[km][0] #拿到通讯内容后删除通讯内容km.sendall(bytes(jkd+"好", encoding="utf-8")) #将通讯内容加个好字，在发给客户端lib2.remove(km ) #在通讯列表移除当前通讯地址for fh in c: #如果监听连接出现异常lib.remove(fh) #移除当前连接

#!/usr/bin/env python
# -*- coding:utf8 -*-
"""创建客户端"""
import socket #导入模块
z = socket.socket() #创建socket对象
b = z.connect(('127.0.0.1', 9991,))#连接服务端，在客户端绑定服务端IP和端口
while True:a = input("输入要发送的信息")z.sendall(bytes(a, encoding="utf-8"))f = z.recv(1024) #客户端接收服务端sendall()发来的信息，1024表示最大接收1024字节f2 = str(f, encoding='utf-8') #将接收到的服务端字节信息转换成字符串print(f2) #打印出服务端发来的信息