今日内容

• socket模块(套接字)

• 实际应用

• 通讯循环

• 代码优化和链接循环

• 半连接池

socket模块(套接字)

如果我们需要编写基于网络进行数据交互的程序 意味着我们需要自己通过代码来控制我们之前所学习的OSI七层(很繁琐 很复杂 类似于我们自己编写操作系统)

socket类似于操作系统 封装了丑陋复杂的接口提供简单快捷的接口

socket也叫套接字
	基于文件类型的套接字家族(单机)
  	AF_UNIX
  基于网络类型的套接字家族(联网)
  	AF_INET
 
它为我们提供了快捷方式，不需要我们自己去处理OSI七层的每一层

实际应用

# 服务端
import socket

# 1.产生一个socket对象并指定采用的通信协议(TCP)
server = socket.socket()  # 括号内不写参数 默认就是TCP协议 family=AF_INET基于 网络的套接字 type=SOCK_STREAM流式协议即TCP协议
# 2.绑定一个固定的地址(服务端必备的条件)
server.bind(('127.0.0.1', 8080))  # 127.0.0.1为本地回环地址 只有自己的电脑可以访问
# 3.设立半连接池
server.listen(5)
# 4.等待接客
sock, addr = server.accept()  # sock,addr 三次握手
print(sock, addr)  # sock就是双向通道 addr就是客户地址
# 5.服务客人
data = sock.recv(1024)  # 接收客户端发送过来的消息 1024字节
print(data.decode('utf8'))
sock.send('客人你好'.encode('utf8'))  # 给客户端发送消息 注意消息必须是bytes类型
# 6.关闭双向通道
sock.close()  # 四次挥手
# 7.关闭服务端
server.close()  # 店倒闭了

# 客户端
import socket

# 1.产生一个socket对象并指定采用的通信协议(TCP)
client = socket.socket()
# 2.通过服务端的地址链接服务端
client.connect(('127.0.0.1', 8080))
# 3.直接给服务端发送消息
client.send('我来了'.encode('utf8'))
# 4.接收服务端发送过来的消息
data = client.recv(1024)
print(data.decode('utf8'))
# 5.断开与服务端的链接
client.close()

通讯循环

# 1.解决信息固定的问题 聊天内容自定义
	利用input获取用户输入
# 2.解决通信循环的问题 让聊天循环起来
	将双方用于数据交互的代码循环起来 聊天部分用循环包起来	
    
# 服务端
import socket

server = socket.socket()
server.bind(('127.0.0.1', 8080))
server.listen(5)

sock, addr = server.accept()
while True:
    data = sock.recv(1024)  # 获取别人说什么  
    print(f'来自于客户端{addr}的消息:', data.decode('utf8'))  # 解码别人说的啥    
    msg = input('请输入发送给客户端的消息:').strip()
    sock.send(msg.encode('utf8'))  # 回复别人的话 因为基于网络传输 使用二进制编码

    

# 客户端
import socket

client = socket.socket()
client.connect(('127.0.0.1', 8080))
while True:
    msg = input('请输入您想要发送给服务端的消息:').strip()
    client.send(msg.encode('utf8'))  # 给服务端发消息
    data = client.recv(1024)  # 接收服务端回复的消息
    print('来自于服务端发送过来的消息:', data.decode('utf8'))

代码优化和链接循环

1.用户的输入消息不能为空
	本质其实是两边不能都是recv或者send 一定是一方收一方发
    统计长度然后进行判断(len)
# 客户端
while True:
    msg = input('请输入您想要发送给服务端的消息:').strip()
    if len(msg) == 0: # 判断输入的字节是否等于0
        print('不能发送空消息')
        continue
    client.send(msg.encode('utf8'))  # 给服务端发消息
    data = client.recv(1024)  # 接收服务端回复的消息
    print('来自于服务端发送过来的消息:', data.decode('utf8'))
    
    
2、反复重启服务端可能会发生报错: address in use
 解决方法：
# 在最上面放一个
 from socket import SOL_SOCKET,SO_REUSEADDR
# 在bind上面放
 server.setsockopt(SOL_SOCKET,SO_REUSEADDR,1)
  

3.当客户端异常断开的情况下 如何让服务端继续服务其他客人
	
链接循环
"""
如果在windows客户端异常处理退出之后服务端就会直接报错
  mac服务端会有一段时间反复接收空消息延迟报错	
  	处理方式:异常处理、空消息判断
while True:
    sock, addr = server.accept()
    while True:
        try:
            data = sock.recv(1024)  # 获取别人说什么
            if len(data) == 0:
                break
            print(f'来自于客户端{addr}的消息:', data.decode('utf8'))  # 解码别人说的啥
            msg = input('请输入发送给客户端的消息:').strip()
            sock.send(msg.encode('utf8'))  # 回复别人的话 因为基于网络传输 使用二进制编码
        except BaseException:
            break
"""

半连接池

server.listen(5)  # 半连接池
py文件默认只能同时只能运行一次，如果想要单独分开运行多次：
Edit Configuration选择all

当有多个客户端来链接的情况下 我们可以设置等待数量(不考虑并发问题)
假设服务端只有一个人的情况下

在测试半连接池的时候 可以不用input获取消息 直接把消息写死即可 
# 半连接池
  设置最大等待人数 >>>:  节省资源，提升效率