当前位置：首页 > news >正文

重庆王网站制作广州seo网站推广平台

news 2025/7/21 13:43:56

重庆王网站制作,广州seo网站推广平台,宁夏住房和城乡建设厅网站首页,体育php网站源码WebSocket是HTML5下一种新的协议，它实现了浏览器与服务器全双工通信，能更好的节省服务器资源和带宽并达到实时通讯的目的在很多项目中，都要用到websocket，使得前端页面与后端页进行实时通信，例如，实时查询…

WebSocket是HTML5下一种新的协议，它实现了浏览器与服务器全双工通信，能更好的节省服务器资源和带宽并达到实时通讯的目的

在很多项目中，都要用到websocket，使得前端页面与后端页进行实时通信，例如，实时查询订单状态、设备状态实时显示到页面。本博文，分为前端页面代码和后端页面代码，在最后有源代码下载链接。前端使用用vue技术，后端使用springboot

一、后端代码

1、websocket代码

@Slf4j
@Component
@ServerEndpoint(value = "/websocket/order")
public class WebsocketProvider {/*** 连接事件，加入注解* @param session*/@OnOpenpublic void onOpen(Session session) {String orderId = WebsocketUtil.getParam(WebsocketUtil.sessionKey, session);log.info("Websocket连接已打开，当前orderId为："+orderId);// 添加到session的映射关系中WebsocketUtil.addSession(orderId, session);//测试发送消息WebsocketUtil.sendMessage(orderId, AjaxResult.success("恭喜，已建立连接"));}/*** 连接事件，加入注解* 用户断开链接* @param session*/@OnClosepublic void onClose(Session session) {String orderId = WebsocketUtil.getParam(WebsocketUtil.sessionKey, session);// 删除映射关系WebsocketUtil.removeSession(orderId);}/*** 当接收到用户上传的消息* @param session*/@OnMessagepublic void onMessage(Session session, String message) {log.info("收到Websocket消息："+message);}/*** 处理用户活连接异常* @param session* @param throwable*/@OnErrorpublic void onError(Session session, Throwable throwable) {try {if (session.isOpen()) {session.close();}} catch (IOException e) {e.printStackTrace();}throwable.printStackTrace();}
}

2、controller发送代码

@Slf4j
@RestController
@RequestMapping("/send")
@Api(tags = "SendController", description = "发送管理")
public class SendController {/*** 相关信息**/@GetMappingpublic String getPayType(String data) {WebsocketUtil.sendMessage("123456", AjaxResult.success(data));return "发送成功";}
}

3、后端向前端发送消息代码

/*** 根据用户ID发送消息** @param result*/public static void sendMessage(String sessionId, AjaxResult result) {sendMessage(sessionId, JSON.toJSONString(result));}/*** 根据用户ID发送消息** @param message*/public static void sendMessage(String sessionId, String message) {Session session = ONLINE_SESSION.get(sessionId);//判断是否存在该用户的session，判断是否还在线if (session == null || !session.isOpen()) {return;}sendMessage(session, message);}

二、VUE前端代码

1、界面代码

<div style="display: flex;"><el-input v-model="sendData" placeholder="请输入要发送的内容"/><el-button type="success" @click="send" style="margin-left: 20px;">发送</el-button></div><div style="margin-top: 25px;margin-bottom: 5px;font-weight: bold;">收到的消息：</div><div v-for="(item,index) in messages"><span>{{item}}</span></div>

2、websocket相关代码

        console.log('进入状态监听*******')var url = payServerUrl+"?orderId="+orderId;//建立webSocket连接proxy.websocket = new WebSocket(url);//打开webSokcet连接时，回调该函数proxy.websocket.onopen = () =>{console.log("连接建立");} //关闭webSocket连接时，回调该函数proxy.websocket.onclose = () =>{console.log("连接关闭");} //接收信息proxy.websocket.onmessage = function (res) {var obj = eval('(' + res.data + ')');console.log(obj)proxy.messages.push(res.data)}