📡 Как использовать WebSocket для получения данных в реальном времени с PowerShell

Современные приложения требуют данные в реальном времени, например котировки акций и криптовалют, спортивные результаты, онлайн-чаты, IoT-устройства и уведомления. Обычные HTTP-запросы неэффективны: клиент вынужден постоянно опрашивать сервер, тратить лишний трафик и ждать обновлений.

WebSocket решает эту проблему: это протокол для постоянного двустороннего соединения между клиентом и сервером. Сервер может самостоятельно отправлять новые данные клиенту, а клиент — отправлять команды и подписки на каналы.

Простая аналогия: вы звоните другу (рукопожатие, handshake), друг проверяет, кто звонит, и принимает вызов (аутентификация), после чего линия остаётся открытой, и вы можете обмениваться сообщениями (поток данных).

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

---

Подключение к WebSocket на примере Cryptocompare

Cryptocompare предоставляет потоковые данные по криптовалютам через WebSocket. Например, можно подписаться на поток BTC/USD.

Ниже приведён универсальный WebSocket-клиент на PowerShell

# =================================================================================
# WebSocket-Client.ps1 — Универсальный WebSocket-клиент для получения данных
# Windows PowerShell >= 5.1
# Автор: hypo69
# Дата создания: 13/09/2025
# =================================================================================

# =================================================================================
# ЛИЦЕНЗИЯ (MIT)
# =================================================================================
<#
Лицензия MIT: https://opensource.org/licenses/MIT
#>

function Start-WebSocketClient {
<#
.SYNOPSIS
    Универсальный WebSocket-клиент с поддержкой переподключений и логированием.

.DESCRIPTION
    Подключается к WebSocket-серверу, отправляет подписку на поток данных
    и выводит входящие сообщения в консоль. Автоматическое переподключение при разрыве.

.PARAMETER Url
    URL WebSocket-сервера (например: "wss://streamer.cryptocompare.com/v2?api_key=ВАШ_API_KEY").

.PARAMETER SubscribeMessage
    Сообщение подписки в формате JSON.

.PARAMETER ReconnectDelay
    Задержка в секундах перед переподключением. По умолчанию 5 сек.

.EXAMPLE
    $Url = "wss://streamer.cryptocompare.com/v2?api_key=ВАШ_API_KEY"
    $SubscribeMessage = '{"action":"SubAdd","subs":["5~CCCAGG~BTC~USD"]}'
    Start-WebSocketClient -Url $Url -SubscribeMessage $SubscribeMessage -ReconnectDelay 5
#>
    [CmdletBinding()]
    param(
        [Parameter(Mandatory, HelpMessage = "Укажите URL WebSocket-сервера.")]
        [string]$Url,

        [Parameter(Mandatory, HelpMessage = "Сообщение подписки в формате JSON.")]
        [string]$SubscribeMessage,

        [Parameter(Mandatory = $false, HelpMessage = "Задержка переподключения (сек).")]
        [int]$ReconnectDelay = 5
    )

    while ($true) {
        try {
            $ws = [System.Net.WebSockets.ClientWebSocket]::new()
            $uri = [Uri] $Url
            $ws.ConnectAsync($uri, [Threading.CancellationToken]::None).Wait()
            Write-Host "✅ Соединение установлено с $Url" -ForegroundColor Green

            if ($SubscribeMessage) {
                $bytes = [System.Text.Encoding]::UTF8.GetBytes($SubscribeMessage)
                $buffer = [System.ArraySegment[byte]]::new($bytes)
                $ws.SendAsync($buffer, [System.Net.WebSockets.WebSocketMessageType]::Text, $true, [Threading.CancellationToken]::None).Wait()
                Write-Host "➡ Подписка отправлена: $SubscribeMessage" -ForegroundColor Cyan
            }

            $bufferSize = 1024
            $buffer = New-Object byte[] $bufferSize
            $segment = [System.ArraySegment[byte]]::new($buffer)

            while ($ws.State -eq [System.Net.WebSockets.WebSocketState]::Open) {
                $receiveTask = $ws.ReceiveAsync($segment, [Threading.CancellationToken]::None)
                $receiveTask.Wait()
                $message = [System.Text.Encoding]::UTF8.GetString($buffer, 0, $receiveTask.Result.Count)
                Write-Host "📩 Получено: $message"
            }
        }
        catch {
            Write-Host "⚠ Ошибка: $_" -ForegroundColor Red
        }

        Write-Host "⏳ Переподключение через $ReconnectDelay секунд..." -ForegroundColor Yellow
        Start-Sleep -Seconds $ReconnectDelay
    }
}

# =================================================================================
# --- ПРИМЕР ИСПОЛЬЗОВАНИЯ ---
# =================================================================================
# Раскомментируйте и замените API_KEY своим ключом Cryptocompare
# $Url = "wss://streamer.cryptocompare.com/v2?api_key=ВАШ_API_KEY"
# $SubscribeMessage = '{"action":"SubAdd","subs":["5~CCCAGG~BTC~USD"]}'
# Start-WebSocketClient -Url $Url -SubscribeMessage $SubscribeMessage -ReconnectDelay 5

---

Данный подход имеет несколько важных преимуществ. Он универсальный и подходит для любых WebSocket-потоков, не ограничиваясь одним сервисом. Реализовано автоматическое переподключение: при разрыве соединения клиент самостоятельно восстанавливает подключение. Скрипт легко адаптировать для разных каналов или типов данных, просто изменив сообщение подписки. Кроме того, его можно расширять — добавлять логирование в файл, фильтровать входящие сообщения, обрабатывать JSON или интегрировать с базой данных.

---

Пояснение к коду

1. [System.Net.WebSockets.ClientWebSocket] — .NET класс для подключения к WebSocket.
2. ConnectAsync — устанавливает соединение с сервером.
3. SendAsync — отправка подписочного сообщения на сервер.
4. ReceiveAsync — получение входящих сообщений.
5. Автопереподключение — реализовано через бесконечный while ($true) и Start-Sleep.
6. Логирование — вывод сообщений в консоль с цветовой индикацией.

---

Рекомендации по работе с WebSocket

1. Всегда используйте защищённый протокол wss://.
2. Проверяйте API-ключи и токены авторизации.
3. Фильтруйте только необходимые данные.
4. Для больших потоков данных сохраняйте сообщения в файл или базу данных.
5. Тестируйте переподключение и обработку ошибок заранее.

---