WebSockets in Kotlin: Echtzeitanwendungen von Grund auf erstellen

WebSockets in Kotlin: Von der Theorie zur Echtzeit-Magie

Stellen Sie sich vor, Sie öffnen einen Messenger, senden eine Nachricht – und sie erscheint sofort beim Gesprächspartner. Ohne Seitenneuladung, ohne ständige Anfragen an den Server. Das ist keine Magie, das sind WebSockets in Kotlin. Wenn Sie jemals Ihren eigenen Chat, ein Echtzeit-Benachrichtigungssystem oder ein Mehrspieler-Spiel erstellen wollten – sind Sie hier genau richtig.

In diesem Artikel analysieren wir, wie WebSockets funktionieren, schreiben eine vollwertige Echtzeitanwendung in Kotlin mit Ktor und zeige ich Ihnen Code, den Sie sofort ausführen können. Los geht's!

Was sind WebSockets und warum werden sie in Kotlin benötigt?

WebSocket ist ein Protokoll für die bidirektionale Kommunikation zwischen Client und Server über eine einzige TCP-Verbindung. Im Gegensatz zum klassischen HTTP, bei dem der Client immer die Anfrage initiiert, ermöglicht WebSocket dem Server, jederzeit selbst Daten an den Client zu senden.

Warum ist WebSocket besser als HTTP?

• Sofortigkeit: Daten werden in Millisekunden zugestellt
• Datenverkehrsersparnis: keine überflüssigen Header wie bei HTTP
• Bidirektionalität: Der Server kann das Senden initiieren
• Dauerhafte Verbindung: Muss nicht jedes Mal neu aufgebaut werden

Kotlin mit seinen Coroutinen und dem Framework Ktor ist ideal für die Arbeit mit WebSockets. Asynchronität, Leichtgewichtigkeit und ausdrucksstarke Syntax – das macht die Kotlin WebSocket-Entwicklung so angenehm.

Wann sollten WebSockets verwendet werden?

Hier sind einige Szenarien, in denen Echtzeitanwendungen in Kotlin mit WebSockets unverzichtbar sind:

• Chats und Messenger – Nachrichtenübertragung in Echtzeit
• Benachrichtigungssysteme – Alarme, Pop-up-Fenster, Statusaktualisierungen
• Online-Spiele – Synchronisation der Spieler
• Börsenkurse – Preisaktualisierung ohne Neuladen
• Gemeinsame Bearbeitung – Google-Docs-ähnliche Funktionalität

Projekteinrichtung: Ktor + WebSockets

Für die Erstellung eines WebSocket-Servers in Kotlin verwenden wir Ktor – ein modernes asynchrones Framework von JetBrains. Lassen Sie uns das Projekt einrichten.

Schritt 1: Abhängigkeiten hinzufügen

Wenn Sie Gradle verwenden (und ich bin sicher, Sie tun das), fügen Sie in build.gradle.kts hinzu:

dependencies {    implementation("io.ktor:ktor-server-core:2.3.7")    implementation("io.ktor:ktor-server-netty:2.3.7")    implementation("io.ktor:ktor-server-websockets:2.3.7")    implementation("ch.qos.logback:logback-classic:1.4.14")}

Schritt 2: WebSocket-Server erstellen

Jetzt schreiben wir den Server selbst. Er wird Verbindungen annehmen und Nachrichten an alle verbundenen Clients senden – die grundlegende Chat-Logik.

import io.ktor.server.engine.*import io.ktor.server.netty.*import io.ktor.server.websocket.*import io.ktor.websocket.*import kotlinx.coroutines.channels.Channelimport kotlinx.coroutines.launch

fun main() {    val clients = mutableSetOf<WebSocketSession>()

    embeddedServer(Netty, port = 8080) {        install(WebSockets) {            pingPeriod = 15_000 // 15 Sekunden            timeout = 15_000            maxFrameSize = Long.MAX_VALUE        }

        routing {            webSocket("/chat") {                // Client hinzufügen                clients.add(this)                println("Neue Verbindung: $this")

                try {                    for (frame in incoming) {                        if (frame is Frame.Text) {                            val message = frame.readText()                            println("Empfangen: $message")

                            // An alle Clients senden