news 2026/8/2 4:06:47

UE4集成MQTT与JSON解析：构建稳定物联网数据可视化客户端

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
UE4集成MQTT与JSON解析：构建稳定物联网数据可视化客户端

1. 项目概述与核心价值

最近在做一个UE4的智慧工厂数字孪生项目，需要把产线上各种传感器和PLC的数据实时同步到虚拟场景里。一开始考虑过TCP长连接或者WebSocket，但设备多、协议杂，维护起来太头疼。后来团队讨论，决定用MQTT协议来做消息中枢，让UE4客户端作为订阅者去接收JSON格式的设备状态消息。这个方案落地后，整个数据流的稳定性和可扩展性都上了一个台阶。今天就来详细聊聊，怎么在UE4里从头搭建一个稳定可靠的MQTT客户端，并处理好JSON消息的解析与分发。无论你是想做物联网可视化、游戏服务器通信，还是简单的设备状态监控，这套流程都能给你一个清晰的参考。

简单说，这个方案的核心就是让UE4扮演一个“消息接收终端”。它不直接和成百上千的设备打交道，而是通过订阅MQTT Broker（消息代理服务器）上的特定主题（Topic），来接收所有设备统一上报的、格式化的JSON数据。这样做的好处显而易见：解耦。设备端（发布者）和UE4端（订阅者）互不关心对方的存在，只和Broker通信；灵活，新增一个传感器，只需要让它按格式发布消息，UE4这边几乎不用动；轻量，MQTT协议专为低带宽、不稳定网络设计，非常节省资源。对于UE4开发者而言，你不需要成为网络协议专家，只需要关注如何连接、订阅、以及收到消息后怎么把JSON数据变成游戏里的动画、材质参数或者UI上的数字。

2. 技术选型与前期准备

在动手写代码之前，得先把“用什么”和“怎么准备”搞清楚。UE4本身没有内置MQTT支持，C++标准库也没有，所以引入第三方库是必经之路。同时，JSON解析库的选择也关系到后续数据处理的便利性。

2.1 MQTT客户端库选型

市面上C++可用的MQTT库不少，我们需要找一个适合嵌入UE4、易于集成、且功能稳定的。经过一番调研和实测，主要考虑了以下几个选项：

  1. Eclipse Paho C++ Client：这是Eclipse基金会下的开源项目，可以说是MQTT领域的“标准答案”之一。它功能完整，支持MQTT 3.1.1和5.0，异步/同步客户端都有，社区活跃。但它的缺点是，作为一个通用库，直接集成到UE4的模块系统中需要一些改造工作，比如处理其自带的网络和线程模型与UE4引擎的协同。
  2. MQTT-C：一个轻量级、单文件的C语言库。极其简洁，依赖少，集成起来最快。如果你的需求只是基础的连接、发布、订阅，它完全够用。缺点是功能相对基础，高级特性（如自动重连、遗嘱消息）需要自己实现，且C风格的API在UE4的C++环境里用起来没那么“优雅”。
  3. 第三方UE4插件：在UE商城或GitHub上，有一些开发者封装好的UE4 MQTT插件，例如MQTT Utilities或VaRest的扩展。这些插件开箱即用，通常提供了蓝图节点，对不熟悉C++的开发者友好。但潜在问题是：插件可能更新不及时，无法满足深度定制需求，或者存在未知的稳定性问题。

我的选择与理由：对于追求稳定、可控和长期维护的项目，我强烈推荐使用Paho C++库进行源码集成。虽然前期集成需要花费一些功夫，但换来的是对协议栈的完全掌控，能够精细地处理连接状态、错误重试，并且可以方便地根据项目需求进行裁剪和优化。本次分享也将以集成Paho C++库为主线。

2.2 JSON解析库选型

