本教程旨在详细讲解如何在Python中使用`ctypes`库接收并解析通过UDP发送的C语言嵌套结构体数组数据。我们将探讨C语言侧的数据序列化方法，以及Python侧使用`ctypes`进行复杂结构体数据反序列化的正确姿势，并提供一种更简洁的纯Python `struct` 模块实现方案，以提高数据处理效率和代码可读性。

1. 引言：C/C++与Python的数据交互挑战

在跨语言通信，特别是C/C++与Python之间进行数据交换时，经常需要处理复杂的数据结构。当这些结构体包含嵌套结构体或动态数组（通过指针表示）时，通过网络（如UDP）传输原始内存数据会遇到挑战。C语言中的指针在序列化时，其值（内存地址）本身并无意义，我们需要发送的是指针所指向的实际数据内容。本教程将以一个包含嵌套结构体数组的C结构体为例，演示如何在Python中正确接收和解析此类数据。

2. C/C++端数据序列化

原始的C代码尝试通过memcpy(&testStruct, buffer, sizeof(MyStruct))直接复制结构体内存来发送数据。然而，当结构体中包含指针（如MyInnerStruct *InnerStruct）时，memcpy只会复制指针变量本身的值（即一个内存地址），而不会复制指针所指向的实际数组内容。这导致Python端接收到的指针值是无效的，无法正确访问数组数据。

正确的C端序列化方法是，将结构体的所有基本类型字段以及指针所指向的数组元素逐一写入一个字节缓冲区。

C/C++结构体定义：

#include <iostream>
#include <vector>
#include <cstring> // For memcpy
#include <winsock2.h> // For network operations (optional for serialization logic)

// 禁用一些警告，实际项目中应谨慎处理
#define _WINSOCK_DEPRECATED_NO_WARNINGS
#define _CRT_SECURE_NO_WARNINGS
#pragma comment(lib, "Ws2_32.lib")

struct MyInnerStruct {
    int intValue;
    float floatValue;
};

struct MyStruct {
    int intValue; // This field will also serve as the count of InnerStructs
    float floatValue;
    MyInnerStruct *InnerStruct; // Pointer to an array of MyInnerStruct
};

// 辅助函数：将MyStruct及其内部数组序列化为字节向量
std::vector<char> serializeMyStruct(const MyStruct& s, int innerStructCount) {
    std::vector<char> buffer;
    // 确保使用小端序（Little-endian）以匹配Python的'<if'格式
    // 实际项目中应考虑网络字节序或明确指定字节序

    // 序列化 MyStruct 的 intValue
    buffer.insert(buffer.end(), (char*)&s.intValue, (char*)&s.intValue + sizeof(s.intValue));
    // 序列化 MyStruct 的 floatValue
    buffer.insert(buffer.end(), (char*)&s.floatValue, (char*)&s.floatValue + sizeof(s.floatValue));

    // 序列化 MyInnerStruct 数组的每个元素
    for (int i = 0; i < innerStructCount; ++i) {
        buffer.insert(buffer.end(), (char*)&s.InnerStruct[i].intValue, (char*)&s.InnerStruct[i].intValue + sizeof(s.InnerStruct[i].intValue));
        buffer.insert(buffer.end(), (char*)&s.InnerStruct[i].floatValue, (char*)&s.InnerStruct[i].floatValue + sizeof(s.InnerStruct[i].floatValue));
    }
    return buffer;
}

int main() {
    // 1. 初始化数据
    MyStruct testStruct;
    testStruct.intValue = 4; // 设定内部数组的元素数量
    testStruct.floatValue = 3.5f;

    // 分配内部结构体数组
    int innerArrayCount = testStruct.intValue;
    testStruct.InnerStruct = new MyStruct::MyInnerStruct[innerArrayCount];

    for (int i = 0; i < innerArrayCount; ++i) {
        testStruct.InnerStruct[i].intValue = i + 1;
        testStruct.InnerStruct[i].floatValue = 1.25f + i * 1.25f / 2;
    }

    // 2. 序列化数据
    std::vector<char> serialized_data = serializeMyStruct(testStruct, innerArrayCount);

    // 3. UDP发送部分 (此处仅作示例，实际需完善错误处理)
    WSADATA wsaData;
    if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0) {
        std::cerr << "Failed to initialize winsock." << std::endl;
        return 1;
    }

    int udpSocket = socket(AF_INET, SOCK_DGRAM, 0);
    if (udpSocket == -1) {
        perror("Error creating socket");
        WSACleanup();
        return 1;
    }

    sockaddr_in serverAddr;
    serverAddr.sin_family = AF_INET;
    serverAddr.sin_port = htons(5000); // 目标端口
    serverAddr.sin_addr.s_addr = inet_addr("127.0.0.1"); // 目标IP

    if (sendto(udpSocket, serialized_data.data(), serialized_data.size(), 0,
               reinterpret_cast<sockaddr*>(&serverAddr), sizeof(serverAddr)) == -1) {
        perror("Error sending data");
        closesocket(udpSocket);
        WSACleanup();
        return 1;
    }

    std::cout << "Struct sent successfully. Data size: " << serialized_data.size() << " bytes." << std::endl;

    // 清理
    delete[] testStruct.InnerStruct;
    closesocket(udpSocket);
    WSACleanup();
    return 0;
}

