数据管道构建

Elasticsearch 的作用Elasticsearch 是一个分布式搜索与分析引擎，核心价值是把文本和结构化数据建立索引后，支持高性能检索与聚合统计。它适合做查询层，比如消息搜索、日志检索、复杂条件过滤和运营分析，不适合作为强事务主库。用户A给用户B发消息，如何做到消息转发标准做法是先持久化再投递。A 发消息到接入层后，服务端先完成鉴权、生成消息 ID、写入存储或消息日志，再根据 B 的在线状态做路由。在线就通过长连接实时推送，离线就写离线队列，等 B 上线拉取。B 收到后回 ACK，服务端更新投递状态；如果超时未 ACK，就走重试或补偿。这样才能同时保证可靠性和可追踪性。HTTP 做业...