-
公开(公告)号:CN113946449A
公开(公告)日:2022-01-18
申请号:CN202111271831.9
申请日:2021-10-29
Applicant: 北京工业大学
Abstract: 本发明公开了一种基于Kafka的消费者端负载均衡方法,属于消息处理技术领域。为解决现有的消费者端负载均衡方法中消费者互相孤立,不能高效地处理由于消费者宕机引起的消费者消息处理能力下降问题,提出一种改进的消费者端负载均衡方法。在Kafka消息传输系统中从生产者集群生产消息、broker存储消息到消费者集群接收消息的整个流程中,通过由负载均衡开始时选出的协调者统一管理分配消费者和分区的对应情况,并且根据分区负载情况制定不同的分配方案,很好的解决了现有的负载均衡策略中消费者互相孤立的问题,能帮助Kafka系统高效快捷地处理突发的负载均衡事件,提高了生产环境下的Kafka的适用性。
-
公开(公告)号:CN112418767B
公开(公告)日:2024-04-23
申请号:CN202011346360.9
申请日:2020-11-25
Applicant: 北京工业大学
IPC: G06Q10/0833 , G06F21/64 , G06K17/00
Abstract: 本发明涉及一种基于区块链和RFID的多环节物品追踪方法,选用联盟链作为区块链平台,通过RFID读写器、上位机,将多环节过程的处理信息实时自动录入区块链,各部门共同参与账本的维护;联盟链采用多通道的架构实现针对不同公司业务的粗粒度保护,在不同的通道内,通过设置访问控制列表实现细粒度隐私保护;通过基于Node‑Serialport的多环节RFID数据自动上链程序监听实现高效的物品处理信息实时自动去人工录入区块链;通过智能合约针对不同部门设置不同数据结构,满足各部门业务需求;通过智能合约对各个部门上传的数据进行校对,融合提取处理保证一物一码,智能合约分别向旅客和管理者提供数据访问和交互接口。
-
公开(公告)号:CN113946449B
公开(公告)日:2024-10-29
申请号:CN202111271831.9
申请日:2021-10-29
Applicant: 北京工业大学
Abstract: 本发明公开了一种基于Kafka的消费者端负载均衡方法,属于消息处理技术领域。为解决现有的消费者端负载均衡方法中消费者互相孤立,不能高效地处理由于消费者宕机引起的消费者消息处理能力下降问题,提出一种改进的消费者端负载均衡方法。在Kafka消息传输系统中从生产者集群生产消息、broker存储消息到消费者集群接收消息的整个流程中,通过由负载均衡开始时选出的协调者统一管理分配消费者和分区的对应情况,并且根据分区负载情况制定不同的分配方案,很好的解决了现有的负载均衡策略中消费者互相孤立的问题,能帮助Kafka系统高效快捷地处理突发的负载均衡事件,提高了生产环境下的Kafka的适用性。
-
公开(公告)号:CN112418767A
公开(公告)日:2021-02-26
申请号:CN202011346360.9
申请日:2020-11-25
Applicant: 北京工业大学
Abstract: 本发明涉及一种基于区块链和RFID的多环节物品追踪方法,选用联盟链作为区块链平台,通过RFID读写器、上位机,将多环节过程的处理信息实时自动录入区块链,各部门共同参与账本的维护;联盟链采用多通道的架构实现针对不同公司业务的粗粒度保护,在不同的通道内,通过设置访问控制列表实现细粒度隐私保护;通过基于Node‑Serialport的多环节RFID数据自动上链程序监听实现高效的物品处理信息实时自动去人工录入区块链;通过智能合约针对不同部门设置不同数据结构,满足各部门业务需求;通过智能合约对各个部门上传的数据进行校对,融合提取处理保证一物一码,智能合约分别向旅客和管理者提供数据访问和交互接口。
-
-
-