UE4接收到的MQTT消息负载（Payload）是JSON字符串，我们需要把它解析成UE4能方便操作的数据结构（如FString，TArray，TMap）。

  1. Json Utilities (UE4内置)：UE4自带了JsonUtilities和Json模块，提供了FJsonObject，FJsonValue等类。它的好处是无缝集成，无需额外依赖，并且与UE4的反射系统、蓝图系统结合得很好。性能对于一般物联网数据流完全足够。
  2. RapidJSON：一个著名的C++高性能JSON解析/生成库。它以速度著称，内存占用小。但它是纯C++库，解析后的数据需要手动转换到UE4的数据类型，会多一步工序。
  3. nlohmann/json：现代C++写的JSON库，API非常直观易用，像操作std::map一样操作JSON。但它同样面临与UE4数据类型转换的问题，并且可能引入额外的编译依赖。

我的选择与理由：直接使用UE4内置的Json模块。理由很简单：省事、稳定、生态好。我们不需要极致的解析性能，物联网消息每秒几十条顶天了，内置库绰绰有余。更重要的是，用内置库解析出来的FJsonObject可以直接用于蓝图暴露、或者方便地转换成FString、float等UE4原生类型，后续数据处理流程更顺畅。

2.3 开发环境准备

  1. 获取Paho C库：Paho C++库依赖于Paho C库。我们需要先编译C库。从GitHub（github.com/eclipse/paho.mqtt.c）下载源码。用CMake生成你所用IDE（如Visual Studio）的工程文件，然后编译。通常我们需要编译出静态库（.lib文件）以方便集成。确保编译时开启PAHO_BUILD_STATIC选项。
  2. 获取Paho C++库：同样从GitHub（github.com/eclipse/paho.mqtt.cpp）下载源码。它需要指定上一步编译好的C库的路径。同样用CMake生成工程并编译出静态库。
  3. UE4项目设置：创建一个新的C++项目（或打开现有项目）。我们需要将编译好的Paho库文件（.lib）和头文件（.h）放入项目目录中，通常是在项目根目录下新建一个ThirdParty文件夹来管理。
  4. 修改Build.cs文件：这是关键一步。打开你项目模块的.Build.cs文件（例如YourProject.Build.cs），添加对Paho库的链接依赖。主要包括：添加头文件搜索路径（PrivateIncludePaths），添加库文件搜索路径（PublicAdditionalLibraries），以及链接具体的.lib文件（PublicAdditionalLibraries中添加库文件名）。同时，别忘了添加UE4内置的Json和JsonUtilities模块依赖。
// 示例：在 YourProject.Build.cs 中的 PublicDependencyModuleNames 添加 PublicDependencyModuleNames.AddRange(new string[] { “Core”, “CoreUObject”, “Engine”, “InputCore”, “Json”, “JsonUtilities” }); // 在构造函数中添加第三方库路径 string BasePath = Path.GetFullPath(Path.Combine(ModuleDirectory, “..”, “..”, “ThirdParty”, “Paho”)); string IncludePath = Path.Combine(BasePath, “include”); string LibraryPath = Path.Combine(BasePath, “lib”); PublicIncludePaths.Add(IncludePath); PublicAdditionalLibraries.Add(Path.Combine(LibraryPath, “paho-mqtt3a.lib”)); // 异步客户端静态库 PublicAdditionalLibraries.Add(Path.Combine(LibraryPath, “paho-mqtt3as.lib”)); // 异步SSL客户端静态库（如果不用SSL可省略） PublicAdditionalLibraries.Add(Path.Combine(LibraryPath, “paho-mqttpp3.lib”)); // C++封装库静态库

完成以上步骤，编译项目应该能通过，这样我们的“地基”就打好了。

3. MQTT客户端核心类设计与实现

接下来，我们要在UE4中创建一个管理MQTT连接和消息的核心类。这个类将封装Paho C++库的细节，提供一套简洁、易用且符合UE4编程习惯的接口。

3.1 类结构设计

我通常会创建一个继承自UObject的类，比如叫UMQTTClientComponent或UMQTTClientSubsystem。继承UObject可以利用UE4的垃圾回收和反射系统，方便在蓝图中使用和设置属性。这里我选择创建一个UMQTTClientSubsystem，作为游戏实例子系统，这样它可以在整个游戏生命周期内存在，方便不同关卡和蓝图访问。

