socket又叫套接字,就是進(jìn)行數(shù)據(jù)通信兩端。分為服務(wù)器套接字和客戶端套接字。
套接字編程:自己寫服務(wù)器或者客戶端,進(jìn)行數(shù)據(jù)傳輸。
python對(duì)socket編程的支持:提供一個(gè)socket庫(內(nèi)置)
import socket
一、服務(wù)器端(socket)
1、創(chuàng)建套接字對(duì)象
def creat_server():
socket(family,type)
a.family:確定IP協(xié)議類型
AF_INET:ipv4(默認(rèn))
AF_INET6:ipv6
b.type:傳輸協(xié)議類型
SOCK_STREAM:TCP協(xié)議(默認(rèn))
SOCK_DGRAM:UDP協(xié)議
server = socket.socket()
2、綁定IP地址和端口
端口:一臺(tái)電腦上一個(gè)端口標(biāo)記一個(gè)唯一的服務(wù)。范圍0~65535,0~1014是著名端口,專門標(biāo)記一個(gè)特殊服務(wù),一般不適用。
注意:同一端口同一時(shí)間只能綁定一個(gè)服務(wù)。
server.bind(("10.7.153.113",8080))
3、監(jiān)聽(客戶端請(qǐng)求)
listen(個(gè)數(shù))
同一時(shí)間能夠連接的客戶端個(gè)數(shù)。
"""
server.listen()
4、讓服務(wù)器處于運(yùn)行狀態(tài)
while True:
print('監(jiān)聽狀態(tài)!')
連接客戶端(建立連接),返回連接對(duì)象和客戶端地址。
這句代碼會(huì)阻塞線程,直到有客戶端來請(qǐng)求當(dāng)前服務(wù)器為止。
connect, addr = server.accept()
print(addr)
5、服務(wù)器給客戶端發(fā)送消息
```
send(data)
date:python3中要求類型是bytes,python2中可以是字符串。
字符串 >>>> 二進(jìn)制 :
1、字符串.encode(編碼方式)默認(rèn)utf-8
2、bytes(字符串,編碼方式)默認(rèn)None
connect.send('你好!'.encode())
connect.send(bytes('你好','utf-8'))
#6、接收從客戶端發(fā)送過來的消息
recv(bufsize)
bufsize:每次能夠接收的最大字節(jié)數(shù)
返回值:接收到的數(shù)據(jù)(二進(jìn)制)
二進(jìn)制 >>> 字符串:
1、二進(jìn)制.decode()
2、str(二進(jìn)制,編碼方式)
注意:recv方法也會(huì)阻塞線程。
recv_data = connect.recv(1024)
print(recv_data.decode())
print(str(recv_data, 'utf-8'))
#7、斷開連接
connect.close()
二、客戶端(socket)
1、創(chuàng)建套接字對(duì)象
import socket
def creat_client():
client = socket.socket()
2、連接服務(wù)器
"""
connect(服務(wù)器地址,端口)
"""
client.connect(('10.7.153.113', 8080))
3、接收服務(wù)器發(fā)送的消息
data = client.recv(1024)
print(data.decode(encoding='utf-8'))
4、給服務(wù)器發(fā)送消息
client.send('我是客戶端~~'.encode())
5、斷開連接
client.close()
實(shí)例一:通信
服務(wù)器端
"""__author__=Deathfeeling"""
import socket
def creat_server():
"""寫一個(gè)服務(wù)器"""
# 1、創(chuàng)建套接字對(duì)象
server = socket.socket()
# 2、綁定IP地址和端口
server.bind(("10.7.153.113",8080))
# 3、監(jiān)聽(客戶端請(qǐng)求)
server.listen(5)
print('監(jiān)聽狀態(tài)!')
connect, addr = server.accept()
# 4、讓服務(wù)器處于運(yùn)行狀態(tài)
while True:
mesag = input('服務(wù)器:')
connect.send(mesag.encode())
#6、接收從客戶端發(fā)送過來的消息
recv_data = connect.recv(1024)
print(recv_data.decode())
#7、斷開連接
connect.close()
creat_server()
客戶端
"""__author__=Deathfeeling"""
import socket
def creat_client():
# 1、創(chuàng)建套接字對(duì)象
client = socket.socket()
# 2、連接服務(wù)器
"""
connect(服務(wù)器地址)
"""
client.connect(('10.7.153.113', 8080))
while True:
# 3、接收服務(wù)器發(fā)送的消息
data = client.recv(1024)
print(data.decode(encoding='utf-8'))
# 4、給服務(wù)器發(fā)送消息
mesag = input('客戶端:')
client.send(mesag.encode())
# 5、斷開連接
client.close()
creat_client()
實(shí)例二:下載圖片
圖片服務(wù)器
"""__author__=Deathfeeling"""
import socket
server = socket.socket()
server.bind(('10.7.153.113', 8082))
server.listen(100)
while True:
connect,addr = server.accept()
with open('./beauty.png','rb') as f:
data = f.read()
connect.send(data)
connect.close()
#圖片客戶端
"""__author__=Deathfeeling"""
import socket
client = socket.socket()
client.connect(('10.7.153.113',8082))
#創(chuàng)建一個(gè)空的二進(jìn)制數(shù)據(jù)
all_data = bytes()
data = client.recv(1024)
while data:
print('正在接收~~~')
#拼接二進(jìn)制數(shù)據(jù),得到完整的圖片
all_data += data
data = client.recv(1024)
print('接收完畢!')
#寫入在本地
with open('./new.png','wb') as f:
f.write(all_data)
client.close()
三、網(wǎng)絡(luò)請(qǐng)求
get方法
"""__author__=Deathfeeling"""
import requests
# 1、準(zhǔn)備url
url = 'https://www.apiopen.top/satinApi?type=1&page=1'
# 2、發(fā)送請(qǐng)求(get)
"""
get(url,參數(shù)對(duì)應(yīng)的字典)
post(url,參數(shù)對(duì)應(yīng)的字典)
"""
response = requests.get(url)
# requests.get('https://www.apiopen.top/satinApi',{'type'=1,'page'=1})
print(response)
3、通過相應(yīng)獲取服務(wù)器返回的數(shù)據(jù)
a、獲取字符串類型的數(shù)據(jù)
print(response.text)
b、獲取json的數(shù)據(jù)
print(response.json)
c、獲取二進(jìn)制格式的數(shù)據(jù)
print(response.content)
d、獲取響應(yīng)頭(了解)
print(response.headers)
post類似,但是需要有對(duì)應(yīng)的post接口。