1
zwh8800 2017-03-07 13:53:59 +08:00
如果能分布式就更好了
|
2
myself659410 OP @zwh8800 分布式可以直接上 kafka ,这个主要是方便 goroutine 之间通信
|
3
gwind 2017-03-07 16:38:53 +08:00
不错,还可以搞下 mangos
zeromq, nanomsg, https://github.com/go-mangos/mangos |
4
fyibmsd 2017-03-07 17:20:24 +08:00
和 nsq 有什么不同
|
5
myself659410 OP @fyibmsd
主要是应用场景不一样, nsq 应用于进程级 pub-sub 通信,一般有三种类型进程: 1. nsqd 守护进程 2. consumer 进程 3. producer 进程 chanbroker 应用于同一个进程内 goroutine 的 pub-sub 通信,通过 channel 传输 interface (支持多种数据),有三种类型 goroutine : 1. Producer 2. Consumer(Subscriber) 3. Broker |
6
mengzhuo 2017-03-08 07:20:20 +08:00 via iPhone
其实还有 nanomsg
|
7
myself659410 OP @mengzhuo 写了多年 c ,竟然不知道 nanomsg ,涨姿势了
|
8
mengskysama 2017-03-08 10:32:14 +08:00 via iPhone
不错。不知道我有没有理解对, stop 方法如果调用的时候没有处理干净就会导致一些 channel 永远不能关闭。
|
9
myself659410 OP @mengskysama 谢谢提醒,再看了一下代码虽然有条件触发关闭,在一定情况下,确实存在一些 channel 永远不能关闭
|
10
tcpdumpp 2017-03-08 13:42:42 +08:00
可以参考 nats https://github.com/nats-io/gnatsd
|