Node.js中DaprServer无法同时暴露API与接收PubSub事件？

问题代码 #

import { DaprServer, CommunicationProtocolEnum } from "@dapr/dapr";
import express from "express";

const myApp = express();

myApp.get("/my-custom-endpoint", (req, res) => {
  res.send({ msg: "My own express app!" });
});

const daprServer = new DaprServer({
      serverHost: "127.0.0.1",
      serverPort: "3000",
      serverHttp: myApp,
    });

await daprServer.pubsub.subscribe("pubsub", "messages", async (messageId) => {
        console.log(`Subscriber received: ${JSON.stringify(messageId)}`)
    });

await daprServer.start();

问题描述 #

期望通过上述DaprServer实例同时实现两个功能：

• 暴露自定义HTTP API端点
• 监听pubsub组件的messages主题事件

但执行启动命令 dapr run --app-id background-with-api --app-port 3000 -- node main.js 后，PubSub事件监听功能失效。相同配置逻辑在C# ASP.NET Core中可正常运行，Node.js已支持线程，为何无法实现？是否遗漏配置步骤？

原因与解决方案 #

核心原因 #

Node.js的Dapr SDK与ASP.NET Core的SDK实现逻辑不同：ASP.NET Core会自动集成Dapr中间件处理订阅路由，而Node.js SDK在使用自定义Express实例时，不会自动将PubSub订阅的路由注册到你的应用中，导致Dapr无法将事件转发到你的订阅回调。

解决步骤 #

1. 手动挂载Dapr路由中间件
   需要将Dapr内部的Express路由中间件挂载到你的自定义Express应用上，让Dapr能通过正确的端点推送事件。修改代码如下：

   import { DaprServer, CommunicationProtocolEnum } from "@dapr/dapr";
   import express from "express";
   
   const myApp = express();
   
   myApp.get("/my-custom-endpoint", (req, res) => {
     res.send({ msg: "My own express app!" });
   });
   
   const daprServer = new DaprServer({
         serverHost: "127.0.0.1",
         serverPort: "3000",
         serverHttp: myApp,
       });
   
   // 关键：挂载Dapr的路由中间件到自定义应用
   myApp.use(daprServer.getServerHttp().router);
   
   await daprServer.pubsub.subscribe("pubsub", "messages", async (data, message) => {
       console.log(`Subscriber received content: ${JSON.stringify(data)}`);
       console.log(`Message ID: ${message.id}`);
   });
   
   await daprServer.start();
   

2. 修正订阅回调参数
   原代码中的回调参数messageId不符合SDK规范，正确的回调参数应为：

   • 第一个参数：data（实际的消息内容）
   • 第二个参数：message（包含id、topic等元数据的对象）
     参数错误会导致无法正确接收消息内容，也是功能失效的潜在原因。

3. 验证启动配置
   确保启动命令中的--app-port与代码中serverPort完全一致，Dapr依赖这个端口向你的应用推送PubSub事件。

内容的提问来源于stack exchange，提问作者Chedy2149