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')

實現(xiàn)多線程方式1

1.耗時操作放到主線程中，會阻塞線程
耗時操作放到主線程坑律，會阻塞線程
多個耗時操作都放到一個線程中執(zhí)行晃择，最終執(zhí)行的時間是二個耗時操作de時間和
2.怎么解決問題
多線程
python內(nèi)置的threading模塊也物，可以支持多線程
所有的進(jìn)程默認(rèn)都有一個線程(一般都叫主線程)
如果想要在進(jìn)程中添加

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=['愛情公寓',7])
    #2.在子線程中執(zhí)行任務(wù)
    t1.start()

    t2 = threading.Thread(target=download,args=['狄仁杰',3])
    t2.start()
    #download('愛情公寓')
    #download('狄仁杰')
    print('=======')

實現(xiàn)多線程方式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

        # 獲取文件后綴
        #在正則表達(dá)式里表示結(jié)束$
        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('!!!!!')

客戶端

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())

耗時操作

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('!!!')

多線程應(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))