前情回顾

1. 文件的存储

   blob

2. 网络编程

   什么是网络 : 传输数据

   OSI七层模型 : 网络通信标准模型

   网络协议 : 通信中双方都遵守的约定

   网络地址 : ip port

   客户端 / 服务端

cookie :
理论问题
这是什么–>具体描述–> 好处/作用是什么–>引申–>我用它干了什么

3. 基于udp的网络通信

   socket

   socket()–>bind()–>recvfrom()–>sendto()–>close()

   socket()–>sendto()–>recvfrom()–>close()

1.2.4 UDP套接字特点

• 可能会出现数据丢失的情况
• 传输过程简单，实现容易
• 数据以数据包形式表达传输
• 数据传输效率较高

1.3 TCP 传输方法

1.3.1 TCP传输特点

*** 面向连接的传输服务**

• 传输特征 ： 提供了可靠的数据传输，可靠性指数据传输过程中无丢失，无失序，无差错，无重复。
• 可靠性保障机制（都是操作系统网络服务自动帮应用完成的）：
  • 在通信前需要建立数据连接
  • 确认应答机制
  • 通信结束要正常断开连接

*** 三次握手（建立连接）**

• 客户端向服务器发送消息报文请求连接
• 服务器收到请求后，回复报文确定可以连接
• 客户端收到回复，发送最终报文连接建立

四次挥手（断开连接）

主动方发送报文请求断开连接
被动方收到请求后，立即回复，表示准备断开
被动方准备就绪，再次发送报文表示可以断开
主动方收到确定，发送最终报文完成断开

1.3.2 TCP服务端

创建套接字

sockfd=socket.socket(socket_family,socket_type,proto=0)
功能：创建套接字
参数：socket_family  网络地址类型 AF_INET表示ipv4socket_type  套接字类型 SOCK_STREAM 表示tcp套接字 （也叫流式套接字） proto  通常为0  选择子协议

绑定地址 （与udp套接字相同）

sockfd.listen(n)
功能 ： 将套接字设置为监听套接字，确定监听队列大小
参数 ： 监听队列大小

处理客户端连接请求

connfd,addr = sockfd.accept()
功能： 阻塞等待处理客户端请求
返回值： connfd  客户端连接套接字addr  连接的客户端地址

消息收发

data = connfd.recv(buffersize)
功能 : 接受客户端消息
参数 ：每次最多接收消息的大小
返回值： 接收到的内容
​
n = connfd.send(data)
功能 : 发送消息
参数 ：要发送的内容  bytes格式
返回值： 发送的字节数

关闭套接字 (与udp套接字相同)

1.3.3 TCP客户端

创建TCP套接字
请求连接

sockfd.connect(server_addr)
功能：连接服务器
参数：元组  服务器地址

收发消息

注意： 防止两端都阻塞，recv send要配合

1.3.4 TCP套接字细节
tcp连接中当一端退出，另一端如果阻塞在recv，此时recv会立即返回一个空字串。

tcp连接中如果一端已经不存在，仍然试图通过send向其发送数据则会产生BrokenPipeError

一个服务端可以同时连接多个客户端，也能够重复被连接

tcp粘包问题

产生原因

为了解决数据再传输过程中可能产生的速度不协调问题，操作系统设置了缓冲区
实际网络工作过程比较复杂，导致消息收发速度不一致
tcp以字节流方式进行数据传输，在接收时不区分消息边界

带来的影响

如果每次发送内容是一个独立的含义，需要接收端独立解析此时粘包会有影响。
处理方法

人为的添加消息边界，用作消息之间的分割
控制发送的速度

"""
tcp 服务端循环流程 1特点 : 每次只处理一个客户端事务,处理完一个
客户端再处理下一个重点代码!!!
"""from socket import *# 创建tcp套接字 其实使用默认值就是tcp套接字
tcp_socket = socket(AF_INET,SOCK_STREAM)# 绑定地址
tcp_socket.bind(("0.0.0.0",8888))# 设置监听,让tcp套接字可以被链接
tcp_socket.listen(5)# 处理客户端连接
while True:print("等待客户端连接....")connfd,addr = tcp_socket.accept()print("连接:",addr) # 客户端地址# 先接收后发送 为客户端服务while True:data = connfd.recv(5)# 退出方案2 如果data是空字节串意味着客户端退出if not data:break# 循环退出方案1  收到quit意味着客户端退出了# if data == b"quit":#     breakprint("接收到:",data.decode())connfd.send(b"Thanks#")connfd.close() # 客户端退出链接套接字就没用了# 关闭
tcp_socket.close()

"""
tcp 客户端循环流程 1
重点代码 !!!
"""
from socket import *#  服务端地址
ADDR = ("127.0.0.1",8888)# 默认值就是创建tcp套接字
tcp_socket = socket()# 发起链接 对应 accept
tcp_socket.connect(ADDR)# 发送接受消息
while True:msg = input(">>")# 循环退出方案2  不通知服务端if not msg:breaktcp_socket.send(msg.encode())# 输入quit退出 循环退出方案1# if msg == 'quit':#     breakdata = tcp_socket.recv(1024)print("Server:",data.decode())# 关闭
tcp_socket.close()

"""
tcp 客户端循环流程 2
重点代码 !!!
"""
from socket import *#  服务端地址
ADDR = ("127.0.0.1",8888)while True:msg = input(">>")if not msg:break# 默认值就是创建tcp套接字tcp_socket = socket()# 发起链接 对应 accepttcp_socket.connect(ADDR)tcp_socket.send(msg.encode())data = tcp_socket.recv(1024)print("Server:",data.decode())# 关闭tcp_socket.close()