关键点：

• serializeMyStruct函数负责将MyStruct的字段和MyInnerStruct数组的每个元素逐个复制到std::vector缓冲区中。
• testStruct.intValue被用作MyInnerStruct数组的元素数量，这是一种常见的将数组长度与结构体一同传输的方式。
• 字节序（Endianness）非常重要。C++端需要与Python端（struct.pack或struct.unpack的格式字符串）保持一致。本例中，Python使用

3. Python端接收与解析（ctypes方法）

Python的ctypes库允许我们定义与C语言结构体对应的Python类，并直接操作内存。然而，对于从网络接收到的原始字节流，我们不能直接将其强制转换为包含指针的ctypes结构体。因为字节流中的“指针”不再是有效的内存地址，而是序列化时混入的数据。

Whimsical

Whimsical推出的AI思维导图工具

182 查看详情

正确的做法是：

1. 首先使用struct模块解析出顶层结构体的基本字段（特别是数组长度）。
2. 根据数组长度，动态创建ctypes数组。
3. 迭代地从字节流中解析出数组的每个元素，并填充到ctypes数组中。
4. 将填充好的ctypes数组的引用赋值给顶层ctypes结构体中的指针字段。

Python ctypes接收端代码：

import socket
import struct
import ctypes as ct

# 定义与C语言对应的内部结构体
class MyInnerStruct(ct.Structure):
    _fields_ = (('field4', ct.c_int),
                ('field5', ct.c_float))

    def __repr__(self):  # 用于方便打印显示
        return f'({self.field4}, {self.field5})'

# 定义与C语言对应的外部结构体
class MyStruct(ct.Structure):
    _fields_ = (('field1', ct.c_int),
                ('field2', ct.c_float),
                ('field3', ct.POINTER(MyInnerStruct))) # 指向内部结构体数组的指针

    def __repr__(self):  # 用于方便打印显示
        # 访问field3时，需要确保它已被正确赋值为一个数组
        if self.field3:
            # 使用切片[:self.field1]来获取实际的数组元素，self.field1是数组长度
            return f'[{self.field1}, {self.field2}, {list(self.field3[:self.field1])}]'
        else:
            return f'[{self.field1}, {self.field2}, (null_pointer)]'

# UDP socket设置
HOST = '' # 监听所有可用接口
PORT = 5000

sock = socket.socket(type=socket.SOCK_DGRAM)
sock.bind((HOST, PORT))
print(f"Listening on UDP port {PORT}...")

try:
    while True:
        # 接收数据，假设最大数据包大小为40960字节
        data, addr = sock.recvfrom(40960)
        print(f"Received {len(data)} bytes from {addr}")

        # 1. 解包MyStruct的field1和field2
        # '<if' 表示小端序，一个int，一个float
        field1, field2 = struct.unpack_from('<if', data)

        # 创建MyStruct实例，此时field3（指针）仍为空
        received_struct = MyStruct(field1, field2)

        # 2. 根据field1（内部数组的元素数量）动态分配MyInnerStruct数组
        # MyInnerStruct * field1 创建一个包含 field1 个 MyInnerStruct 元素的数组类型
        inner_array_type = MyInnerStruct * field1
        inner_array = inner_array_type() # 实例化这个数组

        # 3. 计算内部结构体数据在缓冲区中的起始位置和每个元素的大小
        # MyStruct的前两个字段的大小
        start_of_inner = struct.calcsize('<if') 
        # MyInnerStruct 的大小
        size_of_inner_element = struct.calcsize('<if') 

        # 4. 迭代解包并填充内部数组
        current_index = start_of_inner
        for i in range(field1):
            # 从当前位置开始解包一个MyInnerStruct元素
            field4, field5 = struct.unpack_from('<if', data, current_index)
            inner_array[i] = MyInnerStruct(field4, field5) # 赋值给数组元素
            current_index += size_of_inner_element # 移动到下一个元素的位置

        # 5. 将填充好的内部数组赋值给MyStruct的field3指针
        received_struct.field3 = inner_array

        # 打印完整的接收结构体
        print("Received MyStruct:", received_struct)

