一、Kafka概述1.Kafka是一个分布式流媒体平台，它有三个关键功能：(1)发布和订阅记录流，类似于消息队列或企业消息传递系统；(2)以容错的持久方式存储记录流；(3)记录发送时处理流。2.Kafka通常应用的两大类应用(1)构建在系统或应用程序之间的可靠获取数据的实时流数据管道；(2)构建转换或响应数据流的实施

SOFAStack是蚂蚁金服完全自主研发的金融级分布式架构，包含了构建金融级云原生架构所需的各个组件，如微服务研发框架、RPC框架、服务注册中心、分布式定时任务、限流/熔断框架、动态配置推送、分布式链路追踪、Metrics监控度量、分布式高可用消息队列、分布式事务框架和分布式数据库代理层等。SOFAStack：https://gitee.com/

概述相较于Redis4.0，Redis5.0增加了很多新的特性，而streams是其中最重要的特性之一。streams是redis的一种基本数据结构，它是一个新的强大的支持多播的可持久化的消息队列，在设计上借鉴了kafaka。streams的数据类型本身非常简单，有点类似于hash结构，但是它的额外特性异常强大且复杂：支持持久化。st

网络分区的意义RabbitMQ的模型类似交换机模型，且采用erlang这种电信网络方面的专用语言实现。RabbitMQ集群是不能跨LAN部署（如果要WAN部署需要采用专门的插件）的，也就是基于网络情况良好的前提下运行的。为什么RabbitMQ需要这种前提假设？这个和它本身的数据一致性复制原理有关。RabbitMQ采用的镜像队列是一种环

在多线程编程环境下并发安全队列是不可或缺的一个重要工具类，为了实现并发安全可以有两种方式：一种是阻塞式的，例如：LinkedBlockingQueue；另一种即是我们将要探讨的非阻塞式，例如：ConcurrentLinkedQueue。相比较于阻塞式，非阻塞的最显著的优点就是性能，非阻塞式算法使用CAS来原子性的更新数据，避免了加锁的时间，同时也保证了数据的

简介scrapy\_redis是一个基于Redis的Scrapy组件，用于scrapy项目的分布式部署和开发你可以启动多个spider对象，互相之间共享有一个redis的request队列，最适合多个域名的广泛内容的爬取特点分布式爬取分布式数据处理爬取到的item数据被推送到redis中，这意味着你可以启动尽可能多的item处理程序

一、简介RocketMQRocektMQ是阿里巴巴在2012年开源的一个纯java、分布式、队列模型的第三代消息中间件，不仅在传统高频交易链路有着低延迟的出色表现，在实时计算等大数据领域也有着不错的吞吐。2016年11月11号，双十一大促见证了RocketMQ低延迟存储架构的成功试水，99.996%的延迟落在了10ms以内，极个别由于

消息持久化消息在传输过程中，可能会出现各种异常失败甚至宕机情况，为了保证消息传输的可靠性，需要进行持久化，也就是在数据写在磁盘上。消息队列持久化包括三部分：1.Message持久化，也就是发送时消息持久化。（Message包含body,body为我们需要发送的消息具体内容，一般以json字符串发送，消费端

一、题目解读CSPJ2019年的“公交换乘”题目（洛谷P5661）要求模拟地铁与公交交替出行的费用计算。题目核心在于地铁消费会产生优惠券，而公交可在45分钟内使用优惠券抵扣车费。需要处理n条出行记录，优化总费用。该问题考察对时间窗口与动态资源管理的理解，需