WebSocket实现简易版的多人聊天室
生活随笔
收集整理的這篇文章主要介紹了
WebSocket实现简易版的多人聊天室
小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.
一、websocket簡(jiǎn)介? ? ?
? ? ?WebSocket是一種在單個(gè)TCP連接上進(jìn)行全雙工通信的協(xié)議。WebSocket使得客戶端和服務(wù)器之間的數(shù)據(jù)交換變得更加簡(jiǎn)單，允許服務(wù)端主動(dòng)向客戶端推送數(shù)據(jù)。在WebSocket API中，瀏覽器和服務(wù)器只需要完成一次握手，兩者之間就直接可以創(chuàng)建持久性的連接，并進(jìn)行雙向數(shù)據(jù)傳輸。（百度百科）
二、多人聊天室的實(shí)現(xiàn)
1、后端服務(wù)器
（1）后端使用springboot搭建服務(wù)器，在IDEA中新建一個(gè)springboot工程，在pom.xml文件中引入spring-boot-starter-websocket依賴
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-websocket</artifactId><version>2.0.4.RELEASE</version> </dependency>（2）寫一個(gè)配置類
@Configuration public class WebSocketConfig {@Beanpublic ServerEndpointExporter serverEndpointExporter() {return new ServerEndpointExporter();} }（3）controller
package com.joe.study.eshopdemo.controller;import org.springframework.stereotype.Controller; import javax.websocket.*; import javax.websocket.server.PathParam; import javax.websocket.server.ServerEndpoint; import java.io.IOException; import java.util.ArrayList; import java.util.List; import java.util.concurrent.ConcurrentHashMap;@Controller @ServerEndpoint("/groupChat/{roomId}/{username}") public class GroupChatController {// 保存 聊天室id -> 聊天室成員 的映射關(guān)系private static ConcurrentHashMap<String, List<Session>> rooms = new ConcurrentHashMap<>();// 收到消息調(diào)用的方法，群成員發(fā)送消息@OnMessagepublic void onMessage(@PathParam("roomId") String roomId,@PathParam("username") String username, String message) {List<Session> sessionList = rooms.get(roomId);// 分別向聊天室的成員發(fā)送消息sessionList.forEach(item -> {try {String text = username + ": " + message;item.getBasicRemote().sendText(text);} catch (IOException e) {e.printStackTrace();}});}// 建立連接調(diào)用的方法，群成員加入@OnOpenpublic void onOpen(Session session, @PathParam("roomId") String roomId) {List<Session> sessionList = rooms.get(roomId);if (sessionList == null) {sessionList = new ArrayList<>();rooms.put(roomId, sessionList);}sessionList.add(session);System.out.println("成員加入---- 聊天室號(hào)：" + roomId + " 當(dāng)前聊天室人數(shù)：" + sessionList.size());}// 關(guān)閉連接調(diào)用的方法，群成員退出@OnClosepublic void onClose(Session session, @PathParam("roomId") String roomId) {List<Session> sessionList = rooms.get(roomId);sessionList.remove(session);System.out.println("成員退出---- 聊天室號(hào)：" + roomId + " 當(dāng)前聊天室人數(shù)：" + sessionList.size());}// 傳輸消息錯(cuò)誤調(diào)用的方法@OnErrorpublic void OnError(Throwable error) {System.out.println("消息傳遞出錯(cuò)");} }2、前端
<!DOCTYPE html> <html lang="en"><head><meta charset="UTF-8" /><title>websocket多人聊天室</title><style>.container {margin-top: 30px;margin-left: 30px;}.span1 {display: inline-block;width: 80px;font-size: 13px;}input {width: 200px;height: 30px;outline: none;border: 1px solid #3998f7;border-radius: 3px;padding: 0 10px;}input:hover,textarea:hover {box-shadow: 0 0 3px #3998f7;}#name {margin-top: 15px;}button {width: 100px;height: 30px;outline: none;color: #fff;font-size: 13px;font-weight: bold;background-color: #168ed1;border: none;border-radius: 5px;cursor: pointer;}#connectBtn,#content,#sendBtn,#closeBtn {margin-top: 10px;}#messages {margin-top: 20px;}textarea {width: 300px;height: 80px;outline: none;border: 1px solid #3998f7;border-radius: 3px;color: rgba(0, 0, 0, 0.7);font-size: 13px;font-weight: bold;padding: 5px;}#messages, .me, .name {color: rgba(0, 0, 0, 0.7);font-size: 14px;font-weight: bold;}.me {color: red;}.name {color: royalblue;}</style></head><body><div class="container"><span class="span1">聊天室id:</span><input type="text" id="roomId" placeholder="請(qǐng)輸入聊天室id" /><br /><span class="span1">昵稱:</span><input type="text" id="name" placeholder="請(qǐng)輸入你的昵稱" /><br /><button id="connectBtn">連接</button><br /><textarea id="content" placeholder="請(qǐng)輸入要發(fā)送的消息"></textarea><br /><button id="sendBtn">發(fā)送</button><button id="closeBtn">退出</button><br /><div id="messages"></div></div><script type="text/javascript">const connectBtn = document.getElementById("connectBtn");const sendBtn = document.getElementById("sendBtn");const closeBtn = document.getElementById("closeBtn");const roomIdDOM = document.getElementById("roomId");const nameDOM = document.getElementById("name");const messagesDOM = document.getElementById("messages");const contentDOM = document.getElementById("content");let webSocket = null;// 加入聊天室connectBtn.addEventListener("click", () => {const roomId = roomIdDOM.value;const name = nameDOM.value;if (!roomId || !name) {alert("房間號(hào)和用戶名不能為空");return;}const url = "ws://localhost:8787/groupChat/" + roomId + "/" + name;webSocket = new WebSocket(url);webSocket.onerror = e => {alert("出錯(cuò)了");};webSocket.onopen = e => {messagesDOM.innerHTML = "您已加入聊天室！";connectBtn.style.display = 'none'};webSocket.onmessage = e => {const nickname = e.data.split(":")[0];const data = e.data.slice(e.data.indexOf(':') + 1)messagesDOM.innerHTML += `<br /><span class='${nickname === name ? "me" : "name"}'>${nickname === name ? "我" : nickname}: </span>  ${data}`;};webSocket.onclose = e => {connectBtn.style.display = 'none'alert("您已退出聊天室");};});// 發(fā)送消息sendBtn.addEventListener("click", () => {webSocket.send(contentDOM.value);contentDOM.value = "";});// 退出聊天室closeBtn.addEventListener("click", () => {webSocket.close();});</script></body> </html>?3、效果
總結(jié)
以上是生活随笔為你收集整理的WebSocket实现简易版的多人聊天室的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 将Intel集成显卡GMA HD4000
- 下一篇： iphone：让有角标强迫症的你彻底摆脱