Apache Flink 漫谈系列(05) - Fault Tolerance
实际问题
在流计算场景中,数据会源源不断的流入Apache Flink系统,每条数据进入Apache Flink系统都会触发计算。那么在计算过程中如果网络、机器等原因导致Task运行失败了,Apache Flink会如何处理呢?在 《Apache Flink 漫谈系列 - State》一篇中我们介绍了 Apache Flink 会利用State记录计算的状态,在Failover时候Task会根据State进行恢复。
消息中间件系列一、消息中间件的基本了解
一、消息中间件的定义:
没有标准定义,一般认为,采用消息传送机制/消息队列 的中间件技术,进行数据交流,用在分布式系统的集成
二、为什么要用消息中间件?
解决分布式系统之间消息的传递。电商场景: 用户下单减库存,调用物流系统,系统扩充后服务化和业务拆分。
亿级流量电商系统多级缓存架构
亿级流量电商系统多级缓存架构
Redis基础
数据类型String hash list set zset
java操作Redis
redis的RDB和AOF两种持久化机制
Redis Transcation
Redis高级
redis企业级数据备份
Lua脚本与redis抢红包实战案例.