在這個(gè)周末剛剛寫出來(lái)的python桌面應(yīng)用--網(wǎng)絡(luò)聊天室，主要通過(guò)pyqt5作為桌面應(yīng)用框架，socket作為網(wǎng)絡(luò)編程的框架，從而實(shí)現(xiàn)包括客戶端和服務(wù)端的網(wǎng)絡(luò)聊天室的GUI應(yīng)用，希望可以一起學(xué)習(xí)、一起進(jìn)步！

應(yīng)用包括服務(wù)端server_ui.py、客戶端client_ui.py兩個(gè)python模塊實(shí)現(xiàn)，并且在pyqt5的使用過(guò)程中都使用QThread多線程應(yīng)用以及基本的UI頁(yè)面布局。開始之前通過(guò)一個(gè)動(dòng)態(tài)圖來(lái)觀察一下socket服務(wù)端、socket客戶端通信的實(shí)現(xiàn)效果。

【閱讀全文】

socket_ui.py 服務(wù)端

1-1. 依賴引用

在socket服務(wù)端的實(shí)現(xiàn)過(guò)程中，除了pyqt5相關(guān)的UI界面的引用外，還包括time、threading、sys、socket等輔助模塊來(lái)一起實(shí)現(xiàn)socket服務(wù)端的桌面應(yīng)用程序。

from PyQt5.QtWidgets import * from PyQt5.QtCore import * from PyQt5.QtGui import * import sysfrom QCandyUi import CandyWindow# 導(dǎo)入 socket 通訊模塊 import socket # 導(dǎo)入時(shí)間管理模塊 import time # 導(dǎo)入多線程模塊 import threading

1-2. 實(shí)現(xiàn)過(guò)程

在服務(wù)端的業(yè)務(wù)實(shí)現(xiàn)上面，我們依然是按照之前的GUI實(shí)現(xiàn)方式，采用主線程用來(lái)實(shí)現(xiàn)頁(yè)面布局，子線程QThread來(lái)實(shí)現(xiàn)業(yè)務(wù)邏輯的方式來(lái)進(jìn)行實(shí)現(xiàn)的，socket的服務(wù)端通信業(yè)務(wù)都是在子線程ServerThread中編寫的。下面是socket服務(wù)端桌面應(yīng)用實(shí)現(xiàn)的全部代碼塊，copy到自己的ide中即可直接啟動(dòng)使用。

