使用springboot整合websocket实现群聊教程

飞奔的炮台

websocket怎么说呢，就是服务器可以主动向客户端发起对话，下面就是springboot整合websocket实现群聊的操作代码，一起来看一下get新技能吧

先上效果图：

相对来说更好看那么一点但是，实现代码都是一样的。

先来准备工作导入依赖

<!--websocket依赖-->
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-websocket</artifactId>
    </dependency>

其实springboot已经内置了，直接在主函数启动就行。但我们这次就讲这个。

导入依赖后扫描启用

package com.nx.study.springstudy.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.server.standard.ServerEndpointExporter;
@Configuration
public class WS {
  @Bean
  public ServerEndpointExporter serverEndpointExporter(){
    return new ServerEndpointExporter();
  }
}

**@ServerEndpoint("/websocket/{username}")**

接收前端传回数据
@Component启用

package com.nx.study.springstudy.bean;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.JsonMappingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import net.sf.json.JSONObject;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.RequestParam;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;
import javax.websocket.*;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CopyOnWriteArraySet;
@ServerEndpoint("/websocket/{username}")
@Component
public class Myws {
  private static Map<String, Myws> webSocketSet = new ConcurrentHashMap<String, Myws>();
  private static Map<String, Session> map = new HashMap<String, Session>();
  private static List<String> namelist = new ArrayList<String>();
  private static JSONObject jsonObject = new JSONObject();
  private static JSONObject jsonObject2 = new JSONObject();
  private static List<String> nm_msg = new ArrayList<String>();
  private SocketMsg socketMsg;
  private Session session;
  private String name;
  @OnOpen
  public void onpen(Session session, @PathParam(value = "username") String username){
    if(username == null){
      username = "游客";
    }
    this.session = session;
//    this.name = "南" + getname();
    this.name = username;
    webSocketSet.put(name, this);
    map.put(username, session);
    namelist.clear();  // 清空原来的信息
    setonlion();
    jsonObject.put("onlinepp", namelist);
    String message = jsonObject.toString();
    broadcast2(message);
  }
  @OnClose
  public void onclose(){
    webSocketSet.remove(this.name);  // 移除对象
    namelist.clear();
    setonlion();
    jsonObject.clear();
    jsonObject.put("onlinepp", namelist);
    String message = jsonObject.toString();
    broadcast3(message);
  }
  @OnMessage
  public void onmessage(String message){
    nm_msg.clear();
    jsonObject2.clear();
    nm_msg.add(name);
    nm_msg.add(message);
    jsonObject2.put("chat", nm_msg);
    String message2 = jsonObject2.toString();
   broadcast(message2);
  }
  @OnError
  public void onError(Session session, Throwable error) {
    System.out.println("发生错误");
    error.printStackTrace();
  }
  public void broadcast(String message){
    for (Map.Entry<String, Myws> item : webSocketSet.entrySet()){
      item.getValue().session.getAsyncRemote().sendText(message);
    }
  }
  public void broadcast2(String message){
    for (Map.Entry<String, Myws> item : webSocketSet.entrySet()){
      item.getValue().session.getAsyncRemote().sendText(message);
    }
  }
  public void broadcast3(String message){
    for (Map.Entry<String, Myws> item : webSocketSet.entrySet()){
      if (!item.getKey().equals(name)){
        item.getValue().session.getAsyncRemote().sendText(message);
      }
    }
  }
  public void setonlion(){
    for (Map.Entry<String, Myws> item : webSocketSet.entrySet()){
        namelist.add(item.getKey());
    }
  }
  public String getname() {
    String linkNo = "";
    // 用字符数组的方式随机
    String model = "小大天明画美丽豪子余多少浩然兄弟朋友美韵紫萱好人坏蛋误解不要停栖栖遑遑可";
    char[] m = model.toCharArray();
    for (int j = 0; j < 2; j++) {
      char c = m[(int) (Math.random() * 36)];
      // 保证六位随机数之间没有重复的
      if (linkNo.contains(String.valueOf(c))) {
        j--;
        continue;
      }
      linkNo = linkNo + c;
    }
    return linkNo;
  }
}

