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

HOST = ''    #任意主機(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)前客戶端連接，然后等待另一個客
戶端連接。如果確實(shí)得到了客戶端發(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()

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()

"""

  這個腳本創(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() 

#這個腳本創(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()