Python之socket详解

Socket编程

1.基本概念

1.什么是客户端/服务器架构？
服务器就是一系列硬件或软件，为一个或多个客户端（服务的用户）提供所需的“服务”。它存在唯一目的就是等待客户端的请求，
并响应它们（提供服务），然后等待更多请求。
说白了就是一个提供服务，一个请求服务得到相应的一个过程。

2.套接字：通信端点
套接字是计算机网络数据结构，它体现了上节中描述的“通信端点”的概念。在任何类型的通信开始之前，网络应用程序必须创建套接字。
可以将它们比作电话插孔，没有它将无法进行通信。

Python只支持AF_UNIX、AF_NETLINK、AF_TIPC 和 AF_INET ，重点使用基于网络的AF_INET.

3.套接字地址：主机-端口对
它是网络通信过程中端点的抽象表示，python使用元组保存:ADDR = (HOST,PORT)。

4.套接字类型
流式套接字(SOCK_STREAM):用于提供面向连接、可靠的数据传输服务。

数据报套接字(SOCK_DGRAM):提供了一种无连接的服务。该服务并不能保证数据传输的可靠性，数据有可能在传输过程中丢失或出现数据重复，且无法保证顺序地接收到数据。

2.Python网络编程

2.1 常见的套接字对象方法和属性

2.2 创建服务和客户端

2.2.1 创建TCP服务

一般的创建流程：

ss = socket()       #  创建服务器套接字
ss.bind(ADDR)       #  套接字与地址绑定
ss.listen()         #  监听连接
while True:         #  服务器无限循环
cs = ss.accept()    #  接受客户端连接
comm_loop:          #  通信循环
cs.recv()/cs.send() #  对话（接收 / 发送）
cs.close()          #  关闭客户端套接字
ss.close()          #  关闭服务器套接字 # （可选）

2.2.2 创建 TCP 客户端

一般的创建流程：

cs = socket()       #  创建客户端套接字
cs.connect()        #  尝试连接服务器
comm_loop:          #  通信循环
cs.send()/cs.recv() #  对话（发送 / 接收）
cs.close()          #  关闭客户端套接字

2.2.3 创建UDP服务

一般的创建流程：

ss = socket()       #  创建服务器套接字
ss.bind(ADDR)       #  套接字与地址绑定
while True:         #  服务器无限循环
ss.sendto()         #  发送
ss.recvfrom()       #  接收
ss.close()          #  关闭服务器套接字 # （可选）

2.2.4 创建 UDP 客户端

一般的创建流程：

cs = socket()       #  创建客户端套接字
comm_loop:          #  通信循环
cs.sendto()         #  发送
cs.recvfrom()       #  接收
cs.close()          #  关闭客户端套接字

import socket
from time import ctime
import json
import time
HOST = ‘‘
PORT = 9001
ADDR = (HOST, PORT)
BUFFSIZE = 1024
MAX_LISTEN = 5

def tcpServer():
    # TCP服务
    # with socket.socket() as s:
    with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
        # 绑定服务器地址和端口
        s.bind(ADDR)
        # 启动服务监听
        s.listen(MAX_LISTEN)
        print(‘等待用户接入。。。。。。。。。。。。‘)
        while True:
            # 等待客户端连接请求,获取connSock
            conn, addr = s.accept()
            print(‘警告，远端客户:{} 接入系统！！！‘.format(addr))
            with conn:
                while True:
                    print(‘接收请求信息。。。。。‘)
                    # 接收请求信息
                    data = conn.recv(BUFFSIZE)
                    print(‘data=%s‘ % data)
                    print(‘接收数据：{!r}‘.format(data.decode(‘utf-8‘)))

                    # 发送请求数据
                    conn.send(data.encode(‘utf-8‘))
                    print(‘发送返回完毕！！！‘)
            s.close()

# 创建UDP服务
def udpServer():
    # 创建UPD服务端套接字
    with socket.socket(socket.AF_INET, socket.SOCK_DGRAM) as s:
        # 绑定地址和端口
        s.bind(ADDR)
        # 等待接收信息
        while True:
            print(‘UDP服务启动，准备接收数据。。。‘)
            # 接收数据和客户端请求地址
            data, address = s.recvfrom(BUFFSIZE)

            if not data:
                break

            print(‘接收请求信息：{}‘.format(data.decode(‘utf-8‘)))

            s.sendto(b‘i am udp,i got it‘, address)

        s.close()

if __name__ == ‘__main__‘:

    while True:
        choice = input(‘input choice t-tcp or u-udp:‘)

        if choice != ‘t‘ and choice != ‘u‘:
            print(‘please input t or u,ok?‘)
            continue

        if choice == ‘t‘:
            print(‘execute tcpsever‘)
            tcpServer()
        else:
            print(‘execute udpsever‘)
            udpServer()

client.py代码

import socket

from time import ctime
HOST = ‘localhost‘
PORT = 9001
ADDR = (HOST, PORT)
ENCODING = ‘utf-8‘
BUFFSIZE = 1024

def tcpClient():
    # 创建客户套接字
    with socket.socket(family=socket.AF_INET, type=socket.SOCK_STREAM) as s:
        # 尝试连接服务器
        s.connect(ADDR)
        print(‘连接服务成功！！‘)
        # 通信循环
        while True:
            inData = input(‘pleace input something:‘)
            if inData == ‘q‘:
                break
            # 发送数据到服务器
            inData = ‘[{}]:{}‘.format(ctime(), inData)

            s.send(inData.encode(ENCODING))
            print(‘发送成功！‘)

            # 接收返回数据
            outData = s.recv(BUFFSIZE)
            print(‘返回数据信息：{!r}‘.format(outData))

        # 关闭客户端套接字
        s.close()

def udpClient():
    # 创建客户端套接字
    with socket.socket(socket.AF_INET, socket.SOCK_DGRAM) as s:
        while True:
            # 发送信息到服务器
            data = input(‘please input message to server or input \‘quit\‘:‘)
            if data == ‘quit‘:
                break
            data = ‘[{}]:{}‘.format(ctime(), data)

            s.sendto(data.encode(‘utf-8‘), ADDR)

            print(‘send success‘)

            # 接收服务端返回信息
            recvData, addrs = s.recvfrom(BUFFSIZE)

            print(‘recv message : {}‘.format(recvData.decode(‘utf-8‘)))

        # 关闭套接字
        s.close()

if __name__ == ‘__main__‘:

    while True:
        choice = input(‘input choice t-tcp or u-udp or q-quit:‘)
        if choice == ‘q‘:
            break
        if choice != ‘t‘ and choice != ‘u‘:
            print(‘please input t or u,ok?‘)
            continue

        if choice == ‘t‘:
            print(‘execute tcpsever‘)
            tcpClient()
        else:
            print(‘execute udpsever‘)
            udpClient()

代码说明：先执行 python server.py,在执行python client.py,就可以测试TPC/UDP简单的通信了。

原文地址：https://www.cnblogs.com/lonelyhiker/p/8577009.html