当前位置： 首页 > article >正文

车载以太网网络测试 -23【TCPUDP通信示例】

article 2025/3/26 22:04:23

1 摘要

在车载通信场景中，TCP以及UDP的通信可以用于多种应用，例如车辆状态监控、远程控制、数据采集等。以下是详细的代码示例，展示了如何使用Python实现简单的TCP客户端与服务端通信以及简单的UDP客户端与服务端通信，并模拟了车载整车数据上传场景。

2 整车数据上传TCP通信

2.1 整车数据上传需求简述

在车载通信场景中，整车数据上传是指车辆将其实时状态信息（如车速、发动机转速、电池状态、GPS位置等）通过TCP协议发送到远程服务器。服务器接收这些数据后，可以进行实时监控、数据分析、故障诊断等操作。为了保证数据的实时性和可靠性，通常使用TCP协议进行通信。

2.2 TCP代码示例

以下是一个简单的TCP客户端与服务端的代码示例，模拟整车数据上传的场景。客户端（车载控制器，如GW）将模拟的整车数据发送到服务端（远程服务器），服务端接收并处理这些数据。

2.2.1 服务端代码（接收车辆数据）

import socket

def start_server(host='0.0.0.0', port=65432):
    # 创建TCP套接字
    with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as server_socket:
        # 绑定IP和端口
        server_socket.bind((host, port))
        # 监听连接
        server_socket.listen()
        print(f"Server listening on {host}:{port}")

        while True:
            # 接受客户端连接
            client_socket, client_address = server_socket.accept()
            with client_socket:
                print(f"Connected by {client_address}")
                while True:
                    # 接收数据
                    data = client_socket.recv(1024)
                    if not data:
                        break
                    # 处理数据
                    print(f"Received data: {data.decode('utf-8')}")
                    # 发送确认消息
                    client_socket.sendall(b"Data received")

if __name__ == "__main__":
    start_server()

代码说明：

  1. 创建一个TCP套接字，并绑定到指定的IP地址和端口。
  2. 监听客户端的连接请求。
  3. 当客户端连接成功后，接收客户端发送的数据，并打印到控制台。
  4. 向客户端发送确认消息，表示数据已接收。

2.2.2 客户端代码（发送车辆数据）

import socket
import time

def send_vehicle_data(host='127.0.0.1', port=65432):
    # 创建TCP套接字
    with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as client_socket:
        # 连接到服务器
        client_socket.connect((host, port))
        print(f"Connected to server at {host}:{port}")

        while True:
            # 模拟整车数据
            vehicle_data = {
                "speed": 60,  # 车速
                "rpm": 2000,  # 发动机转速
                "battery_level": 80,  # 电池电量
                "gps": "37.7749,-122.4194"  # GPS位置
            }
            # 将数据转换为字符串并发送
            data_str = str(vehicle_data)
            client_socket.sendall(data_str.encode('utf-8'))
            print(f"Sent data: {data_str}")
            # 接收服务器确认
            response = client_socket.recv(1024)
            print(f"Server response: {response.decode('utf-8')}")
            # 等待一段时间后再次发送数据
            time.sleep(5)

if __name__ == "__main__":
    send_vehicle_data()

代码说明：

  1. 创建一个TCP套接字，并连接到服务器。
  2. 模拟整车数据（如车速、发动机转速、电池状态、GPS位置等），并将其转换为字符串格式。
  3. 将数据发送到服务器，并等待服务器的确认消息。
  4. 每隔5秒发送一次数据。

2.2.3 代码输出说明

  • 服务端输出：

    `Server listening on 0.0.0.0:65432`：表示服务器已启动并正在监听指定端口。
`Connected by ('127.0.0.1', 12345)`：表示客户端已成功连接到服务器。
`Received data: {'speed': 60, 'rpm': 2000, 'battery_level': 80, 'gps': '37.7749,-122.4194'}`：表示服务器已接收到客户端发送的整车数据。
...

  • 客户端输出：

    `Connected to server at 127.0.0.1:65432`：表示客户端已成功连接到服务器。
`Sent data: {'speed': 60, 'rpm': 2000, 'battery_level': 80, 'gps': '37.7749,-122.4194'}`：表示客户端已发送整车数据。
`Server response: Data received`：表示服务器已确认接收到数据。
...

通过上述代码示例，我们实现了一个简单的TCP通信场景，模拟了整车数据上传的过程。服务端接收并处理客户端发送的数据，客户端定期发送模拟的整车数据。

2.3 UDP代码示例

在车载通信场景中，UDP（用户数据报协议）是一种常用的传输协议，特别是在需要低延迟和高吞吐量的场景中。UDP 是一种无连接的协议，适用于实时数据传输，如车辆传感器数据的实时上传。

