一种基于数据通信线程的告警方法、设备及其存储介质

    公开(公告)号:CN118984265A

    公开(公告)日:2024-11-19

    申请号:CN202410982175.0

    申请日:2024-07-22

    发明人: 冯俊 张超

    摘要: 本申请公开了一种基于数据通信线程的告警方法、设备及其存储介质,方法包括:发送端将传输数据帧通过数据通信线程发送至接收端,并实时监测;所有传输数据帧中的状态参数值与预设的告警参数数值进行比较,触发告警参数条件时,生成告警消息并将告警发送标识打开;目标数据帧通过数据通信线程发送至接收端后,再调用告警消息发送接口将告警消息通过数据通信线程发送至接收端;其中,数据通信线程为两组传输数据帧之间发送延时大于告警消息发送时间的线程。本发明通过连发式共生数据通信线程,合理有效的利用了业务资源,减少了系统资源的消耗;还将数据帧问题通过告警消息发送至接收端,让使用者更加清晰明了的知道当前数据的状态。

    交易数据的处理方法、装置及实时数仓系统

    公开(公告)号:CN118864077A

    公开(公告)日:2024-10-29

    申请号:CN202410850161.3

    申请日:2024-06-27

    摘要: 本发明公开了一种交易数据的处理方法、装置及实时数仓系统。涉及金融科技领域或其他相关技术领域。该方法包括:接收采用目标传输方式传输的第一交易数据,其中,目标传输方式包括:基于流式处理技术对数据进行传输的传输方式、基于数据缓冲区,采用排队机制对数据进行传输的传输方式,第一交易数据包括从目标金融平台获取的交易数据,目标金融平台用于为客户和多个金融机构提供金融服务;对第一交易数据进行预处理,得到第二交易数据;将第二交易数据分发至N个计算节点,接收N个计算节点返回的N个结算结果;对N个结算结果进行合并,得到第一交易数据的结算结果。本发明解决了采用批量处理方式处理开放银行交易数据,处理效率低的技术问题。

    一种交换网络性能分析方法、及其网络结构与调度方法

    公开(公告)号:CN115720216B

    公开(公告)日:2024-10-29

    申请号:CN202211069087.9

    申请日:2022-09-01

    IPC分类号: H04L49/90 H04L47/30 H04L47/50

    摘要: 本申请公开了一种交叉节点带缓存(Combined Input and Crosspoint Queued structure,CICQ)交换网络的结构与其性能分析方法。所述结构由虚拟输出队列(Virtual Output Queuing,VOQ)、带缓存的交叉开关(Buffered Crossbar,BX)组成。所述性能分析方法:通过增加仿真时间,得到所述网络系统稳定状态;当得到系统的稳定分布后,即可通过累加求和的方式,计算出队列长度N;利用队列长度的公式计算求得队列长度均值,进而得出系统的平均排队时延W、系统的丢包率L、吞吐率T;分析交叉点缓冲区大小B、交换规模大小C与吞吐率T、丢包率L、平均排队时延W、队列长度N的关系。本发明在交叉节点设置了少量缓存空间,数据包在调度时不用立即被转发至输出端口。如此设计不需要集中式的调度,大幅降低了调度复杂度,实现高速流水作业。

    物联网消息处理方法、装置、电子设备及存储介质

    公开(公告)号:CN115914346B

    公开(公告)日:2024-10-22

    申请号:CN202110910238.8

    申请日:2021-08-09

    发明人: 杨勇

    IPC分类号: H04L67/51 H04L67/12 H04L47/50

    摘要: 本申请提供了一种物联网消息处理方法、装置、电子设备及计算机可读存储介质;方法包括:接收物联网设备发送的物联网消息;基于所述物联网消息的消息类型、及消息类型与消息消费者服务的对应关系,确定所述物联网消息对应的至少一个消息消费者服务;确定所述至少一个消息消费者服务中每一个消息消费者服务关联的目标消息队列;将所述物联网消息添加至每一个目标消息队列;其中,消息消费者服务用于对关联的目标消息队列内的物联网消息进行消费处理。通过本申请,能够高效灵活地对多种类型的物联网消息进行处理。

    具有主动队列管理的令牌桶

    公开(公告)号:CN116266824B

    公开(公告)日:2024-10-15

    申请号:CN202210433924.5

    申请日:2022-04-24

    IPC分类号: H04L47/215 H04L47/50

    摘要: 本公开涉及具有主动队列管理的令牌桶。提供了用于网络设备处具有比传统QoS原语更好性能的新型服务质量(QoS)原语的系统和方法。QoS原语可以包括具有主动队列管理的令牌桶(TBAQM)。具体地,TBAQM可以接收由令牌桶处理的数据分组;调整与令牌桶相关联的令牌,其中基于配置速率添加令牌,并与处理数据分组相关联地减去令牌;确定与令牌桶相关联的令牌数量,包括:当令牌桶具有0个令牌时,用数据分组发起第一动作,以及当令牌桶具有多于0个令牌时,基于令牌数量确定标记概率,并基于标记概率发起第二动作。

    基于FPGA实现TTE时间触发的调度方法

    公开(公告)号:CN118740756A

    公开(公告)日:2024-10-01

    申请号:CN202410915434.8

    申请日:2024-07-09

    IPC分类号: H04L47/50 G05B19/042

    摘要: 本发明公开了一种基于FPGA实现TTE时间触发的调度方法,包括如下步骤:根据TT消息中调度需要的信息生成调度参数表和调度表,调度表包括调度入口点表和子调度表;FPGA根据调度参数表和调度表运行调度入口点模块和子调度模块。本发明的调度方法能够确定TTE中的TT消息的处理时间和固定延迟,可以精确满足TT消息的确定性、可分析和可测量的特性。

    TTE系统低延迟传输BE数据的方法、TTE系统

    公开(公告)号:CN116032862B

    公开(公告)日:2024-09-27

    申请号:CN202211609192.7

    申请日:2022-12-14

    IPC分类号: H04L49/9057 H04L47/50

    摘要: 本申请涉及一种TTE系统低延迟传输BE数据的方法、TTE系统,在TTE端系统驱动中增加一级数据帧类型转换,根据BE和RC虚链路映射关系表,实现关键BE数据帧与RC数据帧的转换,在不影响原本TTE网络PCF、TT、RC业务传输优先级的基础上,将关键BE流量的优先级提高,保证上层BE应用的高效、可靠运行;驱动软件修改底层数据调度规则,上层应用无需做任何修改适配,有效降低指定的BE业务数据的传输时延,提高了指定BE数据业务的传输实时性和可靠性;在某些大流量混合BE背景下,可将指定BE业务的传输延时从20us降低大约10us。

    一种报文传输方法、系统及设备
    9.
    发明公开

    公开(公告)号:CN118694724A

    公开(公告)日:2024-09-24

    申请号:CN202310327309.0

    申请日:2023-03-23

    摘要: 一种报文传输方法、系统及设备,本申请中,第一设备的第一端口对待发送的报文流中的报文分组,形成至少一组报文,为每组报文中的报文配置组队列号,每组报文中的报文的组队列号相同。第一端口向存储设备的第二端口发送报文流中的报文。第二端口按照组队列号的大小顺序依次将组队列号相同的报文发送给存储设备,存储设备根据报文存储报文中携带的数据。作为报文的接收方,存储设备的第二端口按照组队列号的大小顺序依次将组队列号相同的报文发送给存储设备,保证存储设备有序的获取该报文流中的报文,报文传输效率有效提升,存储设备无需额外向第一设备反馈接收成功消息,减少了生产者‑消费者的传输模型中的信令交互。