标签: 分布式
所有带有标签 "分布式".
Kafka(五)消费者回调 +定时重试 + 理解Rebalance
至此为止,利用Kafka实现一个消息系统就基本完成了,所有关键的代码都在不同的博文中并进行了详细说明,说过想要体会完整的设计、实现思路,请移步源码仓库获取完整代码。下一篇关于Kafak的博文打算分享一下如何利用Kafka Connect将Oracle数据库的数据同步到Postgre SQL中。
Kafka(四)消费者消费JSON消息+使用统一反序列化器+提升吞吐量
介绍Kafka消费者处理JSON消息的实现,包括统一反序列化、消息去重、失败重试与偏移量提交。结合压测讨论分区数和消费参数的调整,并使用模板方法复用不同优先级邮件的消费流程。
Kafka(二)将邮件发送从业务系统中解耦之消息系统设计
以邮件发送为例,介绍通过Kafka解耦业务系统与邮件系统的设计思路。讨论两者的职责边界、统一消息格式、发送与回调流程,以及新旧系统切换时的回退方案,为后续生产者和消费者实现提供背景。
数据库中间件ShardingSphere-ShardingJdbc使用(二)读写分离
在数据分片示例的基础上,为MySQL主从架构配置ShardingJDBC读写分离。文章介绍主从数据源与从库负载均衡策略,通过连续查询观察请求在从库间的切换,并记录首次查询较慢这一尚未解决的问题。