RocketMQ是阿里開源的分布式消息中間件，在阿里云上有它的商業(yè)版本ONS，類似的開源消息中間件還有Kafka, ActiveMQ等。跟其它中間件相比，rocketMQ的特...
IP屬地：廣東
-
RocketMQ源碼解析(一)-架構(gòu)原理 -
[從零開始的Unity網(wǎng)絡(luò)同步] 1.在Unity中搭建網(wǎng)絡(luò)模塊前言 最近在鼓搗網(wǎng)絡(luò)同步相關(guān)的東西,略有心得,故此打算寫些心得和感悟,也方便以后重溫復(fù)習(xí). 1.在Unity中配置網(wǎng)絡(luò) 雖然在Unity中有個自帶的掛在GameObject上...
-
已知一個消息只會唄同個consumerGroup內(nèi)的一個消費(fèi)者消費(fèi)， 假如consumer1和consumer2都在消費(fèi) queueId=1的隊(duì)列. consumer1 pull到了queueOffset=1的消息，但是消費(fèi)失敗了，完了之后，還沒來得及往%RETRY%TOPIC回寫消息又掛了. consumer2 pull到了queueOffset=2的消息，正常消費(fèi)了， 那consumerOffset.json記錄的queueOffset值會是多少？ 會不會導(dǎo)致queueOffset=1的消息 丟失？ 這個搞不懂rocketmq怎么處理的
RocketMQ源碼解析(十一)-Broker#消息消費(fèi)
終于講到Broker消息處理流程的最后一步了。講Consumer的時候說到消費(fèi)消息分為Pull和Push兩種模式，底層其實(shí)都是依靠Pull實(shí)現(xiàn)的。在Broker這端處理Pus...
-
消費(fèi)失敗的那里沒太懂， 如果消費(fèi)失敗，要重新消費(fèi)由客戶端重新發(fā)消息到%RETRY%topic 來進(jìn)行重新消息？ 如果客戶端發(fā)送到%RETRY%topic之前掛了，這消息豈不是丟了？ 感覺還是得結(jié)合 broker 服務(wù)器端怎么處理pull請求再細(xì)講下才比較明白
RocketMQ源碼解析(四)-Consumer
消息消費(fèi)方式 Consumer分為兩種，PullConsumer和PushConsumer。從名字就可以看出一種是拉取的方式，一種是主動Push的方式。具體實(shí)現(xiàn)如下： Pul...
-
跟菜鳥一起學(xué)習(xí)vertx1、什么是vertx vert.x是Eclipse軟件基金會頂級java開源項(xiàng)目之一，它基于netty的、運(yùn)行在jvm之上的、支持多種編程語言的異步、非阻塞、響應(yīng)式編程的工具...
-
idea2020.3bug(java.lang.UnsupportedClassVersionError)昨天新下載了2020.3的idea來使用，隨手先運(yùn)行了main方法，打印個hello world。 然后~~直接給我報了個下面的錯。 2020.3：java.lang.Uns...
-
我擦， 還真可以
idea2020.3bug(java.lang.UnsupportedClassVersionError)
昨天新下載了2020.3的idea來使用，隨手先運(yùn)行了main方法，打印個hello world。 然后~~直接給我報了個下面的錯。 2020.3：java.lang.Uns...
-
spring循環(huán)依賴分析個人學(xué)習(xí)總結(jié) 整個緩存分為三級 singletonObjects，一級緩存，存儲的是所有創(chuàng)建好了的單例 Bean earlySingletonObjects，完成實(shí)例化，但是...
-
Kubeadm方式安裝
kubeadm是官方社區(qū)推出的一個用于快速部署kubernetes集群的工具。 這個工具能通過兩條指令完成一個kubernetes集群的部署： 1. 安裝要求 在開始之前，部...
-
Protocol buffers協(xié)議分析
簡介 protocol buffers是Google的一個靈活的、高效的、自動化的用于對結(jié)構(gòu)化數(shù)據(jù)進(jìn)行序列化的協(xié)議，與json、xml相比，protocol buffers序...
-
Android Studio4.0構(gòu)建項(xiàng)目報錯錯誤如下 cd到sdk路徑，我這邊是C:\Users\86137\AppData\Local\Android\Sdk\tools\bin執(zhí)行命令
-
Java 程序員<br><br>個人網(wǎng)站：<a href="https://links.jianshu.com/go?to=https%3A%2F%2Fthinkinjava.cn" target="_blank">https://thinkinjava.cn</a><br>Stay hungry. Stay foolish.
-
[java] ganymed-ssh2 遠(yuǎn)程執(zhí)行shell腳本需求場景: 用戶微信三方平臺授權(quán)通過后,需要上傳微信業(yè)務(wù)文件至nginx前端服務(wù)器中 后臺實(shí)現(xiàn)方案: 1.客戶登錄微信公眾平臺,下載業(yè)務(wù)文件 如:MP_verify_xxx....
-
-
goland debug運(yùn)行報錯問題goland run運(yùn)行正常，但是debug運(yùn)行報如下錯誤 主要是因?yàn)槿鄙賒lv， go程序debug需要dlv下面是安裝dlv的步驟 百度出來結(jié)果都是，執(zhí)行以下命令,但是我...
