基于python3的socket聊天編程

更新時間：2020年02月17日 14:22:02 作者：Dyy8686

這篇文章主要為大家詳細介紹了基于python3的socket聊天編程，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下

本文實例為大家分享了基于python3的socket聊天編程，供大家參考，具體內(nèi)容如下

階段一：最簡易的聊天系統(tǒng)

缺點：程序不夠完善，只能一來一回，且沒人每次只能說一句話

server端：

import socket
HostPort = ('127.0.0.1',9999)
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
s.bind(HostPort)
s.listen(1)
conn,addr = s.accept()
#print('Connecting by : %s ' % addr)
while 1:
 data = conn.recv(1024).decode()
 print (data)
 user_input = input('>>>')
 conn.send(user_input.encode('utf8'))
 #conn.close()
s.close()

client端：

import socket
hostport = ('127.0.0.1',9999)
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
s.connect(hostport)
 
while 1:
 user_input = input('>>> ').strip()
 s.send(user_input.encode('utf-8'))
 if len(user_input) == 0:
 continue
 if user_input == 'quit':
 s.close()
 break
 server_reply = s.recv(1024).decode()
 print (server_reply)

注意事項：在python 3中，bytes和str是兩個不同的概念，send和recv的數(shù)據(jù)都是bytes，而str轉(zhuǎn)化成bytes是通過encode('utf8')實現(xiàn)，bytes轉(zhuǎn)化成str,是通過decode()實現(xiàn)；

在該階段，服務十分不穩(wěn)定，經(jīng)常會斷開，所以有下一個階段，且每人每次可以發(fā)送多條消息；

階段二 多線程并發(fā)聊天系統(tǒng)

在階段一中，服務器端和客戶的通信只能一發(fā)一收，不能實現(xiàn)服務器端和客戶端雙方的自由消息發(fā)送，所以，我們引用多線程，我們將消息的接收單獨開一個線程，這樣便可以服務器端和客戶端實現(xiàn)同時發(fā)送多條消息，并不影響接收；

開始上代碼：

server端：

import socket
import threading # 導入多線程模塊
print("Waitting to be connected......")
HostPort = ('127.0.0.1',9999)
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM) # 創(chuàng)建socket實例
s.bind(HostPort)
s.listen(1)
conn,addr = s.accept()
true=True
addr = str(addr)
print('Connecting by : %s ' %addr )
def Receve(conn):   # 將接收定義成一個函數(shù)
 global true # 聲明全局變量，當接收到的消息為quit時，則觸發(fā)全局變量 true = False，則會將socket關閉
 while true:
 data = conn.recv(1024).decode('utf8') 
 if data == 'quit':
 true=False
 print("you have receve: "+data+" from"+addr) # 當接收的值為'quit'時，退出接收線程，否則，循環(huán)接收并打印
thrd=threading.Thread(target=Receve,args=(conn,)) # 線程實例化，target為方法，args為方法的參數(shù) 
thrd.start()    # 啟動線程
while true:
 user_input = input('>>>')
 conn.send(user_input.encode('utf8'))  # 循環(huán)發(fā)送消息
 if user_input == 'quit':   # 當發(fā)送為‘quit'時，關閉socket
 true = False
 #conn.close()
s.close()

client 端

import socket
import threading
hostport = ('127.0.0.1',9999)
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
s.connect(hostport)
true = True
def Receve(s):
 global true
 while true:
 data = s.recv(1024).decode('utf8')
 if data == 'quit':
 true = False
 print('recevie news:\033[5;37;46m%s\033[0m' % data )
thrd=threading.Thread(target=Receve,args=(s,))
thrd.start()
while true:
 user_input = input('>>>')
 s.send(user_input.encode('utf8'))
 if user_input == 'quit':
 true = False
s.close()

效果展示（紫色字體為接收消息，白色字體為發(fā)送消息，雙方任意一方輸入'quit'，即可退出）

1、服務器端：（原來只能服務器端先接收消息后才能發(fā)送消息，現(xiàn)在沒有這種限制，可以隨時主動發(fā)送）