python怎么连接socket_python socket连接实现即时通讯
最近閑暇無事,好多人問即時通訊怎么做的,尤其是對于當下大火的python更是如此,大多數人都知道一個xmpp或者xampp框架,于是開了簡書,大致說明一下
不明白tcp/udp協議底層原理的,自行百度,這里就不再贅述。
在python中,要想實現即時通訊,需要明白socket協議的兩個概念,socket.AF_INET和socket_STREAM,前者是通訊的IP協議模式,代表IPv4,IPv4跟IPv6的區別在于,IPv4是32位整數位經過8字節劃分之后的取值,預想結果192.xx.xx.xx? ,而IPv6是128位整數位劃分之后的取值,預想結果xxxx.xxxx.xxxx.xxxx.xxxx.xxxx.xxxx.xxxx? ,v4的長度是有限制的,20個字節,而v6理論上是沒有限制的,這就是為什么大公司一般用v6而小公司用v4的原因。
后者socket_STREAM,見名知意,就是流的意思,這是一種服務端發送接收數據的數據形式,即字節(byte),在c/s交互的過程中,獲取到數據的流,進行decode或者encode編碼輸出即可,編碼格式大部分遵循utf-8,也有遵循gbk的,不再多說。
步驟:
1、創建客戶端py文件,連接服務端IP地址即服務器地址,如連接成功,發送數據并進行對應編碼;
2、創建服務端py文件,綁定域名,服務器掛起也就是等待連接,一旦接受到客戶端發送的數據,服務器自動進行處理;
核心代碼:
服務端(server.py):
import socket
#創建服務
server= socket.socket(socket.AF_INET,socket.SOCK_STREAM)
#綁定IP、端口? 這里我寫的是本機的IP,只要是服務啟動、端口對應就可以
server.bind(('192.168.1.112',8081))
#服務器監聽
server.listen(10)
print('socket連接成功')
#等待連接? ?服務器掛起狀態,等待客戶端喚起
clientSocket,clirentAddress= server.accept()
# server.close()? ? 因為是長連接,close操作根據你項目的具體場景而定
#這里寫一個死循環,執行下一步操作
while True:
#接收的數據? 來自客戶端
data= clientSocket.recv(1024)#這里填寫1024即可,就是一kb,最大值
print('客戶端:',data.decode('utf-8'))
if data:
backData= input('請回復客戶端:')
clientSocket.send(backData.encode('utf-8'))
客戶端(client.py):
import socket #導入包
client= socket.socket(socket.AF_INET,socket.SOCK_STREAM)
client.connect(('192.168.1.112',8081))? #IP地址跟端口號必須跟服務器一致
#循環執行操作
while True:
data= input('你對服務器說:')? #傳輸數據
client.send(data.encode('utf-8'))? ?#編碼解析數據
info= client.recv(1024)? ?#數據接收 (客戶端接收來自服務器的)
print('服務器說:',info.decode('utf-8'))
這種寫法只能是點對點發送信息,如果是點對多,需要循環執行對接的客戶端,時間原因,不再敲代碼。
總結
以上是生活随笔為你收集整理的python怎么连接socket_python socket连接实现即时通讯的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 数据仓库—stg层_数据仓库之Hive快
- 下一篇: duilib 子窗口位置_Duilib学