我相信這個問題與this幾乎相同。但是我在 Echo 框架中使用 websocket 而不是 Gorilla。所以我認為方法會有所不同。Echo 確實提供了示例。但它只顯示了如何與單個客戶端連接。當有多個客戶端時，其他客戶端不會收到來自服務器的消息。如何讓服務器向所有連接的客戶端廣播消息？來自引用鏈接的接受答案說我必須使用連接池向所有連接廣播消息。我怎樣才能在 Echo 框架中做到這一點？
1 回答
江戶川亂折騰
TA貢獻1851條經驗 獲得超5個贊
您確實需要遵循連接池的相同原則。
這是 Echo 示例，其中包含一個非?；镜某貙崿F：
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 關注
- 342 瀏覽
添加回答
舉報
0/150
提交
取消