Welche Lösung haben Sie für die Arbeit mit WebSocket…

In Projekten, die eine bidirektionale Interaktion in Echtzeit erforderten, habe ich erfolgreich URLSessionWebSocketTask verwendet.

Dies ist eine integrierte Lösung des Frameworks Network, die ab iOS 13 verfügbar ist.

Vorteile von URLSessionWebSocketTask:

Native: Integriert in URLSession, was die Verwaltung von Verbindungen und die Verarbeitung von Netzwerkevents vereinfacht.
Leistung: Für die Arbeit mit dem Netzwerk auf Systemebene optimiert.
Zuverlässigkeit: Eingebauter Mechanismus für Pings und Pongs, automatische Wiederverbindungsversuche (obwohl zusätzliche Logik für komplexe Szenarien erforderlich sein kann).
Sicherheit: Unterstützt TLS von Haus aus.

Hauptarbeitsphasen:

Erstellen einer Instanz von URLSessionWebSocketTask.

// Erstellen einer URLSession-Instanz mit Standardkonfiguration
let session = URLSession(configuration: .default)
// Initialisieren der WebSocket-Aufgabe
let webSocketTask = session.webSocketTask(with: URL(string: "wss://example.com/socket")!)

Verbindung starten.

// Aufgabe wieder aufnehmen, um die Verbindung herzustellen
webSocketTask.resume()

Nachrichten senden (Text oder Binärdaten).

// Senden einer Textnachricht
webSocketTask.send(.string("Hello, world!")) { error in
    if let error = error {
        print("Fehler beim Senden: \(error)")
    }
}

// Binärdaten senden
let dataToSend = Data([1, 2, 3])
webSocketTask.send(.data(dataToSend)) { error in
    if let error = error {
        print("Fehler beim Senden: \(error)")
    }
}

Nachrichten empfangen. Dies ist ein asynchroner Prozess.

// Rekursive Funktion zum Empfangen von Nachrichten
func receiveMessage() {
    webSocketTask.receive { result in
        switch result {
        case .failure(let error):
            print("Fehler beim Empfang: \(error)")
            // Fehlerbehandlung, möglicherweise erneuter Verbindungsversuch
        case .success(let message):
            switch message {
            case .string(let text):
                print("Empfangene Textnachricht: \(text)")
            case .data(let data):
                print("Empfangene Binärdaten: \(data)")
            @unknown default:
                fatalError("Unbekannter Nachrichtentyp")
            }
            // Weiter Nachrichten hören
            self.receiveMessage()
        }
    }
}

// Hörfunktion starten
receiveMessage()

Ereignisse im Lebenszyklus der Verbindung verwalten (Öffnen, Schließen, Fehler) mit dem Delegate URLSessionWebSocketDelegate.

// Beispiel für die Implementierung des Delegates
class WebSocketHandler: NSObject, URLSessionWebSocketDelegate {
    func urlSession(_ session: URLSession, webSocketTask: URLSessionWebSocketTask, didOpenWithProtocol protocol: String?) {
        print("Verbindung geöffnet")
        // Nach dem Öffnen mit dem Empfang von Nachrichten beginnen
        receiveMessage() // Es wird angenommen, dass receiveMessage definiert ist
    }

    func urlSession(_ session: URLSession, webSocketTask: URLSessionWebSocketTask, didCloseWith closeCode: URLSessionWebSocketTask.CloseCode, reason: Data?) {
        let reasonString = reason.flatMap { String(data: $0, encoding: .utf8) } ?? "Unbekannter Grund"
        print("Verbindung geschlossen mit Code \(closeCode.rawValue), Grund: \(reasonString)")
        // Logik für Wiederverbindung oder Beendigung
    }

    // Fehler der Sitzung behandeln
    func urlSession(_ session: URLSession, task: URLSessionTask, didCompleteWithError error: Error?) {
        if let error = error {
            print("Aufgabe mit Fehler beendet: \(error)")
            // Zusätzliche Fehlerbehandlungslogik
        }
    }
}

// Bei der Erstellung der Sitzung den Delegate verwenden
let delegate = WebSocketHandler()
let sessionWithDelegate = URLSession(configuration: .default, delegate: delegate, delegateQueue: OperationQueue())
let webSocketTaskWithDelegate = sessionWithDelegate.webSocketTask(with: URL(string: "wss://example.com/socket")!)

Ich habe auch Drittanbieterbibliotheken wie Starscream verwendet, wenn Unterstützung für ältere iOS-Versionen oder bestimmte Funktionen erforderlich waren, die in der nativen Lösung nicht verfügbar sind (z.B. automatische Wiederverbindung mit exponentiellem Backoff). Wo immer möglich, habe ich URLSessionWebSocketTask bevorzugt wegen der oben genannten Vorteile.

Welche Lösung haben Sie für die Arbeit mit WebSocket verwendet?