class ServerUI(QWidget):def __init__(self):super(ServerUI, self).__init__()self.init_ui()def init_ui(self):self.setWindowTitle('socket 服務(wù)端 公眾號(hào)：[Python 集中營(yíng)]')self.setWindowIcon(QIcon('hi.ico'))self.setFixedSize(500, 300)hbox = QHBoxLayout()hbox_v1 = QVBoxLayout()self.brower = QTextBrowser()self.brower.setFont(QFont('宋體', 8))self.brower.setReadOnly(True)self.brower.setPlaceholderText('消息展示區(qū)域...')self.brower.ensureCursorVisible()hbox_v1.addWidget(self.brower)hbox_v2 = QVBoxLayout()hbox_v2_f1 = QFormLayout()self.ip_label = QLabel()self.ip_label.setText('ip地址 ')self.ip_txt = QLineEdit()self.ip_txt.setPlaceholderText('0.0.0.0')self.port_label = QLabel()self.port_label.setText('端口 ')self.port_txt = QLineEdit()self.port_txt.setPlaceholderText('4444')self.lis_num_label = QLabel()self.lis_num_label.setText('最大監(jiān)聽個(gè)數(shù) ')self.lis_num_txt = QLineEdit()self.lis_num_txt.setPlaceholderText('10')self.close_cli_label = QLabel()self.close_cli_label.setText('客戶端關(guān)閉指令 ')self.close_cli_txt = QLineEdit()self.close_cli_txt.setPlaceholderText('exit，客戶端發(fā)送相應(yīng)指令則關(guān)閉')hbox_v2_f1.addRow(self.ip_label, self.ip_txt)hbox_v2_f1.addRow(self.port_label, self.port_txt)hbox_v2_f1.addRow(self.lis_num_label, self.lis_num_txt)hbox_v2_f1.addRow(self.close_cli_label, self.close_cli_txt)self.start_btn = QPushButton()self.start_btn.setText('開啟服務(wù)端')self.start_btn.clicked.connect(self.start_btn_clk)hbox_v2.addLayout(hbox_v2_f1)hbox_v2.addWidget(self.start_btn)hbox.addLayout(hbox_v1)hbox.addLayout(hbox_v2)self.thread_ = ServerThread(self)self.thread_.message.connect(self.show_message)self.setLayout(hbox)def show_message(self, text):'''槽函數(shù)：向文本瀏覽器中寫入內(nèi)容:param text::return:'''cursor = self.brower.textCursor()cursor.movePosition(QTextCursor.End)self.brower.append(text)self.brower.setTextCursor(cursor)self.brower.ensureCursorVisible()def start_btn_clk(self):self.thread_.start()self.start_btn.setEnabled(False)class ServerThread(QThread):message = pyqtSignal(str)def __init__(self, parent=None):super(ServerThread, self).__init__(parent)self.parent = parentself.working = Truedef __del__(self):self.working = Falseself.wait()def run(self):self.message.emit('準(zhǔn)備啟動(dòng)socket服務(wù)端...')# 創(chuàng)建服務(wù)端 socketsocket_server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)# 綁定服務(wù)地址、端口address = (self.parent.ip_txt.text().strip(), int(self.parent.port_txt.text().strip()))socket_server.bind(address)# 設(shè)置監(jiān)聽最大等待數(shù)socket_server.listen(int(self.parent.lis_num_txt.text().strip()))self.message.emit("服務(wù)已經(jīng)啟動(dòng)，正在等待客戶端連接...")while True:# 設(shè)置睡眠時(shí)間time.sleep(0.1)# 允許客戶端連接client, info = socket_server.accept()self.client, self.info = client, info# 啟用新線程調(diào)用消息處理thread = threading.Thread(target=self.catch_message)# 設(shè)置為守護(hù)線程thread.setDaemon(True)# 開啟線程執(zhí)行thread.start()def catch_message(self):self.client.send("歡迎來(lái)到網(wǎng)絡(luò)聊天室".encode('utf-8'))self.message.emit("客戶端信息：" + str(self.info))close_cli = self.parent.close_cli_txt.text().strip()while True:try:# 接收客戶端消息、接收最大長(zhǎng)度為 1024，并進(jìn)行 utf-8 解碼message = self.client.recv(1024).decode('utf-8')# 校驗(yàn)是否關(guān)閉客戶端if not message and close_cli == message:self.client.close()self.message.emit("當(dāng)前客戶端已關(guān)閉！")breakself.message.emit("接收到消息：" + message)# 將消息進(jìn)行 utf-8 編碼后發(fā)給客戶端rcv = "服務(wù)端成功接收消息：" + messageself.client.send(rcv.encode('utf-8'))except Exception as e:self.client.send("服務(wù)端處理消息異常！".encode('utf-8'))breakif __name__ == '__main__':app = QApplication(sys.argv)w = CandyWindow.createWindow(ServerUI(), theme='blueGreen', title='socket 服務(wù)端 公眾號(hào)：[Python 集中營(yíng)]',ico_path='hi.ico')w.show()sys.exit(app.exec_())

1-3. 實(shí)現(xiàn)效果

client_ui.py 客戶端

2-1. 依賴引用

在socket客戶端的實(shí)現(xiàn)過(guò)程中，除了pyqt5相關(guān)的UI界面的引用外，還包括sys、socket等輔助模塊來(lái)一起實(shí)現(xiàn)socket服務(wù)端的桌面應(yīng)用程序，相比服務(wù)端來(lái)說(shuō)，客戶端并沒有使用多線程threading模塊。

from PyQt5.QtWidgets import * from PyQt5.QtCore import * from PyQt5.QtGui import * import sysfrom QCandyUi import CandyWindow# 導(dǎo)入socket 通信模塊 import socket

2-2. 實(shí)現(xiàn)過(guò)程

客戶端的實(shí)現(xiàn)過(guò)程和服務(wù)端server_ui.py實(shí)現(xiàn)是基本相似的，同樣也使用到了pyqt5的QThread的子線程應(yīng)用，唯一不同的是socket客戶端通信方式跟服務(wù)端不大相同，同樣將下面的代碼塊copy到自己的ide中直接使用即可。

