疯狂的羊

写在前面 上篇文章我们介绍了新增节点后分区怎么重新负载，但这种情况很少发生。因为kafka单机负载能力很是强悍，一般3个节点即可，5个节点的都很少见。然而很大概率出现的问题是...

疯狂的羊

写在前面 假如有一天，你单位业务不断增长发财了。有天老板说我们需要增加kafka集群节点，这是怎莫办？那就新增加一台机器呗！很简单我们只需要从已经部署好的Kafka节点中复制...

疯狂的羊

写在前面 上篇说到了kafka由于重复发送消息导致消息重复的问题。那不重发就不会重复了，的确是这样的，但这样也会带来一个问题。producer只发送一次，那消息丢失了怎莫办？...

疯狂的羊

写在前面 我在rabbitMQ系列分别从生产者，队列和消费者三方面，讨论了消息可靠性保证。而本系列要讨论的kafka和rabbit系列有诸多相似之处。RabbitMQ传送门[...

疯狂的羊

一. 前言 刚入坑java时，Socket编程是大家都绕不过去的一个环节。先回顾下经典socket编程，直接上代码如下： 服务端 客户端 BIO与NIO传统socket编程中...

疯狂的羊

一. 前言 我在spring篇，介绍过ApplicationListener，接收到spring的一些事件，就会触发相应的通知操作。这是典型的发布订阅模式，也就是观察者模式。...

疯狂的羊

前言 spring cloud gateway作为一种简单有效的统一的API路由管理方式，为我们限流措施提供了一个有效的入口。 一. 限流算法 本文从常用的令牌桶限流算法说起...

疯狂的羊

写在前面 以前在项目中遇到了解析CAD平面图形的需求，网上荡了许久没有全面的工具类，羊手把手一步步封装了解析cad中类型文件dxf的项目，并封装成了starter,欢迎各位大...

疯狂的羊

一. 前言 前一篇中，羊介绍了spring cache的抽象。大多数的缓存，常放入专用的缓存中间件，如redis。本文就探讨下结合外置redis实现JSR-107规范。 二....

疯狂的羊

一. JSR-107是啥 Java Specification Requests ，简称JSR。简而言之，就是该规范告诉我们如何在java中使用缓存。和JDBC类似，jsr-...

疯狂的羊

一. 消费端的ACK机制 消费端消费消息后需要发送Ack确认报文给Broker端，告知自己是否已消费完成，否则可能会一直重发消息直到消息过期。1、如果消费者收到消息后，在确认...

疯狂的羊

前一篇文中，我们说了rabbitMQ的confirm机制和事务，接下来我们讨论下消息的存储。 一. 消息持久化 消息写入磁盘是rabbitMQ保证可用性的基础。1.1 Exc...

疯狂的羊

一. 前言 消息队列一般有三部分：生产者，队列本身和消费者。消息出现问题，一般也就围绕这三部分。 二. 消息丢失处理 2.1 发送端确认机制发送端确认(publisher c...

疯狂的羊

一.为啥要持久化 大家都知道Redis是内存数据库，宕机后数据会消失。为了Redis重启后快速恢复数据，所以需要持久化机制。总而言之，Redis持久化是为了快速的恢复数据而不...

疯狂的羊

Zookeeper 允许客户端向服务端的某个 Znode 注册一个 Watcher 监听，当服务端的一些指定事件触发了这个 Watcher，服务端会向指定客户端发送一个事件通...