python中的socket套接字用于實現(xiàn)網(wǎng)絡(luò)通信
tcp套接字的使用流程如下：

1. 創(chuàng)建套接字對象 --- clientSocket = socket(AF_INET,SOCK_STREAM)
2. 連接服務(wù)器，指定服務(wù)器的ip地址和端口（參數(shù)是個元組）------------clientSocket.connect(('192.168.99.173',9999))
3. 發(fā)送信息 -------------clientSocket.send(msg.encode('utf8'))
4. 接收信息 ----------------msg = clientSocket.recv(1024)

我們先實現(xiàn)一個tcp的客戶端

由于socket在接收數(shù)據(jù)時默認(rèn)為堵塞狀態(tài)，當(dāng)接收數(shù)據(jù)是進程就刮起了，這時就無法發(fā)送信息，要實現(xiàn)全雙工的通信，需要給接收數(shù)據(jù)和發(fā)送數(shù)據(jù)各自分配一個線程。

from socket import *
from threading import Thread



def sendMsg(clientSocket):
    while True:
        msg = input('>>')
        clientSocket.send(msg.encode('utf8'))

def recvMsg(clientSocket):
    while True:
        msg = clientSocket.recv(1024)
        print('\r>>%s'%msg.decode('utf8'))

def main():

    clientSocket = socket(AF_INET,SOCK_STREAM)

    clientSocket.connect(('192.168.99.173',9999))

    tr = Thread(target=recvMsg,args=(clientSocket,)) #將套接字作為參數(shù)傳給新線程，各自的線程中分別執(zhí)行收，發(fā)數(shù)據(jù)
    ts = Thread(target=sendMsg,args=(clientSocket,))

    tr.start()
    ts.start()

if __name__ == '__main__':
    main()

接下來實現(xiàn)服務(wù)端

服務(wù)端的套接字比較特殊，因為是為客戶端服務(wù)，所以要確定下來ip地址和端口號以便客戶端訪問，然后服務(wù)器還要能生成新的客服套接字單獨為一個客戶端服務(wù)，利用多進程就可以生成多個同時工作的客服socket了。
服務(wù)器的套接字工作流程如下：

1. 創(chuàng)建主套接字 --------serverSocket = socket(AF_INET,SOCK_STREAM)
2. 綁定ip和端口 --------------------- serverSocket.bind(('',9999))
3. 改為被動套接字 ------------------------------serverSocket.listen(5)
4. 檢測客戶端連接 ，若連接則返回 新的服務(wù)套接字和客戶端地址ip----- newSocket,destAdr = serverSocket.accept()
5. 每個服務(wù)套接字進行與客戶端的數(shù)據(jù)交換（在各自的進程里）

# 要求
#1. 使用tcp協(xié)議通信
#2. 使用多進程配合多線程配合多線程的方式實現(xiàn)多個全雙工的對話。

#實現(xiàn)
#1. 創(chuàng)建tcp的套接字，綁定，監(jiān)聽，變?yōu)楸粍?#2. 每收到一次請求返回新的套接字，同時創(chuàng)建子進程，用來單獨用新套接字對話
#3. 子進程中創(chuàng)建兩個線程，用來收發(fā)數(shù)據(jù)
import os
from socket import *
from multiprocessing import Process
from threading import Thread,local
import time

def worker(newSocket,destAdr):
    print('創(chuàng)建子會話進程成功..')
    #local_school = local() #創(chuàng)建ThreadLocal對象，用來儲存各線程的局部變量
    ts = Thread(target=sendMsg,args=(newSocket,))
    tr = Thread(target=recvMsg,args=(newSocket,))

    ts.start()
    tr.start()
    
    ts.join()
    tr.join()

def sendMsg(newSocket):
    print('發(fā)送進程準(zhǔn)備完畢！')
    print(os.getpid())
    while True:
        msg = str( os.getpid())
        newSocket.send(msg.encode('utf8'))
        time.sleep(5)
def ps_is_end():
    print('子進程結(jié)束')

def recvMsg(newSocket):
    print('接受進程準(zhǔn)備完畢！')
    while True:
        msg = newSocket.recv(1024)
        if msg.decode('utf8')!= '':  #在ubantu中測試當(dāng)客戶端連接關(guān)閉時會自動發(fā)送‘’，而在windows下運行卻會報錯
            print('\r>>%s'%msg.decode('utf8'))
        else:
            print('%d下限了'%os.getpid())
            newSocket.close()
            break


def main():
    serverSocket = socket(AF_INET,SOCK_STREAM)

    serverSocket.bind(('',9999))

    serverSocket.listen(5)

    while True:

        newSocket,destAdr = serverSocket.accept()
        p = Process(target=worker,args=(newSocket,destAdr,))
       
        p.start()
        newSocket.close()#拷貝到了新的進程中，這里的可以刪掉了
    
    serverSocket.close()


if __name__ == '__main__':
    main()

試一下效果，先啟動服務(wù)器，再啟動客戶端，然后客戶端發(fā)條信息

捕獲.PNG

捕獲2.PNG