Golang-Entwicklung: Verwendung von Websocket zur Implementierung einer Echtzeit-Chat-Anwendung-Golang-php.cn

Golang-Entwicklung: Verwendung von Websocket zur Implementierung einer Echtzeit-Chat-Anwendung

WBOY

Freigeben： 2023-09-20 13:15:28

Original

802 Leute haben es durchsucht

Golang-Entwicklung: Verwendung von Websocket zur Implementierung einer Echtzeit-Chat-Anwendung

Golang-Entwicklung: Echtzeit-Chat-Anwendung mit Websocket

Im heutigen Internetzeitalter ist Echtzeitkommunikation zu einem unverzichtbaren Bestandteil des Lebens der Menschen geworden. Ob Instant Messaging, Echtzeit-Chat oder Echtzeit-Updates: Um dies zu erreichen, ist eine effiziente und stabile Kommunikationsmethode erforderlich. Websocket ist ein Protokoll, das sich sehr gut für die Echtzeitkommunikation eignet.

Golang ist eine einfache und effiziente Programmiersprache mit hervorragender Parallelitätsleistung und eignet sich sehr gut für die Entwicklung von Echtzeit-Kommunikationsanwendungen. In diesem Artikel wird erläutert, wie Sie mit der Websocket-Bibliothek von Golang eine Echtzeit-Chat-Anwendung implementieren und entsprechende Codebeispiele bereitstellen.

Zuerst müssen wir ein Golang-Projekt erstellen und die Websocket-Bibliothek von Golang vorstellen.

package main

import (
    "log"
    "net/http"

    "github.com/gorilla/websocket"
)

Nach dem Login kopieren

Als nächstes müssen wir einige globale Variablen und Strukturen definieren.

var clients = make(map[*websocket.Conn]bool) // 客户端集合
var broadcast = make(chan Message)           // 广播消息通道

// 消息结构体
type Message struct {
    Username string `json:"username"`
    Message  string `json:"message"`
}

Nach dem Login kopieren

Dann müssen wir eine Funktion implementieren, die Websocket-Verbindungen verarbeitet.

func handleWebSocket(w http.ResponseWriter, r *http.Request) {
    // 升级HTTP连接为Websocket连接
    upgrader := websocket.Upgrader{}
    conn, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        log.Fatal(err)
    }

    // 将连接添加到客户端集合中
    clients[conn] = true

    // 关闭连接时，从客户端集合中移除
    defer func() {
        delete(clients, conn)
        conn.Close()
    }()

    // 循环接收和发送消息
    for {
        var message Message
        err := conn.ReadJSON(&message)
        if err != nil {
            log.Printf("error: %v", err)
            delete(clients, conn)
            break
        }
        broadcast <- message
    }
}

Nach dem Login kopieren

Als nächstes müssen wir eine Funktion implementieren, die die Nachricht an alle Clients sendet.

func broadcastMessages() {
    for {
        // 从广播通道中接收消息
        message := <-broadcast

        // 将消息发送给所有客户端
        for client := range clients {
            err := client.WriteJSON(message)
            if err != nil {
                log.Printf("error: %v", err)
                client.Close()
                delete(clients, client)
            }
        }
    }
}

Nach dem Login kopieren

Zuletzt müssen wir den Websocket-Server in der Hauptfunktion starten.

func main() {
    // 设置静态文件目录
    fs := http.FileServer(http.Dir("public"))
    http.Handle("/", fs)

    // 设置Websocket路由
    http.HandleFunc("/ws", handleWebSocket)

    // 启动Websocket服务器
    go broadcastMessages()

    // 开始监听端口
    log.Println("Server started on :8080")
    err := http.ListenAndServe(":8080", nil)
    if err != nil {
        log.Fatal(err)
    }
}

Nach dem Login kopieren

Als nächstes können wir eine HTML-Seite erstellen, um die Benutzeroberfläche zu implementieren.

<!DOCTYPE html>
<html>

<head>
  <meta charset="UTF-8">
  <title>实时聊天应用</title>
</head>

<body>
  <h1>实时聊天应用</h1>
  
  <div id="message-container"></div>
  
  <form>
    <input type="text" id="username" placeholder="请输入用户名">
    <input type="text" id="message" placeholder="请输入消息">
    <button type="button" onclick="sendMessage()">发送</button>
  </form>

  <script>
    // 创建Websocket连接
    var socket = new WebSocket("ws://localhost:8080/ws");
    
    // 监听连接事件
    socket.onopen = function() {
      console.log("连接成功");
    };
    
    // 监听消息事件
    socket.onmessage = function(event) {
      var message = JSON.parse(event.data);
      var username = message.username;
      var content = message.message;
      var container = document.getElementById("message-container");
      container.innerHTML += "<p><b>" + username + "：</b>" + content + "</p>";
    };
    
    // 监听错误事件
    socket.onerror = function(error) {
      console.log("出现错误：" + error);
    }
    
    // 监听关闭事件
    socket.onclose = function(event) {
      console.log("连接关闭");
    }
    
    // 发送消息
    function sendMessage() {
      var username = document.getElementById("username").value;
      var message = document.getElementById("message").value;
      if (username && message) {
        var data = {
          username: username,
          message: message
        };
        socket.send(JSON.stringify(data));
        document.getElementById("message").value = "";
      }
    }
  </script>
</body>

</html>

Nach dem Login kopieren

Zu diesem Zeitpunkt haben wir ein Beispiel für die Verwendung der Websocket-Bibliothek von Golang zur Implementierung einer Echtzeit-Chat-Anwendung fertiggestellt. Anhand dieses Beispiels können wir das Funktionsprinzip von Websocket tiefgreifend verstehen und lernen, wie man Golang zur Entwicklung von Echtzeit-Kommunikationsanwendungen verwendet.

Natürlich gibt es in tatsächlichen Projekten viele Details und Sicherheitsüberlegungen, wie z. B. die Überprüfung von Nachrichten, die Verwendung von SSL-Verschlüsselung usw. Aber mit diesem Beispiel haben Sie bereits einen guten Ausgangspunkt für den Aufbau Ihrer eigenen Live-Chat-Anwendung. Viel Spaß beim Codieren!

Das obige ist der detaillierte Inhalt vonGolang-Entwicklung: Verwendung von Websocket zur Implementierung einer Echtzeit-Chat-Anwendung. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!