2.3.1 服务端代码（接收车辆数据）

import socket

def start_server(host='0.0.0.0', port=5005):
    # 创建 UDP socket
    server_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    # 绑定地址和端口
    server_socket.bind((host, port))
    print(f"Server started on {host}:{port}")

    while True:
        # 接收数据
        data, addr = server_socket.recvfrom(1024)  # 缓冲区大小为1024字节
        print(f"Received data from {addr}: {data.decode('utf-8')}")

if __name__ == "__main__":
    start_server()

代码说明：

  1. 创建了一个 UDP socket，并绑定到指定的地址和端口。
  2. 使用 recvfrom 方法接收来自客户端的数据，并打印接收到的数据和客户端地址。
  3. 服务端持续运行，等待接收数据。

2.3.2 客户端代码（发送车辆数据）

import socket
import time

def send_data(host='127.0.0.1', port=5005):
    # 创建 UDP socket
    client_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

    # 模拟车辆数据
    vehicle_data = {
        'speed': 60,  # 速度
        'latitude': 34.0522,  # 纬度
        'longitude': -118.2437,  # 经度
        'temperature': 25  # 温度
    }

    while True:
        # 将数据转换为字符串并发送
        data = str(vehicle_data).encode('utf-8')
        client_socket.sendto(data, (host, port))
        print(f"Sent data to {host}:{port}: {data.decode('utf-8')}")
        time.sleep(1)  # 每隔1秒发送一次数据

if __name__ == "__main__":
    send_data()

代码说明：

  1. 创建了一个 UDP socket，并连接到指定的服务器地址和端口。
  2. 模拟车辆数据（如速度、位置、温度等），并将数据转换为字符串格式。
  3. 使用 sendto 方法将数据发送到服务器，并打印发送的数据。
  4. 客户端每隔1秒发送一次数据。

2.3.3 代码输出说明

  • 服务端输出：

    Server started on 0.0.0.0:5005
Received data from ('127.0.0.1', 12345): {'speed': 60, 'latitude': 34.0522, 'longitude': -118.2437, 'temperature': 25}
Received data from ('127.0.0.1', 12345): {'speed': 60, 'latitude': 34.0522, 'longitude': -118.2437, 'temperature': 25}
...

    服务端会持续打印接收到的车辆数据，包括速度、位置、温度等信息。

  • 客户端输出：

    Sent data to 127.0.0.1:5005: {'speed': 60, 'latitude': 34.0522, 'longitude': -118.2437, 'temperature': 25}
Sent data to 127.0.0.1:5005: {'speed': 60, 'latitude': 34.0522, 'longitude': -118.2437, 'temperature': 25}
...

    客户端会持续打印发送的车辆数据，并每隔1秒发送一次。

该代码示例展示了如何使用 UDP 协议在车载通信场景中实现客户端与服务端的数据传输。UDP 的低延迟和高吞吐量特性使其非常适合实时数据传输场景，如车辆传感器数据的上传。然而，由于 UDP 不保证数据的可靠性和顺序，因此在实际应用中可能需要额外的容错机制来确保数据的完整性和准确性。

3 总结

以上是基于整车数据上传需求，设计了TCP&UDP客户端与服务端通信流程的代码示例；希望对大家学习车载以太网TCP&UDP通信有所帮助！


http://www.kler.cn/a/599460.html

相关文章：

  • 蓝桥杯——嵌入式学习日记
  • 借助AI Agent实现数据分析
  • Python虚拟环境：从入门到实战指南
  • 在 ASP.NET Core 中实现限流（Rate Limiting）：保护服务免受滥用与攻击
  • ABB机器人更换机器人本体编码器电池的具体步骤
  • 蓝桥杯，冬奥大抽奖
  • 中间件解析漏洞之Tomcat集合
  • 操作系统必知的面试题
  • Maven 构建配置文件
  • 计算机操作系统（四） 操作系统的结构与系统调用
  • 盖泽 寻边器 帮助类
  • C#中状态机Stateless初使用
  • 建库字符集选择`utf8mb4` + `utf8mb4_unicode_ci` 组合
  • 解决 IntelliJ IDEA 方法断点导致程序无法运行的问题
  • python面试高频考点（深度学习大模型方向）
  • 【AndroidRTC-10】webrtc是如何确定双端的编解码类型？
  • C/C++蓝桥杯算法真题打卡（Day10）
  • RAG优化：python从零实现时间管理大师Self-RAG
  • 剑指 Offer II 117. 相似的字符串
  • 网络华为HCIA+HCIP 网络编程自动化