CN104283901B

CN104283901B - 一种分布式直播后台服务系统及其方法

Info

Publication number: CN104283901B
Application number: CN201310269412.0A
Authority: CN
Inventors: 陈亮; 段锐
Original assignee: Yeelion Online Network Technology Beijing Co Ltd
Current assignee: Yeelion Online Network Technology Beijing Co Ltd
Priority date: 2013-07-01
Filing date: 2013-07-01
Publication date: 2018-01-02
Anticipated expiration: 2033-07-01
Also published as: CN104283901A

Abstract

本发明提供了一种分布式直播后台服务系统及分布式直播后台服务方法，其采用了代理服务模块以及相应的功能服务模块，代理服务模块作为请求信息的中转站，请求信息到达代理服务模块，代理服务模块验证完成后，根据请求信息类型分别转给相应功能服务模块进行处理。这种模块架构使得所有进程可以分拆部署，所有的模块可以根据需要而定制，避免了采用上述方法及架构带来的缺陷，因此具有很强的扩展性。

Description

一种分布式直播后台服务系统及其方法

技术领域

本申请涉及一种后台服务系统及其方法，特别是涉及一种分布式直播后台服务系统及其方法。

背景技术

B/S结构，即Browser/Server，浏览器/服务器模式，是WEB兴起后的一种网络结构模式和方法，WEB浏览器是客户端最主要的应用软件。这种模式和方法是采用统一的客户端，将系统功能实现的核心部分集中到服务器上，简化了系统的开发、维护和使用。客户机上只要安装一个浏览器(Browser)，如Internet Explorer或者Firefox，服务器安装Oracle、Sybase、Informix或SQL Server、MYSQL等数据库。浏览器通过Web Server同数据库进行数据交互。上述架构通常是这样工作的，即用户请求信息从web前端发送到WebServer，WebServer一站式处理各种业务逻辑，使用相应的数据库来存储相关数据。

然而，由于B/S结构管理软件只安装在服务器端上，网络管理人员只需要管理服务器就行了，用户界面主要事务逻辑在服务器端完全通过浏览器实现，极少部分事务逻辑在前端实现，所有的客户端只有浏览器，网络管理人员只需要做硬件维护，但是，由于传统WebServer模式的数据和逻辑是集中式设计的，采用具体的处理方法时，是位于同一个服务进程中，应用服务器运行数据负荷较重，如果用户量持续增长，单台服务器无法支撑的时候，无法通过部署多套进程的方法来扩展，一旦发生服务器“崩溃”等问题，后果将不堪设想。因此，这也是很多单位都备有数据库存储服务器的原因，然而，采用备用数据库存储服务器，只是在服务器“崩溃”后采取的被动的应对方式，仍然无法解决防止服务器“崩溃”的问题，因此需要采用一种新的方法，即采用一种新的后台服务系统及方法，主动的减少服务器的负荷，从根本上解决服务器“崩溃”的问题，进一步提高服务器的安全。

发明内容

本发明的目的是提供一种分布式直播后台服务系统，该系统采用了代理服务模块以及相应的功能服务模块，代理服务模块作为请求信息的中转站，请求信息到达代理服务模块，代理服务模块验证完成后，根据请求信息类型分别转给相应功能服务模块进行处理。这种模块架构使得所有进程可以分拆部署，所有的模块可以根据需要而定制，避免了采用上述方法及架构带来的缺陷，因此具有很强的扩展性。

本发明的另一个目的是提供一种分布式直播后台服务的方法，该方法采用了配置的代理服务模块以及相应的功能服务模块，采用代理服务模块处理请求信息，代理服务模块验证完成后，根据请求信息类型分别转给相应的功能服务模块进行处理。

本发明的所述分布式直播后台服务系统所采取的技术方案如下：

一种分布式直播后台服务系统，其包括信息接收模块、信息判断模块、代理服务模块、功能服务模块、音视频服务模块、实时聊天服务模块和交易服务模块，其中功能服务模块包括房间服务模块、数据服务模块、统计服务模块，用户请求信息从web前端到达代理服务模块，代理服务模块对登录信息进行验证后，根据请求信息类型及资源取模后的值分别转给对应的功能服务模块即数据服务模块、房间服务模块、统计服务模块，并且其中

音视频服务模块对用户请求信息中直接的音视频服务请求信息进行响应，提供发布、接收音视频直播、流管理操作，并对用户身份信息进行合法性验证；

代理服务模块用于对登录信息进行验证，并对用户请求信息进行转发；

