在多个客户端之间并发中继数据

Question

我目前正在开发一个应用程序，使用 WebSockets 将手机通过服务器发送的数据中继到浏览器。我正在用 go 编写服务器，手机和浏览器之间是一对一的关系，如下图所示。但是，我希望多个会话同时工作。我读过 go 提供了并发模型，这些模型遵循使用 goroutines 和通道的“通过通信共享内存”的原则。我更喜欢使用上述原则而不是使用sync.Mutex原语锁定。尽管如此，我还是无法将这些信息映射到我的问题上，想请教您是否可以提出解决方案。

Answer 1

我遇到了与您的问题类似的问题，我需要多个连接，每个连接都通过多个服务器相互发送数据。

我使用了WAMP协议

WAMP is an open standard WebSocket subprotocol that provides two application messaging patterns in one unified protocol:

Remote Procedure Calls + Publish & Subscribe.

你也可以看看我的一个项目，它是用 go 编写的，并使用了手头的协议：github.com/neutrinoapp/neutrino

Answer 2

在 Go 中使用互斥锁并没有错。这是使用互斥锁的解决方案。

声明端点映射。我假设字符串键足以识别端点：

type endpoint struct {

    c *websocket.Conn

    sync.Mutex  // protects write to c

}

var (

   endpoints = map[string]*endpoint

   endpointsMu sync.Mutex   // protects endpoints

)

func addEndpoint(key string, c *websocket.Connection) {

   endpointsMu.Lock()

   endpoints[key] = &endpoint{c:c}

   endpointsMu.Unlock()

}

func removeEndpoint(key string) {

    endpointsMu.Lock()

    delete(endpoints, key)

    endpointsMu.Unlock()

}

func sendToEndpoint(key string, message []byte) error {

    endpointsMu.Lock()

    e := endpoints[key]

    endpointsMu.Unlock()

    if e === nil {

        return errors.New("no endpoint")

    }

    e.Lock()

    defer e.Unlock()

    return e.c.WriteMessage(websocket.TextMessage, message)

}

addEndpoint当客户端连接时，将连接添加到地图。removeEndpoint关闭连接时从地图中删除连接。使用 将消息发送到命名端点sendToEndpoint。

该大猩猩聊天例如可以适用于解决这个问题。将集线器映射更改为connections map[string]*connection，更新通道以发送具有连接和密钥的类型，并将广播循环更改为发送到单个连接。