知识回顾
1.正则表达式
匹配字符： . \w \s \d (^ $ \b \B) \W \D \S [] [^]
控制次数：* + ? {} *? +? ?? {N,}? {N,M}? {,N}? (在次数后面加？代表次数尽可能少的去匹配)
分支：|
分组：() 分组，捕获，重复（\数字）
正则符号的转义：想要有特殊功能的符号表示它本身，通过 \ 转义
除了\ 和 - ，其他符号放在[]都表示符号本身
2.re模块
compile --> 将正则表达式转换成对象
a.匹配相关：match，fullmatch ——> 返回值是匹配对象/None
span(), group(), string, start(), end()
b.查找：search(正则表达式， 字符串) --> 返回值是匹配对象/None
去字符串中查找满足正则表达式的子串， 如果有只取第一个满足条件的字符串的匹配对象
findall --> 获取所有满足正则条件的子串，返回一个元素是字符串的列表。如果正则中有分组，只取分组中的内容
finditer --> 获取所有满足正则条件的子串，返回一个迭代器，迭代器中内容是匹配对象
c.切割
split() --> 按满足正则条件的子串对字符串进行切割
d.替换
sub(正则表达式， 替换值， 字符串)
socket 服务器
socket又叫套接字，实现网络通信的两端就是套接字。分为服务器对应的套接字和客户端对应的套接字
python通过提供socket标准库来支持socket编程。
socket编程就是用程序实现服务器和客户端
import socket
写一个服务器程序
1.创建服务器对应的套接字对象
socket(family, type)
family:设置ip类型 AF_INET(ipv4)->默认值 AF_INET6(ipv6)
type:设置传输类型 SOCK_STREAM(TCP可靠传输)—>默认值 SOCK_DGRAM(UDP不可靠传输)
server = socket.socket() # 创建一个基于ipv4的可靠传输的服务器套接字
2.绑定ip和端口
bind((ip, 端口))
ip:服务器的地址
端口：不同的端口用来区分电脑上的不同服务。取值范围是0~65535，注意0~1024属于著名端口(用来绑定特殊服务的端口，不要随便用)
注意：同一时间同一端口只能绑定一个服务
server.bind(('10.7.156.129', 8080))
3.监听请求
litsen(个数) -> 需要通过数字设置服务器一次可以处理的请求的最大个数
server.listen(512)
print('开始监听')
4.让服务器一直处于启动状态
while True:
# 5.接受客户端的请求
"""
执行到accept()，程序会停下来，直到有客户端来请求这个服务器的时候才会往下执行。返回会话和客户端的地址
"""
conversion, addr = server.accept()
print(addr)
# 6.服务器给客户端发送数据
"""
send(data) -> 发送数据
data:需要发送数据，要求是二进制数据(bytes)
str 转 bytes:
bytes(字符串， encoding='utf-8')
字符串.encode(编码方式)
"""
message = input('>>>')
message_data = message.encode(encoding='utf-8')
# message_data = bytes(message, encoding='utf-8')
conversion.send(message_data)
# 7.接受客户端发送的消息（听电话）
"""
recv(字节数) -> 接受从客户端发送的数据，参数是用来设置一次能接收的最大字节数.返回值是接收到的数据
bytes 转 str
str(二进制， encoding)
二进制.decode(编码方式)
注意：recv方法也会阻塞线程，程序运行到这会停下等，等到对方发送消息为止
"""
print('准备接收消息')
data = conversion.recv(1024)
# re_message = str(data, encoding='utf-8')
re_message = data.decode(encoding='utf-8')
print(re_message)
# 发送图片
with open('./files/.jpg', 'rb') as f:
content = f.read()
conversion.send(content)
# 关闭连接
conversion.close()
socket客户端
import socket
1.创建套接字对象
client = socket.socket()
2.连接服务器
connect(地址)
client.connect(('10.7.156.129', 8080))
while True:
# 4.给服务器发送消息
message = input('客户端：')
client.send(message.encode('utf-8'))
# 3.接受服务器返回的数据
re_data = client.recv(1024)
print('服务器：', re_data.decode('utf-8'))
socket服务器升级
import socket
1.创建服务器套接字
server = socket.socket()
2.绑定地址
server.bind(('10.7.156.129', 8080))
3.监听
server.listen(512)
让服务器一直运行
while True:
# 4.接受请求
conversion, addr = server.accept()
# 保持通话
while True:
# 接收消息
message_re = conversion.recv(1024).decode('utf-8')
print('客户端(%s):%s' % (addr[0][-2:], message_re))
# 发送消息
message = input('服务器：')
conversion.send(message.encode('utf-8'))
接受图片的客户端
import socket
client = socket.socket()
client.connect(('10.7.156.97', 8082))
message_re = client.recv(1024)
data = bytes() # 创建一个空的二进制数据
while message_re:
# print(message_re)
print('接收数据')
data += message_re # 将每次获取到的数据叠加
message_re = client.recv(1024)
with open('./new.jpg', 'bw') as f:
f.write(data)
print('接收完成')
request请求
python没有一个标准库来支持网络请求，但是目前有一个第三方库，支持http
import requests
requests.get(url, params) -> 返回服务器的响应
url -> 请求地址
params -> 客户端给服务器发送的数据（字典） {参数名：值}
https://www.apiopen.top/satinApi?type=1&page=1
url = 'https://www.apiopen.top/satinApi?type=1&page=1'
response = requests.get(url)
# 1.获取响应头
print(response.headers)
# 2.获取二进制形式的响应体
data_bytes = response.content
# print(data_bytes)
print(type(data_bytes))
# 3.获取字符串形式的响应体
data_str = response.text
print(type(data_str))
# print(data_str)
# 4.获取json格式对应的python数据
data_json = response.json()
print(type(data_json))
response = requests.get('http://wimg.spriteapp.cn/profile/large/2018/02/24/5a90448611639_mini.jpg')
content = response.content
with open('./a.jpg', 'wb') as f:
f.write(content)
作业
作业：
第一题：
写一个客户端和服务器的套接字：
客户端连接服务器后展示界面：
===========================
- 需要图片
- 需要文字
- 通知结束
==========================
请选择：
如果客户端选1，服务器给客户端发送一张图片，客户端保存图片到本地
如果客户端选2, 服务器输入一段文字发送给客户端， 客户端将文字保存在一个message.txt文件中
如果客户端选3，通知服务器关闭连接，并且客户端结束
服务器
import socket
server = socket.socket()
server.bind(('10.7.156.129', 8080))
server.listen(1024)
print('开始监听')
while True:
conversion, addr = server.accept()
while True:
print('正在访问服务器的设备：', addr)
str_menu = '===========================\n1.请求文字\n2.请求图片\n3.结束\n===========================\n请选择：'
menu = str_menu.encode('utf-8')
conversion.send(menu)
print('接受请求：')
req = conversion.recv(1024)
message = req.decode('utf-8')
print(message)
if message == '1':
text_str = '给客户端返回的文字内容1111111'
text = text_str.encode('utf-8')
conversion.send(text)
continue
elif message == '2':
try:
with open('./哆啦A梦.jpg', 'rb') as f:
content = f.read()
conversion.send(content)
conversion.close()
except FileNotFoundError:
print('没有找到对应文件！')
continue
elif message == '3':
print('结束')
break
break
客户端
import socket
client = socket.socket()
client.connect(('10.7.156.129', 8080))
while True:
re_data = client.recv(1024)
print(re_data.decode('utf-8'))
n = input()
num = n.encode('utf-8')
client.send(num)
if n == '1':
print('向服务器请求文字')
re_text = client.recv(1024)
text = re_text.decode('utf-8')
with open('./files/message.txt', 'w', encoding='utf-8') as f:
f.write(text)
print('接收文字保存成功')
continue
elif n == '2':
print('向服务器请求图片')
data = bytes()
re_img = client.recv(1024)
while re_img:
print("接收数据中...")
data += re_img
re_img = client.recv(1024)
with open('./files/dlam.jpg', 'wb') as f:
f.write(data)
print('接收保存图片成功')
continue
elif n == '3':
print('结束')
break
结果：
第二题：
请求接口：https://www.apiopen.top/satinApi?type=1&page=1 获取网络数据。
将内容中所有的name和text对应的值取出，并且保存到一个json文件中，保存的格式：
[{“name”:”张三”, “text”:”哈哈，让我们一起自由的飞翔”}, {“name”:”喒你家玻璃”, “text”:”截图暂停，截到的将会是对你爱情的预言三词！”}]
import requests
import json
url = 'https://www.apiopen.top/satinApi?type=1&page=1'
response = requests.get(url=url)
re_json = response.json()
# print(re_json)
list1 = []
data = re_json['data']
# print(data)
for index in data:
dict1 = {}
# print(index['name'], index['text'])
dict1['name'] = index['name']
dict1['text'] = index['text']
list1.append(dict1)
# print(list1)
with open('./files/abc.json', 'w', encoding='utf-8') as f:
json.dump(list1, f)
with open('./files/abc.json', 'r', encoding='utf-8') as f:
content = json.load(f)
print(content)
结果：
