对直播消息的发布进行优化的方法及系统.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN105872574A(43)申请公布日2016.08.17(21)申请号201610191728.6(22)申请日2016.03.30(71)申请人乐视控股（北京）有限公司地址100025北京市朝阳区姚家园路105号3号楼10层1102申请人乐视云计算有限公司(72)发明人刘斌(74)专利代理机构北京商专永信知识产权代理事务所(普通合伙)11400代理人方挺黄谦(51)Int.Cl.H04N21/2187(2011.01)H04N21/262(2011.01)H04N21/643(2011.01)权利要求书2页说明书5页附图2页(54)发明名称对直播消息的发布进行优化的方法及系统(57)摘要本发明实施例提供一种对直播消息的发布进行优化的方法及系统，该方法包括：在用于发布直播消息的消息发布池与用于生产流的组件之间配置消息中转站；所述用于生产流的组件生成直播消息，并将所述直播消息发送至所述消息中转站；所述消息中转站将接收到的所述直播消息发送至所述消息发布池。本发明实施例的方法和系统提升了线上设备的负载能力和消息发布池对外发布消息的能力，降低了生产流的组件与消息发布池之间的对接难度。CN105872574ACN105872574A权利要求书1/2页1.一种对直播消息的发布进行优化的方法，其特征在于，包括：在用于发布直播消息的消息发布池与用于生产流的组件之间配置消息中转站；所述用于生产流的组件生成直播消息，并将所述直播消息发送至所述消息中转站；所述消息中转站将接收到的所述直播消息发送至所述消息发布池。2.根据权利要求1所述的方法，其中，所述用于生产流的组件将所述直播消息发送至所述消息中转站包括：所述用于生产流的组件将生成的所述直播消息写入本地的消息队列；所述消息中转站从所述消息队列中读取直播消息，并将所述直播消息插入消息中转队列中。3.根据权利要求2所述的方法，其中，所述用于生产流的组件将生成的所述直播消息写入本地的消息队列包括：所述用于生产流的组件将生成的直播消息进行封装，封装的内容包括所述直播消息对应的m3u8的生成时间、序列号、m3u8的类型及发布主题位置，并将封装后的数据按序列号写入消息队列；所述消息中转站从所述消息队列中读取直播消息，并将所述直播消息插入消息中转队列中包括：所述消息中转站开设单独的线程从所述消息队列中读取直播消息，并将直播消息按序列号插入所述消息中转队列。4.根据权利要求2或3所述的方法，其中，所述消息中转站将接收到的所述直播消息发送至所述消息发布池包括：在所述消息中转站与所述消息发布池之间建立固定数量的TCP连接；通过所述TCP连接，实时发送所述直播消息至所述消息发布池，或在检测到所述消息中转队列为空时，每隔固定时间间隔对所述消息中转队列进行再次检测，并在所述消息中转队列不为空时，通过所述TCP连接发送所述消息中转队列中的全部直播消息至所述消息发布池。5.根据权利要求4所述的方法，其特征在于，所述固定数量的TCP连接为一条。6.一种对直播消息的发布进行优化的系统，包括用于发布直播消息的消息发布池和用于生产流的组件，其特征在于，在所述消息发布池和所述用于生产流的组件之间还配置有消息中转站，其中，所述用于生产流的组件生成直播消息发送至所述消息中转站，所述消息中转站接收所述直播消息发送至所述消息发布池。7.根据权利要求6所述的系统，其特征在于，所述用于生产流的组件包括消息写入单元，用于将生成的直播消息写入本地的消息队列；所述消息中转站中包括消息读取单元，用于从所述消息队列中读取直播消息，并将所述直播消息插入消息中转队列中。8.根据权利要求7所述系统，其中，所述消息写入单元用于将生成的直播消息封装的内容包括所述直播消息对应的m3u8的生成时间、序列号、m3u8的类型及发布主题位置，并将封装后的数据按序列号写入消息队列；所述消息读取单元用于开设单独的线程从所述消息队列中读取直播消息，并将直播消2CN105872574A权利要求书2/2页息按序列号插入所述消息中转队列。9.根据权利要求7或8所述的系统，其特征在于，所述消息中转站还包括消息发送单元，用于在所述消息中转站与所述消息发布池之间建立固定数量的TCP连接，通过所述TCP连接，实时发送所述直播消息至所述消息发布池，或在检测到所述消息中转队列为空时，每隔固定时间间隔对所述消息中转队列进行再次检测，并在所述消息中转队列不为空时，通过所述TCP连接发送所述消息中转队列中的全部直播消息至所述消息发布池。10.根据权利要求9所述的系统，其特征在于，所述固定数量的TCP连接为一条。3CN105872574A说明书1/5页对直播消息的发布进行优化的方法及系统技术领域[0001]本发明实施例涉及视频直播