douqie1884 2017-09-05 17:48
浏览 180

向两个客户端发送websocket消息

I started a personal project from gorilla chat example. Every time a client calls "register" I check if it has an opponent. Suppose clients are game players. What I am trying to do is to couple clients two per two.

Clients are:

type Client struct {
    hub      *Hub
    opponent *Client
    conn     *websocket.Conn
    send     chan []byte
}

So when I client call register, if exists one client with opponent nil, I tie two clients with

c.opponent = client
client.opponent = c

And then, I send together a message:

c.conn.WriteMessage(websocket.TextMessage, dat)
client.conn.WriteMessage(websocket.TextMessage, dat)

but no one receive the message. How can I send a message to just two clients?

package main

import (
    "github.com/gorilla/websocket"
    "log"
)

func newHub() *Hub {
    return &Hub{
        broadcast:  make(chan []byte),
        register:   make(chan *Client),
        unregister: make(chan *Client),
        clients:    make(map[*Client]bool),
    }
}

func (h *Hub) run() {
    for {
        select {

        // register new client
        case client := <-h.register:
            log.Println("register")
            h.clients[client] = true
            for c := range h.clients {
                if c != client {
                    if c.opponent == nil {
                        c.opponent = client
                        client.opponent = c
                        dat := []byte(`{"foo":"bar"}`)
                        c.conn.WriteMessage(websocket.TextMessage, dat)
                        client.conn.WriteMessage(websocket.TextMessage, dat)
                    }
                }
            }

        case client := <-h.unregister:
            log.Println("unregister")
            if _, ok := h.clients[client]; ok {
                delete(h.clients, client)
                close(client.send)
            }

        case message := <-h.broadcast:
            for client := range h.clients {
                select {
                case client.send <- message:
                default:
                    close(client.send)
                    delete(h.clients, client)
                }
            }

        }
    }
}
  • 写回答

0条回答

    报告相同问题?

    悬赏问题

    • ¥15 C++使用Gunplot
    • ¥15 这个电路是如何实现路灯控制器的,原理是什么,怎么求解灯亮起后熄灭的时间如图?
    • ¥15 matlab数字图像处理频率域滤波
    • ¥15 在abaqus做了二维正交切削模型,给刀具添加了超声振动条件后输出切削力为什么比普通切削增大这么多
    • ¥15 ELGamal和paillier计算效率谁快?
    • ¥15 file converter 转换格式失败 报错 Error marking filters as finished,如何解决?
    • ¥15 Arcgis相交分析无法绘制一个或多个图形
    • ¥15 关于#r语言#的问题:差异分析前数据准备,报错Error in data[, sampleName1] : subscript out of bounds请问怎么解决呀以下是全部代码:
    • ¥15 seatunnel-web使用SQL组件时候后台报错,无法找到表格
    • ¥15 fpga自动售货机数码管(相关搜索:数字时钟)