GMSL接口详解

发布时间：2023-05-18

一、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() 方法以开始接受客户端连接。当客户端连接时，我们创建一个新的线程，并在该线程中处理客户端连接。主线程等待客户端连接，而处理客户端连接的线程则与客户端进行通信，并在必要时关闭连接。

推荐文章