03Python网络编程系列之服务端

  • Z时代
  • 2024-01-10
  • 分类：综合

03Python网络编程系列之服务端[Python基础]

# 这里边是一个定义了服务端的一系列函数，是Python网络编程这本书第七章的第一个例子。
# 这是供后边函数进行调用了，然后我们来进行研究网络的单线程编程，多线程编程、异步网络编程等。

# 导入网络编程socket、时间time、cmd参数获取模块
import argparse, socket, time

# 定义一个字典用来存放发送给客户端的消息。
aphorisms = {b"Beautiful is better than?": b"Ugly.",
             b"Explicit is better than?": b"Implicit.",
             b"Simple is better than?": b"Complex."}

# 获取答案， 如果客户端发送了问题，就从上边的字典里边获取，如果没有的话就返回我不知道的错误。
def get_answer(aphorism):
    """Return the string response to a particular Zen-of-Python aphorism."""
    time.sleep(0.0)  # increase to simulate an expensive operation
    return aphorisms.get(aphorism, b"Error: unknown aphorism.")

# 定义一个函数用来获取终端需要传入的参数。 host：主机IP或者名称 -p：端口，默认为1060
# 返回值是一个元祖，包含IP端口。
def parse_command_line(description):
    """Parse command line and return a socket address."""
    parser = argparse.ArgumentParser(description=description)
    parser.add_argument("host", help="IP or hostname")
    parser.add_argument("-p", metavar="port", type=int, default=1060,
                        help="TCP port (default 1060)")
    args = parser.parse_args()
    address = (args.host, args.p)
    return address

# 创造一个socket套接字，这里的入参是上边那个函数的出参。
def create_srv_socket(address):
    """Build and return a listening server socket."""
    # 创造一个套接字。
    listener = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    # 设置。
    listener.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    # 服务端绑定IP和端口。
    listener.bind(address)
    # 设置服务端能够监听的数量，这里设置的是最大能够同时监听64个。
    listener.listen(64)
    # 打印出绑定的IP端口，服务端绑定的。
    print("Listening at {}".format(address))
    # 返回这个套接字。
    return listener

# 一直持续不断的进行监听， 观察有没有客户端和服务端进行连接。
# 这里的入参是上边函数的出参
def accept_connections_forever(listener):
    """Forever answer incoming connections on a listening socket."""
    # 死循环
    while True:
        # 服务端一直在监听端口，看有没有客户端进行连接。
        # 这个是阻塞的，如果有的话那么才会进行下边的操作。
        sock, address = listener.accept()
        # 打印出客户端IP端口
        print("Accepted connection from {}".format(address))
        handle_conversation(sock, address)

# 处理连接对话函数。
def handle_conversation(sock, address):
    """Converse with a client over `sock` until they are done talking."""
    try:
        while True:
            # 这里一直处理客户端的请求。
            handle_request(sock)
    # 接收异常，代表着客户端断开了连接。
    except EOFError:
        print("Client socket to {} has closed".format(address))
    # 如果有其他错误，我们也需要进行接收下来。
    except Exception as e:
        print("Client {} error: {}".format(address, e))
    # 最后关闭服务端的套接字。
    finally:
        sock.close()

# 处理请求函数。
def handle_request(sock):
    """Receive a single client request on `sock` and send the answer."""
    # 这里我们调用函数进行接收客户端发送过来的消息。
    aphorism = recv_until(sock, b"?")
    # 然后调用获取答案函数，将我们的答案回复给客户端。
    answer = get_answer(aphorism)
    # 服务端进行发送消息
    sock.sendall(answer)

# 服务端和客户端进行连接后，一直进行接收客户端发送过来的消息，直到客户端发送了suffix
# 这里我们的入参为？，如果客户端发送了suffix就代表着客户端发送完了消息。就需要进行关闭了。
def recv_until(sock, suffix):
    """Receive bytes over socket `sock` until we receive the `suffix`."""
    # 接收数据，
    message = sock.recv(4096)
    # 如果数据为空。就抛出一个连接关闭的错误。
    if not message:
        raise EOFError("socket closed")
    # 判断接收的消息最后是否是suffix，如果是地话，那我们就直接反悔了。
    # 如果不是，就代表着客户端还有数据进行发送，服务端就需要继续进行接收。
    while not message.endswith(suffix):
        # 能够进来while循环，就代表着客户端还有数据进行发送，
        # 那么我们需要继续进行接收
        data = sock.recv(4096)
        # 如果客户端的数据为空。
        # 再次抛出一个异常。
        if not data:
            raise IOError("received {!r} then socket closed".format(message))
        message += data
    # 返回接收的数据。
    return message

以上是 03Python网络编程系列之服务端 的全部内容， 来源链接： utcz.com/z/538122.html

回到顶部