pchan

pchan

职责

• 接上游server消息
• 将消息转发给下游proxy
• 维持一个mmap，消息传递发生阻塞时，负责将消息落盘，避免消息丢失

源码实现

源码实现请见pchan.go

结构

type PChan struct {
    exit       chan struct{} //退出信号
    needStore  bool          //是否需要落盘
    storeMutex *sync.Mutex   //锁
    waiter     *sync.WaitGroup
    queue      *fqueue.FQueue //利用fqueue实现的mmap，大小4G
    limit      int            //阈值
    input      chan []byte    //input管道，有缓冲型，大小 limit*1.5
    output     chan []byte    //output管道，有缓冲型l,大小 limit*1.5
    Input  chan<- []byte //外部使用的input,主要是给server使用，还有proxy失败回传
    Output <-chan []byte //外部使用的output，主要是给proxy使用，proxy从中读取消息
}

注意事项

• pchan中不对消息的内容做任何处理，只负责向下游传递
• pchan的主要功能就是防止因为下游消息生产阻塞，造成上游业务阻塞