优化消息处理的方法、存储介质

    公开(公告)号:CN111796930B

    公开(公告)日:2023-12-22

    申请号:CN202010435296.5

    申请日:2020-05-21

    IPC分类号: G06F9/50 G06F9/54

    摘要: 本发明提供一种优化消息处理的方法、存储介质,方法包括:创建与线程池中各个线程一一对应的队列;在本地缓存中创建一数据结构,所述数据结构用于记录消息类型和线程标识的关联关系;依据待写入消息的消息类型查询所述数据结构中是否存在对应的线程标识;若是,则依据所述对应的线程标识将所述待写入消息写入对应的线程;若否,获取线程池中当前队列内元素数量最少的线程,并将所述待写入消息写入其中,将所述待写入消息的消息类型和所写入线程的线程标识的关联关系写入所述一数据结构。本发明能够最大化利用空闲的线程;能够有效缓解因某些消息延时而引起所有消息延时,从而显著提高消息处理的效率。

    一种监控数据的优化方法及服务端

    公开(公告)号:CN112965811B

    公开(公告)日:2023-12-19

    申请号:CN202110147788.9

    申请日:2021-02-03

    IPC分类号: G06F9/50 G06F11/30

    摘要: 本发明公开了一种监控数据的优化方法及服务端,其方法的实现步骤如下:获取监控程序采集监控数据的监控周期,在每一个监控周期内采集实时业务资源使用率;服务端判断实时业务资源使用率是否超过预设业务资源使用率,若是,则对业务流量进行限流,预设业务资源使用率为总资源使用率减去预设监控资源使用率,预设监控资源使用率大于或等于监控程序采集监控数据的最多资源使用率。本发明在使得监控程序在和业务程序共享资源的同时能保证自身进行监控数据的正常工作。

    防止出现无效请求的方法、存储介质

    公开(公告)号:CN111552577B

    公开(公告)日:2023-11-03

    申请号:CN202010212679.6

    申请日:2020-03-24

    IPC分类号: G06F9/54 G06F11/07

    摘要: 本发明提供一种防止出现无效请求的方法、存储介质,方法包括:客户端发送携带超时时间的请求至服务端;服务端创建对应所述请求的共享对象,并将所述请求的超时时间设置其中;记录服务端依据所述请求调用各微服务接口调用方法的执行时间;若依据所述记录和所述共享对象中的超时时间判定所述请求已超时,则服务端停止处理所述请求。本发明能够有效防止微服务无效请求的发生,从而提高系统的效率和可用性;而且具备实施方式简便、易行、效果显著等优点。

    一种Java垃圾回收监控方法及终端

    公开(公告)号:CN112764880B

    公开(公告)日:2023-07-07

    申请号:CN202110067946.X

    申请日:2021-01-19

    IPC分类号: G06F9/455 G06F11/30

    摘要: 本发明公开了一种Java垃圾回收监控方法及终端,获取JVM中一个GC周期内的业务执行时间及GC执行时间;根据所述业务执行时间及所述GC执行时间判断该GC周期是否正常,若否,则将所述GC执行时间记入GC累计时间;判断所述GC累计时间是否超过阈值,若是,则判断所述JVM状态异常并对所述JVM进行干预;本发明以GC周期内业务执行时间和GC执行的时间对比作为一个GC周期内是否出现异常的判断标准,同时设定GC累计时间,当GC累计时间也超过阈值才判断JVM出现异常,能够实现对JVM出现的GC占用资源过多但又未引起宕机情况的自动检测及处理,实现对GC的智能监控。

    提高集群可用性的方法及其系统

    公开(公告)号:CN111858190B

    公开(公告)日:2023-05-23

    申请号:CN202010541421.0

    申请日:2020-06-15

    摘要: 本发明提供一种提高集群可用性的方法及其系统,方法包括:业务系统通过访问缓存设置,确定当前所使用的集群;业务系统向当前所使用的集群执行数据库操作;同步所执行的数据库操作至另一集群;当监控到当前所使用的集群异常时,通过修改缓存设置,切换为使用另一集群。本发明能够防止集群或者集群内部不可用而影响业务,从而提高业务系统的可用性和性能稳定性;能够确保主备集群之间数据同步的及时且准确;故障集群恢复正常后依然提供备用功能,甚至能直接切换回原样而无影响;各自使用专门的线程和队列独立来完成同步,能够提高数据同步的正确性,且降低故障概率;以字典形式在缓存设置集群切换开关,具有易于控制其而不易出错的特点。

    一种大数据场景下消息处理的方法及终端

    公开(公告)号:CN112351096B

    公开(公告)日:2023-03-24

    申请号:CN202011216505.3

    申请日:2020-11-04

    摘要: 本发明提供了一种大数据场景下消息处理的方法及终端,在redis集群的每个redis节点上构建Nginx、lua与redis组成的代理,代理可执行lua脚本;将代理与自身所在的redis节点及其余redis节点所对应的代理之间都建立长连接;通过lua脚本及所述长连接,将单个redis节点接收的数据在redis集群中进行集合运算;本发明通过在redis集群的每个redis节点上构建代理,使得每个redis节点都能通过代理与redis集群中的其余redis节点建立长连接进行数据传递,并且保证了每个redis节点的独立性,使得批量运算还可以执行,并且能够在redis集群中进行分布式计算。

    集群数据扩容的方法、存储介质

    公开(公告)号:CN112100273B

    公开(公告)日:2022-10-21

    申请号:CN202010807804.8

    申请日:2020-08-12

    IPC分类号: G06F16/27 G06F9/50

    摘要: 本发明提供集群数据扩容的方法、存储介质,方法包括:S1:执行首次迁移时,获取预设数量的迁移数据,并执行迁移;S2:完成所获取迁移数据的迁移后,计算预设时长内redis集群处理请求的成功率和平均耗时;S3:若所述成功率和所述平均耗均未达到对应的阈值,则获取上一次获取数量加N数量的迁移数据,并返回执行S2,直至无法获取迁移数据;其中,所述N小于上一次获取数量;S4:若所述成功率或所述平均耗均达到对应的阈值,则获取上一次获取数量的迁移数据,并返回执行S2,直至无法获取迁移数据。本发明能在避免阻塞主线程的前提下,实现快速扩容。

    一种数据同步方法及终端

    公开(公告)号:CN112612799B

    公开(公告)日:2022-10-18

    申请号:CN202011444370.6

    申请日:2020-12-08

    IPC分类号: G06F16/23 G06F16/27

    摘要: 本发明公开了一种数据同步方法及终端,接收每一条待同步数据,获取待同步数据的用户唯一标识,将用户唯一标识和预设消息存储分区数进行取模运算,得到用户唯一标识所分配的预设消息存储分区,将待同步数据存储到所分配的预设消息存储分区内;按照预设消费规则从预设消息存储分区内拉取所存储的待同步数据,并对所拉取的待同步数据按照同一用户唯一标识进行合并,得到已合并待同步数据;对已合并待同步数据进行数据同步。本发明通过分区和合并减少了需要消费的消息数量,能够缓解数据同步中数据量过大的问题,特别针对写数据较多的场景下,能够在一定程度之上提高消息的消费速率,减少消费延迟。

    提高接口访问效率的方法、存储介质

    公开(公告)号:CN110865845B

    公开(公告)日:2022-07-26

    申请号:CN201911029688.5

    申请日:2019-10-28

    IPC分类号: G06F9/4401

    摘要: 本发明提供一种提高接口访问效率的方法、存储介质,方法包括:获取应用启动时所需调用的各个非缓存类接口;应用启动时,发送一存储有所述各个非缓存类接口的参数信息的UDP信息包至服务端;服务端依据所述UDP信息包,逐一调用所述各个非缓存类接口,并缓存其结果。本发明能够减少http请求的耗时,提高应用启动效率。

    新加入负载节点分流的方法、存储介质

    公开(公告)号:CN110445725B

    公开(公告)日:2022-07-26

    申请号:CN201910609417.0

    申请日:2019-07-08

    IPC分类号: H04L47/125 G06F9/50

    摘要: 本发明提供一种新加入负载节点分流的方法、存储介质,方法包括:各节点在周期性发送给中心节点的心跳包中附上自身服务器的磁盘使用率;以预设速度缓慢写入数据至新加入节点,直至新加入节点对应的磁盘使用率达到第一预设值;所述新加入节点对应的磁盘使用率达到第一预设值后,依据公式1/总比例份数*最大比例计算分配至所述新加入节点的流量。本发明不仅能克服新节点短期负载压力过大而崩溃的问题;而且能在新节点加入后尽快达到系统各节点的负载相对均衡,从而显著提高集群的可用性。