Springboot整合Websocket实现后端向前端主动推送消息案例
发布时间：2025-11-05 12:09:22 来源：云智核 作者：域名
在手机上相信都有来自服务器的整合主动推送消息，比如一些及时的现后消息新闻信息，这篇文章主要就是前端实现这个功能，只演示一个基本的推送案例。使用的案例是websocket技术。
一、整合主动什么是现后消息websocke
tWebSocket协议是基于TCP的一种新的网络协议。它实现了客户端与服务器全双工通信，前端学过计算机网络都知道，推送既然是案例全双工，就说明了服务器可以主动发送信息给客户端。整合主动这与我们的现后消息推送技术或者是多人在线聊天的功能不谋而合。
为什么不使用HTTP 协议呢?前端这是因为HTTP是单工通信，通信只能由客户端发起，推送客户端请求一下，b2b供应网案例服务器处理一下，这就太麻烦了。于是websocket应运而生。
下面我们就直接开始使用Springboot开始整合。以下案例都在我自己的电脑上测试成功，你可以根据自己的功能进行修改即可。
二、整合websocket
1、环境配置
Idea 2018专业版(已破解)
Maven 4.0.0
SpringBoot 2.2.2
websocket 2.1.3
jdk 1.8
下面我们新建一个普通的Springboot项目。
2、添加依赖
<dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-websocket</artifactId> <version>2.1.3.RELEASE</version> </dependency> </dependencies>3、在application.properties文件修改端口号
一句话：server.port=8081
4、新建config包，创建WebSocketConfig类
1@Configuration 2public class WebSocketConfig { 3 @Bean 4 public ServerEndpointExporter serverEndpointExporter() { 5 return new ServerEndpointExporter(); 6 } 7}5、新建service包，创建WebSocketServer类
@ServerEndpoint("/websocket/{sid}") @Component public class WebSocketServer { static Log log= LogFactory.getLog(WebSocketServer.class); //静态变量，用来记录当前在线连接数。应该把它设计成线程安全的。 private static int onlineCount = 0; //concurrent包的线程安全Set，用来存放每个客户端对应的MyWebSocket对象。 private static CopyOnWriteArraySet<WebSocketServer> webSocketSet = new CopyOnWriteArraySet<WebSocketServer>(); //与某个客户端的连接会话，需要通过它来给客户端发送数据 private Session session; //接收sid private String sid=""; /** * 连接建立成功调用的源码库方法 */ @OnOpen public void onOpen(Session session,@PathParam("sid") String sid) { this.session = session; webSocketSet.add(this); //加入set中 addOnlineCount(); //在线数加1 log.info("有新窗口开始监听:"+sid+",当前在线人数为" + getOnlineCount()); this.sid=sid; try { sendMessage("连接成功"); } catch (IOException e) { log.error("websocket IO异常"); } } /** * 连接关闭调用的方法 */ @OnClose public void onClose() { webSocketSet.remove(this); //从set中删除 subOnlineCount(); //在线数减1 log.info("有一连接关闭！当前在线人数为" + getOnlineCount()); } /** * 收到客户端消息后调用的方法 * @param message 客户端发送过来的消息 */ @OnMessage public void onMessage(String message, Session session) { log.info("收到来自窗口"+sid+"的信息:"+message); //群发消息 for (WebSocketServer item : webSocketSet) { try { item.sendMessage(message); } catch (IOException e) { e.printStackTrace(); } } } @OnError public void onError(Session session, Throwable error) { log.error("发生错误"); error.printStackTrace(); } //实现服务器主动推送 public void sendMessage(String message) throws IOException { this.session.getBasicRemote().sendText(message); } //群发自定义消息 public static void sendInfo(String message,@PathParam("sid") String sid) throws IOException { log.info("推送消息到窗口"+sid+"，推送内容:"+message); for (WebSocketServer item : webSocketSet) { try { //这里可以设定只推送给这个sid的，为null则全部推送 if(sid==null) { item.sendMessage(message); }else if(item.sid.equals(sid)){ item.sendMessage(message); } } catch (IOException e) { continue; } } } public static synchronized int getOnlineCount() { return onlineCount; } public static synchronized void addOnlineCount() { WebSocketServer.onlineCount++; } public static synchronized void subOnlineCount() { WebSocketServer.onlineCount--; }6、新建controller包，创建Mycontroller类
@Controller public class MyController { //页面请求 @GetMapping("/socket/{cid}") public ModelAndView socket(@PathVariable String cid) { ModelAndView mav=new ModelAndView("/socket"); mav.addObject("cid", cid); return mav; } //推送数据接口 @ResponseBody @RequestMapping("/socket/push/{cid}") public String pushToWeb(@PathVariable String cid,String message) { try { WebSocketServer.sendInfo(message,cid); } catch (IOException e) { e.printStackTrace(); return "推送失败"; } return "发送成功"; } }}7、新建一个websocket.html页面
<html> <head> <meta name="viewport" content="initial-scale=1.0, user-scalable=no" /> <script type="text/javascript"> var socket; if (typeof (WebSocket) == "undefined") { console.log("您的浏览器不支持WebSocket"); } else { console.log("您的浏览器支持WebSocket"); //实现化WebSocket对象，指定要连接的服务器地址与端口 建立连接 socket = new WebSocket("ws://localhost:8081/websocket/1"); //打开事件 socket.onopen = function () { console.log("Socket 已打开"); socket.send("这是来自客户端的消息" + location.href + new Date()); }; //获得消息事件 socket.onmessage = function (msg) { console.log(msg.data); }; //关闭事件 socket.onclose = function () { console.log("Socket已关闭"); }; //发生了错误事件 socket.onerror = function () { alert("Socket发生了错误"); } } </script> </head> </html>现在开发服务器和网页就可以看到效果了。一般情况下Springboot2+Netty+Websocket的组合方式更加的常用一下。这个只是给出了一个基本的案例，你可以根据自己的需求进行更改。
本文转载自微信公众号「愚公要移山」，可以通过以下二维码关注。转载本文请联系愚公要移山公众号。
- 电脑音乐键盘制作教程——打造你的个人音乐天地（从零开始，教你制作独一无二的电脑音乐键盘！）
- Win 7系统中正确配置ipv6协议地址的方法介绍
- windows 7怎么使用休眠功能具体实现步骤
- windows7自动播放自动运行功能禁用图解
- 你可能已经知道如何将你的 Ubuntu 桌面升级到最新版本了，不过假如你用的 Ubuntu Server，而且也正好又希望升级一下的话（前提是，不会影响你的应用。一般来说，对于服务器操作系统，应该采用保守态度。假如不是必须升级才能解决的安全问题，最好不要升级，而是采用各种外部手段来解决。）假如想从Ubuntu14.04/13.10/13.04/12.10/12.04或者更老的版本升级到14.10，只要遵循下面给出的步骤。注意，你不能直接从13.10升级到14.10。你应该先将13.10升级到14.04在从14.04升级到14.10。下面是详细步骤。下面的步骤不仅能用于14.10，也兼容于一些像Lubuntu14.10，Kubuntu14.10和Xubuntu14.10等的Ubuntu衍生版本重要：在升级之前，保险起见，不要忘了将你的数据在U盘或外部硬盘上保存一下。服务器升级从ubuntu14.04的服务器升级到14.10的服务器，采用下面的步骤。安装update-manager-core 这个包假如之前没唷安装的话：复制代码代码如下:sudo apt-get install update-manager-core编辑 /etc/update-manager/release-upgrades这个文件。复制代码代码如下:sudo nano /etc/update-manager/release-upgrades像下面那样设置Prompt=normal或者Prompt=lts复制代码代码如下:# Default behavior for the release upgrader. [DEFAULT] # Default prompting behavior, valid options: # # never - Never check for a new release. # normal - Check to see if a new release is available. If more than one new # release is found, the release upgrader will attempt to upgrade to # the release that immediately succeeds the currently-running # release. # lts - Check to see if a new LTS release is available. The upgrader # will attempt to upgrade to the first LTS release available after # the currently-running one. Note that this option should not be # used if the currently-running release is not itself an LTS # release, since in that case the upgrader wont be able to # determine if a newer release is available. Prompt=normal现在可以通过下面的命令来更新你的服务系统了。复制代码代码如下:sudo do-release-upgrade -d直到屏幕提示你已完成。
- windows 8系统关闭操作中心方法步骤
- 自己动手安装一个纯净的Window7系统全过程分享
- 重装windows 7过程中用户需要注意的事项例如一些初始化设置
- 海信i630m手机（性能强大、拍照出色，海信i630m让你的生活更便捷）
- windows 7系统升级VirtualBox后无法打开新任务错误代码0x8000400
- 宸景光电（从光电产品到智能科技，宸景光电引领行业变革）
- windows7/windows8系统点击关机后提示确认关机的解决方法
- windows 7系统电脑硬盘指示灯一直闪不停的三种解决办法
- windows 7我的电脑中无法看到摄像头图标的解决方法
- 双4a手机的卓越表现与绝佳用户体验（领先市场的性能与创新，重新定义智能手机）
- Windows7系统如何添加或删除输入法操作图解
- windows 7|windows 8.1更新kb3045645后无法安装语言包解决办法
- windows 7系统开启或关闭自动连接无线网络具体步骤
- 要想使用命令行安装和卸载软件，当然得事先知道要安装或卸载的软件包名称。而APT 是基于Debian 的Linux 发行版(包括Ubuntu)包管理命令，使用 apt-cache 我们便可以找出系统中包相关的元数据信息，本文中将就将向大家介绍如何查看Ubuntu 安装包信息。使用apt-cache假如要列出 Ubuntu 系统中所有可用的软件包，我们只需执行如下命令：复制代码代码如下:apt-cache pkgnames | less该命令中的 | less 管道输出，可以让我们在数据较多时通过上、下箭头或“PgUp” 及“PgDn” 来滚动查看。当我们不找到所需包名或不需要滚动查看时，只需按 q 即可退出。假如你知道软件包名的开头字符，我们便可以使用搜索功能来缩小范围。例如要查看Firefox 的包名，则可使用类似如下命令：复制代码代码如下:apt-cache pkgnames firef 使用上述命令，我们便可以查看到所有以 firef 开头的软件包。当我们知道包名后，要显示软件包的详细信息，例如：版本号、大小、校验值和软件描述等信息时，则可使用 show 选项来进行查看：复制代码代码如下:apt-cache show firefox 当大家要查看某个软件包所需依赖及哪些包依赖于该软件包时，则需要使用 showpkg 选项：复制代码代码如下:apt-cache showpkg firefox 当我们需要查看当前 Ubuntu 不同类型包的统计及整体统计信息时，可以使用 stats 选项：复制代码代码如下:apt-cache stats 要了解某个软件包的迁移及相关说明时，我们可以使用search 选项：复制代码代码如下:apt-cache search firefox-locale-zh-hans 使用axi-cacheaxi-cache 可以算是apt-cache 命令的孪生兄弟，但它可以提供的描述信息和相关性更强。我们还是以Firefox 来举个例子：复制代码代码如下:axi-cache search firef 该命令默认中显示20条结果：查看更多信息可使用如下命令：复制代码代码如下:axi-cache more 以上就是告诉大家Ubuntu安装包信息是如何查看的，希望该文对大家的学习有所帮助。
- Windows7系统如何取消U盘自动运行功能 windows 7设置关闭U盘自动
随便看看
IT资讯网服务器租用IT技术网香港云服务器益华科技企商汇源码库源码下载亿华云益强前沿资讯汇智坊亿华科技极客编程编程之道云智核益华IT技术论坛IT资讯网益强数据堂云站无忧益强智囊团益强科技益华科技码力社亿华智慧云全栈开发科技前瞻运维纵横益华科技亿华云计算技术快报益强编程堂创站工坊亿华云亿华灵动思维库益强科技智能时代亿华互联益强IT技术网益强编程舍亿华智造码上建站益强资讯优选
- Copyright © 2025 Powered by Springboot整合Websocket实现后端向前端主动推送消息案例,云智核 滇ICP备2023006006号-28sitemap