撸了一个 golang 的 channel 的 pub-sub 的实现，欢迎大家使用与反馈
myself659410 · 2017-03-07 13:47:34 +08:00 · 1946 次点击这是一个创建于 2854 天前的主题，其中的信息可能已经有所发展或是发生改变。
 |
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
|
Select Language