Освоение WebSockets С Go - Подробное руководство

• Обычные HTTP API неэффективны для реального времени.  

• WebSockets позволяют двунаправленную связь между клиентом и сервером.  

• В этом уроке рассмотрим, как использовать WebSockets в Go для создания приложений реального времени.  

• Распространенные ошибки в API WebSockets, такие как аутентификация.  

• Решение проблем на уровне HTTP.  

• Создание приложения чата с использованием WebSockets и Go.  

• WebSockets используют HTTP для инициализации соединения.  

• Клиент отправляет HTTP-запрос с заголовком "обновление соединения".  

• Сервер отвечает переключением протоколов на WebSockets.  

• WebSockets широко используются в чат-приложениях и играх.  

• Примеры приложений, использующих WebSockets для передачи данных в реальном времени.  

• Создание HTTP-сервера с файловым сервером в Go.  

• Использование vanilla JavaScript для клиентской стороны.  

• Создание модуля и основного пакета.  

• Настройка HTTP-маршрутов и файлового сервера.  

• Создание HTML-страницы для отображения информации и подключения к WebSockets.  

• Создание формы для выбора комнаты чата.  

• Обработка событий WebSockets при изменении комнаты чата.  

• Отображение сообщений чата в текстовой области.  

• Приложение чата с формами для выбора комнаты и отправки сообщений.  

• Завершение настройки и демонстрация работы приложения.  

• Добавление тега script для хранения JavaScript.  

• Пример функции для изменения комнаты чата.  

• Проверка наличия комнаты чата и предотвращение перехода на другую страницу.  

• Создание функции для отправки сообщений.  

• Проверка поддержки WebSockets в браузере.  

• Добавление CSS для улучшения внешнего вида.  

• Запуск HTTP-сервера на порту 8080.  

• Проверка работы сервера и интерфейса.  

• Подключение к WebSockets через встроенный JavaScript.  

• Исправление ошибки с неправильным идентификатором формы.  

• Обновление сервера для поддержки WebSockets.  

• Добавление менеджера для управления WebSockets.  

• Использование библиотеки gorilla.websocket.  

• Создание структуры manager и фабричной функции.  

• Настройка обработчика HTTP и обновление запросов до WebSockets.  

• Менеджер теперь может принимать подключения через WebSocket.  

• API должен корректно обрабатывать эти подключения.  

• Создается новый менеджер и добавляются конечные точки для WebSocket.  

• Запрос на WebSocket API отправляется и обрабатывается.  

• В инструменте разработчика можно увидеть сообщения, отправляемые через WebSocket.  

• Создается новый файл "клиент" для обработки логики каждого клиента.  

• Каждый клиент имеет подключение к WebSocket и указатель на менеджера.  

• Структура клиента включает подключение к WebSocket и менеджера.  

• Менеджер управляет клиентами и транслирует информацию.  

• Обновление менеджера для защиты от одновременных подключений.  

• Добавление вспомогательных функций для добавления и удаления клиентов.  

• Чтение и запись сообщений в WebSocket API.  

• Использование небуферизованного канала для предотвращения спама сообщений.  

• Открытие диспетчера для обработки сообщений от клиентов.  

• Создание двух рутин для чтения и записи сообщений.  

• Продолжаем работу с Go client.  

• Добавляем клиента в список и запускаем процесс чтения сообщений.  

• Создаем функцию readmessage для чтения сообщений.  

• Типы сообщений: ping, pong, data, binary.  

• Проверяем наличие ошибок и разрываем цикл при закрытии соединения.  

• Используем вспомогательные функции для проверки ошибок.  

• Проверяем, не является ли ошибка закрытием соединения.  

• Разрываем цикл при аномальном закрытии соединения.  

• Удаляем клиента из менеджера при закрытии соединения.  

• Очищаем соединение и удаляем клиента из менеджера.  

• Распечатываем тип сообщения и полезную нагрузку.  

• Проверяем, что закрытие соединения происходит нормально.  

• Тестируем чтение сообщений.  

• Возвращаемся к интерфейсу и отправляем сообщения через websocket.  

• Отправляем сообщения на JavaScript.  

• Пользователь вводит данные в форму и отправляет их через соединение WebSocket.  

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

• Типы сообщений: текстовые, двоичные, закрытые.  

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

• Gorilla рекомендует использовать небуферизованный канал для решения этой проблемы.  

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

• Менеджер удаляет клиентов, которые не используются или имеют проблемы.  

• Если канал закрывается, сервер отправляет сообщение клиенту о закрытии соединения.  

