Этот HTML-клиент:

• Подключается к серверу WebSocket по адресу ws://localhost:8080/ws.
• Отправляет сообщения, введенные в поле ввода.
• Отображает входящие сообщения в блоке

  var clients = make(map[*websocket.Conn]bool) // Track active clientsfunc handleConnections(w http.ResponseWriter, r *http.Request) {    ws, err := upgrader.Upgrade(w, r, nil)    if err != nil {        fmt.Println(err)        return    }    defer ws.Close()    clients[ws] = true    for {        _, msg, err := ws.ReadMessage()        if err != nil {            fmt.Println(\\\"read error:\\\", err)            delete(clients, ws)            break        }        // Broadcast message to all clients        for client := range clients {            if err := client.WriteMessage(websocket.TextMessage, msg); err != nil {                fmt.Println(\\\"broadcast error:\\\", err)                client.Close()                delete(clients, client)            }        }    }}

  Теперь при получении сообщения оно рассылается всем подключенным клиентам. Это распространенный подход для приложений чата или обновлений в реальном времени.

  Грамотная обработка отключений

  Чтобы обрабатывать отключения клиентов, используйте defer ws.Close() и удалите клиента из карты клиентов, если операция чтения не удалась.
  

  defer func() {    delete(clients, ws)    ws.Close()}()

  Пинг/понг для здоровья соединения

  WebSockets поддерживают кадры пинга/понга, чтобы поддерживать соединение и проверять, подключен ли клиент.
  

  ws.SetPongHandler(func(appData string) error {    fmt.Println(\\\"pong received\\\")    return nil})

  ---

  Лучшие практики для WebSockets

  1. Ограничить количество подключений: защитите свой сервер от перегрузки, ограничив количество активных подключений.
  2. Закрыть неактивные соединения: используйте таймауты или фреймы пинг-понга, чтобы закрыть неактивные соединения.
  3. Используйте TLS (wss): в целях безопасности всегда используйте wss (WebSocket Secure) в рабочей среде для шифрования соединения.
  4. Обработка ошибок корректно: всегда проверяйте наличие ошибок при чтении или записи в WebSockets и соответствующим образом протоколируйте их.

  ---

  Заключительные мысли

  WebSockets позволяют создавать интерактивные приложения реального времени, выходящие за рамки традиционных циклов запросов и ответов. Настроив сервер WebSocket в Go, вы теперь можете легко обрабатывать данные в реальном времени. Независимо от того, создаете ли вы приложение для чата, интерактивную панель управления или инструмент для совместной работы, WebSockets дает вам возможность создавать бесшовные интерактивные возможности.

  Попробуйте: настройте сервер WebSocket и начните экспериментировать! Как только вы освоитесь, вы поймете, почему WebSockets необходимы для приложений реального времени.

  ---

  Какой вариант использования WebSockets вам больше всего нравится? Дайте мне знать в комментариях или поделитесь своими советами по созданию приложений реального времени!

  ","image":"http://www.luping.net/uploads/20241013/1728810388670b8d9479c1a.jpg","datePublished":"2024-11-23T16:15:18+08:00","dateModified":"2024-11-23T16:15:18+08:00","author":{"@type":"Person","name":"luping.net","url":"https://www.luping.net/articlelist/0_1.html"}}
  «Если рабочий хочет хорошо выполнять свою работу, он должен сначала заточить свои инструменты» — Конфуций, «Аналитики Конфуция. Лу Лингун»

  Онлайн-инструменты

  Учебник по программному обеспечению

  Навигация по сайту

  программирование
  титульная страница > программирование > Использование WebSockets в Go для общения в реальном времени

  Использование WebSockets в Go для общения в реальном времени

  Опубликовано 23 ноября 2024 г.

  Просматривать:796

  

  Создание приложений, требующих обновлений в режиме реального времени, таких как приложения чата, живые уведомления или инструменты для совместной работы, требует более быстрого и интерактивного метода связи, чем традиционный HTTP. Вот тут-то и приходят на помощь WebSockets! Сегодня мы рассмотрим, как использовать WebSockets в Go, чтобы вы могли добавлять в свои приложения функциональность реального времени.

  В этом посте мы рассмотрим:

  • Что такое WebSockets и как они работают.
  • Настройка сервера WebSocket в Go.
  • Создание простого клиента WebSocket.
  • Обработка событий и поддержание связей.

  Давайте в реальном времени! ?

  ---

  Что такое веб-сокеты? ?

  WebSockets обеспечивает полнодуплексный канал связи через одно долгоживущее соединение. В отличие от традиционных HTTP-запросов, которые следуют циклу запрос-ответ, WebSockets позволяют серверу и клиенту отправлять и получать сообщения независимо, что делает его идеальным для приложений реального времени.

  Ключевые особенности:

  • Полнодуплексная связь: И клиент, и сервер могут отправлять сообщения независимо, не дожидаясь ответа.
  • Низкая задержка: WebSockets поддерживает постоянное соединение открытым, сокращая задержку между сообщениями.
  • Управление событиями: WebSockets обрабатывают данные как события, что позволяет мгновенно реагировать на входящие сообщения.

  ---

  Настройка сервера WebSocket в Go

  Для создания сервера WebSocket мы будем использовать пакет Gorilla WebSocket, который упрощает работу с WebSocket в Go.

  Шаг 1. Установите Gorilla WebSocket

  Установите пакет с помощью go get:
  

  go get -u github.com/gorilla/websocket
  

  Шаг 2. Создайте сервер WebSocket.

  Теперь давайте настроим простой сервер WebSocket, который прослушивает входящие соединения и возвращает любые полученные сообщения:
  

  package main
  
  import (
      "fmt"
      "net/http"
      "github.com/gorilla/websocket"
  )
  
  var upgrader = websocket.Upgrader{
      CheckOrigin: func(r *http.Request) bool { return true }, // Allow all connections
  }
  
  func handleConnections(w http.ResponseWriter, r *http.Request) {
      // Upgrade initial GET request to a WebSocket
      ws, err := upgrader.Upgrade(w, r, nil)
      if err != nil {
          fmt.Println(err)
          return
      }
      defer ws.Close()
  
      for {
          // Read message from browser
          _, msg, err := ws.ReadMessage()
          if err != nil {
              fmt.Println("read error:", err)
              break
          }
          fmt.Printf("Received: %s\n", msg)
  
          // Write message back to browser
          if err := ws.WriteMessage(websocket.TextMessage, msg); err != nil {
              fmt.Println("write error:", err)
              break
          }
      }
  }
  
  func main() {
      http.HandleFunc("/ws", handleConnections)
  
      fmt.Println("WebSocket server started on :8080")
      err := http.ListenAndServe(":8080", nil)
      if err != nil {
          fmt.Println("ListenAndServe:", err)
      }
  }
  

  В этом примере:

  • Обновление: мы обновляем HTTP-соединение до соединения WebSocket с помощью Upgrader.
  • Цикл чтения/записи: мы входим в цикл, в котором читаем сообщения от клиента и возвращаем их обратно.

  Примечание: CheckOrigin в программе обновления разрешает все соединения. В производственной среде обязательно подтвердите источник, чтобы избежать межсайтового перехвата WebSocket.

  ---

  Настройка простого клиента WebSocket

  Чтобы протестировать сервер WebSocket, вы можете использовать HTML-клиент с JavaScript, который подключается к серверу WebSocket и отправляет/получает сообщения.

  Пример HTML-клиента:

  
  
      
  WebSocket Client
      Send
      
  
  
      

  пусть сокет = новый WebSocket("ws://localhost:8080/ws"); сокет.onopen = функция (событие) { document.getElementById("messages").textContent = "Подключено к серверу WebSocket\n"; }; сокет.onmessage = функция (событие) { document.getElementById("messages").textContent = "Получено: " event.data "\n"; }; Socket.onclose = функция (событие) { document.getElementById("messages").textContent = "Отключение от сервера WebSocket\n"; }; функция sendMessage() { let message = document.getElementById("messageInput").value; сокет.отправить (сообщение); document.getElementById("messageInput").value = ""; } скрипт> тело>

  Заявление о выпуске Эта статья воспроизведена по адресу: https://dev.to/neelp03/using-websockets-in-go-for-real-time-communication-4b3l?1. Если есть какие-либо нарушения, свяжитесь с [email protected], чтобы удалить это

  Последний учебник Более>

  • 

    Использование WebSockets в Go для общения в реальном времени

    Создание приложений, требующих обновлений в режиме реального времени, таких как приложения чата, живые уведомления или инструменты для совместной рабо...

    программирование Опубликовано 23 ноября 2024 г.
  • 

    Множество

    Методы — это fns, которые можно вызывать на объектах Массивы — это объекты, поэтому в JS у них тоже есть методы. срез (начало): извлечь часть ...

    программирование Опубликовано 23 ноября 2024 г.
  • 

    Что случилось со смещением столбцов в бета-версии Bootstrap 4?

    Bootstrap 4 Beta: удаление и восстановление смещения столбцовBootstrap 4 в своей бета-версии 1 внес существенные изменения в способ столбцы были смеще...

    программирование Опубликовано 23 ноября 2024 г.
  • 

    Как я могу найти пользователей, у которых сегодня дни рождения, используя MySQL?

    Как определить пользователей с сегодняшним днем ​​рождения с помощью MySQLОпределение того, является ли сегодня день рождения пользователя с помощью M...

    программирование Опубликовано 23 ноября 2024 г.
  • 

    Помимо операторов if: где еще можно использовать тип с явным преобразованием bool без приведения?

    Контекстное преобразование в bool разрешено без приведения Ваш класс определяет явное преобразование в bool, что позволяет использовать его экземпляр ...

    программирование Опубликовано 23 ноября 2024 г.
  • 

    Почему Go выдает ошибку «ошибка объявлена ​​и не используется»?

    Использование переменной в GoВ Go объявление переменной подразумевает ее предполагаемое использование, а неиспользование ее приводит к возникновению о...

    программирование Опубликовано 23 ноября 2024 г.
  • 

    Как объединить два ассоциативных массива в PHP, сохранив при этом уникальные идентификаторы и обработав повторяющиеся имена?

    Объединение ассоциативных массивов в PHPВ PHP объединение двух ассоциативных массивов в один — распространенная задача. Рассмотрим следующий запрос:Оп...

    программирование Опубликовано 23 ноября 2024 г.
  • 

    Как SWIG может устранить разрыв между библиотеками C++ и Node.js?

    Как интегрировать библиотеки C в Node.js с помощью SWIGИспользование библиотек C в Node.js может улучшить функциональность вашего Node.js. js-приложен...

    программирование Опубликовано 23 ноября 2024 г.
  • 

    Как мы можем имитировать запросы и ответы при модульном тестировании Python?

    Как имитировать запросы и ответыВведениеМодульное тестирование в Python часто включает в себя макетирование внешние зависимости для моделирования реал...

    программирование Опубликовано 23 ноября 2024 г.
  • 

    Как исправить «Неправильно сконфигурировано: ошибка загрузки модуля MySQLdb» в Django на macOS?

    Неправильно настроен MySQL: проблема с относительными путямиПри запуске сервера запуска Python Manage.py в Django вы можете столкнуться со следующей о...

    программирование Опубликовано 23 ноября 2024 г.
  • 

    Как проверить делимость в Python без ошибок деления?

    Проверка делимости в Python: другой взглядСтолкнувшись с задачей определить, делится ли число на другое, многие разработчики инстинктивно прибегнуть к...

    программирование Опубликовано 23 ноября 2024 г.
  • 

    Как реализовать универсальную обработку ошибок в Go без дженериков?

    Реализация общей обработки ошибок в GoОтсутствие универсальных возможностей в Go создает проблемы при попытке обобщить функциональные возможности. Рас...

    программирование Опубликовано 23 ноября 2024 г.
  • 

    Как создать бесконечную анимацию вращения CSS для значка?

    Бесконечная анимация вращения CSS: как непрерывно вращать значокЧтобы добиться бесконечного вращения значка с помощью CSS, комбинации CSS-анимаций и к...

    программирование Опубликовано 23 ноября 2024 г.
  • 

    Как дженерики повышают возможность повторного использования и эффективность кода Java?

    Демистификация дженериков в Java: раскрытие их истинной природы и приложенийХотя концепция дженериков поначалу может показаться неуловимой, понимание ...

    программирование Опубликовано 23 ноября 2024 г.
  • 

    Почему `console.log(content)` выводит `undefined` при чтении файла с помощью `fs.readFile` в Node.js?

    Доступ к данным с помощью fs.readFile: понимание асинхронных обратных вызововВ области Node.js чтение файлов с помощью fs.readFile может представить п...

    программирование Опубликовано 23 ноября 2024 г.

  КлассификацияБолее>

  изучать японский учить корейский учить китайский учить иностранный язык игра Общая проблема Технологическая периферия ИИ Учебник по программному обеспечению программирование статья

  Изучайте китайский

  • 1 Как сказать «гулять» по-китайски? 走路 Китайское произношение, 走路 Изучение китайского языка
  • 2 Как сказать «Сесть на самолет» по-китайски? 坐飞机 Китайское произношение, 坐飞机 Изучение китайского языка
  • 3 Как сказать «сесть на поезд» по-китайски? 坐火车 Китайское произношение, 坐火车 Изучение китайского языка
  • 4 Как сказать «поехать на автобусе» по-китайски? 坐车 Китайское произношение, 坐车 Изучение китайского языка
  • 5 Как сказать «Ездить» по-китайски? 开车 Китайское произношение, 开车 Изучение китайского языка
  • 6 Как будет плавание по-китайски? 游泳 Китайское произношение, 游泳 Изучение китайского языка
  • 7 Как сказать «кататься на велосипеде» по-китайски? 骑自行车 Китайское произношение, 骑自行车 Изучение китайского языка
  • 8 Как поздороваться по-китайски? 你好Китайское произношение, 你好Изучение китайского языка
  • 9 Как сказать спасибо по-китайски? 谢谢Китайское произношение, 谢谢Изучение китайского языка
  • 10 How to say goodbye in Chinese? 再见Chinese pronunciation, 再见Chinese learning

  инструментБолее>

  

  Декодирование изображения в формате base64

  

  Китайский Пиньинь

  

  Кодировка Юникод

  

  JS-обфускация, шифрование, сжатие

  

  Инструмент шестнадцатеричного шифрования URL-адресов

  

  Инструмент преобразования кодировки UTF-8

  

  Онлайн-инструменты кодирования и декодирования Ascii

  

  Инструмент шифрования MD5

  

  Онлайн-инструмент для шифрования и дешифрования хеша/хеш-текста

  

  Онлайн-шифрование SHA

  Отказ от ответственности: Все предоставленные ресурсы частично взяты из Интернета. В случае нарушения ваших авторских прав или других прав и интересов, пожалуйста, объясните подробные причины и предоставьте доказательства авторских прав или прав и интересов, а затем отправьте их по электронной почте: [email protected]. Мы сделаем это за вас как можно скорее.

  Copyright© 2022 湘ICP备2022001581号-3