.NET Windows Service订阅Salesforce Streaming API无通知问题排查

我之前也碰到过类似的CometD与Salesforce Streaming API的连接稳定性问题，结合你的场景，给你几个针对性的排查方向和解决办法：

1. 优先确认重连后的订阅恢复逻辑 #

Salesforce的Streaming API会对长时间无活动的连接做清理，虽然你的客户端显示“恢复连接成功”，但CometD的重连不会自动恢复之前的Push Topic订阅——这是很多人踩过的坑。你需要：

• 检查代码里是否在CometD的Connected回调事件中，重新执行了Push Topic的订阅逻辑。每次重连成功后，必须手动重新订阅，否则即使连接通了，也收不到任何通知。
• 给订阅操作加上成功/失败的回调日志，确保订阅请求确实被Salesforce接收并确认。

2. 深挖"403::Unknown client"错误的本质 #

这个错误不是单纯的连接问题，而是Salesforce的会话凭证失效了：

• Salesforce的Session ID默认2小时过期，长时间无活动后，旧的凭证会被作废。即使CometD层面重连成功，用失效的凭证请求订阅，Salesforce会拒绝你的客户端身份。
• 你需要在CometD的错误回调里捕获这个403错误，触发完整的重新授权流程：重新获取新的Session ID，断开现有CometD连接，用新凭证重新初始化连接，再重新订阅Push Topic。不要只做简单的重连，那样只是用旧凭证重复失败。

3. 调整CometD的心跳配置 #

默认的心跳间隔可能太长，导致Salesforce判定连接失效：

• 把CometD的心跳间隔（interval选项）设置为30秒到1分钟，比如bayeuxClient.SetOption("interval", 30000)。这样能保持连接的活跃性，避免被Salesforce主动断开。
• 同时启用CometD的reconnect和maxNetworkDelay选项，确保网络波动时能快速重连。

4. 增强日志定位问题 #

建议补充关键节点的日志：

• 记录每次连接、重连、订阅的请求/响应细节（注意脱敏敏感信息），比如Salesforce返回的会话过期时间、订阅请求的状态码。
• 记录CometD的连接状态变化（从Disconnected到Connected的完整流程），以及每次收到通知的时间戳，方便对比无活动时段的状态变化。

5. 针对你使用的库的适配调整 #

你用的是特定fork版本的CometD.NET和Salesforce_PushTopics库，可能需要做小修改：

• 检查Salesforce_PushTopics库的订阅逻辑，看它是否自带了重连后自动订阅的机制，如果没有，需要自己扩展这个逻辑。
• 确认CometD.NET库是否正确处理了授权凭证的更新，有些旧版本的客户端不会在重连时更新Authorization头部，导致用旧凭证请求失败。

简单代码示例参考 #

重连时重新订阅的逻辑：

bayeuxClient.Connected += (sender, e) =>
{
    // 每次连接成功都重新订阅Push Topic
    var pushTopicClient = new PushTopicClient(bayeuxClient);
    pushTopicClient.Subscribe("YourPushTopicName", (message) =>
    {
        // 处理通知的业务逻辑
        Log.Info($"收到Salesforce通知: {message.Data}");
    }, 
    (subscriptionFailedMsg) =>
    {
        // 订阅失败的日志记录
        Log.Error($"订阅Push Topic失败: {subscriptionFailedMsg}");
    });
};

捕获403错误并重新授权：

bayeuxClient.Exception += (sender, e) =>
{
    if (e.Exception.Message.Contains("403::Unknown client"))
    {
        Log.Warn("Salesforce会话过期，开始重新授权并重连");
        // 步骤1：重新获取新的Session ID
        var newSessionId = GetValidSalesforceSessionId();
        // 步骤2：断开现有连接并更新凭证
        bayeuxClient.Disconnect();
        bayeuxClient.SetOption("authorization", $"OAuth {newSessionId}");
        // 步骤3：重新连接
        bayeuxClient.Connect();
    }
};

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