一、TCP

1、tcp服務(wù)器創(chuàng)建

#創(chuàng)建服務(wù)器

from socket import *

from time import ctime #導(dǎo)入ctime

HOST = '' #任意主機(jī)

PORT = 21567 #隨機(jī)提供個(gè)端口號(hào)

BUFSIZ = 1024 # 緩沖區(qū)大小設(shè)置為1KB，可以根據(jù)網(wǎng)絡(luò)性能和程序需要改變這個(gè)容量

ADDR = (HOST, PORT)

tcpSerSock = socket(AF_INET, SOCK_STREAM) #分配了 TCP 服務(wù)器套接字

tcpSerSock.bind(ADDR) #綁定到服務(wù)器地址以及開啟 TCP 監(jiān)聽器的調(diào)用。

tcpSerSock.listen(5) #listen()方法的參數(shù)是在連接被轉(zhuǎn)接或拒絕之前，傳入連接請(qǐng)求的最大數(shù)

"""

一旦進(jìn)入服務(wù)器的無限循環(huán)之中，我們就(被動(dòng)地)等待客戶端的連接。當(dāng)一個(gè)連接請(qǐng)求出

現(xiàn)時(shí)，我們進(jìn)入對(duì)話循環(huán)中，在該循環(huán)中我們等待客戶端發(fā)送的消息。如果消息是空白的，這意

味著客戶端已經(jīng)退出，所以此時(shí)我們將跳出對(duì)話循環(huán)，關(guān)閉當(dāng)前客戶端連接，然后等待另一個(gè)客

戶端連接。如果確實(shí)得到了客戶端發(fā)送的消息，就將其格式化并返回相同的數(shù)據(jù)，但是會(huì)在這些

數(shù)據(jù)中加上當(dāng)前時(shí)間戳的前綴。最后一行永遠(yuǎn)不會(huì)執(zhí)行，它只是用來提醒讀者，如果寫了一個(gè)處

理程序來考慮一個(gè)更加優(yōu)雅的退出方式，正如前面討論的，那么應(yīng)該調(diào)用 close()方法。

"""

while True:

print("waiting for connection")

tcpCliSock, addr = tcpSerSock.accept() # 接收客戶端連接，返回客戶端和地址

print("...connected from:", addr)

while True:

data = tcpCliSock.recv(BUFSIZ).decode() #對(duì)話(接收 / 發(fā)送) 接收客戶端的data

if not data:

break

tcpCliSock.send(('service：'+ctime()+'--'+data).encode()) #發(fā)送時(shí)間戳 和data信息給客戶端

tcpCliSock.close()

tcpSerSock.close()

2、tcp客戶端創(chuàng)建

from socket import *

HOST = 'localhost'

PORT = 21567 #端口號(hào) PORT 應(yīng)該與你為服務(wù)器設(shè)置的完全相同(否則，將無法進(jìn)行通信)

BUFSIZ = 1024

ADDR = (HOST, PORT)

tcpCliSock = socket(AF_INET, SOCK_STREAM) #分配 TCP 客戶端套接字

tcpCliSock.connect(ADDR) #主動(dòng)連接

"""

我們必須解碼來自服務(wù)器端的字符串(借助于distutils.log.warn()

"""

while True:

data = input("> ")

if not data: #用戶如果沒有輸入，則終止

break

tcpCliSock.send(data.encode()) #發(fā)送客戶端的data給服務(wù)器

data = tcpCliSock.recv(BUFSIZ).decode() #接收服務(wù)器的data

if not data: #或者服務(wù)器終止且對(duì) recv()方法的調(diào)用失敗

break

print('返回:%s'%data)

tcpCliSock.close()

二、UDP

1、UDP服務(wù)器創(chuàng)建

"""

這個(gè)腳本創(chuàng)建一個(gè) UDP 服務(wù)器，它接受客戶端發(fā)來的消息，并將加了時(shí)間戳前綴的該消息返回給客戶端。

"""

from socket import *

from time import ctime

HOST = ""

PORT = 21567

BUFSIZ = 1024

ADDR = (HOST, PORT)

udpServer = socket(AF_INET, SOCK_DGRAM)

udpServer.bind(ADDR)

while True:

print("waiting for masssage")

data,addr = udpServer.recvfrom(BUFSIZ) #接收

data = data.decode()

udpServer.sendto((ctime()+"--"+ data).encode(),addr)

print("received from and returned to ",addr)

udpServer.close()

2、UDP客戶端創(chuàng)建

#這個(gè)腳本創(chuàng)建一個(gè) UDP 客戶端，它提示用戶輸入發(fā)送給服務(wù)器的消息，并接收服務(wù)器加了時(shí)間戳前綴的消息，然后將它們顯示給用戶。

from socket import *

HOST = 'localhost'

PORT = 21567 #端口號(hào) PORT 應(yīng)該與你為服務(wù)器設(shè)置的完全相同(否則，將無法進(jìn)行通信)

BUFSIZ = 1024

ADDR = (HOST, PORT)

udpCS = socket(AF_INET, SOCK_DGRAM)

while True:

data = input("> ")

if not data:

break

udpCS.sendto(data.encode(),ADDR)

data,ADDR = udpCS.recvfrom(BUFSIZ)

if not data:

break

print(data)

udpCS.close()

其實(shí)道理都差不多，在python3中，利用套接字傳輸?shù)膬?nèi)容都以byte形式傳輸，這時(shí)候傳送時(shí)(send/sendto)需要encode，接收(recv)時(shí)需要decode。只要掌握這個(gè)重點(diǎn)，處理這個(gè)問題就很簡(jiǎn)單了。

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持我們。

本文標(biāo)題: 詳解python3中socket套接字的編碼問題解決

本文地址: http://www.cppcns.com/jiaoben/python/195081.html

總結(jié)

以上是生活随笔為你收集整理的python socket自动重连_详解python3中socket套接字的编码问题解决的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

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