01-socket服務(wù)器
socket又叫套接字椅文，實(shí)現(xiàn)網(wǎng)絡(luò)通信的兩端就是套接字站故。分為服務(wù)器對(duì)應(yīng)的套接字和客戶端對(duì)應(yīng)的套接字
python通過(guò)提供socket標(biāo)準(zhǔn)庫(kù)來(lái)支持socket編程屁擅。
socket編程就是用程序?qū)崿F(xiàn)服務(wù)器和客戶端
import socket
========寫(xiě)一個(gè)服務(wù)器程序=======
1.創(chuàng)建服務(wù)器對(duì)應(yīng)的套接字對(duì)象(買了一個(gè)座機(jī)機(jī)器)
socket(family, type)
family: 設(shè)置ip類型 AF_INET(ipv4) -> 默認(rèn)值 AF_INET6(ipv6)
type：設(shè)置傳輸類型 SOCK_STREAM(TCP可靠傳輸) -> 默認(rèn)值 SOCK_DGRAM(UDP不可靠傳輸)
server = socket.socket() # 創(chuàng)建一個(gè)基于ipv4的可靠傳輸?shù)姆?wù)器套接字
2.綁定IP和端口（插電話線-確定電話號(hào)碼）
bind((ip, 端口))
ip: 服務(wù)器的地址
端口：不同的端口用來(lái)區(qū)分電腦上不同服務(wù)序宦。取值范圍是065535滥玷，注意01024屬于著名端口(用來(lái)綁定特殊服務(wù)端口辟癌，不要隨便用)
注意：同一時(shí)間同一個(gè)端口只能綁定一個(gè)服務(wù)
server.bind(('10.7.156.97', 8082))
3.監(jiān)聽(tīng)請(qǐng)求（交電話費(fèi)）
listen(個(gè)數(shù)) --> 需要通過(guò)數(shù)字設(shè)置服務(wù)器一次可以處理最大的請(qǐng)求個(gè)數(shù)
server.listen(512)
print('開(kāi)始監(jiān)聽(tīng)')
4.讓服務(wù)一直處于啟動(dòng)狀態(tài)
while True:
5.接收客戶端的請(qǐng)求(電話響了寒屯，接電話)
執(zhí)行到accept()，程序會(huì)停下來(lái)黍少，直到有客戶端在請(qǐng)求這個(gè)服務(wù)器的時(shí)候才會(huì)往下執(zhí)行浩螺。返回會(huì)話和客戶端的地址
conversation, addr = server.accept()
print(addr)
6.服務(wù)器給客戶端發(fā)送數(shù)據(jù)（說(shuō)話）
send(data) --> 發(fā)送數(shù)據(jù)
data: 需要發(fā)送的數(shù)據(jù)，要求是二進(jìn)制數(shù)據(jù)（bytes）
a.str 轉(zhuǎn) bytes：
bytes(字符串,encoding='utf-8)
字符串.encode(編碼方式)
#message = input('>>>')
## message_data = bytes(message, encoding='utf-8')
#message_data = message.encode('utf-8')
#conversation.send(message_data)
# 發(fā)送一張圖片
with open('./files/luffy4.jpg', 'br') as f:
content = f.read()
conversation.send(content)
# 關(guān)閉連接
conversation.close()
7.接收客戶端發(fā)送的消息(聽(tīng)電話)
recv(字節(jié)數(shù)) --> 接收從客戶端發(fā)送的數(shù)據(jù)仍侥，參數(shù)是用來(lái)設(shè)置一次能接收的最大字節(jié)數(shù)要出。返回值是接收到的數(shù)據(jù)(二進(jìn)制)
bytes 轉(zhuǎn) 字符串
str(二進(jìn)制,encoding='utf-8')
二進(jìn)制.decode(編碼方式)
注意：recv方法也會(huì)阻塞線程，程序運(yùn)行到這兒會(huì)停下等农渊，等到對(duì)方發(fā)送消息為止
data = conversation.recv(1024)
# re_message = str(data, encoding='utf-8')
re_message = data.decode('utf-8')
print(re_message)
02-socket客戶端
1.創(chuàng)建客戶端套接字對(duì)象
client = socket.socket()
2.連接服務(wù)器
"""
connect(地址)
"""
client.connect(('10.7.156.97', 8080))
while True:
3.給服務(wù)器發(fā)送消息
message = input('客戶端:')
client.send(message.encode('utf-8'))
if message == '拜拜':
break
4.接收服務(wù)器返回的數(shù)據(jù)
re_data = client.recv(1024)
print('服務(wù)器:',re_data.decode('utf-8'))
if re_data.decode('utf-8') == '拜拜':
break
03-socket服務(wù)器升級(jí)
import socket
# 1.創(chuàng)建服務(wù)器套接字
server = socket.socket()
# 2.綁定地址
server.bind(('10.7.156.97', 8080))
# 3.監(jiān)聽(tīng)
server.listen(100)
# 讓服務(wù)器一直處于運(yùn)行狀態(tài)
while True:
# 4.接收請(qǐng)求
conversation, addr = server.accept()
print(addr)
# 保持通話
while True:
# 接收消息
message_re = conversation.recv(1024).decode('utf-8')
print('客戶端(%s): %s' % (addr[0][-2:], message_re))
if message_re == '拜拜':
break
# 發(fā)送消息
message = input('服務(wù)器:')
conversation.send(message.encode('utf-8'))
if message == '拜拜':
break
04-接收?qǐng)D片的客戶端
import socket
client = socket.socket()
client.connect(('10.7.156.97', 8082))
message_re = client.recv(1024)
data = bytes() # 創(chuàng)建一個(gè)空的二進(jìn)制數(shù)據(jù)
while message_re:
# print(message_re)
data += message_re # 將每次獲取到的數(shù)據(jù)疊加
# print('接收到數(shù)據(jù)')
message_re = client.recv(1024)
with open('./new.jpg', 'bw') as f:
f.write(data)
print('接收完成')
05-requst請(qǐng)求
python沒(méi)有一個(gè)標(biāo)準(zhǔn)庫(kù)來(lái)支持網(wǎng)絡(luò)請(qǐng)求患蹂，但是目前有一個(gè)第三方庫(kù)，支持http請(qǐng)求
imp~~~ort requests
requests.get(url, params) --> 返回服務(wù)的響應(yīng)
url -> 請(qǐng)求地址
params -> 客戶端給服務(wù)發(fā)送的數(shù)據(jù)(字典) {參數(shù)名:值}
https://www.apiopen.top/satinApi?type=1&page=1
url = 'https://www.apiopen.top/satinApi'
response = requests.get(url, {'type': 1, 'page': 1})
## 1.獲取響應(yīng)頭
print(response.headers)
## 2.拿二進(jìn)制形式的響應(yīng)體
data_bytes = response.content
print(type(data_bytes))
## 3.拿字符串形式的響應(yīng)體
data_text = response.text
print(type(data_text), data_text)
## 4.拿json格式對(duì)應(yīng)python數(shù)據(jù)
data_json = response.json()
print(type(data_json), data_json['code'],)
## 下載圖片到本地
response = requests.get('http://wimg.spriteapp.cn/profile/large/2018/02/24/5a90448611639_mini.jpg')
content = response.content
with open('./aa.jpg', 'wb') as f:
f.write(content)
