Consumer连接管理，也同样使用ChannelId来标识一个连接
Merge https://github.com/alibaba/RocketMQ