socket編程
socket又叫套接字凳寺，指的就是實現(xiàn)通信過程的兩個端柴信。等待請求的一端叫服務(wù)端套接字套啤，發(fā)送請求的一端叫客戶端套接字
python中提供了socket模塊來支持socket編程
import socket
==========服務(wù)器套接字=============
1.創(chuàng)建套接字對象
socket(family, type)
family - 設(shè)置ip類型 AF_INET(默認(rèn)值) - ipv4 AF_INET6 - ipv6
type - 設(shè)置傳輸類型 SOCK_STREAM(默認(rèn)值) - tcp SOCK_DGRAM - udp
"""
創(chuàng)建一個基于ipv4和TCP的套接字對象
server = socket.socket()
2.綁定ip地址和端口
bind((ip地址, 端口號))
ip地址 - 服務(wù)器對應(yīng)的計算機的ip地址，字符串
端口號 - 用來區(qū)分計算機上不同服務(wù); 是一個數(shù)字随常，范圍是0~65535;
但是其中1024以下的是著名端口潜沦，用來表示一個特殊的服務(wù),一般不要用;
同一時間一個端口只能對應(yīng)一個服務(wù)
server.bind(('10.7.187.149', 8081))
3.開始監(jiān)聽
listen(最大監(jiān)聽數(shù))
最大監(jiān)聽數(shù) - 用來設(shè)置當(dāng)前服務(wù)器一次可以處理多少個請求
server.listen(100)
print('開始監(jiān)聽')
# 4. 讓服務(wù)一直處于啟動狀態(tài)
while True:
# 5.接收客戶端發(fā)送的請求，返回建立的會話和客戶端地址绪氛；
# 注意唆鸡，這段代碼會阻塞線程(程序運行到這兒會停下來，直到有客戶端給當(dāng)前服務(wù)器發(fā)送請求為止)
conversation, addr = server.accept()
print('接收到請求:', addr)
# 6.接收消息(客戶端發(fā)送給服務(wù)器的消息)
"""
recv(緩存大小) - 獲取客戶端給服務(wù)器發(fā)送的數(shù)據(jù)枣察，返回值是二進制
緩存大小 - 決定一次可以接收的數(shù)據(jù)的最大字節(jié)數(shù)
這兒也會阻塞線程争占，直到客戶端發(fā)送了消息才會接著往后執(zhí)行
"""
re_data = conversation.recv(1024)
print('======')
print(re_data.decode('utf-8'))
# 7.發(fā)送數(shù)據(jù)(服務(wù)器給客戶端發(fā)送數(shù)據(jù))
"""
send(數(shù)據(jù)) - 將指定的數(shù)據(jù)發(fā)送給客戶端
數(shù)據(jù) - 要求是二進制
字符串(str)轉(zhuǎn)二進制(bytes):
a.bytes(字符串, 'utf-8')
b.字符串.encode('utf-8')
二進制轉(zhuǎn)字符串
a.str(二進制數(shù)據(jù), 'utf-8')
b.二進制.decode('utf-8')
"""
# message = 'HTTP/1.1 200 OK\r\n\r\n <html><<head><meta charset="utf-8" /><title>表格</title></head><body>你好!</body></html>'
message = '你好！Ｑ燃乍！'
# conversation.send(bytes(message, encoding='utf-8'))
conversation.send(message.encode(encoding='utf-8'))
# 8.關(guān)閉連接
conversation.close()
客戶端套接字
import socket
# 1.創(chuàng)建套接字對象
client = socket.socket()
# 2.連接服務(wù)器
"""
connect((ip, 端口))
"""
client.connect(('172.21.203.2', 8088))
# 3.發(fā)送消息
message = input('>>')
client.send(message.encode('utf-8'))
# 4.接收消息
re_data = client.recv(1024)
print(re_data.decode('utf-8'))
圖片服務(wù)器
import socket
# 1.創(chuàng)建套接字對象
server = socket.socket()
# 2.綁定ip和端口
server.bind(('10.7.187.149', 9093))
# 3.監(jiān)聽
server.listen(512)
print('開始監(jiān)聽!')
while True:
# 4.接收請求
conversation, addr = server.accept()
print(addr)
# ==========2.保持通話==============
while True:
# 接收消息
data = conversation.recv(1024)
print('客戶端:', data.decode('utf-8'))
# 發(fā)送消息
message = input('服務(wù)器:')
conversation.send(message.encode('utf-8'))
# ===========1.發(fā)送圖片=============
# with open('luffy.png', 'br') as f:
# content = f.read()
# conversation.send(content)
#
# conversation.close()
圖片服務(wù)器
import socket
client = socket.socket()
client.connect(('10.7.187.149', 9092))
# ========2.保持通話=============
while True:
# 發(fā)送消息
message = input('客戶端:')
client.send(message.encode('utf-8'))
# 接收消息
data = client.recv(1024)
print('服務(wù)器:', data.decode('utf-8'))
# ========1.接收圖片==========
# 不斷接收數(shù)據(jù)，直到接收完為止
# 創(chuàng)建一個空的二進制數(shù)據(jù)
# data = bytes()
# while True:
# re_data = client.recv(1024)
# data += re_data
# print('接收到數(shù)據(jù)!')
# if not re_data:
# break
#
# print('數(shù)據(jù)接收完了')
# with open('new.png', 'bw') as f:
# f.write(data)
網(wǎng)絡(luò)請求
import requests
"""
python中去做http請求宛琅，需要使用一個第三方庫: requests
"""
"""
get(url, 參數(shù)字典) - 返回響應(yīng)
"""
# 1.向服務(wù)器發(fā)送get請求
# a.手動拼接url
# url = 'https://www.apiopen.top/satinApi?type=1&page=1'
# response = requests.get(url)
# print(response)
# b.自動拼接url
url = 'https://www.apiopen.top/satinApi'
response = requests.get(url, {'type': 1, 'page': 1})
print(response)
# 2.獲取響應(yīng)頭
header = response.headers
print(header)
# 3.獲取響應(yīng)體
"""
a.獲取二進制格式的響應(yīng)體
"""
content = response.content
print(type(content))
"""
b.獲取json格式響應(yīng)體 - 自動將json數(shù)據(jù)轉(zhuǎn)換成python
"""
json = response.json()
print(type(json))
"""
c.獲取字符串格式的響應(yīng)體
"""
text = response.text
print(type(text))
# 應(yīng)用：下載網(wǎng)絡(luò)圖片
url = 'https://timgsa.baidu.com/timg?image&quality=80&size=b10000_10000&sec=1543395098&di=2a5bbaa5600097b050ba69a688672de9&src=http://p0.qhimgs4.com/t0112e7ebfdef7f923d.jpg'
response = requests.get(url)
image_data = response.content
with open('王也.jpg', 'wb') as f:
f.write(image_data)
