【腾讯犀牛鸟开源课题实战】支持http sse协议

[liucf3995]

• 背景：框架支持 HTTP SSE特性，可助力业务探索 AI 大模型的业务场景。业务方也期望框架侧提供 HTTP SSE 的支持。
• 需求：希望你能参考当前已有类库的接口，为tRPC-Cpp设计一套灵活、易用的接口，更好地扩展tRPC的生态。具体来来说，在实现时，你需要注意下面的要点：
  • 增加 HTTP SSE特性支持，涵盖服务端与客户端，包括协议、编解码、代理等实现与测试。可能需要实现子模块列表如下：
  • SseEvent：SSE 消息结构体，包含 event-type、data、id、retry 等方法。
  • SseParser：将文本消息解析成 SseEvent 对象，或者将 SseEvent 对象打包成文本消息。
  • codec：http_sse，请求头和响应头解析和现有逻辑一致，Body 采用 SseParser打包、接包。
  • client：HttpSseProxy，当前仅提供 Get 流式接口。
  • server: HttpSseService，提供SseStreamWriter接口，可以写入 SseEvent 文本消息。
  • stream: 复用现有 HTTP 流式接口。
• 你应该尽可能复用tRPC-Cpp的各个模块，具体来说，你应该继承 ServiceProxy，实现一个比如HttpSseProxy，提供设计良好的接口，在实现接口时，应该复用框架的服务发现以及拦截器模块。
• 你应该基于HTTP 流式接口封装业务编程接口，在框架 Fiber 协程模式下实现 SSE 流式。
  -参考资料：
  • 规范文档：https://html.spec.whatwg.org/multipage/server-sent-events.html

小提示：
本issue为2025犀牛鸟开源人才培养活动专属issue，仅供参与犀牛鸟的在校大学生及开发者参与领取，认领前请先报名2025犀牛鸟开源人才培养计划（ https://opensource.tencent.com/summer-of-code ）。
【认领issue】在issue所在repo页面留言“已成功领取本issue”→微信私信犀牛鸟小助手（活动群-黄贵龙）：issue链接+认领截图→犀牛鸟小助手回复“已成功领取本issue”，即可开始做issue任务。
【完成issue】已完成issue的同学，请同步犀牛鸟小助手（私信活动群-黄贵龙回复“已完成本issue任务+代码合入截图等证明”）。
注意：如7天内无提交任何进展包括不限于comment \ commit \ Pull Request，则将视为同学主动放弃issue，组委会将释放issue给下一位等候者。
【第三阶段·实战课题】需要8月1日入围后即可参与，请勿认领

[zhuyanhuazhuyanhua]

已成功领取本issue

[zhuyanhuazhuyanhua]

规范解读：1.结构体包含event_type,data,id,retry 2.每行必须以data/event开头,:之后需要空格 3.默认事件类型为 “message”4.事件流始终解码为 UTF-8。无法指定其他字符编码

[zhuyanhuazhuyanhua]

SseEvent

SseEvent结构

/// @brief SSE event structure
struct SseEvent {`
  std::string event_type;    // event field
  std::string data;          // data field
  std::string id;            // id field
  std::optional<int> retry;  // retry field (milliseconds)

处理带有event的字段核心代码

if (!event_type.empty()) {
      result += "event: " + event_type + "\n";
 }

处理字段核心代码

if (!data.empty()) {
      // Handle multi-line data
      std::istringstream iss(data);
      std::string line;
      while (std::getline(iss, line)) {
        result += "data: " + line + "\n";
      }
    }

测试夹具

class SseEventTest : public ::testing::Test {
 protected:
  void SetUp() override {}
  void TearDown() override {}
};

典型测试用例，参考Sse规范文档

TEST_F(SseEventTest, ToStringBasicMessage) {
  SseEvent event;
  event.data = "This is the first message.";

  std::string result = event.ToString();
  std::string expected = "data: This is the first message.\n\n";

  EXPECT_EQ(result, expected);
}

BUILD构建测试

cc_library(  
    name = "http_sse_event",  
    hdrs = ["http_sse_event.h"],  
    visibility = ["//visibility:public"],  
    deps = [  
    ],  
)  
  

cc_test(  
    name = "http_sse_event_test",  
    srcs = ["http_sse_event_test.cc"],  
    deps = [  
        ":http_sse_event",  
        "@com_google_googletest//:gtest",  
        "@com_google_googletest//:gtest_main",  
    ],  
)

[zhuyanhuazhuyanhua]

SseParser

SseParseer结构

static std::vector<SseEvent> Parse(const std::string& text) {
    std::vector<SseEvent> events;
    std::istringstream stream(text);
    std::string line;

统一不同系统换行符

      / Remove \\r if present (handle \\r\\n line endings)
      if (!line.empty() && line.back() == '\\r') {
        line.pop_back();
      }

空行判断是否有效

 if (line.empty()) {
        if (!data_lines.empty() || !current_event.event_type.empty() || !current_event.id.empty() ||
            current_event.retry.has_value()) {
          // Join data lines with newlines
          `if (!data_lines.empty()) {`
            current_event.data = JoinDataLines(data_lines);
          }

设置默认message

if (current_event.event_type.empty()) {
            current_event.event_type = "message";
          }

SSE格式判断核心

auto colon_pos = line.find(':');
      if (colon_pos == std::string::npos) {
        continue;  // Skip malformed lines
     }

处理解析出的字段值，去除值前的空格

if (!value.empty() && value[0] == ' ') {
        value = value.substr(1);
      }
      if (field == "data") {
        data_lines.push_back(value);
      } else if (field == "event") {
        current_event.event_type = value;
      } else if (field == "id") {
        current_event.id = value;
      } else if (field == "retry") {
        try {
          current_event.retry = std::stoi(value);
        } catch (const std::exception&) {
          // Ignore invalid retry values
       }
      }

[zhuyanhuazhuyanhua]

已成功领取本issue

[L1w-Y]

已成功领取本issue

[xing-cg]

已成功领取本issue

[zhuyanhuazhuyanhua]

已成功领取本issue

[CrocodilePipo]

已成功领取本issue

[Zhichao-Yan]

已成功领取本issue

[lisuhang11]

已成功领取本issue

[siger886]

已成功领取本issue

[Wak209]

已成功领取本issue

[Eiei-Zhang]

已成功领取本issue