我相信這個(gè)問題與this幾乎相同。但是我在 Echo 框架中使用 websocket 而不是 Gorilla。所以我認(rèn)為方法會(huì)有所不同。Echo 確實(shí)提供了示例。但它只顯示了如何與單個(gè)客戶端連接。當(dāng)有多個(gè)客戶端時(shí)，其他客戶端不會(huì)收到來自服務(wù)器的消息。如何讓服務(wù)器向所有連接的客戶端廣播消息？來自引用鏈接的接受答案說我必須使用連接池向所有連接廣播消息。我怎樣才能在 Echo 框架中做到這一點(diǎn)？
1 回答
江戶川亂折騰
TA貢獻(xiàn)1851條經(jīng)驗(yàn) 獲得超5個(gè)贊
您確實(shí)需要遵循連接池的相同原則。
這是 Echo 示例，其中包含一個(gè)非?；镜某貙?shí)現(xiàn)：
package main
import (
"fmt"
"sync"
"github.com/labstack/echo"
mw "github.com/labstack/echo/middleware"
"golang.org/x/net/websocket"
)
var connectionPool = struct {
sync.RWMutex
connections map[*websocket.Conn]struct{}
}{
connections: make(map[*websocket.Conn]struct{}),
}
func main() {
e := echo.New()
e.Use(mw.Logger())
e.Use(mw.Recover())
e.Static("/", "public")
e.WebSocket("/ws", func(c *echo.Context) (err error) {
ws := c.Socket()
connectionPool.Lock()
connectionPool.connections[ws] = struct{}{}
defer func(connection *websocket.Conn){
connectionPool.Lock()
delete(connectionPool.connections, connection)
connectionPool.Unlock()
}(ws)
connectionPool.Unlock()
msg := ""
for {
if err = websocket.Message.Receive(ws, &msg); err != nil {
return err
}
err = sendMessageToAllPool(msg)
if err != nil {
return err
}
fmt.Println(msg)
}
return err
})
e.Run(":1323")
}
func sendMessageToAllPool(message string) error {
connectionPool.RLock()
defer connectionPool.RUnlock()
for connection := range connectionPool.connections {
if err := websocket.Message.Send(connection, message); err != nil {
return err
}
}
return nil
}
- 1 回答
- 0 關(guān)注
- 339 瀏覽
添加回答
舉報(bào)
0/150
提交
取消