其中重点就是4个注解
**@OnOpen，@OnClose，@OnMessage，@OnError**

@OnOpenC>客户端打开链接时候触发执行
@OnCloseC>客户端关闭链接触发执行
@OnMessageC>客户端发送信息触发执行
@OnErrorC>发送错误时候触发执行

对象信息都储存在Session，可以仔细看看上面代码很好理解。
我们只需要理解这4个注解的作用就可以！

前端页面代码

<!DOCTYPE html>
<html lang="en" xmlns:th="http://www.thymeleaf.org">
<head>
  <link rel="icon" type="image/x-icon" th:href="@{/img/user/head/favicon.ico}" />
  <script th:src="@{webjars/jquery/3.1.1/jquery.min.js}"></script>
  <script th:src="@{webjars/bootstrap/3.3.7/js/bootstrap.min.js}"></script>
  <link rel="stylesheet" th:href="@{webjars/bootstrap/3.3.7/css/bootstrap.min.css}" />
  <link th:href="@{/css/home.css}" rel="stylesheet" type="text/css" />
  <meta charset="UTF-8">
  <title>在线聊天室</title>
</head>
<body>
<div class="container-fluid">
  <div>
    <br>
    <h1>文明用语，快乐你我他</h1>
  </div>
  <div>
    <div>
      <div>
        <span class="glyphicon glyphicon-globe"></span>
        <span>群聊</span>
      </div>
      <div>
        <span class="glyphicon glyphicon-star"></span>
        <span th:text="${Springuser.username}">游客</span>
      </div>
      <hr>
      <div id="online">
      </div>
    </div>
    <div>
      <div id="message">
      </div>
      <div>
        <div>
          <button id="btn1" class="btn btn-success">连接上线</button><br>
          <br>
          <button id="btn2" class="btn btn-danger">下线</button>
        </div>
        <div class="input-group">
          <input id="msg" type="text" class="form-control" placeholder="在这里输入想说的话吧！" /><br>
          <button id="btn3" class="btn btn-info">发送消息</button>
        </div>
      </div>
    </div>
  </div>
  <div class="div2">
    <br><br>
    <a href="#"><span>关于我们</span></a>&nbsp;|&nbsp;
    <a href="mailto: 2251798294@qq.com">找我合作</a><br>
    <a href="http://beian.miit.gov.cn">赣ICP备2021004042号</a>
  </div>
