基于python3的socket聊天編程

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

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

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

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

缺點(diǎn)：程序不夠完善，只能一來(lái)一回，且沒(méi)人每次只能說(shuō)一句話(huà)

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)

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

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

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

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

開(kāi)始上代碼：

server端：

import socket
import threading # 導(dǎo)入多線(xiàn)程模塊
print("Waitting to be connected......")
HostPort = ('127.0.0.1',9999)
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM) # 創(chuàng)建socket實(shí)例
s.bind(HostPort)
s.listen(1)
conn,addr = s.accept()
true=True
addr = str(addr)
print('Connecting by : %s ' %addr )
def Receve(conn):   # 將接收定義成一個(gè)函數(shù)
 global true # 聲明全局變量，當(dāng)接收到的消息為quit時(shí)，則觸發(fā)全局變量 true = False，則會(huì)將socket關(guān)閉
 while true:
 data = conn.recv(1024).decode('utf8') 
 if data == 'quit':
 true=False
 print("you have receve: "+data+" from"+addr) # 當(dāng)接收的值為'quit'時(shí)，退出接收線(xiàn)程，否則，循環(huán)接收并打印
thrd=threading.Thread(target=Receve,args=(conn,)) # 線(xiàn)程實(shí)例化，target為方法，args為方法的參數(shù) 
thrd.start()    # 啟動(dòng)線(xiàn)程
while true:
 user_input = input('>>>')
 conn.send(user_input.encode('utf8'))  # 循環(huán)發(fā)送消息
 if user_input == 'quit':   # 當(dāng)發(fā)送為‘quit'時(shí)，關(guān)閉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、服務(wù)器端：（原來(lái)只能服務(wù)器端先接收消息后才能發(fā)送消息，現(xiàn)在沒(méi)有這種限制，可以隨時(shí)主動(dòng)發(fā)送）