pembangunan bahagian belakang
Golang
Bagaimana untuk membangunkan ruang sembang Websocket menggunakan bahasa Go
Bagaimana untuk membangunkan ruang sembang Websocket menggunakan bahasa Go
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 id="Websocket-聊天室">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!
Alat AI Hot
Undresser.AI Undress
Apl berkuasa AI untuk mencipta foto bogel yang realistik
AI Clothes Remover
Alat AI dalam talian untuk mengeluarkan pakaian daripada foto.
Undress AI Tool
Gambar buka pakaian secara percuma
Clothoff.io
Penyingkiran pakaian AI
AI Hentai Generator
Menjana ai hentai secara percuma.
Artikel Panas
Alat panas
Notepad++7.3.1
Editor kod yang mudah digunakan dan percuma
SublimeText3 versi Cina
Versi Cina, sangat mudah digunakan
Hantar Studio 13.0.1
Persekitaran pembangunan bersepadu PHP yang berkuasa
Dreamweaver CS6
Alat pembangunan web visual
SublimeText3 versi Mac
Perisian penyuntingan kod peringkat Tuhan (SublimeText3)
Topik panas
1377
52
Perpustakaan apa yang digunakan untuk operasi nombor terapung di GO?
Apr 02, 2025 pm 02:06 PM
Perpustakaan yang digunakan untuk operasi nombor terapung dalam bahasa Go memperkenalkan cara memastikan ketepatannya ...
Apakah masalah dengan thread giliran di crawler colly go?
Apr 02, 2025 pm 02:09 PM
Masalah Threading Giliran di GO Crawler Colly meneroka masalah menggunakan Perpustakaan Colly Crawler dalam bahasa Go, pemaju sering menghadapi masalah dengan benang dan permintaan beratur. � ...
Apakah perbezaan antara struktur definisi kata kunci `var` dan` type` dalam bahasa Go?
Apr 02, 2025 pm 12:57 PM
Dua cara untuk menentukan struktur dalam bahasa Go: perbezaan antara VAR dan jenis kata kunci. Apabila menentukan struktur, pergi bahasa sering melihat dua cara menulis yang berbeza: pertama ...
Perpustakaan mana yang dibangunkan oleh syarikat besar atau disediakan oleh projek sumber terbuka yang terkenal?
Apr 02, 2025 pm 04:12 PM
Perpustakaan mana yang dibangunkan oleh syarikat besar atau projek sumber terbuka yang terkenal? Semasa pengaturcaraan di GO, pemaju sering menghadapi beberapa keperluan biasa, ...
Di Go, mengapa rentetan percetakan dengan fungsi println dan rentetan () mempunyai kesan yang berbeza?
Apr 02, 2025 pm 02:03 PM
Perbezaan antara percetakan rentetan dalam bahasa Go: perbezaan kesan menggunakan fungsi println dan rentetan () sedang ...
Bagaimana menyelesaikan masalah penukaran jenis user_id semasa menggunakan aliran redis untuk melaksanakan beratur mesej dalam bahasa Go?
Apr 02, 2025 pm 04:54 PM
Masalah menggunakan redisstream untuk melaksanakan beratur mesej dalam bahasa Go menggunakan bahasa Go dan redis ...
Apa yang perlu saya lakukan jika label struktur tersuai di Goland tidak dipaparkan?
Apr 02, 2025 pm 05:09 PM
Apa yang perlu saya lakukan jika label struktur tersuai di Goland tidak dipaparkan? Apabila menggunakan Goland untuk Pembangunan Bahasa GO, banyak pemaju akan menghadapi tag struktur tersuai ...
Kenapa perlu lulus petunjuk apabila menggunakan perpustakaan Go dan Viper?
Apr 02, 2025 pm 04:00 PM
GO Pointer Syntax dan menangani masalah dalam penggunaan perpustakaan Viper semasa pengaturcaraan dalam bahasa Go, adalah penting untuk memahami sintaks dan penggunaan petunjuk, terutama dalam ...