except KeyboardInterrupt:
    print("Shutting down...")
finally:
    sock.close()

关键点：

• struct.unpack_from('
• MyInnerStruct * field1：动态创建一个包含field1个MyInnerStruct元素的ctypes数组类型。
• inner_array_type()：实例化这个数组类型，得到一个实际的ctypes数组对象。
• struct.calcsize('
• received_struct.field3 = inner_array：这是最关键的一步，将动态创建并填充好的ctypes数组赋值给MyStruct实例中的field3指针。ctypes会自动处理这种赋值，使得field3指向inner_array的内存。

4. Python端接收与解析（纯Python struct方法）

对于从网络接收的序列化数据，如果不需要将数据回传给C库或者进行内存层面的直接操作，使用纯Python类结合struct模块进行解析通常更简单、更高效，且避免了ctypes指针的复杂性。

这种方法的核心思想是：定义普通的Python类来表示C结构体，并为这些类添加from_data或from_data_array等工厂方法，负责从原始字节流中解析数据并创建Python对象。

Python struct接收端代码：

import socket
import struct

# 定义内部结构体的纯Python类
class MyInnerStruct:
    _format = '<if'  # 对应C语言中的 int 和 float，小端序
    _size = struct.calcsize(_format) # 计算每个MyInnerStruct元素的大小

    def __init__(self, f4, f5):
        self.field4 = f4
        self.field5 = f5

    @classmethod
    def from_data(cls, data_buffer, offset=0):
        """从字节缓冲区中解析单个MyInnerStruct"""
        f4, f5 = struct.unpack_from(cls._format, data_buffer, offset)
        return cls(f4, f5)

    @classmethod
    def from_data_array(cls, data_buffer, count, offset=0):
        """从字节缓冲区中解析MyInnerStruct数组"""
        inner_structs = []
        current_offset = offset
        for _ in range(count):
            inner_structs.append(cls.from_data(data_buffer, current_offset))
            current_offset += cls._size
        return inner_structs

    def __repr__(self):
        return f'[{self.field4}, {self.field5}]'

# 定义外部结构体的纯Python类
class MyStruct:
    _format = '<if'  # 对应C语言中的 int 和 float，小端序
    _size = struct.calcsize(_format) # 计算MyStruct前两个字段的大小

    def __init__(self, f1, f2, f3_array):
        self.field1 = f1
        self.field2 = f2
        self.field3 = f3_array # 此时field3直接是MyInnerStruct对象的列表

    @classmethod
    def from_data(cls, data_buffer):
        """从字节缓冲区中解析整个MyStruct，包括其内部数组"""
        # 首先解析MyStruct的field1和field2
        f1, f2 = struct.unpack_from(cls._format, data_buffer, 0)

        # 接着解析内部数组，从MyStruct字段之后开始
        inner_array_offset = cls._size
        f3_array = MyInnerStruct.from_data_array(data_buffer, f1, inner_array_offset)

        return cls(f1, f2, f3_array)

    def __repr__(self):
        return f'[{self.field1}, {self.field2}, {self.field3}]'

# UDP socket设置
HOST = '' # 监听所有可用接口
PORT = 5000

sock = socket.socket(type=socket.SOCK_DGRAM)
sock.bind((HOST, PORT))
print(f"Listening on UDP port {PORT}...")

try:
    while True:
        data, addr = sock.recvfrom(40960)
        print(f"Received {len(data)} bytes from {addr}")

        # 直接使用MyStruct的工厂方法从数据中

以上就是Python ctypes与C结构体数组的UDP通信及解析教程的详细内容，更多请关注其它相关文章！

# 怀柔网站推广平台  # 充好  # 创建一个  # 自动生成  # 中应  # 中带  # 的是  # 邯郸短视频seo源头  # 音乐平台推广营销方案  # 数据结构  # 百度营销推广后台网址  # 房山短视频seo机构  # 江津定制网站建设  # 网站推广外贸怎么做的  # 2021学seo  # 厦门胖哥网站建设  # 网站优化重点知识  # word  # 区中  # 文档  # 序列化  # 代码可读性  # stream  # win  # ios  # c++  # ai  # 端口  # 字节  # app  # 大数据  # c语言  # python 

相关栏目： 【 科技资讯46185 】 【 网络学院92790 】

相关推荐： Golang如何实现微服务鉴权与权限控制_Golang微服务鉴权与权限管理实践  J*a递归快速排序中静态变量导致数据累积的陷阱与解决方案  J*aScript 字符串标签转换：使用正则表达式高效替换  为什么我的微信朋友圈看不到别人的更新_微信朋友圈更新显示异常解决方法  J*aScript Promise链中如何正确终止后续.then执行并处理错误  C++ explicit关键字防止隐式转换_C++构造函数安全规范  蛙漫2日版入口 WAMAN2(日版)无删减漫画官网链接  TikTok国际版官网直达_TikTok国际版官网直达进入在线观看  LINUX下如何进行磁盘分区_fdisk与parted工具在LINUX中的使用对比  中兴Axon42Ultra怎样在文件App筛图_iPhone中兴Axon42Ultra文件App筛图【图片筛选】  实现分段式页面滚动导航：CSS与J*aScript教程  小红书商家版怎样在笔记嵌入商品卡路径_小红书商家版在笔记嵌入商品卡路径【挂载教程】  漫蛙官网正版漫画入口 漫蛙2官方网页登录地址  在J*a中如何在J*a中使用异常机制记录错误日志_异常日志实践经验  初次安装JDK时环境变量如何正确配置_J*A_HOME与PATH设置规则讲解  2026年发布！ 美少女养成动作RPG《神剑少女战记》发布实机演示  NetBeans Ant项目：自动化将资源文件复制到dist目录的教程  QQ邮箱正确登录入口_QQ邮箱官方网站使用地址  Python异步编程实践：使用Binance API构建实时交易数据流  css链接悬停下划线样式如何自定义_使用::after结合content和transition  Lar*el用户头像管理：实现图片缩放、存储与旧文件安全删除的最佳实践  Win11网速慢怎么解决 Win11网络设置优化解除限速  Excel函数批量查找替换超快方法_Excel用REPLACE和FIND函数秒级替换  文心一言怎样用批量生成做多版文案_文心一言用批量生成做多版文案【批量创作】  AO3最新可访问网址 Archive of Our Own官方在线入口  深入理解rpy2中的类型转换：优化Python对象到R矩阵的映射  在python-socketio事件处理器中安全访问Flask应用上下文  J*aScript中高效清空DOM列表元素：解决for循环中断与任务管理问题  mc.js官网登录入口 mc.js官方登录入口最新版  Sublime Text怎么设置垂直标尺_Sublime配置Rulers规范代码长度  DLsite中文平台入口 DLsite官网内容在线查看  Lar*el表单中优雅地处理“返回”按钮以规避验证：最佳实践指南  MAC的“快捷指令”怎么同步到iPhone_MAC利用iCloud同步所有设备的自动化指令  解决 Express.js 中 PUT 请求密码修改失败的路由配置指南  在J*a项目里如何构建对象之间的契约_接口约束的实际落地  响应式容器内容自动缩放与宽高比维持教程  理解J*aScript Promise的微任务队列与执行顺序  深入理解J*aScript Promise异步执行与微任务队列  搜狗浏览器如何使用密码生成器创建强密码 搜狗浏览器内置密码安全工具  Lar*el如何生成PDF或Excel文件_Lar*el文档导出工具与使用教程  汽水音乐车机版8.9下载 汽水音乐车机版8.9版本安装入口  windows10怎么关闭系统提示音_windows10彻底静音设置方法  C#如何安全地从用户上传的XML文件中读取数据？ 验证与清理策略  AI抖音网页版免费视频入口 AI抖音网页端最新视频实时观看  蛙漫移动版在线看 蛙漫手机浏览器直达入口  邮编格式怎么匹配地址_根据邮编格式快速匹配详细地址的技巧  微信商城在哪里打开【步骤】  LINUX的I/O重定向是什么_深入理解LINUX中 >、>> 与 < 的区别  sublime如何配置Python开发环境_将sublime打造成轻量级Python IDE  AWS EC2实例间SQL Server连接超时：安全组配置与故障排除指南