撸了一个 golang 的 channel 的 pub-sub 的实现，欢迎大家使用与反馈

如果能分布式就更好了

@zwh8800 分布式可以直接上 kafka ，这个主要是方便 goroutine 之间通信

不错，还可以搞下 mangos
zeromq, nanomsg, https://github.com/go-mangos/mangos

和 nsq 有什么不同

@fyibmsd
主要是应用场景不一样， nsq 应用于进程级 pub-sub 通信，一般有三种类型进程：
1. nsqd 守护进程
2. consumer 进程
3. producer 进程

chanbroker 应用于同一个进程内 goroutine 的 pub-sub 通信，通过 channel 传输 interface （支持多种数据），有三种类型 goroutine ：
1. Producer
2. Consumer(Subscriber)
3. Broker

其实还有 nanomsg

@mengzhuo 写了多年 c ，竟然不知道 nanomsg ，涨姿势了

不错。不知道我有没有理解对， stop 方法如果调用的时候没有处理干净就会导致一些 channel 永远不能关闭。

@mengskysama 谢谢提醒，再看了一下代码虽然有条件触发关闭，在一定情况下，确实存在一些 channel 永远不能关闭

可以参考 nats https://github.com/nats-io/gnatsd