如何复用现有评论服务为AWS Elemental MediaLive直播添加聊天功能

你现有的图文评论服务核心是「关联业务主体ID、存储/拉取评论内容、配套鉴权/审核能力」，直播聊天本质是把单路直播流作为新的业务主体，适配直播场景的实时性、高并发、消息生命周期特性即可，不需要重构核心逻辑。

基础适配层改造 #

• 给每路MediaLive直播流生成唯一的live_stream_id作为绑定评论服务的主体ID，和原有图文帖子的post_id加前缀做区分，比如live-xxxx和post-xxxx，避免ID冲突
• 原有评论服务的发送评论、拉取评论列表、敏感词过滤、用户权限校验等核心逻辑完全复用，仅在接口层加规则判断：如果关联ID为直播类前缀，走直播场景的特殊配置即可

实时性适配改造 #

• 图文评论默认拉取全量历史，直播场景仅需要拉取最近30秒到1分钟的消息，给直播类ID加专用缓存层，把最近的消息存入Redis，拉取请求优先读缓存，大幅降低数据库压力
• 如果原有评论服务没有主动推送能力，前端可以做1-2秒的短轮询拉取最新消息；并发要求高的场景可以额外加一层WebSocket推送服务，原有评论服务写入逻辑不变，写入成功后给WebSocket服务发通知推送给在线观众即可
• 若需要弹幕功能，直接从拉取到的直播评论内容里取数据渲染即可，不需要修改评论服务的存储逻辑

场景规则适配 #

• 给直播类ID单独配置消息过期规则，比如直播结束后7天自动归档聊天消息到冷存储，和图文评论的永久存储逻辑区分，节约主库存储空间
• 敏感词过滤、用户禁言、举报处理等运营能力完全复用原有逻辑，仅需给直播场景单独配置对应的规则阈值即可，不需要额外开发

风险规避 #

如果直播场景的并发峰值远高于原有图文业务的峰值，提前给评论服务的直播相关接口做限流降级，优先级低于原有图文业务，避免直播流量冲垮原有服务。

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