FIN 1 消费消息 MSG 2 FIN 2 SUB 消息架构 protocol messagePump() Tcp InFight Channel Topic Msg IOLoop() Command Msg FIN Timeout PUB RDY > 0 InFight processInFlightQueue() PriorityQueue Map Msg Length DiskQueue 磁盘多个数据⽂件的作⽤ • 过期磁盘⽂件清理的最⼩单位 • 错误异常忽略的最⼩单位 • ⽂件过⼤会造成inode读取效率差 DiskQueue ioLoop select DataRead ReadChan WriteChan DataWrite readOne() writeOne(DataWrite) check Sync() moveForward()