主要成员变量包括：

  • FString ServerURL： Broker地址，如“tcp://192.168.1.100:1883”。
  • FString ClientID： 客户端标识符，需要唯一。可以用设备名+随机数生成。
  • FString Username/FString Password： 如果Broker需要认证。
  • TArray<FString> SubscribeTopics： 需要订阅的主题列表。
  • int32 KeepAliveInterval： 心跳间隔（秒）。
  • mqtt::async_client* MQTTClient： Paho C++异步客户端对象的指针。这是与Broker通信的核心。
  • 各种连接状态标志和回调函数绑定。

主要成员函数包括：

  • bool ConnectToBroker()： 初始化并连接到MQTT代理服务器。
  • void DisconnectFromBroker()： 断开连接。
  • bool SubscribeToTopic(const FString& Topic)： 订阅一个主题。
  • void PublishMessage(const FString& Topic, const FString& Message)： 发布消息（本项目虽以接收为主，但实现发布功能以备不时之需）。
  • virtual void OnMessageReceived(mqtt::const_message_ptr msg)： 消息到达时的回调函数。这是重中之重，JSON解析和业务逻辑将在这里触发。

3.2 连接与订阅的实现细节

在ConnectToBroker函数中，我们需要实例化mqtt::async_client对象，并设置连接选项（mqtt::connect_options）。这里有几个关键点：

  1. 设置遗嘱消息（Last Will）： 这是一个很好的实践。在连接选项中设置遗嘱消息，告诉Broker：“如果我突然异常断开，请替我向某个主题发布一条消息（比如{“status”: “offline”}）”。这样，其他订阅了该主题的客户端就能立刻知道这个客户端离线了。
    mqtt::connect_options connOpts; auto willMsg = mqtt::message(“your/client/status”, “{\“status\”:\“offline\”}”, 1, true); connOpts.set_will(willMsg);
  2. 设置回调： 通过set_message_callback方法，将我们自定义的OnMessageReceived成员函数绑定到客户端。这里需要注意C++成员函数指针与Paho库回调函数签名的适配，通常需要使用std::bind或lambda表达式来绑定this指针。
    MQTTClient->set_message_callback([this](mqtt::const_message_ptr msg) { this->OnMessageReceived(msg); });
  3. 异步连接与等待： 调用client.connect(connOpts)->wait()进行连接。wait()会阻塞当前线程直到连接完成（或超时失败）。在UE4中，为了避免卡住游戏线程，更好的做法是使用connect返回的token，并结合UE4的异步任务（AsyncTask）或在自己的工作线程中进行等待。但对于初始化连接，短暂阻塞通常可接受。
  4. 订阅主题： 连接成功后，遍历SubscribeTopics数组，调用client.subscribe(Topic, Qos)->wait()进行订阅。Qos（服务质量等级）通常设为1，确保消息至少送达一次。

实操心得：ClientID的唯一性：很多新手会忽略ClientID的唯一性。如果两个客户端用相同的ID连接同一个Broker，前一个会被“踢下线”。在UE4中，一个简单的生成唯一ID的方法是组合计算机名、进程ID和时间戳：FString::Printf(TEXT(“UE4Client_%s_%d_%lld”), FPlatformProcess::ComputerName(), FPlatformProcess::GetCurrentProcessId(), FDateTime::Now().ToUnixTimestamp())。

3.3 消息接收回调与JSON解析

当消息到达时，OnMessageReceived函数被调用。这个函数的参数msg包含了主题和负载。

