一、TCP

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

#創(chuàng)建服務(wù)器from socket import *from time import ctime #導(dǎo)入ctimeHOST = ''    #任意主機(jī)PORT = 21567  #隨機(jī)提供個端口號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 監(jiān)聽器的調(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 = 1024ADDR = (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 = 21567BUFSIZ = 1024ADDR = (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()