'''

import socket

1.什么是socket
        socket又叫套接字渠退， 指的是網(wǎng)絡(luò)通信的兩端，分別是服務(wù)器和客戶端
        socket編程指的就是通過代碼實(shí)現(xiàn)客戶端和服務(wù)器之間的通信

2.服務(wù)器的實(shí)現(xiàn)
        """
        # 1.創(chuàng)建套接字對象
        """
        family: ip類型， AF_INET -> ipv4案怯，  AF_INET6 -> ipv6
        type: 傳輸協(xié)議的類型, SOCK_STREAM -> TCP,   SOCK_DGRAM -> UDP
        """
        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ù)器一直處于運(yùn)行狀態(tài)
            while True:
                print('開始監(jiān)聽....')
                # 5.等待客戶端的請求
                # 程序運(yùn)行到這個地方包归，會停下來，等到有客戶端來連接服務(wù)器赘理，才會接著往后執(zhí)行
                connect, addr = server.accept()
                print(connect, addr)
            
                # 6.發(fā)送消息
                """
                send(數(shù)據(jù))     -  發(fā)送數(shù)據(jù)宦言，數(shù)據(jù)是二進(jìn)制數(shù)據(jù)
                """
                message = input('>>>')
                connect.send(message.encode(encoding='utf-8'))

    # 7.接收消息
                """
                recv(字節(jié)數(shù))   - 接收數(shù)據(jù),并且指定一次性接收的數(shù)據(jù)的大小的最大值；返回接收到的二進(jìn)制數(shù)據(jù)
                """
                # 程序運(yùn)行到這個地方會停下來商模，直到客戶端給服務(wù)器發(fā)送消息奠旺，才會接著執(zhí)行
                data = connect.recv(1024)
                print('<<<:')
                print(data.decode(encoding='utf-8'))
                

    # 8.關(guān)閉連接
                connect.close()



========================================================= 創(chuàng)建客戶端套接字=======================================

import socket


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

====================================可以一直連接的服務(wù)器=================================================

import socket
from threading import Thread

class ClientThread(Thread):
    def __init__(self, connect, addr):
        super().__init__()
        self.connect = connect
        self.addr = addr
        self.message = '你好'

    def run(self):
        while True:
            # 發(fā)送消息
            self.connect.send(self.message.encode())

            # 接收消息s
            data = self.connect.recv(1024)
            print(self.addr, ':', data.decode(encoding='utf-8'))
            if data.decode(encoding='utf-8') == '拜拜':
                break


def creat_server():
    server = socket.socket()
    server.bind(('10.7.190.127', 9005))
    server.listen(255)
    # 為了服務(wù)器一直處于運(yùn)行狀態(tài)
    while True:
        # print('開始監(jiān)聽....')
        connect, addr = server.accept()

        # 來一個客戶端連接，為這個客戶端創(chuàng)建一個子線程施流，用于聊天
        # t = Thread(target=del_client, args=(connect, addr))
        t = ClientThread(connect, addr)
        t.start()


creat_server()


=============================================網(wǎng)絡(luò)接口請求數(shù)據(jù)=====================================================
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)獲取二進(jìn)制數(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()
# print(type(message), message)
# print(message['data'])

============================================= 進(jìn)程  線程 ======================================================
"""__author__ = 余婷"""
import threading
from datetime import datetime, date, time
from time import sleep

"""
1.什么是進(jìn)程

            一個正在運(yùn)行的應(yīng)用程序就是一個進(jìn)程响疚。系統(tǒng)會給每個進(jìn)程分配一個獨(dú)立的內(nèi)存區(qū)域，用來保存程序運(yùn)行過程中產(chǎn)生的數(shù)據(jù)瞪醋，
            當(dāng)進(jìn)程結(jié)束的時候忿晕，這個內(nèi)存區(qū)域會自動銷毀

2.什么是線程

            進(jìn)程想要執(zhí)行任務(wù)，就必須要有線程银受。每個進(jìn)程默認(rèn)都有一個線程践盼，這個線程叫主線程；其他的線程叫子線程
            程序默認(rèn)都是在主線程中執(zhí)行的

            一個線程中執(zhí)行多個任務(wù)宾巍，任務(wù)是串行執(zhí)行的(一個一個的按順序執(zhí)行)
            一個進(jìn)程中如果有多個線程咕幻，多線程執(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é)束；進(jìn)程不一定結(jié)束鲜侥，所有的線程都結(jié)束褂始，進(jìn)程才會結(jié)束
print([1, 2][10])
print('+++++++++++')


=============================================== 創(chuàng)建子線程 —— 創(chuàng)建子線程 ======================================================

from threading import Thread, current_thread
import time
from random import randint

# 1.創(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í)行到這個地方會停下來(線程會阻塞)舀寓，直到線程對象中的人物執(zhí)行完成后才執(zhí)行后面的語句
        """
        t1.join()
        t2.join()
        # print('t1結(jié)束')
        end = time.time()
        print('總時間: ', end - start)


'''