socket(套接字)
1.什么是socket:
socket又叫套接字梳凛, 指的是網(wǎng)絡(luò)通信的兩端吵取,分別是服務(wù)器和客戶端
socket編程指的就是通過代碼實現(xiàn)客戶端和服務(wù)器之間的通信
2.服務(wù)器的實現(xiàn)
1.創(chuàng)建套接字對象
"""
family: ip類型, AF_INET -> ipv4男韧, AF_INET6 -> ipv6
type: 傳輸協(xié)議的類型, SOCK_STREAM -> TCP, SOCK_DGRAM -> UDP
"""
import socket
server = socket.socket()
2.綁定IP地址和端口
"""
ip用來區(qū)分互聯(lián)網(wǎng)上設(shè)備
端口是用來區(qū)分一臺計算上的不同的服務(wù)(應(yīng)用),值是0-65535,其中0-1024是著名端口舔腾。其他的隨便選
bind((ip地址,端口號))
"""
server.bind(('10.7.190.127', 8081))
3.啟動服務(wù)器(監(jiān)聽請求)
"""
listen(數(shù)量) - 這兒的數(shù)量指的是一次性能夠處理的最大請求數(shù)
"""
server.listen(255)
4.讓服務(wù)器一直處于運行狀態(tài)
while True:
print('開始監(jiān)聽....')
# 5.等待客戶端的請求
# 程序運行到這個地方,會停下來搂擦,等到有客戶端來連接服務(wù)器稳诚,才會接著往后執(zhí)行
connect, addr = server.accept()
print(connect, addr)
# 6.發(fā)送消息
"""
send(數(shù)據(jù)) - 發(fā)送數(shù)據(jù),數(shù)據(jù)是二進制數(shù)據(jù)
"""
message = input('>>>')
connect.send(message.encode(encoding='utf-8'))
# 7.接收消息
"""
recv(字節(jié)數(shù)) - 接收數(shù)據(jù),并且指定一次性接收的數(shù)據(jù)的大小的最大值瀑踢;返回接收到的二進制數(shù)據(jù)
"""
# 程序運行到這個地方會停下來扳还,直到客戶端給服務(wù)器發(fā)送消息,才會接著執(zhí)行
data = connect.recv(1024)
print('<<<:')
print(data.decode(encoding='utf-8'))
# 8.關(guān)閉連接
connect.close()
3.客戶端的實現(xiàn)
創(chuàng)建客戶端套接字:
# 1.創(chuàng)建套接字對象
client = socket.socket()
# 2.連接服務(wù)器
"""
套接字對象.connect((ip地址, 端口))
"""
client.connect(('10.7.190.127', 8080))
# 3.接收消息
data = client.recv(1024)
print('<<<:')
print(data.decode(encoding='utf-8'))
# 4.發(fā)送消息
message = input('>>>:')
client.send(message.encode(encoding='utf-8'))
# 5.關(guān)閉連接
client.close()
requests庫
import requests
# 根據(jù)網(wǎng)絡(luò)接口請求數(shù)據(jù): 通過第三方庫requests提供的方法
# 1.獲取網(wǎng)絡(luò)數(shù)據(jù)
response = requests.get('http://wimg.spriteapp.cn/profile/large/2017/10/05/59d644960c99b_mini.jpg')
print(response)
# 1)獲取字符串形式的數(shù)據(jù)結(jié)果
# text = response.text
# print(type(text), text)
# 2)獲取二進制數(shù)據(jù)
data = response.content
print(type(data), data)
with open('img.jpg', 'wb') as f:
f.write(data)
# 3)獲取json數(shù)據(jù)
# message = response.json()(把獲取到的json數(shù)據(jù)轉(zhuǎn)換為python數(shù)據(jù))
# print(type(message), message)
# print(message['data'])
多線程
1.什么是進程:
一個正在運行的應(yīng)用程序就是一個進程橱夭。系統(tǒng)會給每個進程分配一個獨立的內(nèi)存區(qū)域氨距,用來保存程序運行過程中產(chǎn)生的數(shù)據(jù),當(dāng)進程結(jié)束的時候棘劣,這個內(nèi)存區(qū)域會自動銷毀
2.什么是線程:
- 進程想要執(zhí)行任務(wù)俏让,就必須要有線程。每個進程默認都有一個線程茬暇,這個線程叫主線程首昔;其他的線程叫子線程,程序默認都是在主線程中執(zhí)行的糙俗;
- 一個線程中執(zhí)行多個任務(wù)勒奇,任務(wù)是串行執(zhí)行的(一個一個的按順序執(zhí)行)
- 一個進程中如果有多個線程,多線程執(zhí)行不同任務(wù)的時候是并行(同時執(zhí)行)
3.python中怎么使用多線程
python通過內(nèi)置的threading模塊來提供多線程相關(guān)技術(shù);其中有一個Thread類巧骚,這個類的對象就是線程對象
def download(film):
print('開始下載: %s time: %s' % (film, str(datetime.now())))
sleep(15)
print('%s下載完成 time:%s' % (film, str(datetime.now())))
print(threading.current_thread())
# 在主線程中下載兩個電影: 一個一個的下載赊颠,一個下載完才下載另一個,總耗時兩個電影耗時之和
# download('戀戀筆記本')
# download('摔跤吧爸爸')
#=========================
# 1.直接創(chuàng)建線程類的對象
"""
a.語法:
線程對象 = Thread(target=函數(shù), args=參數(shù)) - 創(chuàng)建一個線程對象网缝,并且返回巨税。
b.說明
函數(shù) - function類型的變量; 這個函數(shù)的函數(shù)體就會在子線程中執(zhí)行
參數(shù) - 元祖; 參數(shù)會傳給target對應(yīng)的函數(shù)
"""
t1 = threading.Thread(target=download, args=('大國崛起',))
t2 = threading.Thread(target=download, args=('霸王別姬',))
# 2.讓線程開始執(zhí)行任務(wù)
"""
線程對象.start() - 開始執(zhí)行子線程中的任務(wù)
"""
t1.start()
t2.start()
download('變形金剛')
print('=======')
# 某個線程出現(xiàn)異常,是線程直接結(jié)束粉臊;進程不一定結(jié)束草添,所有的線程都結(jié)束,進程才會結(jié)束
print([1, 2][10])
print('+++++++++++')
創(chuàng)建線程子類(推薦)
"""
1)聲明一個類繼承自Thread
2)重寫run方法扼仲,這個方法中的任務(wù)就是需要在子線程中執(zhí)行的任務(wù)
3)創(chuàng)建當(dāng)前類的對象远寸,就是線程對象
4)啟動子線程
"""
class DownloadThread(Thread):
def __init__(self, film):
super().__init__()
self.film = film
def run(self):
print('%s開始下載...' % self.film)
time1 = randint(3, 10)
time.sleep(time1)
print('%s下載結(jié)束抄淑,總耗時%d秒' % (self.film, time1))
# 2.創(chuàng)建線程對象
t1 = DownloadThread('霸王別姬')
t2 = DownloadThread('海賊王')
# 3.啟動線程
"""
線程對象調(diào)用start會自動在子線程中去調(diào)用run方法
直接用線程對象調(diào)用run方法,run方法會在主線程中執(zhí)行
"""
start = time.time()
t1.start()
t2.start()
# 4.join的用法
"""
線程對象.join() -- 程序執(zhí)行到這個地方會停下來(線程會阻塞)驰后,直到線程對象中的任務(wù)執(zhí)行完成后才執(zhí)行后面的語句
"""
t1.join()
t2.join()
# print('t1結(jié)束')
end = time.time()
print('總時間: ', end - start)