</div>
</body>
<script th:inline="javascript" language='javascript'>
  $(document).ready(function(){
    var select;
    var message = "";
    var fromuser = "";
    var touser = "";
    var type = 0;
    var username = [[${Springuser.username}]];
    var websocket = null;
    $("#btn1").click(function(){
      //判断当前浏览器是否支持WebSocket
      if(select === 1){
        alert("你已连接上线路，无需重复连接！")
      }else {
        if ('WebSocket'in window) {
          websocket = new WebSocket("ws://wenhaosuper.top:8000/websocket/" + username);
          alert("欢迎-->" + username + "<--成功上线！");
          select = 1;
        } else {
          alert('Not support websocket')
        }
      }
      //连接发生错误的回调方法
      websocket.onerror = function() {
        alert("错误");
      };
      //连接成功建立的回调方法
      websocket.onopen = function() {
      }
      //接收到消息的回调方法
      websocket.onmessage = function(event) {
        var msg = event.data
        var obj = JSON.parse(msg);
        var zxname = obj.onlinepp;
        var chat = obj.chat;
        if (zxname != null){
          onlinename(zxname);
        }
        if (chat != null){
          setchat(chat);
        }
      }
      //连接关闭的回调方法
      websocket.onclose = function() {
        alert("离开");
        select = 2;
        $("#online").empty();
      }
      //监听窗口关闭事件，当窗口关闭时，主动去关闭websocket连接，防止连接还没断开就关闭窗口，server端会抛异常。
      window.onbeforeunload = function() {
        websocket.onclose;
        websocket.close();
      }
    });
    //将消息显示在网页上
    function setchat(message) {
      $("<div style="width: 560px;min-height: 40px;display: flex;margin-bottom: 20px">\n" +
        "          <div style="width: 40px;height: 40px;background-color: #ffffff;text-align: center;border-radius: 20px">\n" +
        "            <span style="font-size: 28px;margin-top: 9px"><strong>N</strong></span>\n" +
        "          </div>\n" +
        "          <div style="min-height: 40px;margin-left: 10px">\n" +
        "            <div style="height: 18px">\n" +
        "              <span style="color: #7f7777;font-size: 14px">"+message[0]+"</span>\n" +
        "            </div>\n" +
        "            <div style="min-height: 20px;word-break: break-word;background-color: #ffffff;padding: 10px 10px 10px 10px;border-radius: 6px">\n" +
        "              <span>"+message[1]+"</span>\n" +
        "            </div>\n" +
        "          </div>\n" +
        "        </div>").appendTo("#message");
    }
    function onlinename(obj){
      $("#online").empty();
      obj.forEach(function (e){
        $("<div style="width: 160px;height: 40px;margin: auto;margin-top: 10px;background-color: #fdffff;text-align: center;box-shadow: 0px 0px 10px #474749;border-radius: 4px;overflow: hidden">\n" +
          "        <span class="glyphicon glyphicon-user" style="font-size: 30px;padding-top: 2px;padding-bottom: 2px"></span>\n" +
          "        <span style="font-size: 26px">"+e+"</span>\n" +
          "      </div>").appendTo("#online");
      });
    }
    $("#btn2").click(function(){
      websocket.close();
    });
    //发送消息
    $("#btn3").click(function(){
      var message = $("#msg").val();
      websocket.send(message);
      $("#msg").val("");
    });
  });
</script>
</html>

因为我这个是springboot项目

模板引擎代码如下

package com.nx.study.springstudy.controller;
import com.nx.study.springstudy.bean.UserPostForm;
import com.nx.study.springstudy.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;
@Controller
public class WebSocketController {
  @Autowired
  private UserService userService;
  @RequestMapping("/websocket")
  public String webSocket(Model model, HttpServletRequest request){
    HttpSession httpSession = request.getSession();
    String username = (String) request.getSession().getAttribute("username");
    String userpassword = (String) request.getSession().getAttribute("userpassword");
    if (username != null){
      UserPostForm Springuser = userService.query(username,userpassword);
      model.addAttribute("Springuser", Springuser);
      return "index/webSocket";
    }else {
      return "index/ZGZG";
    }
  }
}

最后效果图如下

以上就是使用springboot整合websocket实现群聊教程的详细内容，更多关于springboot整合websocket实现群聊的资料请关注CodeAE代码之家其它相关文章！
原文链接：https://blog.csdn.net/nanxiang11/article/details/119791333

[Java] 使用springboot整合websocket实现群聊教程

相关帖子

Kotlin协程解析系列（上）：协程调度与挂起

简单介绍ASP.NET Core实现文件上传和下载

学会这些linux的“自动化”轻松搞定任务

学到就是赚到，面试加分项之WebServer线程池管理！

Linux下玩转nginx系列（八）---如何使用upsync模块实现动态负载均衡

Mysql8导入数据到Mysql5.7的实现步骤

javascript怎么实现窗口置顶

JavaScript怎样实现点击出现图片效果

使用原生querySelectorAll和forEach来实现点击切换

免插件、DZ内置JS轻松实现外链访问二次确认对话提示框

飞奔的炮台 LV3