• Если отправка сообщения не удалась, соединение закрывается.  

• Создается цикл для отправки сообщений всем клиентам.  

• Интерфейс обновляется для получения полезных данных от клиентов.  

• Проверка работы системы через отправку тестовых сообщений.  

• Создание системы событий для упрощения масштабирования.  

• Введение системы RPC для контроля типов сообщений и улучшения функциональности.  

• Каждое сообщение заключено в событие.  

• Использование поля типа события для маршрутизации сообщений.  

• Добавление нового класса events для отправки и получения сообщений через websocket.  

• Функция route events принимает событие в качестве входных данных.  

• Проверка типа события и выполнение соответствующих действий.  

• Регистрация нового события и обработка неподдерживаемых сообщений.  

• Создание функции send events для отправки событий через websocket.  

• Преобразование полезной нагрузки в JSON и отправка по соединению.  

• Анализ сообщений в формате JSON и создание объекта event.  

• Перенаправление событий на серверную часть для дальнейшей обработки.  

• Создание структуры событий с типом JSON и полезной нагрузкой.  

• Настройка обработчиков событий для различных типов сообщений.  

• Создание обработчика событий для отправки сообщений.  

• Проверка полезной нагрузки и отправка сообщения от клиента.  

• Хранение обработчиков событий в менеджере для дальнейшей обработки.  

• Использование карты для хранения обработчиков событий по типу.  

• Создание функции отправки сообщения и назначение ее обработчику событий.  

• Проверка наличия обработчика события в менеджере и запуск функции.  

• Завершение настройки маршрутизации событий через менеджер.  

• Проверка типа события в обработчиках.  

• Обработка сообщений с помощью функции отправки.  

• Создание структуры событий для обработки сообщений.  

• Изменение функции чтения и записи сообщений.  

• Обработка событий вместо необработанных байтов.  

• Перенос полезной нагрузки в структуру событий.  

• Тестирование отправки и получения событий.  

• Исправление ошибок и перенаправление событий.  

• Проверка работы серверной и клиентской частей.  

• Введение функции ping для проверки соединения.  

• Поддержка активных соединений с помощью keep alive.  

• Настройка интервала отправки сигналов ping.  

• Определение переменных для ожидания и интервала сигналов.  

• Обновление серверного кода для отправки запросов клиентам.  

• Создание тикера для проверки интервала сигналов.  

• Установка тикера для проверки интервала сигналов.  

• Отправка сообщений ping клиентам.  

• Проверка и обработка ошибок при отправке сообщений.  

• WebSockets автоматически запускают сообщения ping и pong.  

• Браузеры поддерживают это, но сторонние реализации могут отличаться.  

• Сервер отправляет ping, клиент отвечает pong.  

• При получении pong нужно обновить таймеры для сброса.  

• Установить время ожидания для чтения сообщений.  

• Использовать функцию set pong handler для применения обработчика.  

• В клиенте создать обработчик pong для сброса таймера.  

• Использовать текущее время для сброса таймера.  

• Проверить работу ping-pong после перезапуска сервера и клиента.  

• Важность сброса таймера для поддержания соединения.  

• Ожидать злонамеренного использования и внедрить ограничение на чтение сообщений.  

• Установить ограничение на размер сообщений в байтах.  

• Ограничить размер сообщений для предотвращения отправки огромных кадров.  

• Исправить проблему с отправкой огромных кадров.  

• Разрешать подключения только из определенных источников для предотвращения подделки межсайтовых запросов.  

• Создать функцию check origin для проверки источника подключения.  

• Установить функцию в обновлении websocket.  

• Проверить работу функции, разрешая подключения только с определенных источников.  

• Важность ограничения источников подключения для безопасности.  

• Проверка работы функции check origin.  

• WebSockets не имеют встроенной аутентификации.  

• Решение: внедрить аутентификацию на основе HTTP.  

• Два распространенных способа аутентификации: базовая аутентификация и одноразовые пароли.  

• Первый способ: обычная конечная точка HTTP для аутентификации.  

• Второй способ: пользователи отправляют событие аутентификации.  

• Предпочтение отдается первому способу из-за предотвращения спама.  

• Добавление заголовка "Connected to WebSockets" в HTML.  

• Создание формы для входа с полем для имени пользователя и пароля.  

• Обработка формы и отправка запроса на вход.  

• Функция входа в систему обрабатывает данные формы и отправляет запрос на вход.  

• Проверка ответа и возврат данных в формате JSON.  

• Обработка ошибок и отправка неавторизованных запросов.  

• Использование одноразового пароля для подключения к WebSockets.  

