SpringBoot2 集成 WebSocket

Stella981
• 阅读 328
  1.  <dependency>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-websocket</artifactId>
     </dependency>
    
  2.   1 package me.abdusalam.websocket.demo.config;
      2 import org.springframework.context.annotation.Bean;
      3 import org.springframework.context.annotation.Configuration;
      4 import org.springframework.web.socket.server.standard.ServerEndpointExporter;
      5 
      6 // 开启 WebSocket 支持
      7 @Configuration
      8 public class WebSocketConfig {
      9 
     10     @Bean
     11     public ServerEndpointExporter serverEndpointExporter() {
     12         return new ServerEndpointExporter();
     13     }
     14 
     15 }
    
  3.   1 package me.abdusalam.websocket.demo.dao;
      2 import me.abdusalam.websocket.demo.server.WebSocketServer;
      3 import java.util.concurrent.CopyOnWriteArraySet;
      4 
      5 // 模拟数据库
      6 public class DB {
      7 
      8     /**
      9      * 记录 有多少个客户端【前端浏览器】与服务端【后端】创建连接 的个数
     10      * 应该把它设计成线程安全的 , 使用 synchronized 进行操作
     11      */
     12     private static Integer connectedClientNum = 0;
     13     public static synchronized void increaseConnectedClientNum() {
     14         connectedClientNum++;
     15     }
     16     public static synchronized void decreaseConnectedClientNum() {
     17         connectedClientNum--;
     18     }
     19     
     20     /**
     21      * java.util.concurrent 包的线程安全的 Set 集合
     22      * 客户端【前端浏览器】 每次 使用 new WebSocket("ws://localhost:8080/websocket") 时,即与服务端【后端】创建连接时,后端 new 一个 WebSocketServer
     23      *      【 可见 WebSocketServer 是多例的 --> 前端有多少个 new WebSocket("ws://localhost:8080/websocket")   就后端有多少个 new WebSocketServer 】
     24      * WebSocketServers 用来存储 总共有多少个 WebSocketServer 被 new 了
     25      */
     26     public static CopyOnWriteArraySet<WebSocketServer> webSocketServers = new CopyOnWriteArraySet<>();
     27 
     28 }
    
  4.   1 package me.abdusalam.websocket.demo.server;
      2 import java.io.IOException;
      3 import javax.websocket.OnClose;
      4 import javax.websocket.OnError;
      5 import javax.websocket.OnMessage;
      6 import javax.websocket.OnOpen;
      7 import javax.websocket.Session;
      8 import javax.websocket.server.ServerEndpoint;
      9 import me.abdusalam.websocket.demo.dao.DB;
     10 import org.springframework.stereotype.Component;
     11 
     12 @Component
     13 @ServerEndpoint("/WebSocketServer")
     14 public class WebSocketServer {
     15 
     16     /**
     17      * 与某一个客户端的连接会话
     18      * 用这个 session 向客户端发消息
     19      */
     20     private Session session;
     21 
     22     // 向所有客户端【浏览器】发消息
     23     public static void sendMessage2allClients(String message){
     24         for (WebSocketServer item : DB.webSocketServers) {
     25             try {
     26                 // 发消息
     27                 item.session.getBasicRemote().sendText(message);
     28             } catch (IOException e) {
     29                 // 给某一个客户端【浏览器】发消息抛异常,没关系,继续给下一个客户端【浏览器】发消息
     30                 continue;
     31             }
     32         }
     33     }
     34 
     35 
     36     // 当前端创建连接【 new WebSocket("ws://localhost:8080/websocket") 】时,调用的方法
     37     @OnOpen
     38     public void clientConnected(Session session) {
     39         DB.increaseConnectedClientNum();
     40         DB.webSocketServers.add(this);
     41         this.session = session;
     42         sendMessage2allClients("系统消息:SESSION_ID 为 " + this.session.getId() + " 的客户端连接成功");
     43     }
     44 
     45 
     46     // 收到客户端【浏览器】消息后调用的方法
     47     @OnMessage
     48     public void receiveMessageFromClient(String message) {
     49         sendMessage2allClients("SESSION_ID " + this.session.getId() + " : " + message);
     50     }
     51 
     52 
     53     //
     54     @OnError
     55     public void onError(Throwable error) {
     56         error.printStackTrace();
     57     }
     58 
     59 
     60     // 连接关闭调用的方法
     61     @OnClose
     62     public void onClose() {
     63         DB.decreaseConnectedClientNum();
     64         DB.webSocketServers.remove(this);
     65         sendMessage2allClients("系统消息:SESSION_ID 为 " + this.session.getId() + " 的客户端断开了连接");
     66     }
     67 
     68 }
    
  5.   1 package me.abdusalam.websocket.demo.controller;
      2 import me.abdusalam.websocket.demo.server.WebSocketServer;
      3 import org.springframework.web.bind.annotation.*;
      4 
      5 @RestController
      6 @RequestMapping("/controller")
      7 public class Controller {
      8 
      9     //推送数据接口
     10     @PostMapping("/sendMessage2allClients")
     11     public void sendMessage2allClients(String message) {
     12         WebSocketServer.sendMessage2allClients( message );
     13     }
     14 }
    
  6.   1 <!DOCTYPE html>
      2 <html lang="en">
      3 <head>
      4     <meta charset="UTF-8">
      5     <title>WebSocket Demo</title>
      6     <script src="https://cdn.bootcss.com/jquery/3.4.1/jquery.min.js"></script>
      7 </head>
      8 <body>
      9 
     10     <h1 style="text-align: center" id="h1"></h1>
     11     <h3 style="padding: 10px">消息展示区:</h3>
     12     <div style="border: 5px solid blue;padding: 10px;" id="div"></div>
     13 
     14     <button onclick="send()">发送</button>
     15 
     16     <script>
     17         if(typeof(WebSocket) == "undefined") {
     18             alert("您的浏览器不支持WebSocket");
     19         }else{
     20 
     21             // 实例化 WebSocket 对象,指定要连接的服务器地址与端口  建立连接
     22             var ws = new WebSocket("ws://localhost:8080/WebSocketServer");
     23 
     24             // 用来消息展示的 div
     25             var div = document.getElementById("div");
     26 
     27             // 打开事件
     28             ws.onopen = function() {
     29                 document.getElementById("h1").innerText = "您已经成功连上服务端了";
     30 
     31                 // 可以使用 ws.send("消息内容") 向服务端发消息
     32             };
     33 
     34             // 获得消息事件
     35             ws.onmessage = function(msg) {
     36                 div.innerHTML = div.innerHTML + "<div style='margin: 10px;'>" + msg.data + "</div>";
     37             };
     38 
     39             // 关闭事件
     40             // ws.onclose = function() {
     41             //    console.log("已关闭");
     42             // };
     43 
     44             // 发生了错误事件
     45             ws.onerror = function() {
     46                 alert("发生了错误");
     47                 //此时可以尝试刷新页面
     48             }
     49 
     50             function send() {
     51                 $.post( '/controller/sendMessage2allClients', {message:prompt("请输入:")}, function(response){} );
     52             }
     53         }
     54     </script>
     55 </body>
     56 </html>
    

    SpringBoot2 集成 WebSocket


    SpringBoot2 集成 WebSocket


    SpringBoot2 集成 WebSocket


    SpringBoot2 集成 WebSocket


    SpringBoot2 集成 WebSocket

