-
公开(公告)号:CN110247971B
公开(公告)日:2021-12-24
申请号:CN201910520789.6
申请日:2019-06-17
申请人: 福建天泉教育科技有限公司
IPC分类号: H04L29/08
摘要: 本发明提供一种减少消息中间件连接数量的方法及其系统,方法包括:客户端发送消息至代理层;代理层中的代理服务依据预设的分配策略,将所述消息分配至相应的连接服务;接收到所述消息的连接服务将所述消息发送至所述消息中指定的MQ连接件。本发明能使系统不受消息中间件连接数量的限制扩充客户端的数量,且同样能保持系统性能的稳定性;同时,还能在一定程度上明显减少与消息中间件直接连接的项目数量;进一步地,还具有实施方式便捷性高、实用性高以及消息传送精准等优点。
-
公开(公告)号:CN113760933A
公开(公告)日:2021-12-07
申请号:CN202110980909.8
申请日:2021-08-25
申请人: 福建天泉教育科技有限公司
IPC分类号: G06F16/23 , G06F16/2458 , G06F16/21 , G06F16/25
摘要: 本发明的一种数据更新方法及终端,接收全量更新消息,依次从ES集群中查询预设数量的数据,得到数据集;根据数据集对全量更新消息的发送方的对应数据进行回调,能够主动得到数据集的最新数据信息,提高业务上的数据查询效率;在将最新数据写入ES集群之前,查询ES集群的负载水平,若负载水平低于预设值,则通过ES接入服务接口将数据集的最新数据信息更新至ES集群,否则限制ES接入服务接口将数据集的最新数据信息更新至ES集群的数量或者速率;因此通过主动回调发送方的预设数量的回调数据,便于根据ES集群资源情况进行主动控制,并且根据ES集群的负载水平确定最新数据写入集群的数量或者速率,能够在保证自身业务的前提下,减少ES集群的压力。
-
公开(公告)号:CN113312234A
公开(公告)日:2021-08-27
申请号:CN202110537971.X
申请日:2021-05-18
申请人: 福建天泉教育科技有限公司
摘要: 本发明公开一种健康检测的优化方法及终端,设置健康检测集群,所述健康检测集群包括一个以上的健康检测节点;接收健康度规则,包括每一个应用节点所对应的健康度检测属性及健康度阈值;根据健康度检测方式通过健康检测节点对待检测的应用节点进行健康检测得到节点健康度,并判断节点健康度是否大于待检测的应用节点所对应的健康度阈值,若否,则断开待检测的应用节点的对外服务;本发明针对每个应用节点定制的健康度检测方式和健康度阈值实现对每一应用节点的个性化配置,针对性高,通过健康检测集群提高健康检测数据的承载量,能够接收并处理更大量的应用节点健康数据,从而能够实现对应用全面的健康检测。
-
公开(公告)号:CN113297324A
公开(公告)日:2021-08-24
申请号:CN202110394218.X
申请日:2021-04-13
申请人: 福建天泉教育科技有限公司
摘要: 本发明公开了一种数据写入的优化方法:当节点集合中的节点接收一条写入数据所对应的多个写入数据包时,监控每一个所述写入数据包的响应时间;标记响应时间超过预设的第一阈值的第一写入数据包,标记第一写入数据包的数量超过预设的第二阈值的节点为第一节点;将第一节点所对应的第一写入数据写入节点集合中的第二节点。本发明在进行数据写入时,对于每个节点都监控写入其中的每个写入数据包的响应时间,若该节点此时的状态不佳,则更换节点进行数据写入而不是等待该节点的响应结果,提升了对客户端写入请求的处理效率。
-
公开(公告)号:CN113242172A
公开(公告)日:2021-08-10
申请号:CN202110451353.3
申请日:2021-04-26
申请人: 福建天泉教育科技有限公司
IPC分类号: H04L12/58
摘要: 一种消息的应答方法及系统,服务端按照目标消息的时间顺序为每一目标消息设置消息标识,消息标识与时间顺序一一对应;服务端发送目标消息及目标消息对应的消息标识至客户端;客户端每接收到一个第一目标消息后就发送响应信息至服务端,响应信息包括第一目标消息所对应的第一消息标识;服务端判断是否存在时间顺序在第一消息标识之前且未响应的第二消息标识,若否,则发送响应成功消息至客户端;客户端接收到响应成功消息后,按照第一消息标识顺序展示所接收到的第一目标消息;本发明客户端接收到一条消息后都由服务端判断是否还存在发送时间更早的未接收消息,避免了使用客户端的用户读取到语义不清的消息的情况。
-
公开(公告)号:CN112217712A
公开(公告)日:2021-01-12
申请号:CN202011015466.0
申请日:2020-09-24
申请人: 福建天泉教育科技有限公司
摘要: 本发明提供消息多端同步的方法、客户端,方法包括:分别在服务端和各个客户端创建与用户ID对应的消息记录表,所述消息记录表中的字段包括消息主键ID、上一条消息主键ID和时间戳;当一客户端离线后重新上线,且接收到重新上线后的第一条消息之后,依据其对应的消息记录表,判断所述第一条消息对应的上一条消息主键ID是否被记录在表中的消息主键ID字段中;若否,则依据表中所述第一条消息对应的消息主键ID及其上一条消息主键ID向服务端获取对应的消息。本发明既减少了无用消息的传输,又减少了客户端和服务端的查询复杂度和查询工作量;进而,能够显著提高多端离线消息同步的效率,同时减少资源损耗。
-
公开(公告)号:CN111800457A
公开(公告)日:2020-10-20
申请号:CN202010435309.9
申请日:2020-05-21
申请人: 福建天泉教育科技有限公司
IPC分类号: H04L29/08
摘要: 本发明提供优化路由分配的方法、存储介质,方法包括:对各个服务器应用进行地域性划分,得到两个以上的地区集群;对所述地区集群进行区域性划分,得到两个以上的区域集群;监控各个服务器应用的负载情况和实际资源使用情况;一客户端发起长链接请求至智能路由,智能路由依据客户端所属的区域转发至对应的区域集群;区域集群依据客户端所属地区集群内各个服务器应用的监控情况,返回服务器应用的路由地址至客户端。本发明能够提高用户实际访问效率,提升用户体验;能够实现系统的负载均衡,连接更稳定;能在地区总资源超负载时及时告警,有助于及时调整和解决。还具有易于实现、成本低且效果显著等特点。
-
公开(公告)号:CN111585774A
公开(公告)日:2020-08-25
申请号:CN202010212698.9
申请日:2020-03-24
申请人: 福建天泉教育科技有限公司
摘要: 本发明提供一种会话更新的方法、存储介质,方法包括:当消费者程序从MQ获取一群消息,异步将所述一群消息的群ID存储至本地内存的一数据结构中;定时扫描所述一数据结构,发送扫描到的群ID至对应的消费者程序,并在扫描结束后清空所述一数据结构;消费者程序接收到群ID后,更新所述群ID对应群成员的会话列表排序。本发明以定时统一更新群会话的方式,大大减少了写数据库的次数,有效缓解了系统与数据库的压力;同时,依然能够使会话列表具备较高时效性,且不影响群消息的即时性更新效果;进一步地,本发明还具有实施方式简便,内存资源占用极少,实用性高等优点。
-
公开(公告)号:CN111552577A
公开(公告)日:2020-08-18
申请号:CN202010212679.6
申请日:2020-03-24
申请人: 福建天泉教育科技有限公司
摘要: 本发明提供一种防止出现无效请求的方法、存储介质,方法包括:客户端发送携带超时时间的请求至服务端;服务端创建对应所述请求的共享对象,并将所述请求的超时时间设置其中;记录服务端依据所述请求调用各微服务接口调用方法的执行时间;若依据所述记录和所述共享对象中的超时时间判定所述请求已超时,则服务端停止处理所述请求。本发明能够有效防止微服务无效请求的发生,从而提高系统的效率和可用性;而且具备实施方式简便、易行、效果显著等优点。
-
公开(公告)号:CN111352936A
公开(公告)日:2020-06-30
申请号:CN202010081576.0
申请日:2020-02-06
申请人: 福建天泉教育科技有限公司
IPC分类号: G06F16/22
摘要: 本发明提供一种ES重建索引的方法、存储介质,方法包括:创建一等待触发消费的消费组线程;对应旧索引的索引操作同步写入所述消费组;配置新索引的设置和映射字段;重建索引;触发所述消费组进行消费,将消费组内的索引操作消费到新建的索引中;当所述消费组的消费延迟低于阈值,则将旧索引与其别名的关联切换为新索引与所述别名的关联。本发明能够实现不停服的进行ES索引切换,给用户带来近乎无感的体验;同时,本发明还具有实施高效、稳健且成本低的特点。
-
-
-
-
-
-
-
-
-