python中的TCP及UDP

python中是經過套接字即socket來實現UDP及TCP通訊的。有兩種套接字面向鏈接的及無鏈接的，也就是TCP套接字及UDP套接字。

TCP通訊模型

建立TCP服務器

　　僞代碼：

ss = socket() # 建立服務器套接字
ss.bind() # 套接字與地址綁定
ss.listen() # 監聽鏈接
inf_loop: # 服務器無限循環
    cs = ss.accept() # 接受客戶端鏈接
    comm_loop: # 通訊循環
        cs.recv()/cs.send() # 對話（接收/發送）
    cs.close() # 關閉客戶端套接字
ss.close() # 關閉服務器套接字#（可選）

　　TCP時間戳服務器：

import socket
from time import ctime

HOST = ''
PORT = 8099
BUFSIZE = 1024
ADDR = (HOST, PORT)
tcpSerSock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
tcpSerSock.bind(ADDR)
tcpSerSock.listen(5)
while True:
    print("等待鏈接......")
    tcpCliSock, addr = tcpSerSock.accept()
    print("...接收到鏈接：", addr)
    while True:
        data = tcpSerSock.recv(BUFSIZE)
        if not data:
            break
        tcpCliSock.send('[%s] %s' % (bytes(ctime(), 'utf-8'), data))
    tcpCliSock.close()
tcpSerSock.close()

 

建立TCP客戶端：

　　僞代碼:

cs = socket()  # 建立客戶端套接字
cs.connect()  # 嘗試鏈接服務器
comm_loop:  # 通訊循環
    cs.send() / cs.recv()  # 對話（發送/接收）
cs.close()  # 關閉客戶端套接字

 

　　TCP時間戳客戶端：

import socket

HOST = 'localhost'
PORT = 8099
BUFSIZE = 1024
ADDR = (HOST, PORT)

tcpCliSock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
tcpCliSock.connect(ADDR)
while True:
    data = input("> ")
    if not data:
        break
    tcpCliSock.send(data)
    data = tcpCliSock.recv(BUFSIZE)
    if not data:
        break
    print(data)
tcpCliSock.close()

 

UDP通訊模型

建立UDP服務器

　　僞代碼：

ss = socket() # 建立服務器套接字
ss.bind() # 綁定服務器套接字
inf_loop: # 服務器無限循環
    cs = ss.recvfrom()/ss.sendto() # 關閉（接收/發送）
ss.close() # 關閉服務器套接字

　　UDP時間戳服務器：

import socket
from time import ctime

HOST = ''
PORT = 8099
BUFSIZE = 1024
ADDR = (HOST, PORT)
udpSerSock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
udpSerSock.bind(ADDR)
while True:
    print("等待鏈接......")
    data, addr = udpSerSock.recvfrom(BUFSIZE)
    udpSerSock.sendto('[%s] %s' % (ctime(), data), addr)
    print("...接收到鏈接：", addr)
udpSerSock.close()

 

建立UDP客戶端

　　僞代碼：

cs = socket()  # 建立客戶端套接字
comm_loop:  # 通訊循環
    cs.sendto() / cs.recvfrom()  # 對話（發送/接收）
cs.close()  # 關閉客戶端套接字

　　UDP時間戳客戶端：

import socket

HOST = 'localhost'
PORT = 8099
BUFSIZE = 1024
ADDR = (HOST, PORT)

udpCliSock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
udpCliSock.connect(ADDR)
while True:
    data = input("> ")
    if not data:
        break
    udpCliSock.sendto(data, ADDR)
    data, ADDR = udpCliSock.recvfrom(BUFSIZE)
    if not data:
        break
    print(data)
udpCliSock.close()