-
公开(公告)号：CN116578590A
公开(公告)日：2023-08-11
申请号：CN202310320291.1
申请日：2023-03-29
Applicant: 飞狐信息技术(天津)有限公司
IPC: G06F16/2455 , G06F16/2458
Abstract: 本申请提供了一种热点数据缓存处理方法和装置，涉及数据处理技术领域，方法包括：确定来自调用方的数据获取请求所请求的目标数据是否已配置缓存，若是且缓存中未存储目标数据，则基于预先生成的过滤器在滑动时间窗口包含的各单位时间内的计数值判断目标数据是否为热数据；若是，则根据过滤器在各单位时间内的计数值，对过滤器在当前时间内的计数值进行更新，并将从数据库获取的目标数据设置到缓存，并返回给调用方；若否，则将过滤器在当前时间内的计数值加1，并将从数据库获取的目标数据返回给调用方。本申请通过过滤器在各单位时间内的计数值确定目标数据是否为热数据，仅在目标数据为热数据时才设置到缓存，避免了大量冷数据写入缓存。
-
公开(公告)号：CN115134262A
公开(公告)日：2022-09-30
申请号：CN202211053264.4
申请日：2022-08-31
Applicant: 飞狐信息技术(天津)有限公司
IPC: H04L43/04 , H04L43/08 , H04L41/0631 , H04L67/1095 , H04L67/56
Abstract: 本发明提供一种RocketMQ监控方法及装置、存储介质及电子设备，确定待监控的RocketMQ和监控配置信息，RocketMQ包含生产端、存储端和消费端，监控配置信息中包含生产端的各个生产监控维度、存储端的各个存储监控维度以及消费端的各个消费监控维度；基于生产端的各个生产监控维度，对生产端进行监控；基于存储端的各个存储监控维度，对存储端进行监控；基于消费端的各个消费监控维度，对消费端进行监控；在监控的过程中，对具有预警需求的监控维度进行预警分析，并在满足预警条件时生成预警信息。本发明全面的对RocketMQ进行监控，可得到全面的监控信息，并且可及时进行预警。
-
公开(公告)号：CN115118708A
公开(公告)日：2022-09-27
申请号：CN202211023609.1
申请日：2022-08-25
Applicant: 飞狐信息技术(天津)有限公司
IPC: H04L67/025 , H04L67/566 , H04L67/568
Abstract: 本申请公开了一种消息中间件的http协议代理方法及装置，客户端与消息中间件之间建立代理服务模块；代理服务模块获取支持http协议的客户端的生产者名称或消费者名称，生成客户端实例；消息生产时，代理服务模块通过生产者客户端对应的客户端实例向消息中间件发送消息并将消息被接收的结果响应返回客户端；消息消费时，代理服务模块通过消费者客户端对应的客户端实例向消息中间件中拉取消息，并将拉取消息的反馈返回客户端进行拉取消息的消费，本发明的代理服务模块对外采用http协议，对内采用消息中间件协议，进而屏蔽了不同语言与消息中间件交互的难度。
-
公开(公告)号：CN114880158A
公开(公告)日：2022-08-09
申请号：CN202210809318.9
申请日：2022-07-11
Applicant: 飞狐信息技术(天津)有限公司
Abstract: 本发明提供一种Redis实例诊断方法及装置，预先对Redis实例的问题进行分类并构建分析模块，在响应用户发起的Redis实例诊断工单之后，调用待诊断Redis实例，运行不同类型问题各自对应的分析模块自动对该待诊断Redis实例进行诊断，能够快速、有效和全面的发现待诊断Redis实例运行过程中所存在的问题。
-
公开(公告)号：CN114640586A
公开(公告)日：2022-06-17
申请号：CN202210541582.9
申请日：2022-05-19
Applicant: 飞狐信息技术(天津)有限公司
IPC: H04L41/082 , H04L67/10 , G06F8/65
Abstract: 本申请公开了集群的版本升级方法、装置、存储介质及设备，在接收到用户输入的目标版本号后，触发集群的节点分组的从节点利用安装信息，生成新配置文件；触发从节点结束运行实例，加载新配置文件运行新实例得到新实例的运行状态；将新实例的运行状态为成功的从节点，标识为候选从节点，并从一个或多个候选从节点中选取一个候选从节点，作为目标节点；调用预设的失效转移命令，将目标节点替代节点分组的主节点，以使目标节点变更为节点分组的新主节点，且被替代的主节点变更为节点分组的新从节点；在新从节点执行预设步骤后，提示用户集群版本升级成功，与现有技术相比，能在实现集群的版本升级的情况下，确保升级过程依旧可以对外提供服务。
-
Patent Agency Ranking
公开(公告)号：CN114629925A
公开(公告)日：2022-06-14
申请号：CN202011458853.1
申请日：2020-12-11
Applicant: 飞狐信息技术(天津)有限公司
IPC: H04L67/1097
Abstract: 本发明提供了一种数据传输方法、装置及电子设备，消息转发系统预先设置有，用于存储业务消息的第一数据存储集群，以及，用于存储与所述业务消息对应的消息轨迹的第二数据存储集群，在进行业务消息的发送时，目标业务消息存储至第一数据存储集群，目标业务消息对应的消息轨迹存储到第二数据存储集群。即通过本发明，将业务消息以及业务消息对应的消息轨迹分开存储，后续在对业务消息或业务消息对应的消息轨迹进行分析时，根据要分析的数据是业务消息还是消息轨迹，直接从对应的存储集群中查找数据即可，相比于从同时存储有业务消息和消息轨迹的存储集群中查找数据的方式，能够快速的找到需要分析的数据，进而简化了数据分析复杂度。
-
公开(公告)号：CN114090304B
公开(公告)日：2022-05-24
申请号：CN202210057544.6
申请日：2022-01-19
Applicant: 飞狐信息技术(天津)有限公司
IPC: G06F9/54
Abstract: 本发明提供一种基于消息中间件的消息回放方法和装置，该方法为：当接收到消息中间件转发的消息回放指令时，构建消息回放实例，该消息回放指令至少包含指定时间段；创建并启动消费线程；根据消息回放实例和消费线程，从消息存储组件的从节点中，获取消息回放指令所指定的处于指定时间段内的待回放消息，若获取得到待回放消息，重新消费待回放消息。本方案中，在接收到消息回放指令时，利用所构建的消息回放实例和消费线程，从消息中间件的消息存储组件从节点中，获取处于指定时间段内的待回放消息，重新消费所获取到的待回放消息，以实现回放任意时间段内的消息。
-
公开(公告)号：CN113900842B
公开(公告)日：2022-04-26
申请号：CN202111504670.3
申请日：2021-12-10
Applicant: 飞狐信息技术(天津)有限公司
Abstract: 本申请提供一种消息的消费方法、装置、电子设备及计算机存储介质，所述消息的消费方法包括：在获取目标消息时；其中，所述目标消息包括：幂等标识和身份证；首先，将所述目标消息的幂等标识作为关键字，将所述目标消息的身份证作为值，并为所述目标消息的身份证添加正在消费的消费状态，存储至数据结构服务器；然后，在预设时间内，判断所述数据结构服务器中是否有所述目标消息的幂等标识；若在预设时间内，判断出所述数据结构服务器中没有所述目标消息的幂等标识，则确定设置成功，进入消费流程；若消费成功则存储目标消息的幂等标识，并将所述目标消息的身份证的消费状态更改为已消费成功。从而可以去重，实现了幂等消费的逻辑。
-
公开(公告)号：CN114372064A
公开(公告)日：2022-04-19
申请号：CN202210281853.1
申请日：2022-03-22
Applicant: 飞狐信息技术(天津)有限公司
IPC: G06F16/22 , G06F16/23 , G06F16/245 , G06F16/28
Abstract: 本发明公开了一种数据处理装置、方法、计算机可读介质及处理器，数据处理装置可以设置有第一获得单元、第一更新单元和RediSearch模块；第一获得单元用于当存储在关系型数据库中的基础元数据出现数据更新时，获得关于基础元数据的数据变更消息；基础元数据中包括至少一种类型信息的数据；第一更新单元用于基于数据变更消息，对存储在Redis数据库中的目标元数据进行数据更新；目标元数据与基础元数据相对应；RediSearch模块用于当监测到目标元数据出现数据更新时，对与目标元数据相对应的目标二级索引进行相应的数据更新；目标二级索引是RediSearch模块基于Redis数据库中的目标元数据创建的。本发明可以实现对二级索引中索引数据的有效更新。
-
公开(公告)号：CN114090304A
公开(公告)日：2022-02-25
申请号：CN202210057544.6
申请日：2022-01-19
Applicant: 飞狐信息技术(天津)有限公司
IPC: G06F9/54
Abstract: 本发明提供一种基于消息中间件的消息回放方法和装置，该方法为：当接收到消息中间件转发的消息回放指令时，构建消息回放实例，该消息回放指令至少包含指定时间段；创建并启动消费线程；根据消息回放实例和消费线程，从消息存储组件的从节点中，获取消息回放指令所指定的处于指定时间段内的待回放消息，若获取得到待回放消息，重新消费待回放消息。本方案中，在接收到消息回放指令时，利用所构建的消息回放实例和消费线程，从消息中间件的消息存储组件从节点中，获取处于指定时间段内的待回放消息，重新消费所获取到的待回放消息，以实现回放任意时间段内的消息。
-
-
-
-
-
-
-
-
-
Search Results
60
records
(took 0.062 seconds)