• Обновление функции connect WebSockets для использования одноразового пароля.  

• Проверка подключения и обновление HTML при успешном подключении.  

• Проверка работы интерфейса и формы для входа.  

• Исправление ошибок и тестирование на успешное подключение.  

• Подготовка серверной части для обработки логинов.  

• Создание нового файла для хранения решения OTP.  

• Создание структуры OTP с ключами "ключ" и "время создания".  

• Создание карты хранения с ключом "OTP" и значением "OTP".  

• Фабрика для карты хранения с контекстом и периодом хранения.  

• Создание карты хранения и функции для создания новых OTP.  

• Функция verify OTP для проверки существования ключа.  

• Функция сохранения OTP с контекстом и периодом хранения.  

• Проверка и удаление просроченных OTP.  

• Запуск фонового процесса для удаления просроченных OTP.  

• Добавление карты хранения в менеджер.  

• Создание конечной точки входа с обработчиком HTTP.  

• Проверка и расшифровка данных запроса.  

• Жестко закодированный логин для проверки.  

• Проверка OTP перед подключением к веб-сокетам.  

• Создание контекста и настройка конечных точек входа.  

• Использование жестко закодированных паролей для проверки.  

• Замена жестко закодированных паролей на собственную логику аутентификации.  

• Тестирование системы с исправлением ошибок.  

• Обсуждение преимуществ и недостатков различных методов аутентификации.  

• WebSockets позволяют определить используемый протокол.  

• В производственной среде рекомендуется использовать WSS для безопасного трафика через HTTPS.  

• Изменение протокола на WSS в URL-адресе обеспечивает безопасность.  

• Создание самозаверяющего сертификата с помощью OpenSSL.  

• Использование OpenSSL для создания серверного ключа и сертификата.  

• Хранение сертификатов в безопасном месте и использование их для шифрования трафика.  

• Изменение HTTP на HTTPS в коде с использованием протокола tls.  

• Добавление файлов сертификата и ключа в код.  

• Проверка соединения с использованием самозаверяющего сертификата.  

• Проверка ошибок подтверждения соединения.  

• Создание обработчиков событий для отправки сообщений и управления сердцебиением.  

• Реализация широковещательных сообщений для всех клиентов.  

• Обновление обработчиков событий для отправки сообщений.  

• Создание нового типа события для отправки сообщений.  

• Итерация всех клиентов для отправки широковещательных сообщений.  

• Реализация интерфейса для отправки сообщений пользователем.  

• Добавление двух новых классов, соответствующих интерфейсу и бэкенду.  

• Создание конструкторов для классов, принимающих сообщения.  

• Обновление функции отправки сообщений для отправки сообщений в нужном формате.  

• Создание нового события отправки сообщения с жестко закодированным именем пользователя.  

• Отправка события в websocket для всех клиентов.  

• Создание события сообщения и назначение полезной нагрузки.  

• Создание функции для добавления сообщения в чат.  

• Форматирование даты и сообщения для отображения в текстовой области.  

• Проверка работы отправки сообщений между клиентами.  

• Обновление кода для корректной обработки сообщений.  

• Демонстрация работы чата с возможностью отправки сообщений между всеми клиентами.  

• Создание нового события "изменить комнату чата".  

• Обновление функции для изменения текущей комнаты чата.  

• Отправка сообщения о смене комнаты чата на websocket.  

• Обновление функции "изменить комнату чата".  

• Проверка работы функции в реальном времени.  

• Демонстрация изменения комнаты чата для всех клиентов.  

• Добавлена комната для переодевания и куратор для этого события.  

• Создано событие в интерфейсе и передано в строке name.  

• Зашли в менеджер и создали функцию обработки чата.  

• Приняли событие "комната для смены" и отменили рассылку полезной нагрузки.  

• Изменили чат-комнату текущего клиента.  

• Добавили проверку, чтобы отправлять сообщения только в текущий чат клиента.  

• Перезапустили серверную часть и проверили работу интерфейсов.  

• Исправили ошибки в HTTP-запросах и перенаправлениях.  

• Перезапустили приложение и убедились, что все работает корректно.  

• Рассмотрены аспекты работы с websockets в Go.  

• Изучены методы подключения, чтения и записи сообщений.  

• Структурирование серверного API с использованием шаблона проектирования на основе событий.  

• Поддержка связи с использованием websockets и других технологий.  

• Шифрование трафика и использование HTTPS и WSS.  

• Призыв к обратной связи и вопросам.  

• Благодарность за просмотр и приглашение подписаться на канал.