构建一个即时消息应用（五）：实时消息

本文是该系列的第五篇。

• 第一篇: 模式
• 第二篇: OAuth
• 第三篇: 对话
• 第四篇: 消息

对于实时消息，我们将使用 服务器发送事件 Server-Sent Events 。这是一个打开的连接，我们可以在其中传输数据流。我们会有个端点，用户会在其中订阅发送给他的所有消息。

消息户端

在 HTTP 部分之前，让我们先编写一个 映射 map ，让所有客户端都监听消息。 像这样全局初始化：

type MessageClient struct {
    Messages chan Message
    UserID   string
}

var messageClients sync.Map

已创建的新消息

还记得在 上一篇文章 中，当我们创建这条消息时，我们留下了一个 “TODO” 注释。在那里，我们将使用这个函数来调度一个 goroutine。

go messageCreated(message)

把这行代码插入到我们留注释的位置。

func messageCreated(message Message) error {

    if err := db.QueryRow(`

 SELECT user\_id FROM participants

 WHERE user\_id != $1 and conversation\_id = $2

 `, message.UserID, message.ConversationID).

    Scan(&message.ReceiverID); err != nil {

        return err

    }

    go broadcastMessage(message)
    return nil

}
func broadcastMessage(message Message) {

    messageClients.Range(func(key, \_ interface{}) bool {

        client := key.(\*MessageClient)

        if client.UserID == message.ReceiverID {

            client.Messages