développement back-end
Golang
Comment développer une salle de discussion Websocket en utilisant le langage Go
Comment développer une salle de discussion Websocket en utilisant le langage Go
Comment développer une salle de discussion Websocket en utilisant le langage Go
Websocket est un protocole de communication en temps réel qui permet une communication bidirectionnelle entre le serveur et le client en établissant une connexion une fois. Websocket est un très bon choix lors du développement de salles de discussion car il permet l'échange de messages en temps réel et offre des performances efficaces. Cet article expliquera comment développer une salle de discussion Websocket simple à l'aide du langage Go et fournira quelques exemples de code spécifiques.
1. Préparation
1. Installez l'environnement linguistique Go
Avant de commencer, vous devez d'abord installer l'environnement linguistique Go. Le site officiel du langage Go (https://golang.org/) propose des packages d'installation pour chaque plateforme, qui peuvent être téléchargés et installés selon votre propre système d'exploitation.
2. Installez la bibliothèque websocket
En langage Go, utilisez le package "github.com/gorilla/websocket" pour fournir les fonctions liées à WebSocket. Le package peut être installé via la commande suivante :
go get github.com/gorilla/websocket
2 Créer un serveur de salle de discussion
Tout d'abord, nous devons créer un serveur simple pour gérer l'établissement des connexions et des messages Websocket. Envoyez et recevez.
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)
}
}
}
}Le code ci-dessus crée un simple serveur de salle de discussion Websocket. Dans la fonction handleConnections, nous mettons le message reçu dans le canal de diffusion. La fonction handleMessages lit les messages du canal de diffusion et les envoie à tous les clients connectés. 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 et affichez le message dans la boîte de message. Envoyez le message d'entrée via socket.send. 🎜🎜4. Exécutez le programme 🎜🎜 Entrez le répertoire du projet dans le terminal et exécutez la commande suivante pour démarrer le serveur : 🎜rrreee🎜 Ensuite, ouvrez la page index.html dans le navigateur, saisissez le nom d'utilisateur et message, puis cliquez sur Envoyer. C'est tout. 🎜🎜Grâce aux étapes ci-dessus, nous avons développé avec succès un salon de discussion Websocket simple utilisant le langage Go. En développement actuel, davantage de fonctions peuvent être ajoutées, telles que les enregistrements de chat, les messages privés, etc. J'espère que cet article pourra vous aider à comprendre et à apprendre le langage Go pour développer des salles de discussion Websocket. 🎜Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!
Outils d'IA chauds
Undresser.AI Undress
Application basée sur l'IA pour créer des photos de nu réalistes
AI Clothes Remover
Outil d'IA en ligne pour supprimer les vêtements des photos.
Undress AI Tool
Images de déshabillage gratuites
Clothoff.io
Dissolvant de vêtements AI
AI Hentai Generator
Générez AI Hentai gratuitement.
Article chaud
Outils chauds
Bloc-notes++7.3.1
Éditeur de code facile à utiliser et gratuit
SublimeText3 version chinoise
Version chinoise, très simple à utiliser
Envoyer Studio 13.0.1
Puissant environnement de développement intégré PHP
Dreamweaver CS6
Outils de développement Web visuel
SublimeText3 version Mac
Logiciel d'édition de code au niveau de Dieu (SublimeText3)
Quelles bibliothèques sont utilisées pour les opérations du numéro de point flottantes en Go?
Apr 02, 2025 pm 02:06 PM
La bibliothèque utilisée pour le fonctionnement du numéro de point flottante dans le langage go présente comment s'assurer que la précision est ...
Quel est le problème avec le fil de file d'attente dans GO's Crawler Colly?
Apr 02, 2025 pm 02:09 PM
Problème de threading de file d'attente dans Go Crawler Colly explore le problème de l'utilisation de la bibliothèque Crawler Crawler dans le langage Go, les développeurs rencontrent souvent des problèmes avec les threads et les files d'attente de demande. � ...
Quelles bibliothèques de GO sont développées par de grandes entreprises ou fournies par des projets open source bien connus?
Apr 02, 2025 pm 04:12 PM
Quelles bibliothèques de GO sont développées par de grandes entreprises ou des projets open source bien connus? Lors de la programmation en Go, les développeurs rencontrent souvent des besoins communs, ...
Dans Go, pourquoi les chaînes d'impression avec println et string () ont-elles des effets différents?
Apr 02, 2025 pm 02:03 PM
La différence entre l'impression de chaîne dans le langage go: la différence dans l'effet de l'utilisation de fonctions println et string () est en Go ...
Quelle est la différence entre la structure de définition des mots clés `var` et« type »dans le langage Go?
Apr 02, 2025 pm 12:57 PM
Deux façons de définir les structures dans le langage GO: la différence entre les mots clés VAR et le type. Lorsque vous définissez des structures, GO Language voit souvent deux façons d'écrire différentes: d'abord ...
Pourquoi est-il nécessaire de passer des pointeurs lors de l'utilisation de bibliothèques Go et Viper?
Apr 02, 2025 pm 04:00 PM
GO POINTER SYNTAXE ET ATTENDRE DES PROBLÈMES DANS LA BIBLIOTHÈQUE VIPER Lors de la programmation en langage Go, il est crucial de comprendre la syntaxe et l'utilisation des pointeurs, en particulier dans ...
Comment résoudre le problème de conversion de type user_id lors de l'utilisation du flux redis pour implémenter les files d'attente de messages dans le langage Go?
Apr 02, 2025 pm 04:54 PM
Le problème de l'utilisation de Redessstream pour implémenter les files d'attente de messages dans le langage GO consiste à utiliser le langage GO et redis ...
Pourquoi toutes les valeurs deviennent-elles le dernier élément lors de l'utilisation de la plage dans le langage GO pour traverser les tranches et stocker des cartes?
Apr 02, 2025 pm 04:09 PM
Pourquoi l'itération de la carte dans GO fait-elle que toutes les valeurs deviennent le dernier élément? En langue go, face à des questions d'entrevue, vous rencontrez souvent des cartes ...
