一、TCP

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

#創(chuàng)建服務(wù)器
from socket import *
from time import ctime #導(dǎo)入ctime

HOST = '' #任意主機
PORT = 21567 #隨機提供個端口號
BUFSIZ = 1024 # 緩沖區(qū)大小設(shè)置為1KB，可以根據(jù)網(wǎng)絡(luò)性能和程序需要改變這個容量
ADDR = (HOST, PORT)

tcpSerSock = socket(AF_INET, SOCK_STREAM) #分配了 TCP 服務(wù)器套接字
tcpSerSock.bind(ADDR) #綁定到服務(wù)器地址以及開啟 TCP 的調(diào)用。
tcpSerSock.listen(5) #listen()方法的參數(shù)是在連接被轉(zhuǎn)接或拒絕之前，傳入連接請求的最大數(shù)

"""
 一旦進(jìn)入服務(wù)器的無限循環(huán)之中，我們就（被動地）等待客戶端的連接。當(dāng)一個連接請求出
現(xiàn)時，我們進(jìn)入對話循環(huán)中，在該循環(huán)中我們等待客戶端發(fā)送的消息。如果消息是空白的，這意
味著客戶端已經(jīng)退出，所以此時我們將跳出對話循環(huán)，關(guān)閉當(dāng)前客戶端連接，然后等待另一個客
戶端連接。如果確實得到了客戶端發(fā)送的消息，就將其格式化并返回相同的數(shù)據(jù)，但是會在這些
數(shù)據(jù)中加上當(dāng)前時間戳的前綴。最后一行永遠(yuǎn)不會執(zhí)行，它只是用來提醒讀者，如果寫了一個處
理程序來考慮一個更加優(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() #對話（接收 / 發(fā)送） 接收客戶端的data
 if not data:
 break
 tcpCliSock.send(('service：'+ctime()+'--'+data).encode()) #發(fā)送時間戳 和data信息給客戶端

 tcpCliSock.close()
tcpSerSock.close()

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

from socket import *

HOST = 'localhost'
PORT = 21567 #端口號 PORT 應(yīng)該與你為服務(wù)器設(shè)置的完全相同（否則，將無法進(jìn)行通信）
BUFSIZ = 1024
ADDR = (HOST, PORT)

tcpCliSock = socket(AF_INET, SOCK_STREAM) #分配 TCP 客戶端套接字
tcpCliSock.connect(ADDR) #主動連接

"""
 我們必須解碼來自服務(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ù)器終止且對 recv()方法的調(diào)用失敗
 break
 print('返回:%s'%data)
tcpCliSock.close()

二、UDP

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

"""
 這個腳本創(chuàng)建一個 UDP 服務(wù)器，它接受客戶端發(fā)來的消息，并將加了時間戳前綴的該消息返回給客戶端。
"""
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)建　

#這個腳本創(chuàng)建一個 UDP 客戶端，它提示用戶輸入發(fā)送給服務(wù)器的消息，并接收服務(wù)器加了時間戳前綴的消息，然后將它們顯示給用戶。
from socket import *
HOST = 'localhost'
PORT = 21567 #端口號 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()

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