fix: 解决 producer send 的潜在内存泄露问题

Author: JimmyDaddy

lib/producer.cpp

@@ -533,11 +533,14 @@ Napi::Value RocketMQProducer::Send(const Napi::CallbackInfo& info) {
   std::unique_ptr<ProducerSendCallback> send_callback(
       new ProducerSendCallback(env, Napi::Persistent(Value()), info[3].As<Napi::Function>()));
 
+  // 先获取原始指针，但保持智能指针的所有权
+  auto* raw_callback = send_callback.get();
   try {
-    // 转移所有权给 RocketMQ，成功后智能指针释放所有权
-    producer_.send(message, send_callback.release());
+    producer_.send(message, raw_callback);
+    // 只有在 send() 成功后才释放所有权
+    send_callback.release();
   } catch (const std::exception& e) {
-    // 如果发送失败，智能指针会自动清理回调对象
+    // 失败时智能指针自动清理，无内存泄漏
     Napi::Error::New(env, e.what()).ThrowAsJavaScriptException();
     return env.Undefined();
   }

lib/producer.h

@@ -55,6 +55,8 @@ class RocketMQProducer : public Napi::ObjectWrap<RocketMQProducer> {
   std::atomic<bool> is_started_{false};
   std::atomic<bool> is_shutting_down_{false};
   std::atomic<bool> is_destroyed_{false};
+  // state_mutex_ 用于保护状态转换的原子性
+  // 注意：start()/shutdown() 期间会持有锁，调用方应避免在回调中访问状态
   mutable std::mutex state_mutex_;
 };
 

lib/push_consumer.h

@@ -60,6 +60,8 @@ class RocketMQPushConsumer : public Napi::ObjectWrap<RocketMQPushConsumer> {
   std::atomic<bool> is_started_{false};
   std::atomic<bool> is_shutting_down_{false};
   std::atomic<bool> is_destroyed_{false};
+  // state_mutex_ 用于保护状态转换的原子性
+  // 注意：start()/shutdown() 期间会持有锁，调用方应避免在回调中访问状态
   mutable std::mutex state_mutex_;
 };