class ClientUI(QWidget):def __init__(self):super(ClientUI, self).__init__()self.init_ui()def init_ui(self):self.setWindowTitle('socket 客戶端 公眾號(hào)：[Python 集中營(yíng)]')self.setWindowIcon(QIcon('hi.ico'))self.setFixedSize(500, 300)hbox = QHBoxLayout()hbox_v1 = QVBoxLayout()self.brower = QTextBrowser()self.brower.setFont(QFont('宋體', 8))self.brower.setReadOnly(True)self.brower.setPlaceholderText('消息展示區(qū)域...')self.brower.ensureCursorVisible()hbox_v1.addWidget(self.brower)hbox_v2 = QVBoxLayout()hbox_v2_g1 = QGridLayout()self.ip_label = QLabel()self.ip_label.setText('ip地址 ')self.ip_txt = QLineEdit()self.ip_txt.setPlaceholderText('0.0.0.0')self.port_label = QLabel()self.port_label.setText('端口 ')self.port_txt = QLineEdit()self.port_txt.setPlaceholderText('4444')self.message = QTextEdit()self.message.setPlaceholderText('發(fā)送消息內(nèi)容...')hbox_v2_g1.addWidget(self.ip_label, 0, 0, 1, 1)hbox_v2_g1.addWidget(self.ip_txt, 0, 1, 1, 1)hbox_v2_g1.addWidget(self.port_label, 1, 0, 1, 1)hbox_v2_g1.addWidget(self.port_txt, 1, 1, 1, 1)hbox_v2_g1.addWidget(self.message, 2, 0, 1, 2)self.start_btn = QPushButton()self.start_btn.setText('發(fā)送消息')self.start_btn.clicked.connect(self.start_btn_clk)hbox_v2.addLayout(hbox_v2_g1)hbox_v2.addWidget(self.start_btn)hbox.addLayout(hbox_v1)hbox.addLayout(hbox_v2)self.thread_ = ClientThread(self)self.thread_.message.connect(self.show_message)self.setLayout(hbox)def show_message(self, text):'''槽函數(shù)：向文本瀏覽器中寫入內(nèi)容:param text::return:'''cursor = self.brower.textCursor()cursor.movePosition(QTextCursor.End)self.brower.append(text)self.brower.setTextCursor(cursor)self.brower.ensureCursorVisible()def start_btn_clk(self):self.thread_.start()class ClientThread(QThread):message = pyqtSignal(str)def __init__(self, parent=None):super(ClientThread, self).__init__(parent)self.parent = parentself.working = Trueself.is_connect = Falsedef __del__(self):self.working = Falseself.wait()def run(self):try:if self.is_connect is False:self.connect_serv()# 將控制臺(tái)輸入消息進(jìn)行 utf-8 編碼后發(fā)送self.socket_client.send(self.parent.message.toPlainText().strip().encode('utf-8'))self.message.emit(self.socket_client.recv(1024).decode('utf-8'))except Exception as e:self.message.emit("發(fā)送消息異常：" + str(e))def connect_serv(self):try:self.message.emit("正在創(chuàng)建客戶端socket...")# 創(chuàng)建客戶端 socketself.socket_client = socket.socket()# 連接服務(wù)端address = (self.parent.ip_txt.text().strip(), int(self.parent.port_txt.text().strip()))self.socket_client.connect(address)self.message.emit("服務(wù)端連接成功...")# 接收服務(wù)端消息并進(jìn)行 utf-8 解碼self.message.emit(self.socket_client.recv(1024).decode())self.is_connect = Trueexcept:self.is_connect = Falseif __name__ == '__main__':app = QApplication(sys.argv)w = CandyWindow.createWindow(ClientUI(), theme='blueGreen', title='socket 客戶端 公眾號(hào)：[Python 集中營(yíng)]',ico_path='hi.ico')w.show()sys.exit(app.exec_())

2-3. 實(shí)現(xiàn)效果

【往期精彩】

零配置python日志，安裝即用！

英語(yǔ)沒學(xué)好到底能不能做coder，別再糾結(jié)了先學(xué)起來(lái)...

數(shù)據(jù)清洗工具flashtext，效率直接提升了幾十倍數(shù)！

一個(gè)help函數(shù)解決了python的所有文檔信息查看...

python 自定義異常/raise關(guān)鍵字拋出異常

總結(jié)

以上是生活随笔為你收集整理的GUI 应用：socket 网络聊天室的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。