Golang 服务器向每个用户发送的事件

问题内容

我使用 Go 已经有一段时间了，但之前从未使用过 SSE。我遇到了一个问题，有人可以提供一个仅发送给特定用户（连接）的服务器发送事件的工作示例吗？

我正在使用 gorilla - 会话进行身份验证，并且我想使用 UserID 来分隔连接。

或者我应该通过 Ajax 使用 5 秒轮询？

非常感谢

这是我发现并尝试过的：

正确答案

创建一个“代理”来将消息分发给连接的用户：

type broker struct { // users is a map where the key is the user id // and the value is a slice of channels to connections // for that user id users map[string][]chan []byte // actions is a channel of functions to call // in the broker's goroutine. the broker executes // everything in that single goroutine to avoid // data races. actions chan func() } // run executes in a goroutine. it simply gets and // calls functions. func (b *broker) run() { for a := range b.actions { a() } } func newbroker() *broker { b := &broker{ users: make(map[string][]chan []byte), actions: make(chan func()), } go b.run() return b } // adduserchan adds a channel for user with given id. func (b *broker) adduserchan(id string, ch chan []byte) { b.actions 登录后复制