golang websocket

Сервер WebSocket in go

Запуск сервера

1. Клонировать это хранилище

2. Установите репозиторий и запустите эту команду, чтобы установить зависимости

 make setup

3. Запустите сервер WebSocket

 make run

4. Сервер WebSocket будет работать на localhost:8080

Использование этого сервера с клиентом

1. После запуска сервера откройте клиент WebSocket. Если у вас их нет, попробуйте расширение Websocket King для Chrome.

2. Подключитесь к ws://localhost:8080/socket , вас будет встречен сервером.

 Server: Welcome! Your ID is f0ab664a-5af3-4f8d-8afe-eb93085267e4

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

 {
  "action": "subscribe",
  "topic": "world"
}

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

 {
  "action": "publish",
  "topic": "world",
  "message": "Hello world!"
}

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

 {
  "action": "unsubscribe",
  "topic": "world"
}

Http vs websocket

Вы можете спросить: «Зачем мне использовать WebSocket вместо API REST»?

REST API использует HTTP, который может отправлять ответ только один раз на запрос.

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

Это может быть полезно в некотором сценарии, например, в чате или пабе.

Вот диаграмма для визуализации разницы между HTTP и WebSocket.

Блок -схема

Эта блок -схема описывает, как работает этот сервер.

Структура проекта

 cmd
└── main
    └── main.go
internal
└── websocket
    └── handler.go
    └── model.go
    └── server.go

Основные файлы

main.go : основной файл, который будет выполнен.

Обработчик

handler.go : обрабатывает подключение/закрыть соединение и передайте сообщение на сервер.

Модель

model.go : хранит модели, используемые сервером.

Сервер

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

Дальнейшая работа

Этот репозиторий далеко не идеален. Это просто доказательство концепции.

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

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

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

Кредит

Этот репозиторий вдохновлен Golang-Pubsub от @tabvn