recode
"""
OSI參考模型：應(yīng)用層寂纪、表示層肝陪、會話層评甜、傳輸層存炮、網(wǎng)絡(luò)層、數(shù)據(jù)鏈路層夺姑、物理
TCP/IP協(xié)議(棧/簇)：OSI參考模型中涉及的所有的協(xié)議
HTTP墩邀、TCP和UDP(HTTP是基于TCP的，DNS是基于UDP)
TCP：可靠傳輸盏浙、建立會話眉睹、大數(shù)據(jù)可以分段傳輸（可以實現(xiàn)長連接）
UDP: 不可靠傳輸、不會建立會話（不是長連接）废膘、數(shù)據(jù)只傳一次竹海，不會分段
HTTP: 對客戶端發(fā)送的請求和服務(wù)器的響應(yīng)做了規(guī)范和要求。
請求：需要發(fā)送請求頭和請求體
響應(yīng)：需要返回響應(yīng)頭和響應(yīng)體
URL: 統(tǒng)一資源定位符
協(xié)議名://主機(jī)地址(ip地址,域名)/路徑(資源在服務(wù)器上的相對路徑)
GET和POST: 對參數(shù)的傳輸方式不一樣
socket： 寫服務(wù)端（創(chuàng)建服務(wù)端對應(yīng)的套接字->綁定ip和端口->監(jiān)聽...接受請求丐黄，TCP就會建立會話斋配，發(fā)送數(shù)據(jù)和接受數(shù)據(jù)）
寫客戶端(創(chuàng)建客戶端對應(yīng)的套接字->連接服務(wù)器...發(fā)送數(shù)據(jù)和接受數(shù)據(jù))
UDP(自己去學(xué))
requests模塊，第三方的
"""
def download(file):
print('開始下載',file)
print(file,'下載完成')
if __name__ == '__main__':
download('A')
download('B')
download('C')
一、多線程技術(shù)1
"""
python內(nèi)置的threading模塊许起，可以支持多線程
所有的進(jìn)程默認(rèn)都有一個線程(一般叫這個線程為主線程)十偶，其他的線程叫子線程
如果想要在進(jìn)程中添加其他的線程菩鲜，就創(chuàng)建線程對象
"""
import threading
import time
def download(file, time1):
print('開始下載',file)
time.sleep(time1)
print(file, '下載結(jié)束')
if __name__ == '__main__':
print('abc')
# 1.創(chuàng)建線程對象
"""
target: 需要在子線程中執(zhí)行的函數(shù)
args: 調(diào)用函數(shù)的實參列表（參數(shù)類型是列表）
返回值: 線程對象
"""
t1 = threading.Thread(target=download, args=['愛情公寓', 10])
# 2.在子線程中執(zhí)行任務(wù)
t1.start()
t2 = threading.Thread(target=download, args=['狄仁杰', 5])
t2.start()
# download('愛情公寓')
# download('狄仁杰')
print('=====')
# t3 = threading.Thread(target=input, args=['>>>'])
# t3.start()
value = input('>>>')
print('!!!!')
二园细、多線程技術(shù)2
"""
方式2：寫一個自己的線程類
1.寫一個類，繼承自Thread類
2.重寫run方法接校，在里面規(guī)定需要在子線程中執(zhí)行的任務(wù)
3.實現(xiàn)在子線程中執(zhí)行的任務(wù)對應(yīng)的功能猛频，如果需要參數(shù)，通過類的對象屬性來傳值
"""
from threading import Thread
import requests
import re
# 下載數(shù)據(jù)
class DownloadThread(Thread):
"""下載類"""
def __init__(self, file_path):
super().__init__()
self.file_path = file_path
def run(self):
"""run方法"""
"""
1.寫在這個方法的內(nèi)容就是在子線程中執(zhí)行的內(nèi)容
2.這個方法不要直接調(diào)用
"""
print('開始下載')
response = requests.request('GET', self.file_path)
data = response.content
# 獲取文件后綴
suffix = re.search(r'\.\w+$', self.file_path).group()
with open('./abc'+suffix, 'wb') as f:
f.write(data)
print('下載完成...')
if __name__ == '__main__':
print('=====')
t1 = DownloadThread('http://10.7.181.117/shareX/Git.exe')
# 通過start間接調(diào)用run方法蛛勉，run方法中的任務(wù)在子線程中執(zhí)行
t1.start()
# 直接調(diào)用run方法鹿寻，run方法中的任務(wù)在當(dāng)前線程中執(zhí)行
# t1.run()
t2 = DownloadThread('https://timgsa.baidu.com/timg?image&quality=80&size=b9999_10000&sec=1533720058151&di=766b5c97653351e805c85881ecaa57d0&imgtype=0&src=http%3A%2F%2Fx.itunes123.com%2Fuploadfiles%2Fb2ab55461e6dc7a82895c7425fc89017.jpg')
t2.start()
print('!!!!!')
三、client
import socket
if __name__ == '__main__':
client = socket.socket()
client.connect(('10.7.181.117', 8080))
while True:
print(client.recv(1024).decode(encoding='utf-8'))
message = input('>>>')
client.send(message.encode())
多線程應(yīng)用
import socket
from threading import Thread
class CoversationThread(Thread):
"""在子線程中處理不同的客戶端會話"""
"""
python中可以在函數(shù)參數(shù)的后面加一個冒號诽凌，來對參數(shù)的類型進(jìn)行說明
"""
def __init__(self, conversation:socket.socket, address):
super().__init__()
self.conversation = conversation
self.address = address
def run(self):
while True:
self.conversation.send('你好!'.encode())
print(self.address,self.conversation.recv(1024).decode(encoding='utf-8'))
if __name__ == '__main__':
server = socket.socket()
server.bind(('10.7.181.117', 8080))
server.listen(512)
while True:
conversation, address = server.accept()
t = CoversationThread(conversation, address)
t.start()
# while True:
# conversation.send('你好毡熏！'.encode())
# print(conversation.recv(1024).decode(encoding='utf-8'))
四、join函數(shù)
from threading import Thread,currentThread
import time
from random import randint
class Download(Thread):
def __init__(self, file):
# 這兒父類的init方法必須調(diào)用侣诵，否則當(dāng)前這個創(chuàng)建的對象中就沒有新的線程
super().__init__()
self.file = file
def run(self):
print(currentThread())
print('開始下載:%s' % self.file)
time.sleep(randint(5, 10))
print('%s下載結(jié)束' % self.file)
if __name__ == '__main__':
# time.time(): 獲取當(dāng)前時間-時間戳
start_time = time.time()
t1 = Download('最強(qiáng)Z.mp4')
t1.start()
t2 = Download('最強(qiáng)A.mp4')
t2.start()
print('====')
# 獲取當(dāng)前線程
"""
主線程: MainThread
子線程: Thread-數(shù)字（數(shù)字從1開始痢法。）
"""
print(currentThread())
# 如果一個任務(wù)想要在另外一個子線程中的任務(wù)執(zhí)行完成后再執(zhí)行，就在當(dāng)前任務(wù)前用子線程對象調(diào)用join方法
# 所以join也會阻塞線程杜顺，阻塞到對應(yīng)的子線程中任務(wù)執(zhí)行完為止
t1.join()
# t2.join()
end_time = time.time()
print('總共消耗時間:%.2f' % (end_time - start_time))
耗時操作
import pygame
from random import randint
import time
"""
1.耗時操作放到主線程中的問題：
耗時操作放到主線程中财搁，會阻塞線程
多個耗時操作都放到一個線程中執(zhí)行，最終執(zhí)行的時間是兩個耗時操作的時間和
2.怎么解決問題躬络？
使用多線程(創(chuàng)建多個線程)
"""
def rand_color():
return randint(0, 255),randint(0, 255),randint(0, 255)
def long_time():
print('耗時操作開始')
time.sleep(10)
print('耗時操作結(jié)束')
def download(file):
print('開始下載',file)
time.sleep(10)
print(file, '下載結(jié)束')
if __name__ == '__main__':
print('====')
print(time.time())
download('狄仁杰')
download('愛情公寓')
print(time.time())
print('!!!')
