So entwickeln Sie einen Websocket-Chatroom mit der Go-Sprache
Websocket ist ein Echtzeit-Kommunikationsprotokoll, das durch einmaliges Herstellen einer Verbindung eine bidirektionale Kommunikation zwischen dem Server und dem Client ermöglicht. Websocket ist eine sehr gute Wahl für die Entwicklung von Chatrooms, da es den Nachrichtenaustausch in Echtzeit ermöglicht und eine effiziente Leistung bietet. In diesem Artikel wird die Entwicklung eines einfachen Websocket-Chatrooms mit der Go-Sprache vorgestellt und einige spezifische Codebeispiele bereitgestellt.
1. Vorbereitung
1. Installieren Sie die Go-Sprachumgebung
Bevor Sie beginnen, müssen Sie zunächst die Go-Sprachumgebung installieren. Die offizielle Website der Go-Sprache (https://golang.org/) stellt Installationspakete für jede Plattform bereit, die entsprechend Ihrem eigenen Betriebssystem heruntergeladen und installiert werden können.
2. Installieren Sie die WebSocket-Bibliothek
Verwenden Sie in der Go-Sprache das Paket „github.com/gorilla/websocket“, um WebSocket-bezogene Funktionen bereitzustellen. Das Paket kann über den folgenden Befehl installiert werden:
go get github.com/gorilla/websocket
2 Erstellen Sie einen Chatroom-Server
Zunächst müssen wir einen einfachen Server erstellen, um den Aufbau von Websocket-Verbindungen und -Nachrichten zu verwalten Senden und Empfangen.
package main
import (
"fmt"
"log"
"net/http"
"github.com/gorilla/websocket"
)
var clients = make(map[*websocket.Conn]bool) // 存储连接的客户端
var broadcast = make(chan Message) // 消息广播通道
// 定义消息结构体
type Message struct {
Username string `json:"username"`
Message string `json:"message"`
}
func main() {
http.HandleFunc("/ws", handleConnections)
go handleMessages()
// 启动服务器
log.Println("服务器启动，监听端口：8080")
err := http.ListenAndServe(":8080", nil)
if err != nil {
log.Fatal("ListenAndServe: ", err)
}
}
func handleConnections(w http.ResponseWriter, r *http.Request) {
// 升级HTTP连接为Websocket连接
ws, err := websocket.Upgrade(w, r, nil, 1024, 1024)
if err != nil {
log.Fatal(err)
}
// 关闭连接
defer ws.Close()
// 将客户端连接添加到clients映射中
clients[ws] = true
for {
var msg Message
// 读取客户端发送的消息
err := ws.ReadJSON(&msg)
if err != nil {
log.Printf("读取消息错误：%v", err)
delete(clients, ws)
break
}
// 将接收到的消息放入广播通道中
broadcast <- msg
}
}
func handleMessages() {
for {
// 从广播通道中读取消息
msg := <-broadcast
// 遍历所有连接的客户端，将消息发送给每个客户端
for client := range clients {
err := client.WriteJSON(msg)
if err != nil {
log.Printf("发送消息错误：%v", err)
client.Close()
delete(clients, client)
}
}
}
}Nach dem Login kopieren
Der obige Code erstellt einen einfachen Websocket-Chatroom-Server. In der Funktion handleConnections stellen wir die empfangene Nachricht in den Broadcast-Kanal. Die Funktion handleMessages liest Nachrichten vom Broadcast-Kanal und sendet sie an alle verbundenen Clients. handleConnections函数中，我们将接收到的消息放入广播通道中。handleMessages函数从广播通道中读取消息，并将消息发送给所有连接的客户端。
三、创建前端界面
接下来，我们需要创建一个前端界面，用于用户输入用户名和消息，并实时显示聊天内容。
<!doctype html>
<html>
<head>
<title>Websocket 聊天室</title>
<style>
#message-box {
height: 500px;
overflow-y: scroll;
}
</style>
</head>
<body>
<h1>Websocket 聊天室</h1>
<div id="message-box"></div>
<form id="message-form" onsubmit="sendMessage(event)">
<input type="text" id="username" placeholder="请输入用户名" required>
<br />
<input type="text" id="message" placeholder="请输入消息" required>
<br />
<button type="submit">发送</button>
</form>
<script>
const socket = new WebSocket("ws://localhost:8080/ws");
socket.onmessage = function (event) {
const data = JSON.parse(event.data);
const messageBox = document.getElementById("message-box");
const messageElement = document.createElement("p");
messageElement.innerText = data.username + ": " + data.message;
messageBox.appendChild(messageElement);
};
function sendMessage(event) {
event.preventDefault();
const username = document.getElementById("username").value;
const message = document.getElementById("message").value;
const data = {
username: username,
message: message
};
socket.send(JSON.stringify(data));
document.getElementById("message").value = "";
}
</script>
</body>
</html>Nach dem Login kopieren
以上代码创建了一个简单的HTML界面，包含一个用户名输入框、一个消息输入框和一个发送按钮。通过socket.onmessage处理接收到的消息，并将消息显示在消息盒子中。通过socket.send发送输入的消息。
四、运行程序
在终端中进入项目目录，执行以下命令启动服务器：
go run main.go
Nach dem Login kopieren
然后，在浏览器中打开index.html
3. Erstellen Sie eine Front-End-Schnittstelle
Als nächstes müssen wir eine Front-End-Schnittstelle erstellen, über die Benutzer Benutzernamen und Nachrichten eingeben und Chat-Inhalte in Echtzeit anzeigen können. 🎜rrreee🎜Der obige Code erstellt eine einfache HTML-Schnittstelle, einschließlich eines Benutzernamen-Eingabefelds, eines Nachrichteneingabefelds und einer Senden-Schaltfläche. Verarbeiten Sie die empfangene Nachricht über
socket.onmessage und zeigen Sie die Nachricht im Meldungsfeld an. Senden Sie die Eingabenachricht über
socket.send. 🎜🎜4. Führen Sie das Programm aus 🎜🎜 Geben Sie das Projektverzeichnis im Terminal ein und führen Sie den folgenden Befehl aus, um den Server zu starten: 🎜rrreee🎜 Öffnen Sie dann die Seite
index.html im Browser, geben Sie die ein Geben Sie den Benutzernamen und die Nachricht ein und klicken Sie auf „Senden“. Das ist es. 🎜🎜Durch die oben genannten Schritte haben wir erfolgreich einen einfachen Websocket-Chatroom mit der Go-Sprache entwickelt. In der tatsächlichen Entwicklung können weitere Funktionen hinzugefügt werden, z. B. Chat-Aufzeichnungen, private Nachrichten usw. Ich hoffe, dieser Artikel kann Ihnen helfen, die Go-Sprache zu verstehen und zu lernen, um Websocket-Chatrooms zu entwickeln. 🎜
Das obige ist der detaillierte Inhalt vonSo entwickeln Sie einen Websocket-Chatroom mit der Go-Sprache. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!
