GMSL接口详解

一、GMSL2接口介绍

GMSL2接口是将数据从一个传输端口发送到另一个接收端口的接口。这个接口是面向消息的，允许您发送和接收消息，这些消息已经被编码成字节序列，可以在传输之前或之后进行解码。

下面是一个运用GMSL2接口的示例，这个例子是从服务器端向客户端发送一个简单的消息：

    
        server = GMSL2Server()
        client = GMSL2Client()
        server.bind(EXAMPLE_PORT)
        client.connect(EXAMPLE_HOST, EXAMPLE_PORT)

        msg = 'Hello, World!'
        server.send(msg.encode())
        received_bytes = client.receive()
        received_msg = received_bytes.decode()
        print(received_msg)
    

在这个例子中，我们创建了一个服务器和一个客户端，绑定了端口号。服务器发送了一条消息，客户端成功接收到并打印出来了。

二、GMS网络接口

1、建立网络连接

GMS网络接口可以用于建立网络连接。以下是一个建立网络连接的示例：

    
        import socket
        import gmsl

        # 创建一个 Socket 对象
        s = socket.socket()

        # 获取本地主机名
        host = socket.gethostname()

        # 设置端口号
        port = 12345

        # 连接服务，指定主机和端口
        s.connect((host, port))

        # 发送消息
        msg = "Hello, GMS!"
        s.send(msg.encode())

        # 接收消息
        message = s.recv(1024)

        # 关闭 Socket
        s.close()
    

在这个例子中，我们首先创建一个 Socket 对象，然后使用 socket.gethostname() 获取本地主机名。接着，我们指定端口号并连接到服务端。之后，我们向服务端发送消息，等待服务器返回消息，最后关闭 Socket。

2、动态绑定和解绑定端口

GMS网络接口允许动态绑定和解绑定端口。以下是一个动态绑定和解绑定端口的示例：

    
        import socket
        import gmsl

        # 创建一个 Socket 对象
        s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

        # 获取本地主机名
        host = socket.gethostname()

        # 设置端口号
        port = 12345

        # 绑定端口
        s.bind((host, port))

        # 等待客户端连接
        s.listen(5)

        # 等待客户端连接
        while True:
            c, addr = s.accept()
            print("连接地址：", addr)
            # 发送消息到客户端
            msg = '连接成功！'
            c.send(msg.encode())
            # 关闭连接
            c.close() 
    

在这个例子中，我们创建了一个 Socket 对象，指定了主机和端口号并绑定了端口。我们使用 s.listen() 方法等待客户端连接。我们还创建了一个无限循环，每当有一个客户端连接到服务器时，服务器就会向客户端发送一条消息并关闭连接。

3、同时处理多个连接

GMS网络接口也允许同时处理多个连接。以下是一个同时处理多个连接的示例：

    
        import socket
        import threading

        # 客户端处理函数
        def client_handler(client_socket):
            # 获取客户端地址
            client_address = client_socket.getpeername()
            print(f'客户端地址: {client_address}')

            # 向客户端发送欢迎消息
            welcome_message = '欢迎光临！'.encode()
            client_socket.send(welcome_message)

            # 客户端消息循环
            while True:
                # 接收客户端消息
                client_message = client_socket.recv(1024)
                if not client_message:
                    break
                # 向客户端发送消息
                server_message = '服务端已接收您的消息！'.encode()
                client_socket.send(server_message)

            # 关闭客户端连接
            client_socket.close()

        # 创建 Socket 服务端
        server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

        # 获取本地主机名
        host = socket.gethostname()

        # 设置端口号
        port = 12345

        # 绑定端口
        server_socket.bind((host, port))

        # 开始监听
        server_socket.listen(5)

        while True:
            # 等待连接
            print('等待连接...')
            client_socket, addr = server_socket.accept()

            # 创建新线程处理客户端连接
            client_thread = threading.Thread(target=client_handler, args=[client_socket])

            # 启动新线程
            client_thread.start()
    

在这个例子中，我们创建了一个 Socket 对象并绑定了端口。我们使用 s.listen() 方法以开始接受客户端连接。当客户端连接时，我们创建一个新的线程，并在该线程中处理客户端连接。主线程等待客户端连接，而处理客户端连接的线程则与客户端进行通信，并在必要时关闭连接。