"""
tcp 服务端循环流程 2特点: 每次收发消息都需要现建立连接一次收发消息结束就要断开连接重点代码!!!
"""from socket import *# 创建tcp套接字 其实使用默认值就是tcp套接字
tcp_socket = socket(AF_INET,SOCK_STREAM)# 绑定地址
tcp_socket.bind(("0.0.0.0",8888))# 设置监听,让tcp套接字可以被链接
tcp_socket.listen(5)# 处理客户端连接
while True:print("等待客户端消息....")connfd,addr = tcp_socket.accept()data = connfd.recv(1024)print("接收到:",data.decode())connfd.send(b"Thanks")connfd.close()# 关闭
tcp_socket.close()

"""
使用udp套接字完成
从客户端输入单词,发送给服务端,从服务端得到
单词的解释 打印出来要求: 客户端可以循环输入单词,直接回车退出服务端利用dict数据库进行单词查询"""from socket import *
import pymysqlclass Database:def __init__(self):# 连接数据库 (连接本机可以不写host和port)self.db = pymysql.connect(user = "root",password = "123456",database = "dict",charset = "utf8")# 创建游标 (执行sql语句获取执行结果的对象)self.cur = self.db.cursor()def close(self):# 关闭游标和数据库连接self.cur.close()self.db.close()def find_word(self,word):sql = "select mean from words where word=%s;"self.cur.execute(sql,[word])result = self.cur.fetchone() # (mean,) None# 分情况讨论if result:return result[0]else:return "Not Found"# 启动服务
def main():# 创建udp套接字udp_socket = socket(AF_INET,SOCK_DGRAM)# 绑定地址udp_socket.bind(("0.0.0.0",8888))db = Database() # 数据库对象while True:# 接受单词word,addr = udp_socket.recvfrom(1024)#得到单词的解释mean = db.find_word(word)# 发送单词解释udp_socket.sendto(mean.encode(),addr)# 关闭套接字udp_socket.close()if __name__ == '__main__':main()"""
查单词客户端"""
from socket import *# 服务端地址写好
address = ("127.0.0.1",8888)# 创建udp套接字
udp_socket = socket(AF_INET,SOCK_DGRAM)# 循环发送
while True:# 输入什么发送什么word = input("Word:")if not word:# msg为空字符串则退出循环breakudp_socket.sendto(word.encode(),address)data,addr = udp_socket.recvfrom(1024)print(word,":",data.decode())# 关闭套接字
udp_socket.close()

"""
练习: 从客户端传递一张图片给服务端,在服务端
以当前日期为名字保存起来思路:  客户端  将文件内容读取出来发送服务端  接收文件内容,写入本地要求 : 文件可能很大,不允许一次性读取循环读取发送
"""from socket import *
import time# 获取图片函数 边接收边写入
def get_image(connfd):filename = "%s-%s-%s.jpg"%time.localtime()[:3]file = open(filename,'wb')# 边接收边写入while True:data = connfd.recv(1024)if not data:breakfile.write(data) # 直接写入字节串file.close()def main():# 创建tcp套接字 其实使用默认值就是tcp套接字tcp_socket = socket(AF_INET,SOCK_STREAM)# 绑定地址tcp_socket.bind(("0.0.0.0",8888))# 设置监听,让tcp套接字可以被链接tcp_socket.listen(5)# 处理客户端连接while True:print("等待客户端连接....")connfd,addr = tcp_socket.accept()print("连接:",addr) # 客户端地址# 接受图片get_image(connfd)connfd.close() # 客户端退出链接套接字就没用了# 关闭tcp_socket.close()if __name__ == '__main__':main()"""
客户端代码
"""from socket import *#  服务端地址
ADDR = ("127.0.0.1",8888)def main(filename):# 默认值就是创建tcp套接字tcp_socket = socket()# 发起链接 对应 accepttcp_socket.connect(ADDR)file = open(filename,'rb')# 边读取边发送while True:data = file.read(1024)# 读到文件结尾为空if not data:breaktcp_socket.send(data)# 关闭file.close()tcp_socket.close()if __name__ == '__main__':main("./timg.jfif")

"""
练习: 模拟一个简单的对话机器人
多个客户端可以同时对话 ,在客户端输入问题发送给
小美(服务端),服务端会根据问题进行回复你多大啦  --> 2岁啦你是男生女生 --> 我是机器人你漂亮么 --> 我天生丽质xxxx --> 人家还小,还不懂
"""from socket import *# 对话字典
chat = {"几岁":"我两岁啦","男生女生":"我是机器人","叫什么":"我叫小美"}def main():# 创建tcp套接字 其实使用默认值就是tcp套接字tcp_socket = socket(AF_INET,SOCK_STREAM)# 绑定地址tcp_socket.bind(("0.0.0.0",8888))# 设置监听,让tcp套接字可以被链接tcp_socket.listen(5)# 处理客户端连接while True:connfd,addr = tcp_socket.accept()data = connfd.recv(1024).decode()# 遍历字典--> 取键for key in chat:if key in data:connfd.send(chat[key].encode())breakelse:connfd.send("人家还小,听不懂".encode())connfd.close()# 关闭tcp_socket.close()if __name__ == '__main__':main()"""
客户端代码
"""
from socket import *#  服务端地址
ADDR = ("127.0.0.1", 8888)while True:msg = input("我:")if not msg:break# 默认值就是创建tcp套接字tcp_socket = socket()# 发起链接 对应 accepttcp_socket.connect(ADDR)# 发送给服务端tcp_socket.send(msg.encode())data = tcp_socket.recv(1024)print("小美:", data.decode())# 关闭tcp_socket.close()