点赞
收藏
评论区
推荐文章
光头强的博客 光头强的博客
2个月前
Java面向对象试题
1、 请创建一个Animal动物类,要求有方法eat()方法,方法输出一条语句“吃东西”。 创建一个接口A,接口里有一个抽象方法fly()。创建一个Bird类继承Animal类并实现 接口A里的方法输出一条有语句“鸟儿飞翔”,重写eat()方法输出一条语句“鸟儿 吃虫”。在Test类中向上转型创建b对象,调用eat方法。然后向下转型调用eat()方
刚刚好 刚刚好
2个月前
css问题
1、 在IOS中图片不显示(给图片加了圆角或者img没有父级) <div<img src""/</div div {width: 20px; height: 20px; borderradius: 20px; overflow: h
blmius blmius
1年前
MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1
文章目录 问题 用navicat导入数据时,报错: 原因这是因为当前的MySQL不支持datetime为0的情况。 解决修改sql\mode: sql\mode:SQL Mode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。 全局s
小森森 小森森
2个月前
校园表白墙微信小程序V1.0 SayLove -基于微信云开发-一键快速搭建,开箱即用
后续会继续更新,敬请期待2.0全新版本 欢迎添加左边的微信一起探讨!项目地址:](https://www.aliyun.com/activity/daily/bestoffer?userCodesskuuw5n) \2. Bug修复更新日历 2. 情侣脸功能大家不要使用了,现在阿里云的接口已经要收费了(土豪请随意), \ \ 和 注意
晴空闲云 晴空闲云
2个月前
css中box-sizing解放盒子实际宽高计算
我们知道传统的盒子模型,如果增加内边距padding和边框border,那么会撑大整个盒子,造成盒子的宽度不好计算,在实务中特别不方便。boxsizing可以设置盒模型的方式,可以很好的设置固定宽高的盒模型。 盒子宽高计算假如我们设置如下盒子:宽度和高度均为200px,那么这会这个盒子实际的宽高就都是200px。但是当我们设置这个盒子的边框和内间距的时候,那
艾木酱 艾木酱
1个月前
快速入门|使用MemFire Cloud构建React Native应用程序
> MemFire Cloud是一款提供云数据库,用户可以创建云数据库,并对数据库进行管理,还可以对数据库进行备份操作。它还提供后端即服务,用户可以在1分钟内新建一个应用,使用自动生成的API和SDK,访问云数据库、对象存储、用户认证与授权等功能,可专
Stella981 Stella981
1年前
H5 WebSocket java服务端push
1.pom <dependency> <groupId>javax</groupId> <artifactId>javaee-api</artifactId> <version>7.0</version> </dependency> 这里使用javax.websocket,没有使用springmvc.webs
Wesley13 Wesley13
1年前
MySQL查询按照指定规则排序
1.按照指定(单个)字段排序 select * from table_name order id desc; 2.按照指定(多个)字段排序 select * from table_name order id desc,status desc; 3.按照指定字段和规则排序 selec
Stella981 Stella981
1年前
Redis使用
1.配置  <dependency>             <groupId>org.springframework.boot</groupId>             <artifactId>spring-boot-starter-data-redis</artifactId>             <exclusions>    
helloworld_28799839 helloworld_28799839
2个月前
常用知识整理
# Javascript ## 判断对象是否为空 ```js Object.keys(myObject).length === 0 ``` ## 经常使用的三元运算 > 我们经常遇到处理表格列状态字段如 `status` 的时候可以用到 ``` vue