在做分布式編譯的時候，每一個worker都有一個consumer，適用的kafka+zookeep的配置都是默認的配置，在消息比較少的情況下，每一個consumer都能均勻得到互不相同的消息，但是當消 ...

介紹 延遲隊列，顧名思義它是一種帶有延遲功能的消息隊列。 那么，是在什么場景下我才需要這樣的隊列呢？ 很多時候我們會有延時處理一個任務的需求，比如說： 2個小時后給用戶發送短信。15分鍾后關閉網 ...

RabbitMQ和kafka從幾個角度簡單的對比 業界對於消息的傳遞有多種方案和產品，本文就比較有代表性的兩個MQ(rabbitMQ,kafka)進行闡述和做簡單的對比， 在應用場景方面， Ra ...

Java中的DelayQueue位於java.util.concurrent包下，本質是由PriorityQueue和BlockingQueue實現的阻塞優先級隊列。 放入隊列的元素需要實現java ...

需求背景 用戶下訂單成功之后隔20分鍾給用戶發送上門服務通知短信 訂單完成一個小時之后通知用戶對上門服務進行評價 業務執行失敗之后隔10分鍾重試一次 類似的場景比較多 簡單的處理方式 ...

前一篇中我們介紹了使用RabbitMQ Java Client訪問RabbitMQ的方法。但是使用這種方式訪問RabbitMQ,開發者在程序中需要自己管理Connection,Channel對象，Co ...

NGiNX_HTTP_Push_Module 是一個 Nginx 的擴展模塊，它實現了 HTTP Push 和Comet server的功能。HTTP Push 被經常用在網頁上主動推的技術，例如一些 ...

　　消息持久性對於可靠消息傳遞來說應該是一種比較好的方法，有了消息持久化，即使發送者和接受者不是同時在線或者消息中心在發送者發送消息后宕機了，在消息中心重新啟動后仍然可以將消息發送出去，如果把這種持久 ...

（一）RabbitMQ基本概念 　　RabbitMQ是流行的開源消息隊列系統，用erlang語言開發。我曾經對這門語言挺有興趣，學過一段時間，后來沒堅持。RabbitMQ是 AMQP（高級消息隊列協 ...

前言 首先提出我們的監控訴求，出現如下情況時，希望能夠及時接收到系統告警通知： RocketMQ 服務宕機 RocketMQ 消費者下線 RocketMQ 消 ...