TCP版本

TCP是有链接的

服务端

addr设置 bind listen accept 固定流程

#coding:utf-8
from socket import *
from time import ctime

HOST = '127.0.0.1' #主机号为空白表示可以使用任何可用的地址。
PORT = 21567 #端口号
BUFSIZ = 1024 #接收数据缓冲大小
ADDR = (HOST, PORT)

tcpSerSock = socket(AF_INET, SOCK_STREAM) #创建TCP服务器套接字
tcpSerSock.bind(ADDR) #套接字与地址绑定
tcpSerSock.listen(5) #监听连接，同时连接请求的最大数目

if __name__ == "__main__":
    print("=====================TCP服务器=====================");
    print('等待客户端的连接...')
    while True:
        tcpCliSock, addr = tcpSerSock.accept() #接收客户端连接请求
        try :
            data = tcpCliSock.recv(BUFSIZ,MSG_WAITALL) #连续接收指定字节的数据，接收到的是字节数组
        except Exception as e:
            print("Exception:",e)
        strData = str(data,encoding="utf8")
        if not data: #如果数据空白，则表示客户端退出，所以退出接收
           continue
        if "exit" in strData:
            tcpCliSock.close() #关闭与客户端的连接
        print(strData)
 
tcpSerSock.close() #关闭服务器socket

客户端

#coding:utf-8
from socket import *
from time import sleep

print("=====================TCP客户端=====================");

HOST = '127.0.0.1' #服务器ip地址，等价于localhost
PORT = 21567 #通信端口号
BUFSIZ = 1024 #接收数据缓冲大小
ADDR = (HOST, PORT)

while True:
    tcpCliSock = socket(AF_INET, SOCK_STREAM) #创建客户端套接字
    tcpCliSock.connect(ADDR) #发起TCP连接
    data = input('> ') #接收用户输入
    tcpCliSock.send(bytes(data, 'utf-8')) #客户端发送消息，必须发送字节数组
    tcpCliSock.close() #关闭客户端socket
    sleep(1)

运行效果

在这里插入图片描述

UDP版本

server

from socket import *
from time import ctime
 
host = '' #监听所有的ip
port = 13141 #接口必须一致
bufsize = 1024
addr = (host,port) 
 
udpServer = socket(AF_INET,SOCK_DGRAM)
udpServer.bind(addr) #开始监听
 
while True:
    print('Waiting for connection...')
    data,addr = udpServer.recvfrom(bufsize)  #接收数据和返回地址
    #处理数据
    data  = data.decode(encoding='utf-8').upper()
    data = "at %s :%s"%(ctime(),data)
    print(data)
 
udpServer.close()

client

from socket import *
 
host  = '127.0.0.1' # 这是客户端的电脑的ip
port = 13141 #接口选择大于10000的，避免冲突
bufsize = 1024  #定义缓冲大小
 
addr = (host,port) # 元祖形式
udpClient = socket(AF_INET,SOCK_DGRAM) #创建客户端
 
while True:
    data = input('>>> ')
    if not data:
        break
    data = data.encode(encoding="utf-8") 
    udpClient.sendto(data,addr) # 发送数据
 
udpClient.close()