[Bug]: HTTP API 使用 SSE 推送的消息有遗漏

[gengyunmaster]

提交前确认

• 我已搜索过现有的 Issues，确认这不是重复问题
• 我使用的是最新版本
• 我已阅读过相关文档

使用平台

Windows

问题严重程度

边缘场景或轻微问题（等待空闲时修复）

问题描述

并非所有新收到的微信消息都会被 SSE 推送，具体来说涉及两方面问题：

• 有时候来自好友或群的消息未被 SSE 推送，特别是短时间内接收到较多条来自好友或群的消息时遗漏的概率很大，这应该是程序的 bug；
• 来自非好友或群的消息（如公众号、微信支付、服务通知等的消息）不会被 SSE 推送，这些也属于消息的范畴，理应被推送，这应该是程序的功能缺陷。

复现步骤

1. 在“设置”中开启 HTTP API ；
2. 开启 SSE ；
3. 使用任意 SSE 客户端连接 SSE 服务端（即 WeFlow ），比如这里给出一个简单的 Python 实现（实际上使用任意 SSE 客户端均可）：

import requests
import time

def sse_client_demo():
    url = "http://127.0.0.1:5031/api/v1/push/messages"
    headers = {
        "Accept": "text/event-stream",
        "Cache-Control": "no-cache",
        "Connection": "keep-alive"
    }
    print(f"正在连接 SSE 服务端: {url}")
    print("等待接收消息...\n")
    try:
        response = requests.get(url, headers=headers, stream=True)
        for line in response.iter_lines():
            if line:
                msg = line.decode('utf-8')
                print(f"[{time.strftime('%Y-%m-%d %H:%M:%S')}] 收到消息:")
                print(msg)
                print("-" * 50)
    except requests.exceptions.ConnectionError:
        print("错误：无法连接服务端，请确认服务已启动！")
    except KeyboardInterrupt:
        print("\n已手动断开连接")
    except Exception as e:
        print(f"异常：{str(e)}")

if __name__ == "__main__":
    sse_client_demo()

4. 在短时间内接收大量来自好友或群的消息，会发现有个别消息未被 SSE 推送；
5. 接收来自非好友或群的消息，会发现这些消息未被 SSE 推送。

预期行为

任何消息都可以被不遗漏地通过 SSE 推送。

实际行为

见上方“问题描述”。

错误日志或截图

操作系统版本

Windows 11 24H2

应用版本

v4.2.1

系统架构

x64

补充信息

No response

[Oject]

你是能收到消息，但是会有遗漏的是吧

[gengyunmaster]

你是能收到消息，但是会有遗漏的是吧

是的。比如一个朋友向我发送“早上好”和“今天吃什么”两条微信消息，有概率出现只有“早上好”这条消息被 SSE 推送，而“今天吃什么”被遗漏的情况。而且似乎短时间内收到的消息越多，发生消息遗漏的概率就越大。我怀疑是 WeFlow 的 bug ，但我也不确定其他用户是否遇到过同样的问题，恳请开发者协助排查，谢谢！

[hicccc77]

@xunchahaha 有空瞅一眼这个

[xunchahaha]

@xunchahaha 有空瞅一眼这个

我觉得有可能是 wcdb 的问题（？🤔 等我看看

[xunchahaha]

漏推送的情况我复现不出来。。。不过非好友和群聊的可以修一下

[hicccc77]

@xunchahaha 有空瞅一眼这个

我觉得有可能是 wcdb 的问题（？🤔 等我看看

嘶，你确认之后我再去看看吧

[hicccc77]

我测试了一遍也没有出现遗漏

[xunchahaha]

我们推送是没漏的 但是是同步微信的消息 所以同时发的消息也会同时推送 需要改一下你接受的策略

[hicccc77]

你说的消息遗漏可能因为你微信打开了和这个人的对话，导致对方消息发来的时候直接进入已读状态，weflow此时有概率读不到这条新消息，为误以为没有新消息到达，你也可以打开一下通知功能验证一下是否存在这种情况

[gengyunmaster]

我有个想法，供开发者参考：关于消息推送，我觉得不仅可以提供 SSE 方式，也可以提供传统 HTTP 请求（ Web Hook ）的方式，即 WeFlow 将收到的微信消息以 HTTP POST 请求的方式发送到一个用户可配置的 URL ，由用户自行选择使用哪种方式。虽然我们知道，如果使用 Web Hook ，每发送一条消息就需要建立一次 HTTP 连接，特别是在消息较多的场景下，这种方式的性能远不如 SSE ，但一方面在消息不频繁的场景下 Web Hook 的性能更有优势（不必维护长连接），比如某些用户可能平均三四个小时才收到一条微信消息，另一方面 Web Hook 的兼容性较好，可以降低与之对接的系统的开发难度，因此我认为提供 Web Hook 方案作为备选并非毫无意义。进一步地，可以考虑允许用户设置黑名单/白名单，自行决定哪些好友/群消息被推送，不过这个功能做不做无关紧要了，用户也完全可以自行在与之对接的系统中做定制化处理。

[gengyunmaster]

你说的消息遗漏可能因为你微信打开了和这个人的对话，导致对方消息发来的时候直接进入已读状态，weflow此时有概率读不到这条新消息，为误以为没有新消息到达，你也可以打开一下通知功能验证一下是否存在这种情况

对的，确实是我打开了和这个人的聊天窗口，新收到的消息就很可能不会被 WeFlow 推送。那我之后使用此功能时就尽量关闭聊天窗口。感谢作者帮忙排查问题，辛苦了！