Rumah > Artikel > pembangunan bahagian belakang > Bagaimana untuk membangunkan ruang sembang Websocket menggunakan bahasa Go
Bagaimana untuk membangunkan ruang sembang Websocket menggunakan bahasa Go
- PHPzasal
- 2023-12-14 13:46:50843semak imbas
Cara membangunkan bilik sembang Websocket menggunakan bahasa Go
Websocket ialah protokol komunikasi masa nyata yang membolehkan komunikasi dua hala antara pelayan dan pelanggan dengan mewujudkan sambungan sekali. Websocket ialah pilihan yang sangat baik apabila membangunkan bilik sembang kerana ia membolehkan pertukaran mesej masa nyata dan memberikan prestasi yang cekap. Artikel ini akan memperkenalkan cara membangunkan ruang sembang Websocket yang ringkas menggunakan bahasa Go dan menyediakan beberapa contoh kod khusus.
1. Persediaan
1. Pasang persekitaran bahasa Go
Sebelum memulakan, anda perlu memasang persekitaran bahasa Go terlebih dahulu. Laman web rasmi bahasa Go (https://golang.org/) menyediakan pakej pemasangan untuk setiap platform, yang boleh dimuat turun dan dipasang mengikut sistem pengendalian anda sendiri.
2. Pasang perpustakaan websocket
Dalam bahasa Go, gunakan pakej "github.com/gorilla/websocket" untuk menyediakan fungsi berkaitan WebSocket. Pakej boleh dipasang melalui arahan berikut:
pergi dapatkan github.com/gorilla/websocket
2 Cipta pelayan bilik sembang
Pertama, kita perlu mencipta pelayan mudah untuk mengendalikan penubuhan sambungan dan mesej Websocket. Hantar dan terima.
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)
}
}
}
}Kod di atas mencipta pelayan bilik sembang Websocket yang mudah. Dalam fungsi handleConnections, kami meletakkan mesej yang diterima ke dalam saluran siaran. Fungsi handleMessages membaca mesej daripada saluran siaran dan menghantarnya kepada semua pelanggan yang disambungkan. 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>以上代码创建了一个简单的HTML界面，包含一个用户名输入框、一个消息输入框和一个发送按钮。通过socket.onmessage处理接收到的消息，并将消息显示在消息盒子中。通过socket.send发送输入的消息。
四、运行程序
在终端中进入项目目录，执行以下命令启动服务器：
go run main.go
然后，在浏览器中打开index.html
socket.onmessage dan paparkan mesej dalam kotak mesej. Hantar mesej input melalui socket.send. 🎜🎜4 Jalankan program 🎜🎜 Masukkan direktori projek dalam terminal dan laksanakan arahan berikut untuk memulakan pelayan: 🎜rrreee🎜 Kemudian, buka halaman index.html dalam penyemak imbas, masukkan nama pengguna dan mesej, dan klik Hantar Itu sahaja. 🎜🎜Melalui langkah di atas, kami berjaya membangunkan ruang sembang Websocket yang ringkas menggunakan bahasa Go. Dalam pembangunan sebenar, lebih banyak fungsi boleh ditambah, seperti rekod sembang, mesej peribadi, dll. Saya harap artikel ini dapat membantu anda memahami dan mempelajari bahasa Go untuk membangunkan bilik sembang Websocket. 🎜Atas ialah kandungan terperinci Bagaimana untuk membangunkan ruang sembang Websocket menggunakan bahasa Go. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!