📡 כיצד להשתמש ב-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
    כתובת השרת WebSocket (למשל: "wss://streamer.cryptocompare.com/v2?api_key=YOUR_API_KEY").

.PARAMETER SubscribeMessage
    הודעת הרשמה בפורמט JSON לשליחה לשרת.

.PARAMETER ReconnectDelay
    זמן המתנה בשניות לפני חיבור מחדש. ברירת מחדל: 5 שניות.

.EXAMPLE
    $Url = "wss://streamer.cryptocompare.com/v2?api_key=YOUR_API_KEY"
    $SubscribeMessage = '{"action":"SubAdd","subs":["5~CCCAGG~BTC~USD"]}'
    Start-WebSocketClient -Url $Url -SubscribeMessage $SubscribeMessage -ReconnectDelay 5
#>
    [CmdletBinding()]
    param(
        [Parameter(Mandatory, HelpMessage = "ציין את כתובת השרת 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
    }
}

# =================================================================================
# --- דוגמת שימוש ---
# =================================================================================
# הסר את ההערה והחלף את YOUR_API_KEY במפתח ה-API שלך מ-Cryptocompare
# $Url = "wss://streamer.cryptocompare.com/v2?api_key=YOUR_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. רישום הודעות — מציג את ההודעות בקונסול בצבעים שונים.

---

המלצות

1. השתמש תמיד בחיבור מאובטח wss://.
2. ודא את מפתחות ה-API ואסימוני האימות שלך.
3. סנן רק את הנתונים הדרושים לך.
4. עבור זרמים עם נפח גבוה, שמור את ההודעות בקובץ או בבסיס נתונים.
5. בדוק מראש את תהליך החיבור מחדש ואת טיפול השגיאות.