fix: ProducerSendCallback 构造函数内存泄漏问题，ConsumerMessageListener 内存管理

Author: JimmyDaddy

AGENTS.md

@@ -0,0 +1,84 @@
+# AI 编码助手项目指令
+
+> **语言要求**: 始终使用中文回复
+
+---
+
+## 🔴 强制规则 (MUST)
+
+以下规则必须严格遵守，违反任何一条都是不可接受的：
+
+
+### 代码质量检查
+编码任务完成前，**必须按顺序执行以下检查**：
+1. TypeScript 检查必须通过
+2. Lint 检查必须通过
+3. 单元测试必须全部通过
+4. Code Review 必须完成
+
+### 单元测试要求
+- **服务端代码必须编写单测**
+- **单测覆盖率必须达到 100%**
+- **禁止 skip 任何测试用例**
+- **必须使用终端工具实际运行单测** - 不能假装运行
+
+---
+
+## 📋 命令参考
+
+### TypeScript 检查
+
+## TIPS
+- ts check
+```shell
+npm run build:ts
+```
+
+### Lint 检查
+```shell
+# TypeScript/JavaScript 文件
+npm run lint
+
+```
+
+### 单元测试
+```shell
+## 可以有选择执行，对 lib 下的  C++ 文件进行编译
+./build.sh local
+## 然后执行
+npm run test <文件路径>
+```
+
+
+## ⚡ 执行流程
+
+完成编码任务的标准流程：
+
+```
+1. 理解需求
+   ↓
+2. 编写/修改代码
+   ↓
+3. 运行 TypeScript 检查
+   ↓
+4. 运行 Lint 检查
+   ↓
+5. 编写单测 (如需要)
+   ↓
+6. 运行单测并等待完成
+   ↓
+7. Code Review
+   ↓
+8. 如有问题，返回步骤 2 修复
+   ↓
+9. 完成
+```
+
+---
+
+## ⏳ 单测执行注意事项
+
+- 单测启动和执行需要较长时间，**耐心等待**
+- 如支持后台进程读取，可使用 Background process 异步等待
+- **绝对禁止使用 sleep 命令等待**
+

lib/producer.cpp

@@ -323,15 +323,21 @@ class ProducerSendCallback : public rocketmq::AutoDeleteSendCallback {
         callback_scheduled_(false),
         callback_completed_(false) {
     std::unique_ptr<CleanupContext> ctx(new CleanupContext());
-    callback_ = Callback::New(env,
-                              callback,
-                              "RocketMQ Send Callback",
-                              0,
-                              1,
-                              ctx.get(),
-                              &Finalize,
-                              static_cast<void*>(nullptr));
-    cleanup_ctx_ = ctx.release();
+    try {
+      callback_ = Callback::New(env,
+                                callback,
+                                "RocketMQ Send Callback",
+                                0,
+                                1,
+                                ctx.get(),
+                                &Finalize,
+                                static_cast<void*>(nullptr));
+      // 只有在 Callback::New 成功后才释放所有权
+      cleanup_ctx_ = ctx.release();
+    } catch (...) {
+      // 如果 Callback::New 失败，智能指针会自动清理
+      throw;
+    }
   }
 
   ~ProducerSendCallback() {

lib/push_consumer.cpp

@@ -506,8 +506,9 @@ class ConsumerMessageListener : public rocketmq::MessageListenerConcurrently {
         return rocketmq::ConsumeStatus::RECONSUME_LATER;
       }
 
-      // 使用原始指针管理内存，确保异常安全
-      auto* data = new MessageAndPromise{msg, std::promise<bool>()};
+      // 使用智能指针管理内存，确保异常安全
+      std::unique_ptr<MessageAndPromise> data_ptr(new MessageAndPromise{msg, std::promise<bool>()});
+      auto* data = data_ptr.get();
       auto future = data->promise.get_future();
 
 #if defined(ROCKETMQ_COVERAGE) || defined(ROCKETMQ_USE_STUB)
@@ -548,17 +549,18 @@ class ConsumerMessageListener : public rocketmq::MessageListenerConcurrently {
 #else
       // Check if we're already aborted before making the call
       if (aborted_.load() || shutdown_requested_.load()) {
-        delete data;
         return rocketmq::ConsumeStatus::RECONSUME_LATER;
       }
 
       status = listener_.BlockingCall(data);
 #endif
       if (status != napi_ok) {
-        delete data;
         return rocketmq::ConsumeStatus::RECONSUME_LATER;
       }
 
+      // 成功调用后释放智能指针的所有权，让 CallConsumerMessageJsListener 管理内存
+      data_ptr.release();
+
       try {
 #if defined(ROCKETMQ_COVERAGE) || defined(ROCKETMQ_USE_STUB)
         if (IsEnvEnabled("ROCKETMQ_STUB_CONSUMER_FORCE_FUTURE_ERROR")) {