1 socket
socket又叫套接字,就是進(jìn)行數(shù)據(jù)通信兩端。分為服務(wù)端套接字和客戶端套接字。
套接字編程:自己寫服務(wù)器和客戶端進(jìn)行數(shù)據(jù)傳輸,python對(duì)socket編程的支持:提供了一個(gè)名字為socket的庫(kù)(內(nèi)置)。
服務(wù)器具體實(shí)現(xiàn)如下代碼所示:
import socket
def creat_server():
"""寫一個(gè)服務(wù)器"""
# 1.創(chuàng)建套接字對(duì)象
"""
socket(fimaly, type)
a.family:確定IP協(xié)議類型
AF_INET:ipv4(默認(rèn)值)
AF_INER6:ipv6
b.type:傳輸協(xié)議類型
SOCK_STREAM:TCP協(xié)議(默認(rèn)值)
SOCK_DGRAM:UDP協(xié)議
"""
server = socket.socket(family=socket.AF_INET, type=socket.SOCK_STREAM)
# 2.綁定IP地址和端口
"""
bin((ip地址, 端口)),里面是一個(gè)元組
端口:一臺(tái)電腦上一個(gè)端口標(biāo)記一個(gè)唯一的服務(wù)。
范圍0~65535,0~1024是著名端口,專門用來標(biāo)記一個(gè)特殊服務(wù),一般不要用。
但是,同一個(gè)端口同一時(shí)間只能綁定一個(gè)服務(wù)。
"""
server.bind(("10.7.153.193", 8080))
# 3.開始監(jiān)聽
"""
listen(最大個(gè)數(shù))
同一時(shí)間能夠連接的客戶端的個(gè)數(shù)
"""
server.listen(6)
# 4.讓服務(wù)器處于運(yùn)行狀態(tài)
while True:
print('監(jiān)聽狀態(tài)')
# 5.連接客戶端(建立連接),返回連接對(duì)象和客戶端地址
# 這句代碼會(huì)阻塞線程,直到有客戶端來請(qǐng)求當(dāng)前服務(wù)器為止
connect, addr = server.accept()
print(addr)
# 6.服務(wù)器給客戶端發(fā)送消息
"""
send(data)
data:要求類型是bytes,python2可以是字符串
字符串(str)轉(zhuǎn)二進(jìn)制(bytes):
a. 字符串.encode(編碼方式) ---> 默認(rèn)編碼方式'utf-8'
b. bytes(字符串, 編碼方式)
"""
while True:
message = input('服務(wù)器:')
connect.send(message.encode())
# connect.send('你好!'.encode())
# connect.send(bytes('OK!', 'utf-8'))
# 7.接收從客戶端發(fā)送過來的消息
# 注意:recv方法也會(huì)阻塞線程
"""
recv(bufsize)
bufsize:每次能夠接收的最大的字節(jié)數(shù)
返回值:接收到的數(shù)據(jù),類型是bytes
2.二進(jìn)制轉(zhuǎn)字符串:
二進(jìn)制.decode()
str.(二進(jìn)制, 編碼方式)
"""
recv_data = connect.recv(1024)
print(recv_data.decode())
# print(str(recv_data, 'utf-8'))
# 8.斷開連接
connect.close()
2 客戶端套接字
客戶端套接字具體實(shí)現(xiàn)如下代碼所示:
def creat_client():
# 1.創(chuàng)建套接字對(duì)象
client = socket.socket()
# 2.連接服務(wù)器
"""
connect(服務(wù)器地址)
"""
client.connect(('10.7.153.193', 8080))
while True:
# 3.接收服務(wù)器發(fā)送的消息
data = client.recv(1024)
print(data.decode(encoding='utf-8'))
# 4.給服務(wù)器發(fā)消息
message = input('客戶端:')
client.send(message.encode())
# 5.斷開連接
client.close()
3 圖片服務(wù)器
# 1.創(chuàng)建套接字(創(chuàng)建一個(gè)座機(jī))
server = socket.socket()
# 2.綁定地址(插電話線,綁定電話號(hào)碼)
server.bind(('10.7.153.193', 8081))
# 3.監(jiān)聽(人坐在電話旁)
server.listen(512)
# 保證電話可以被打通(等電話)
while True:
# 4.接收請(qǐng)求(接電話)
connect, addr = server.accept()
print(addr)
# 5.發(fā)送數(shù)據(jù)(講電話)
with open('./picture/dlw.jpg', 'br') as f:
data = f.read()
connect.send(data)
# 6.接收數(shù)據(jù)(聽對(duì)方講話)
connect.recv(1024)
# 7.關(guān)閉連接(掛電話)
connect.close()
4 圖片客戶端
client = socket.socket()
client.connect(('10.7.153.103', 12344))
data = client.recv(1024)
# all_data = data
# 創(chuàng)建一個(gè)空的二進(jìn)制數(shù)據(jù)
all_data = bytes()
while data:
print('接收到數(shù)據(jù)')
# 拼接二進(jìn)制數(shù)據(jù)
all_data += data
data = client.recv(1024)
with open('./picture/new_d.jpg', 'wb') as f:
f.write(all_data)
client.close()
5 http請(qǐng)求
具體流程如下代碼所示:
# 1.準(zhǔn)備url
url = 'https://www.apiopen.top/satinApi?type=1&page=1'
# 2.發(fā)送請(qǐng)求(GET請(qǐng)求)
# requests.get('https://www.apiopen.top/satinApi', {'type':1, 'page':1})
"""
get(url, 參數(shù)對(duì)應(yīng)的字典)
post(url, 參數(shù)對(duì)應(yīng)的字典)
返回值是服務(wù)器返回的響應(yīng)
"""
response = requests.get(url)
print(response)
# 3.通過響應(yīng)獲取服務(wù)器返回的數(shù)據(jù)
# a.獲取字符串類型的數(shù)據(jù)
print(response.text)
# b.獲取json格式的數(shù)據(jù)
print(response.json()['msg'])
# c.獲取二進(jìn)制格式的數(shù)據(jù)
print(response.content)