房间服务模块用于提供房间服务操作，用户在房间服务模块的各类数据更新，房间服务模块会根据资源取模，并且同步更新到对应的数据服务模块；

数据服务模块用于提供数据更新和查询，包括用户基础数据、用户状态、房间基础数据、房间状态数据信息；

统计服务模块对用户请求信息中的相应请求进行响应，输出实时统计的房间服务模块中的房间热度排行、主播分类排行信息；

交易服务模块为房间服务模块中的相应操作提供各种交易操作，并且按月输出统计报表；

实时聊天服务模块提供消息的群发和单发，即用户在房间的聊天信息，通过实时聊天服务模块来转发。

进一步地，统计服务模块和代理服务模块按照镜像的方式来操作；

进一步地，本发明上述系统中的代理服务模块能够横向扩展；

进一步地，房间服务模块提供的房间服务操作包括用户进入房间以及用户在房间的各种操作，且是按照房间号取模的方式来操作；

进一步地，所述各种交易操作包括充值、赠送、扣除以及余额查询；

进一步地，本发明上述系统中的数据服务模块按照用户uid取模的方式来存储用户数据，并且还包括对用户基础数据、用户状态、房间基础数据、房间状态数据进行更新和查询，同时用于读写静态配置信息以及动态数据。

本发明的所述分布式直播后台服务方法所采取的技术方案如下：

一种分布式直播后台服务方法，其包括如下步骤：

1)、由信息接收模块接收用户请求信息；

2)、由信息判断模块对请求信息进行判断：

如果是音视频服务请求信息，则通过音视频服务模块进行发布、接收音视频直播、流管理操作；

如果是聊天信息，则通过实时聊天服务模块进行操作；

如果不是上述两种信息，则由代理服务模块接收来自web前端的用户请求信息，对登录信息进行验证，

3)、判断代理服务模块接收的请求信息类型，按照资源取模后的值分别转发相应的功能服务模块，

4)、若步骤3)中的请求信息是查询信息，则由统计服务模块提供相应查询结果信息；

若步骤3)中的请求信息是数据服务信息，则将该信息传到数据服务模块；

若步骤3)中的请求信息是房间服务信息，则将该信息传到房间服务模块进行房间服务操作，同时，用户在房间服务模块的各类数据更新，房间服务模块会根据资源取模，同步更新到对应的数据服务模块；

5)、将步骤4)中传送到房间服务模块中的交易服务请求信息传到交易服务模块，进行交易操作；

进一步地，其中步骤2)中的代理服务模块和步骤4)中的统计服务模块按照镜像的方式来操作；

进一步地，步骤2)中的代理服务模块能够横向扩展；

进一步地，步骤4)中的数据服务模块提供数据更新和查询，包括用户基础数据、用户状态、房间基础数据、房间状态数据信息；

进一步地，步骤4)中的查询结果信息是实时统计的房间热度排行、主播分类排行信息；

进一步地，步骤5)中交易操作包括充值、赠送、扣除以及余额查询，并且按月输出统计报表；

进一步地，步骤4)中房间服务模块提供的房间服务操作包括用户进入房间以及用户在房间的各种操作；

进一步地，所述的数据服务模块还按照用户uid取模的方式来存储用户数据，并且还包括对用户基础数据、用户状态、房间基础数据、房间状态数据进行更新和查询，同时用于读写静态配置信息以及动态数据。

进一步地，实时聊天服务模块提供聊天信息的群发和单发，用户在房间的聊天信息，也通过实时聊天服务模块来转发。

附图说明

附图1为本发明方法的流程图；

具体实施方式

以下结合附图和具体实施例对本发明进行详细的说明。

本实施例以酷我秀场为例，参见附图，为酷我秀场采用的方法流程图，首先由用户在前端提出请求，信息接收模块接收用户的请求信息后，由信息判断模块进行判断，同时交由相应的代理服务模块、音视频服务模块、实时聊天服务模块处理，具体的是，如果是音视频服务请求信息，则通过音视频服务模块进行发布、接收音视频直播、流管理操作，同时，如果是发布视频操作，音视频服务模块还可以对用户身份信息或发布内容信息进行合法性验证；如果是聊天信息，则通过实时聊天服务模块进行操作；如果不是上述两种信息，则由代理服务模块接收来自web前端的用户请求信息，对登录信息进行验证。代理服务模块接收请求信息后，会判断请求信息的类型，按照资源取模后的值分别转发相应的功能服务模块，若请求信息是查询信息，则由统计服务模块提供相应查询结果信息，例如房间热度排行、主播分类排行等信息；若请求信息是数据服务信息，则将该信息传到数据服务模块，数据服务模块还会按照用户uid取模的方式来存储用户数据；若请求信息是房间服务信息，则将该信息传到房间服务模块进行房间服务操作，房间服务操作时按照房间号取模的方式来操作的，同时，用户在房间服务模块的各类数据更新，包括用户基础数据、用户状态、房间基础数据、房间状态数据信息，房间服务模块会根据资源取模，同步更新到对应的数据服务模块。上述代理服务模块和统计服务模块具体是按照镜像的方式来操作。

