基于Python+TCP/IP的簡易聊天室

首先我們要了解TCP/IP連接的過程

服務器

1 創建套接字

tcpSerSock=socket(AF_INET,SOCK_STREAM)

2 bind一個地址，因為沒有服務器，所以綁定了本地地址和端口

tcpSerSock.bind(Addr)
Addr=(Host,Port)

3 開始監聽客戶端，參數為監聽的個數

tcpSerSock.listen(5)

4 append到客戶端

sockets.append(tcpCliSock)

5 然后就是發送字節和接收字節的事

data=tcpCliSock.recv(1024)#接收字節
socket.send(data)#發送字節

6 最后要關閉連接和關閉套接字

tcpCliSock.close()

客戶端

1 創建TCP/IP套接字

tcpCliSock=socket(AF_INET,SOCK_STREAM)

2 連接服務器，連接的是本地服務器

Host='localhost'
Port=10000
Addr=(Host,Port)
tcpCliSock.connect(Addr)

3 進行發送和接收字節

recv_data=tcpCliSock.recv(1024)
tcpCliSock.send(msg.encode('utf-8'))

4 最后也要記得關閉連接

tcpCliSock.close()

如果想要多人同時聊天，要加入多線程
然后在封裝的函數里啟用多線程

最后全部的代碼

服務器：

from socket import *
from time import ctime
from threading import Thread
sockets=[]

Host=''
Port=10000
Addr=(Host,Port)
    
tcpSerSock=socket(AF_INET,SOCK_STREAM)
tcpSerSock.bind(Addr)
tcpSerSock.listen(5)
    

def main():
    while True:
        print("waiting for connection...")
        tcpCliSock,addr=tcpSerSock.accept()
        sockets.append(tcpCliSock)
        print('connected from:',addr,ctime())
        t=Thread(target=readMsg,args=(tcpCliSock,))
        t.start()
        
        
def readMsg(tcpCliSock):
    while True:
        data=tcpCliSock.recv(1024)
        if data.decode('utf-8').endswith('bye'):
            sockets.remove(tcpCliSock)
            tcpCliSock.close()
            print('有客戶端退出')
            
            break
        
        for socket in sockets:
            socket.send(data)
        
    tcpCliSock.close()
    

        
if __name__=='__main__':
    main()

客戶端：

from socket import *
from time import ctime
from threading import Thread
flag=True

Host='localhost'
Port=10000
Addr=(Host,Port)
    
tcpCliSock=socket(AF_INET,SOCK_STREAM)
tcpCliSock.connect(Addr)

name=input ('請輸入用戶名:')
def readMsg(tcpCliSock):
    while flag:
        recv_data=tcpCliSock.recv(1024)
        print(recv_data.decode('utf-8'))

def writeMsg(tcpCliSock):
    global flag
    while flag:
        msg=input('>')
        msg=name+':'+msg
        tcpCliSock.send(msg.encode('utf-8'))
        if msg.endswith('bye'):
            flag=False
            break

t1=Thread(target=readMsg,args=(tcpCliSock,))
t1.start()

t2=Thread(target=writeMsg,args=(tcpCliSock,))
t2.start()
t1.join()
t2.join()
tcpCliSock.close()

只要啟動，然后輸入名字，就能進行聊天了