發(fā)簡信
IP屬地：北京
-
史上最完整的SpringBoot整合Kafka教程，基于2.1.3版本
-
kafka之真香腳本（二）
寫在前面 上篇文章我們介紹了新增節(jié)點后分區(qū)怎么重新負載，但這種情況很少發(fā)生。因為kafka單機負載能力很是強悍，一般3個節(jié)點即可，5個節(jié)點的都很少見。然而很大概率出現的問題是...
-
kafka之真香腳本（一）
寫在前面 假如有一天，你單位業(yè)務不斷增長發(fā)財了。有天老板說我們需要增加kafka集群節(jié)點，這是怎莫辦？那就新增加一臺機器唄！很簡單我們只需要從已經部署好的Kafka節(jié)點中復制...
-
kafka是如何保障消息的可靠性的（二）
寫在前面 上篇說到了kafka由于重復發(fā)送消息導致消息重復的問題。那不重發(fā)就不會重復了，的確是這樣的，但這樣也會帶來一個問題。producer只發(fā)送一次，那消息丟失了怎莫辦？...
-
kafka是如何保障消息的可靠性的（一）
寫在前面 我在rabbitMQ系列分別從生產者，隊列和消費者三方面，討論了消息可靠性保證。而本系列要討論的kafka和rabbit系列有諸多相似之處。RabbitMQ傳送門[...
-
NIO系列（一）舍棄BIO
一. 前言 剛入坑java時，Socket編程是大家都繞不過去的一個環(huán)節(jié)。先回顧下經典socket編程，直接上代碼如下： 服務端 客戶端 BIO與NIO傳統socket編程中...
-
-
springCloud（一）-----網關之限流
前言 spring cloud gateway作為一種簡單有效的統一的API路由管理方式，為我們限流措施提供了一個有效的入口。 一. 限流算法 本文從常用的令牌桶限流算法說起...
-
如何自定義starter
寫在前面 以前在項目中遇到了解析CAD平面圖形的需求，網上蕩了許久沒有全面的工具類，羊手把手一步步封裝了解析cad中類型文件dxf的項目，并封裝成了starter,歡迎各位大...
-
springboot實現JSR-107規(guī)范（二）
一. 前言 前一篇中，羊介紹了spring cache的抽象。大多數的緩存，常放入專用的緩存中間件，如redis。本文就探討下結合外置redis實現JSR-107規(guī)范。 二....
-
springboot實現JSR-107規(guī)范（一）
一. JSR-107是啥 Java Specification Requests ，簡稱JSR。簡而言之，就是該規(guī)范告訴我們如何在java中使用緩存。和JDBC類似，jsr-...
-
rabbitMQ是如何保障消息可靠性的（三）
一. 消費端的ACK機制 消費端消費消息后需要發(fā)送Ack確認報文給Broker端，告知自己是否已消費完成，否則可能會一直重發(fā)消息直到消息過期。1、如果消費者收到消息后，在確認...
-
rabbitMQ是如何保障消息可靠性的（二）
前一篇文中，我們說了rabbitMQ的confirm機制和事務，接下來我們討論下消息的存儲。 一. 消息持久化 消息寫入磁盤是rabbitMQ保證可用性的基礎。1.1 Exc...
-
rabbitMQ是如何保障消息可靠性的（一）
一. 前言 消息隊列一般有三部分：生產者，隊列本身和消費者。消息出現問題，一般也就圍繞這三部分。 二. 消息丟失處理 2.1 發(fā)送端確認機制發(fā)送端確認(publisher c...
-
redis的持久化（一）
一.為啥要持久化 大家都知道Redis是內存數據庫，宕機后數據會消失。為了Redis重啟后快速恢復數據，所以需要持久化機制。總而言之，Redis持久化是為了快速的恢復數據而不...
-
zookeeper（六）聊聊watcher機制
Zookeeper 允許客戶端向服務端的某個 Znode 注冊一個 Watcher 監(jiān)聽，當服務端的一些指定事件觸發(fā)了這個 Watcher，服務端會向指定客戶端發(fā)送一個事件通...
