使用python構(gòu)建一個自己的聊天室
一、簡介
本篇文章旨在通過實現(xiàn)一個簡單的多人聊天室,幫助讀者掌握Python的socket編程。我們將分為以下幾個部分來展開本文的內(nèi)容:
二、網(wǎng)絡(luò)編程基礎(chǔ)概念
- IP地址:網(wǎng)絡(luò)中每個設(shè)備的唯一標識符,用于在網(wǎng)絡(luò)中定位設(shè)備。
- 端口:標識設(shè)備上的不同網(wǎng)絡(luò)應(yīng)用,一個端口對應(yīng)一個特定的服務(wù)或應(yīng)用。
- 協(xié)議:數(shù)據(jù)通信的規(guī)則,如TCP和UDP。
三、Socket編程簡介及原理
- Socket是一種通信句柄,用于在網(wǎng)絡(luò)中傳輸數(shù)據(jù)。
- Python的
socket
庫提供了豐富的函數(shù)和類,用于實現(xiàn)網(wǎng)絡(luò)編程。 - Socket編程主要包括創(chuàng)建socket對象、綁定地址和端口、監(jiān)聽連接、接受和發(fā)送數(shù)據(jù)等操作。
四、聊天室架構(gòu)及功能需求
- 聊天室分為服務(wù)器端和客戶端。
- 服務(wù)器端負責(zé)接收客戶端的連接請求,轉(zhuǎn)發(fā)客戶端的消息。
- 客戶端負責(zé)與服務(wù)器建立連接,并發(fā)送和接收消息。
- 聊天室需要支持多個客戶端同時在線,并實時接收和發(fā)送消息。
五、實現(xiàn)聊天室服務(wù)器端
1.使用socket創(chuàng)建服務(wù)器端socket對象。
import socket import threading server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
2.綁定IP地址和端口。
server.bind(("0.0.0.0", 8080))
3.監(jiān)聽客戶端連接。
server.listen(5)
4.當有新的客戶端連接時,將其加入已連接的客戶端列表。
clients = [] while True: client_socket, client_address = server.accept() clients.append(client_socket) thread = threading.Thread(target=handle_client, args=(client_socket, client_address)) thread.start()
5.使用多線程處理每個客戶端的消息接收和發(fā)送。
def handle_client(client_socket, client_address): print(f"[INFO] Client {client_address} connected.") while True: try: message = client_socket.recv(1024).decode("utf-8") if not message: break print(f"[{client_address}] {message}") broadcast(client_socket, f"[{client_address}] {message}") except: break print(f"[INFO] Client {client_address} disconnected.") clients.remove(client_socket) client_socket.close() ``
6.當客戶端斷開連接時,從客戶端列表中移除
clients.remove(client_socket) client_socket.close()
7.廣播消息給其他客戶端。
def broadcast(from_client_socket, message): for client_socket in clients: if client_socket != from_client_socket: client_socket.send(message.encode("utf-8"))
8.聊天室服務(wù)器端完整代碼:
import socket import threading def handle_client(client_socket, client_address): print(f"[INFO] Client {client_address} connected.") while True: try: message = client_socket.recv(1024).decode("utf-8") if not message: break print(f"[{client_address}] {message}") broadcast(client_socket, f"[{client_address}] {message}") except: break print(f"[INFO] Client {client_address} disconnected.") clients.remove(client_socket) client_socket.close() def broadcast(from_client_socket, message): for client_socket in clients: if client_socket != from_client_socket: client_socket.send(message.encode("utf-8")) server = socket.socket(socket.AF_INET, socket.SOCK_STREAM) server.bind(("0.0.0.0", 8080)) server.listen(5) print("[INFO] Server is listening...") clients = [] while True: client_socket, client_address = server.accept() clients.append(client_socket) thread = threading.Thread(target=handle_client, args=(client_socket, client_address)) thread.start()
六、實現(xiàn)聊天室客戶端
1.使用socket創(chuàng)建客戶端socket對象。
import socket import threading client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
2.連接到服務(wù)器端的IP地址和端口。
client.connect(("127.0.0.1", 8080))
3.使用多線程處理服務(wù)器端發(fā)送過來的消息。
def receive_message(): while True: message = client.recv(1024).decode("utf-8") print(message) thread = threading.Thread(target=receive_message) thread.start()
4.接收用戶輸入的消息,并發(fā)送給服務(wù)器端。
while True: message = input() client.send(message.encode("utf-8"))
5.聊天室客戶端完整代碼:
import socket import threading def receive_message(): while True: message = client.recv(1024).decode("utf-8") print(message) client = socket.socket(socket.AF_INET, socket.SOCK_STREAM) client.connect(("127.0.0.1", 8080)) print("[INFO] Connected to the server.") thread = threading.Thread(target=receive_message) thread.start() while True: message = input() client.send(message.encode("utf-8"))
七、測試聊天室
分別啟動聊天室服務(wù)器端和多個客戶端。在客戶端發(fā)送消息,觀察其他客戶端是否能收到消息。嘗試斷開客戶端,觀察服務(wù)器端和其他客戶端的表現(xiàn)。
到此這篇關(guān)于使用python構(gòu)建一個自己的聊天室的文章就介紹到這了,更多相關(guān)python構(gòu)建聊天室內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
基于Django的樂觀鎖與悲觀鎖解決訂單并發(fā)問題詳解
這篇文章主要介紹了基于Django的樂觀鎖與悲觀鎖解決訂單并發(fā)問題詳解,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2019-07-07詳解python opencv、scikit-image和PIL圖像處理庫比較
這篇文章主要介紹了詳解python opencv、scikit-image和PIL圖像處理庫比較,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-12-12python使用openpyxl庫讀寫Excel表格的方法(增刪改查操作)
這篇文章主要介紹了python使用openpyxl庫讀寫Excel表格的方法(增刪改查操作),本文通過實例圖文相結(jié)合給大家介紹的非常詳細,對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2021-05-05升級keras解決load_weights()中的未定義skip_mismatch關(guān)鍵字問題
這篇文章主要介紹了升級keras解決load_weights()中的未定義skip_mismatch關(guān)鍵字問題,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2020-06-06PyQt5基本控件使用詳解:單選按鈕、復(fù)選框、下拉框
這篇文章主要介紹了PyQt5基本控件使用:單選按鈕、復(fù)選框、下拉框,本文中的內(nèi)容和實例也基本回答了開篇提到的問題。需要的朋友可以參考下2019-08-08Python爬蟲實現(xiàn)的根據(jù)分類爬取豆瓣電影信息功能示例
這篇文章主要介紹了Python爬蟲實現(xiàn)的根據(jù)分類爬取豆瓣電影信息功能,結(jié)合完整實例形式分析了Python針對電影信息分類抓取的相關(guān)實現(xiàn)技巧,需要的朋友可以參考下2019-09-09