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