Hiï¼RocketMQç®åçæ¬ä¸çå¤å¯æ¬æ¹æ¡ä»ä¸»å¤å¤å¶æ¨¡å¼ä¸åä¸ºåæ¥ååå弿¥å忍¡å¼ï¼åæ¶å¨è½çæ¹å¼ä¸ä¹åä¸ºåæ¥å弿¥æ¹å¼ï¼éè¿è¿ä¸¤è çé ç½®ï¼å¯ä»¥è®©æ´ä¸ªç³»ç»å¨å¯ç¨æ§ä»¥åæ¶æ¯çå¯é æ§ä¸ææä¾§éï¼å ·ä½å¯ä»¥åèï¼ org.apache.rocketmq.store.config.MessageStoreConfig#flushDiskType org.apache.rocketmq.store.config.MessageStoreConfig#brokerRole
两个é 置项ã åæ¶æä»¬ä¹æ£å¨åºäºRaftãPaxosåå¸å¼ä¸è´æ§å议设计æ°ä¸ä»£çå¤å¯æ¬æ¹æ¡ï¼åç»å¯ä»¥å ³æ³¨ä¸ãå¦æå¯¹è¿æ¹ä¾¿æå ´è¶£ï¼æ¬¢è¿é®ä»¶äº¤æµã On 2018/03/13 03:56:08, æç æ´² <[email protected]> wrote: > hiï¼å¤§å®¶å¥½ãææ¯ç¾å¢åºç¡æ¶æé¨çæç > æ´²ï¼æè¿å¨å¯¹rocketmqåä¸äºæ§è½æ¹é¢çæµè¯ï¼å¨é 读代ç > çæ¶ååç°ä¸¤ä¸ªé®é¢ï¼å¸æå大家讨论ä¸ä¸ > 1ãAppendMessageResult > doAppend彿°ï¼ä½ç¨æ¯æå ·ä½çæ¶æ¯æ > ¼å¼åå¹¶å·å°Commitlogçbytebufferéé¢ï¼ä½æ¯æè§å¤çé»è¾æäºæ§è½æèï¼æç代ç > æ¯å æmessageçæ¶æ¯å > 容以åççä¸äºä¿¡æ¯ç»ä¸åå°å为msgStoreItemMemoryçbytebufferéé¢ï¼ç¶ååæmsgStoreItemMemoryå·å°åºå±commitLogçbytebufferéé¢ï¼æè§å¦ææçåæ¡æ¶æ¯çbodyé常大çè¯ï¼å夿·è´æ¥æ·è´å»å¸¦æ¥çæ§è½å¼éè¿æ¯è®å¤§ç > 2ãåéæ¶æ¯åå¤çè½çæ¹å¼å主ä»åæ¥ç代ç > é¨åï¼æè§è¿é¨åå®å ¨å¯ä»¥å¼æ¥åçï¼ä½æ¯æç代ç > 使ç¨äºwaitånotifyçæ¹å¼è¿è¡äºï¼rocketmq乿¯ç¨çreactorç½ç»æ¨¡åï¼å¨çå®ç½ç»ç¯å¢ä¸ï¼ä¸»ä»åæ¥ä¸åæ¶æ¯æ¯è¾å®¹æåºç°çé®é¢ï¼ä¸æ¦ç¨äºwait+notify > æå³çä¸é¢çå¤ç线ç¨ä¼è¢«å > µä½ï¼æ´ä½çååå°±ä¸ä¸å»äºï¼å¨æ«å¯¹rocketmqåæ§è½æµè¯ï¼ä¸»è¦èæ¶ç¹æä¸ä¸ªå°±æ¯å > éè§£éï¼æè§åè¿ä¸ªæå¾å¤§å ³ç³» >