在房间中，用户可以进行各种操作，例如用户进入房间后，可以进行相应的操作，例如可以进行充值酷币、赠送酷豆、赠送礼物、扣除酷豆、余额查询，并且按月输出统计报表等操作，还可以通过实时聊天服务模块进行群聊或私聊。

本发明中使用mysql存储静态配置信息，使用ksql存储动态数据，使用独立mysql存储交易中的货币相关数据。

以上对本发明实施例所提供的技术方案进行了详细介绍，本文中应用了具体个例对本发明实施例的原理以及实施方式进行了阐述，以上实施例的说明只适用于帮助理解本发明实施例的原理；同时本领域的一般技术人员，根据本发明的实施例，在具体实施方式以及应用范围上均会有改变之处，综上所述，本发明书内容不应理解为对本发明的限制。

Claims

1.一种分布式直播后台服务系统，其特征在于：包括信息接收模块、信息判断模块、代理服务模块、功能服务模块、音视频服务模块、实时聊天服务模块和交易服务模块，其中功能服务模块包括房间服务模块、数据服务模块、统计服务模块，用户请求信息由信息接收模块接收，由信息判断模块判断，如果是音视频服务请求信息，则通过音视频服务模块进行发布、接收音视频直播、流管理操作，同时，如果是发布视频操作，音视频服务模块还可以对用户身份信息或发布内容信息进行合法性验证；如果是聊天信息，则通过实时聊天服务模块进行操作；如果不是上述两种信息，则将相应信息由web前端送到代理服务模块，代理服务模块对登录信息进行验证后，根据请求信息类型及资源取模后的值分别转给对应的功能服务模块即数据服务模块、房间服务模块、统计服务模块，并且其中

交易服务模块为房间服务模块中的相应操作提供各种交易操作，包括充值、赠送、扣除以及余额查询，并且按月输出统计报表；

实时聊天服务模块提供聊天信息的群发和单发，用户在房间的聊天信息，通过实时聊天服务模块来转发。

2.根据权利要求1所述的分布式直播后台服务系统，其特征是：所述统计服务模块和代理服务模块按照镜像的方式来操作，上述系统中的代理服务模块能够横向扩展。

3.根据权利要求2所述的分布式直播后台服务系统，其特征是：所述房间服务模块提供的房间服务操作包括用户进入房间以及用户在房间的各种操作，且是按照房间号取模的方式来操作。

4.一种分布式直播后台服务方法，其包括如下步骤：

1)、由信息接收模块接收用户请求信息；

2)、由信息判断模块对请求信息进行判断：

如果是聊天信息，则通过实时聊天服务模块进行操作；

3)、判断代理服务模块接收的请求信息类型，按照资源取模后的值分别转发相应的功能服务模块；

5)、将步骤4)中传送到房间服务模块中的交易服务请求信息传到交易服务模块，进行交易操作。

5.根据权利要求4所述的分布式直播后台服务方法，其中步骤2)中的代理服务模块和步骤4)中的统计服务模块按照镜像的方式来操作，并且代理服务模块能够横向扩展。

6.根据权利要求5所述的分布式直播后台服务方法，其中所述数据服务模块按照用户uid取模的方式来存储用户数据，且提供数据更新和查询，包括用户基础数据、用户状态、房间基础数据、房间状态数据信息，同时用于读写静态配置信息以及动态数据。

7.根据权利要求4所述的分布式直播后台服务方法，其中步骤4)中的查询结果信息是实时统计的房间热度排行、主播分类排行信息，房间服务模块提供的房间服务操作包括用户进入房间以及用户在房间的各种操作。

8.根据权利要求4所述的分布式直播后台服务方法，其中步骤5)中交易操作包括充值、赠送、扣除以及余额查询，并且按月输出统计报表。

9.根据权利要求4所述的分布式直播后台服务方法，聊天信息的群发和单发由实时聊天服务模块来完成，用户在房间的聊天信息，也通过实时聊天服务模块来转发。