Этот 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-06T23:40:30+08:00","dateModified":"2024-11-06T23:40:30+08:00","author":{"@type":"Person","name":"luping.net","url":"https://www.luping.net/articlelist/0_1.html"}}
  «Если рабочий хочет хорошо выполнять свою работу, он должен сначала заточить свои инструменты» — Конфуций, «Аналитики Конфуция. Лу Лингун»

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

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

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

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

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

  Опубликовано 6 ноября 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], чтобы удалить это

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

  • 

    Почему я получаю ошибку MySQL 1022: «Невозможно записать; дублирующийся ключ в таблице». Хотя у меня только один ключ?

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

    Купить обзоры на Amazon

    https://dmhelpshop.com/product/buy-amazon-reviews/ Купить отзывы на Amazon Когда дело доходит до коммерции и продажи продуктов на Amazon, значение отз...

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

    Упрощение передачи данных в Laravel с помощью DTO

    Вот пошаговый пример создания объектов передачи данных (DTO) с использованием Данные Laravel: 1. Установить пакет данных Laravel Для начала ус...

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

    Как я могу найти файлы относительно исходного файла в Go?

    Поиск файлов относительно исходного файла в GoВ отличие от интерпретируемых языков, программы Go компилируются, и исходный файл не требуется для выпол...

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

    Как я могу эффективно подсчитывать появление элементов в Python?

    Подсчет частоты элементов в Python с повышенной эффективностьюПодсчет появления элементов в списке — обычная задача программирования. В этом вопросе р...

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

    Изучение Async Deepgram API: преобразование речи в текст с использованием Python

    Сегодня мы рассмотрим API Deepgram для преобразования голоса в текст [транскрипция]. Независимо от того, создаете ли вы голосового помощника, расшифро...

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

    Как обрабатывать неверные символы UTF-8 в кодировке PHP JSON?

    Обработка неверных символов UTF-8 в кодировке PHP JSONПри использовании json_encode() для сериализации массива, содержащего русские символы, вы можете...

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

    ips для использования Var на сертификационном экзамене по Java

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

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

    Изучите управление состоянием, создав (глупый) генератор историй (Изучите Modulo.js — Часть f).

    ? Добро пожаловать! Не успели посмотреть Часть 1? Не волнуйтесь, вы можете начать с самого начала или просто погрузиться сюда! Представляем: в...

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

    ПОЛУЧИТЕ СЛЕДУЮЩУЮ СТРОКУ Проект, ЧТОБЫ научиться работать с файловыми дескрипторами и вводом-выводом системы.

    В области программирования на C эффективное управление вводом, выводом и памятью имеет основополагающее значение. Чтобы помочь вам понять эти важные к...

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

    Почему основная функция Go имеет бесконечный цикл?

    Среда выполнения Go: тайна бесконечного цикла в основной функцииВ основе среды выполнения Go лежит src/runtime/proc.go, здесь есть загадочная особенно...

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

    iostream против iostream.h: что следует использовать в современном C++?

    Различия между iostream и iostream.hВ C программисты могут встретить два термина, которые служат схожей цели: iostream и iostream.h . Это руководство ...

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

    VLONE Clothing: бренд уличной одежды, переосмысливающий городскую моду

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

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

    Как запросить один столбец в одной строке с помощью PDO?

    Запрос одного столбца в одной строке с помощью PDOПри работе с запросами SQL, нацеленными на определенный столбец в одной строке, часто необходимо пол...

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

    Как я создал PeerSplit: бесплатное одноранговое приложение для разделения расходов — от идеи до запуска всего за несколько недель.

    Я создал PeerSplit — бесплатную одноранговую альтернативу Splitwise — всего за две недели, от идеи до запуска! PeerSplit — это локальное приложение дл...

    программирование Опубликовано 7 ноября 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