摘要： commitlog管理文件，通過(guò)MappedFileQueue管理一個(gè)MappedFile列表，用的是RandomAccessFile和堆外內(nèi)存MappedByteBuffer（零拷貝，更快）。 commitlog本身是順序?qū)懀琤roker收到的所有message，一個(gè)一個(gè)的拼到后面，因?yàn)槊總€(gè)Map 閱讀全文

摘要： return Flux.fromIterable(this.handlerMappings) .concatMap(mapping -> mapping.getHandler(exchange)) .next() .switchIfEmpty(createNotFoundError()) .flat 閱讀全文

摘要： 為什么客戶端這邊瞬間發(fā)起多個(gè)請(qǐng)求，響應(yīng)會(huì)絲毫不差的對(duì)應(yīng)到多個(gè)請(qǐng)求上，不會(huì)發(fā)生錯(cuò)位呢？主要還是需要客戶端來(lái)負(fù)責(zé)，指望服務(wù)端是不現(xiàn)實(shí)的。當(dāng)然如果客戶端和服務(wù)端都是自己的，那么就更靈活了。 rocketMQ是netty，用requestId，一個(gè)channel。 redisson也是netty，24個(gè)ch 閱讀全文

摘要： 客戶端(包含生產(chǎn)者和消費(fèi)者)定時(shí)任務(wù)里updateTopicRouteInfoFromNameServer方法，定時(shí)向nameService獲取topic(當(dāng)前客戶端所包含的所有消費(fèi)者者消費(fèi)的和生產(chǎn)者要發(fā)送的)的信息 對(duì)于一個(gè)topic來(lái)說(shuō)，可能會(huì)在多個(gè)broker上有隊(duì)列，所以broker信息會(huì)是 閱讀全文

摘要： orderly：1、SUSPEND_CURRENT_QUEUE_A_MOMENT：在本地重試，先判斷重新消費(fèi)次數(shù)有沒(méi)有達(dá)到最大值(consumer定義的時(shí)候傳入，不傳為Integer最大值)，如果沒(méi)達(dá)到，重試次數(shù)+1，放入消費(fèi)池，1秒（默認(rèn)）之后再消費(fèi)，直到達(dá)到最大消費(fèi)次數(shù)。發(fā)送到重試隊(duì)列（這個(gè)時(shí)候 閱讀全文

摘要： broker定時(shí)向namesrv 注冊(cè)，會(huì)告訴namesrv自己的brokername、brokeraddress、topic+隊(duì)列數(shù)量信息等，namesrv會(huì)把topic的信息放到topicQueueTable（只有版本號(hào)改變才修改，broker只有topic信息發(fā)生改變了才改變版本號(hào)）中，同一個(gè) 閱讀全文

摘要： indexFile（索引文件）和 ConsumeQueue（消費(fèi)隊(duì)列），都是為了更快的查找而建立的索引，后者是根據(jù)topic，前者是根據(jù)key。在ReputMessageService（一個(gè)ServiceThread的實(shí)現(xiàn)類）的doReput方法中， 會(huì)循環(huán)遍歷每一條新收到的消息， DefaultM 閱讀全文

摘要： 權(quán)限控制初步： 官網(wǎng)是這樣啟動(dòng)broker： nohup sh bin/mqbroker -n localhost:9876 & 在阿里云部署的時(shí)候，namesrv給producer的是局域網(wǎng)地址，所以要在啟動(dòng)的時(shí)候綁定外網(wǎng)ip，broker啟動(dòng)時(shí)候源碼中是從 -c 參數(shù)指定的文件(broker.c 閱讀全文

摘要： 在RequestMappingHandlerAdapter.afterPropertiesSet >getDefaultArgumentResolvers方法中，先往argumentResolvers屬性中添加默認(rèn)的一批去處理有注解的參數(shù)，再添加一批處理特定對(duì)象類型的參數(shù)，此時(shí)還剩下的就是其他對(duì)象類 閱讀全文

摘要： vm.init，先為computed變量（假設(shè)是age，并在computed方法中依賴于另一個(gè)變量vm.factor）初始化，age會(huì)關(guān)聯(lián)一個(gè)watcher（假設(shè)為cWatcher，lazy為true），vm.age的get方法被重寫(xiě)，cWatcher的dirty屬性被置為true。其getter屬 閱讀全文