Как не отправлять сообщение отправителю websocket в языке GO?

Question

[Riedel87]

Всем привет!
Вот тут я взял пример для создания веб-сокета (ссылка ниже на гитхаб) и отправки сообщения всем устройствам, которые подключены к серверу.
Сервер все хорошо отправляет, но он отправляет сообщение даже тому, кто послал это сообщение, а вот этого не нужно.
Не могу понять, как выцепить отправителя и не слать ему сообщение его же.
Можете помочь? Гугл весь обшарил уже :(
Там есть функция sendall, она отвечает за отправку, видимо в ней как-то нужно подправить...
https://github.com/jakecoffman/go-angular-tutorial...

Answer 1

[Александр Павлюк]

Полагаю, вам нужно это

func sendAll(msg []byte, myconn *websocket.Conn) {
    for conn := range connections {
        if myconn != conn {
            if err := conn.WriteMessage(websocket.TextMessage, msg); err != nil {
                delete(connections, conn)
                conn.Close()
            }
        }
    }
}

P.S. А еще вы изменяете map из нескольких потоков одновременно, это очень плохо. Однажды ваше приложение рухнет из-за ошибки памяти. Если хотите изменять глобальные объекты из нескольких горутин (а net/http каждое соединение обрабатывает в отдельной горутине), то вам нужно обеспечить чтобы с map-ом в каждый момент времени работала только одна горутина. Это делается через мьютексы, например.

Comments

[Riedel87]

Александр Павлюк : спасибо большое, попробую, отпишусь как что получится.
Мьютексы? Ухты, я про такое даже не слышал) буду гуглить. Просто я новичок в Go, встала задача сокеты сделать на сервере, что смог собрать по документации gorilla и т.п., то и сделал) поэтому сильно не ругайте) Спасибо еще раз большое, а про постскриптум изучу внимательнее этот вопрос!

[Никита]

Не мьютексы, а каналы. Не учите новенького антипаттернам =) А точнее если принялся за go, то уж извольте придерживаться идеологии языка.
https://blog.golang.org/share-memory-by-communicating

[Александр Павлюк]

Никита: на задаче двустороннего доступа к глобальному объекту использование мьютексов оправданно, имхо. Ибо на каналах это будет и медленнее и неприятно глазу.

[Никита]

Александр Павлюк: Так вся суть "Share memory by communicating" означает отсутствие глобальных объектов. Я ведь не говорю делать из каналов мьютексы.

[Александр Павлюк]

Никита: можно и так, но придется вообще все переписать. Кстати, вы могли бы переделать код автора и показать, как надо. Будет интересно.

[Riedel87]

Александр Павлюк: Спасибо большое за ответы, буду все читать и изучать, что вы написали!) А вот если мою функцию переписали бы и показали бы - думаю, быстрее понял бы, о чем речь идет)

[Riedel87]

Никита: Спасибо большое за ответы, буду все читать и изучать, что вы написали! Спасибо, что не бросили на произвол судьбы :)

[Никита]

Александр Павлюк: Странно что в примере автора так написано, ведь в примерах самого пакета вебсокетов есть достойный пример https://github.com/gorilla/websocket/tree/master/e... . Переделывать лень, чеснслово )

[Riedel87]

Никита: Подскажите, пожалуйста, сейчас видима та проблема, про которую вы пишите - если раньше небольшая строка передавалась, все ок было, сейчас данных больше передается, бинарник и после передачи бинарника, коннект обрывается. Это из-за чего?

[Александр Павлюк]

Riedel87: я ж писал вроде о проблеме )) У вас там в логах что? Не паника случаем?

[Riedel87]

Александр Павлюк: не, паники нет) разобрались роде - нужно было в base64 передавать серверу)
вот ваша функция, которую вы сверху переписали не работает, пишет что недостаточно аргументов(

[Александр Павлюк]

Riedel87: очевидно же, в нее нужно посылать еще и текущее соединение, посмотрите по ее параметрам. Если у вас возникают такие вопросы по вызову функций, то вам следует изучить сначала самые основы go, а потом уже браться за проекты.

[Riedel87]

Александр Павлюк: нет, это сделал, т.е. функция вызывается у меня так sendAll(msg, myconn), это я сделал, пропустил. Но сейчас пишется, что myconn не идентифицирована.
Согласен, но захотели GO, поэтому начал делать, учусь по ходу((

[Александр Павлюк]

у вас в том месте, где вызывается sendAll, переменная, в которой хранится соединение называется conn, а не myconn. Поэтому вызывать надо sendAll(msg, conn)

[Riedel87]

Александр Павлюк: да, запустился сервер, все работает, текстовые сообщения как нужно приходят, отправителю нет, еще нужно правда с фотками и бинарниками разобраться, думаю разберемся) Блин, от меня огромное спасибо вам! С меня вкусные печеньки)))
Можно последний вопрос, может куда пнете меня) - мне нужно сделать подсчет трафика, т.е. в лог сумму всех пакетов в конце соединения вывести, сколько байт прошло) как сделать можно и что почитать? У меня пока это последняя проблема(

[Riedel87]

Александр Павлюк: и сумму времени, сколько коннект шел тоже писать в сумму...куда копать?

[Александр Павлюк]

Riedel87: вам нужно копать в сторону внутренностей модуля net/http. При создании http сервера можно подменить http.Transport, например, на свою реализацию, которая будет считать нужные вещи, и прокидывать управление в настоящий транспорт.

[Riedel87]

Александр Павлюк: ох, ок, буду копать и читать! Спасибо, Александр ;)