void UMQTTClientSubsystem::OnMessageReceived(mqtt::const_message_ptr msg) { FString Topic = UTF8_TO_TCHAR(msg->get_topic().c_str()); std::string payload = msg->to_string(); FString PayloadStr = UTF8_TO_TCHAR(payload.c_str()); // 1. 日志输出（调试用） UE_LOG(LogTemp, Log, TEXT(“MQTT Message Received. Topic: %s, Payload: %s”), *Topic, *PayloadStr); // 2. 根据主题分发处理（可选） if (Topic.Equals(“sensor/temperature”)) { HandleTemperatureData(PayloadStr); } else if (Topic.Equals(“robot/status”)) { HandleRobotStatus(PayloadStr); } // … 其他主题处理 // 3. 或者，触发一个多播委托，让其他蓝图或C++类来订阅处理 OnMQTTMessageReceived.Broadcast(Topic, PayloadStr); }

HandleTemperatureData这类函数就是处理具体JSON的地方。我们使用UE4的JsonUtilities来解析：

void UMQTTClientSubsystem::HandleTemperatureData(const FString& JsonString) { TSharedPtr<FJsonObject> JsonObject; TSharedRef<TJsonReader<>> JsonReader = TJsonReaderFactory<>::Create(JsonString); if (FJsonSerializer::Deserialize(JsonReader, JsonObject) && JsonObject.IsValid()) { // 假设JSON格式为 {“device_id”: “sensor01”, “value”: 25.6, “timestamp”: 1640995200} FString DeviceID; float TemperatureValue; int64 Timestamp; if (JsonObject->TryGetStringField(TEXT(“device_id”), DeviceID) && JsonObject->TryGetNumberField(TEXT(“value”), TemperatureValue) && JsonObject->TryGetNumberField(TEXT(“timestamp”), Timestamp)) { // 解析成功！现在可以使用这些数据了。 UE_LOG(LogTemp, Warning, TEXT(“Device %s reports temperature: %.2f”), *DeviceID, TemperatureValue); // 在这里，你可以更新UI、设置材质参数、触发蓝图事件等。 // 例如，通过GameInstance找到某个Actor并更新其属性： // ATemperatureDisplayActor* DisplayActor = …; // DisplayActor->UpdateTemperature(TemperatureValue); // 或者，将数据存储到一个全局的数据管理器中，供其他系统查询。 GetGameInstance()->GetSubsystem<UDataManagerSubsystem>()->UpdateSensorData(DeviceID, TemperatureValue); } else { UE_LOG(LogTemp, Error, TEXT(“Failed to parse required fields from temperature JSON.”)); } } else { UE_LOG(LogTemp, Error, TEXT(“Failed to deserialize temperature JSON string.”)); } }

注意事项：线程安全：OnMessageReceived回调通常运行在Paho库的内部网络线程中，不是UE4的游戏线程（GameThread）。在UE4中，直接从这个回调里修改UObject的属性、调用蓝图函数或操作UI是危险的，会导致崩溃。必须将数据派发（Dispatch）到游戏线程处理。上面示例中，如果UpdateTemperature或UpdateSensorData涉及UE4对象操作，就需要用AsyncTask(ENamedThreads::GameThread, […] { … })或FFunctionGraphTask::CreateAndDispatchWhenReady来包裹执行逻辑。

4. 在UE4编辑器中集成与测试

代码写好了，我们需要把它暴露给蓝图，方便关卡设计师和美术同事进行配置和测试。

4.1 创建蓝图可访问的组件或子系统

由于我们创建的是UGameInstanceSubsystem的子类，它默认就可以通过蓝图节点“Get Game Instance Subsystem”来获取。但我们需要将一些关键属性和函数暴露给蓝图。

  1. 属性暴露：在头文件中，使用UPROPERTY宏标记ServerURL，ClientID等变量，并设置BlueprintReadWrite，Category等参数，它们就会出现在蓝图的细节面板中。
    UPROPERTY(EditAnywhere, BlueprintReadWrite, Category = “MQTT Connection”) FString ServerURL;
  2. 函数暴露：同样，使用UFUNCTION宏标记ConnectToBroker，SubscribeToTopic等函数，并设置BlueprintCallable。
    UFUNCTION(BlueprintCallable, Category = “MQTT Client”) bool ConnectToBroker();
  3. 事件暴露：为了能让蓝图响应消息到达事件，我们使用多播委托（DECLARE_DYNAMIC_MULTICAST_DELEGATE_TwoParams）。在头文件中声明一个委托类型，例如FOnMQTTMessageReceived，然后在类中声明一个该类型的变量，并用BlueprintAssignable标记。这样在蓝图中就可以为这个委托添加事件了。
    DECLARE_DYNAMIC_MULTICAST_DELEGATE_TwoParams(FOnMQTTMessageReceived, const FString&, Topic, const FString&, Payload); UPROPERTY(BlueprintAssignable, Category = “MQTT Events”) FOnMQTTMessageReceived OnMQTTMessageReceived;
    在OnMessageReceived回调中，在将任务派发到游戏线程后，调用这个委托的Broadcast方法。

4.2 搭建简易测试环境

在真正连接硬件设备之前，我们可以在本地搭建一个测试环境。

  1. 安装本地MQTT Broker：最常用的是Mosquitto。去官网下载安装，在Windows上安装为服务后，它默认就在本地的1883端口运行了。你也可以使用Docker快速启动一个：docker run -it -p 1883:1883 eclipse-mosquitto。
  2. 使用MQTT桌面客户端进行测试：下载一个MQTT客户端工具，如MQTTX或Mosquitto自带的mosquitto_pub/mosquitto_sub`命令行工具。用这个工具模拟设备，向Broker发布JSON消息。
  3. 在UE4编辑器中测试：
    • 创建一个新的蓝图，比如叫BP_MQTT_TestController。
    • 在事件开始运行（Event BeginPlay）时，获取你的UMQTTClientSubsystem实例。
    • 调用ConnectToBroker，并绑定OnMQTTMessageReceived事件。
    • 运行PIE（在编辑器中播放）。
    • 切换到MQTTX，向你的UE4客户端订阅的主题（例如sensor/data）发布一条JSON消息，比如{“id”:1, “temp”:22.5}。
    • 观察UE4编辑器的输出日志（Output Log），看是否收到了消息，并触发了蓝图事件。

这个“发送-接收”的闭环测试能快速验证整个链路是否通畅。

4.3 数据驱动场景应用示例

假设我们在做一个智慧工厂的数字看板。收到一条设备状态消息{“device”: “AGV_01”, “status”: “moving”, “battery”: 85, “position”: {“x”: 10.5, “y”: 3.2}}。

  1. 解析嵌套JSON：position字段是一个对象。使用TryGetObjectField来获取嵌套对象。
    const TSharedPtr<FJsonObject>* PositionObject; if (JsonObject->TryGetObjectField(TEXT(“position”), PositionObject)) { double PosX, PosY; (*PositionObject)->TryGetNumberField(TEXT(“x”), PosX); (*PositionObject)->TryGetNumberField(TEXT(“y”), PosY); FVector NewLocation(PosX * 100, PosY * 100, 0); // 假设单位转换 // 更新场景中AGV_01模型的位置 }
  2. 驱动场景元素：
    • 位置更新：根据position数据，通过FindComponentByTag或数据管理器找到场景中对应的AActor（AGV模型），设置其位置（SetActorLocation）。为了平滑移动，可以在Tick中插值更新。
    • 状态可视化：根据status字段（如“moving”， “charging”， “error”），改变模型材质（通过动态材质实例DynamicMaterialInstance设置颜色或发光强度），或在模型上方显示一个状态图标UI（UWidgetComponent）。
    • UI更新：将battery值更新到HUD或监控大屏的UI控件上。可以通过蓝图接口或数据表将解析后的数据传递给UI蓝图。

5. 性能优化、稳定化与故障排查

当基础功能跑通后，就要考虑生产环境的稳定性和性能了。

5.1 连接稳定性与重连机制

网络是不稳定的。MQTT客户端必须能处理断线重连。

  1. 监听连接丢失事件：Paho C++客户端可以设置连接丢失回调（set_connection_lost_callback）。在这个回调里，不要立即尝试重连，而是设置一个标志，并启动一个带退避策略的重连定时器。
  2. 实现指数退避重连：第一次断开后等待1秒重试，如果失败，下次等待2秒，然后4秒、8秒…直到一个最大值（如60秒）。这可以避免在Broker短暂故障时疯狂重连。
  3. 在UE4中管理定时器：可以使用FTimerHandle和GetWorld()->GetTimerManager()来管理重连定时器。注意，重连逻辑本身（调用ConnectToBroker）也必须放在游戏线程中执行。
void UMQTTClientSubsystem::OnConnectionLost(const std::string& cause) { UE_LOG(LogTemp, Warning, TEXT(“MQTT Connection Lost: %s”), UTF8_TO_TCHAR(cause.c_str())); bIsConnected = false; // 派发到游戏线程启动重连定时器 AsyncTask(ENamedThreads::GameThread, [this]() { this->StartReconnectTimer(); }); } void UMQTTClientSubsystem::StartReconnectTimer() { // 清除现有定时器 GetWorld()->GetTimerManager().ClearTimer(ReconnectTimerHandle); // 计算下次重连延迟（指数退避） CurrentReconnectDelay = FMath::Min(CurrentReconnectDelay * 2, MaxReconnectDelay); if (CurrentReconnectDelay == 0) CurrentReconnectDelay = 1.0f; UE_LOG(LogTemp, Log, TEXT(“Will attempt to reconnect in %.1f seconds.”), CurrentReconnectDelay); GetWorld()->GetTimerManager().SetTimer(ReconnectTimerHandle, this, &UMQTTClientSubsystem::AttemptReconnect, CurrentReconnectDelay, false); } void UMQTTClientSubsystem::AttemptReconnect() { if (ConnectToBroker()) { CurrentReconnectDelay = 1.0f; // 重连成功，重置延迟 UE_LOG(LogTemp, Log, TEXT(“Reconnected to MQTT broker successfully.”)); } else { // 重连失败，再次启动定时器 StartReconnectTimer(); } }

5.2 消息处理性能与线程优化

如果消息频率很高（每秒上百条），直接在游戏线程处理每条消息的JSON解析和场景更新可能会造成卡顿。

  1. 工作线程池：在OnMessageReceived回调中（此时还在网络线程），不要立即解析JSON和派发游戏线程任务。可以将原始的Topic和PayloadStr包装成一个结构体，推入一个线程安全的队列（如TQueue）。
  2. 专用工作线程：启动一个单独的FRunnable线程，或者使用UE4的Async系统，从这个队列中取出消息，进行JSON解析（这是CPU密集型操作，适合在后台线程做）。解析完成后，将结构化的数据（比如一个包含设备ID、数值的简单结构体）再派发到游戏线程去更新场景。这样，游戏线程只负责轻量的属性赋值和Actor变换，压力大大减轻。
  3. 消息批量处理：对于UI更新等操作，不必每收到一条消息就更新一次。可以每0.1秒（或一帧）检查一次是否有新数据，然后批量更新。这能减少UI的无效刷新和渲染开销。

5.3 常见问题与排查技巧

在实际开发中，你肯定会遇到各种问题。下面是一个快速排查清单：

问题现象可能原因排查步骤
编译失败，链接错误（LNK2019等）Paho库链接不正确；缺少运行时库（如paho-mqtt3a.dll）1. 检查.Build.cs中的库路径和文件名是否正确。
2. 确保编译Paho时使用的是与UE4项目相同的运行时库（MT/MTd vs MD/MDd）。UE4通常使用/MD（动态链接运行时）。
3. 将Paho C的动态库（.dll）放到可执行文件（.exe）同级目录，或系统PATH包含的目录。
连接Broker失败地址/端口错误；防火墙阻止；Broker未运行；ClientID冲突1. 用MQTTX等客户端工具测试Broker地址和端口是否可达。
2. 关闭防火墙或添加规则。
3. 检查Broker服务是否启动（`netstat -ano
能连接但收不到消息主题（Topic）订阅失败；Qos不匹配；发布端未成功1. 在SubscribeToTopic后检查返回值，或通过Broker日志查看订阅状态。
2. 确保发布和订阅的Topic字符串完全一致，包括大小写。
3. 用MQTTX同时订阅相同Topic，看是否能收到消息，以确定问题在发布端还是UE4客户端。
收到消息但JSON解析失败JSON格式错误；编码问题；字段名不匹配1. 将收到的PayloadStr打印到日志，复制出来用在线JSON校验工具检查格式。
2. 检查是否有不可见字符（如BOM）。
3. 确认TryGetStringField等函数中的字段名与JSON中的键名完全一致。
游戏运行时崩溃（断点指向MQTT回调）在非游戏线程中操作了UObject1.确保所有对UE4对象（Actor， Component， UI）的修改，都通过AsyncTask或委托Broadcast到游戏线程执行。
2. 在回调函数开头加日志，确认线程ID，与游戏线程ID对比。
内存缓慢增长消息队列未及时消费；JSON对象未释放；回调函数捕获导致循环引用1. 检查后台处理线程是否正常工作，队列是否堆积。
2. 确保TSharedPtr<FJsonObject>等智能指针在离开作用域后能正常释放。
3. 检查lambda表达式是否以值捕获（[this]）了this指针，而在对象销毁时未取消回调，可能导致悬空指针。考虑使用弱指针（TWeakObjectPtr）。

一个高级技巧：使用QoS 1和持久化会话。在连接选项（connect_options）中设置set_clean_session(false)，并给客户端一个固定的ClientID。这样，即使客户端短暂离线，Broker也会为它保存离线期间发送到已订阅主题的QoS 1消息（如果Broker支持）。重连后，客户端能收到这些消息，避免数据丢失。这对于关键的状态同步非常重要。

最后，记得在游戏退出或关卡切换时，在BeginDestroy或Shutdown函数中，有序地断开MQTT连接（disconnect()->wait()）并清理Paho客户端资源，避免内存泄漏和网络资源未释放。

版权声明: 本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若内容造成侵权/违法违规/事实不符，请联系邮箱：809451989@qq.com进行投诉反馈，一经查实，立即删除！
网站建设 2026/8/2 4:06:20

eNSP、DevEco、（VMware）并存在同一台电脑的2种方法

方法1.双启动&#xff1a;启动电脑时 系统2选1方法2.做两个脚本&#xff1a;使用哪一个应用前 就选择 限制另一个应用的脚本关闭Hyper-V【eNSP专用】.batecho offbcdedit /set hypervisorlaunchtype offecho Hyper-V已关闭&#xff0c;请重启电脑生效&#xff01;pause开启Hype…

作者头像 李华
网站建设 2026/8/2 4:03:23

智能体框架如何革新计算化学工作流：从自动化到智能化

1. 项目概述&#xff1a;当智能体遇上计算化学最近在跟几个做计算化学和药物设计的同行聊天&#xff0c;大家不约而同地提到一个痛点&#xff1a;工作流太碎了。从分子建模、结构优化、性质计算到数据分析&#xff0c;每一步都可能涉及不同的软件、脚本和参数设置。一个完整的课…

作者头像 李华
网站建设 2026/8/2 4:03:21

AI查重与降重工具在学术写作中的应用与实战技巧

1. 项目概述&#xff1a;学术写作中的AI查重与降重实战去年帮导师审研究生论文时&#xff0c;发现有个现象特别有意思&#xff1a;学生交上来的初稿里&#xff0c;那些语法过于完美的段落&#xff0c;查重率往往高得离谱。后来才知道&#xff0c;这些孩子都在用AI辅助写作&…

作者头像 李华
网站建设 2026/8/2 4:02:02

倒L天线设计实战：从原理到PCB布局与Vivado调试避坑指南

1. 从“一根线”到“倒L天线”&#xff1a;为什么它依然是入门与应急的首选&#xff1f;在射频和嵌入式调试的世界里&#xff0c;天线常常是那个最容易被忽视&#xff0c;却又决定成败的关键角色。当你埋头在Vivado里抓取ILA信号&#xff0c;或者在调试一个NFC读卡器时&#xf…

作者头像 李华
网站建设 2026/8/2 4:01:57

[GESP202606 二级] 完全平方数计数

B4553 [GESP202606 二级] 完全平方数计数 https://www.luogu.com.cn/problem/B4553 C GESP 2026年6月 完全平方计数 https://www.bilibili.com/video/BV169Nc6XEt5/ GESP考级C202403三级T2&#xff1a;完全平方数 https://www.bilibili.com/video/BV18D421N7hK/ 数论专题第17讲…

作者头像 李华
网站建设 2026/8/2 4:01:00

紫光PDS开发工具实战：从安装到调试的FPGA设计全流程指南

1. 项目概述与背景最近拿到了一块紫光同创的FPGA开发板&#xff0c;型号是Logos-2系列的PGC2KG。对于习惯了Xilinx Vivado或Intel Quartus的工程师来说&#xff0c;切换到国产FPGA平台&#xff0c;第一步要过的就是软件工具关。紫光同创提供的官方开发工具是Pango Design Suite…

作者头像 李华