django 网站开发,广告版面设计图片,做食品网站,专做企业网站的1 介绍
WebSocket 是基于 TCP 的一种新的网络协议。它实现了浏览器与服务器全双工通信——浏览器和服务器只需要完成一次握手#xff0c;两者之间就可以创建持久性的连接#xff0c; 并进行双向数据传输。
HTTP协议和WebSocket协议对比#xff1a; HTTP是短连接#xff0…1 介绍
WebSocket 是基于 TCP 的一种新的网络协议。它实现了浏览器与服务器全双工通信——浏览器和服务器只需要完成一次握手两者之间就可以创建持久性的连接 并进行双向数据传输。
HTTP协议和WebSocket协议对比 HTTP是短连接一次响应完即消除 WebSocket是长连接持久连接 HTTP通信是单向的基于请求响应模式 WebSocket支持双向通信 HTTP和WebSocket底层都是TCP连接 思考既然WebSocket支持双向通信功能看似比HTTP强大那么我们是不是可以基于WebSocket开发所有的业务功能
WebSocket缺点
服务器长期维护长连接需要一定的成本 各个浏览器支持程度不一 WebSocket 是长连接受网络限制比较大需要处理好重连
结论WebSocket并不能完全取代HTTP它只适合在特定的场景下使用 WebSocket应用场景(数据实时更新)
1). 视频弹幕 2). 网页聊天 3). 体育实况更新 4). 股票基金报价实时更新 2 入门案例
2.1 案例分析
需求实现浏览器与服务器全双工通信。浏览器既可以向服务器发送消息服务器也可主动向浏览器推送消息。
效果展示 实现步骤
1). 直接使用websocket.html页面作为WebSocket客户端
2). 导入WebSocket的maven坐标
3). 导入WebSocket服务端组件WebSocketServer用于和客户端通信
4). 导入配置类WebSocketConfiguration注册WebSocket的服务端组件
5). 导入定时任务类WebSocketTask定时向客户端推送数据 (效果演示) 2.2 代码开发
1). 定义websocket.html页面
!DOCTYPE HTML
html
headmeta charsetUTF-8titleWebSocket Demo/title
/head
bodyinput idtext typetext /button onclicksend()发送消息/buttonbutton onclickcloseWebSocket()关闭连接/buttondiv idmessage/div
/body
script typetext/javascriptvar websocket null;var clientId Math.random().toString(36).substr(2);
//判断当前浏览器是否支持WebSocketif(WebSocket in window){//连接WebSocket节点websocket new WebSocket(ws://localhost:8080/ws/clientId);}else{alert(Not support websocket)}
//连接发生错误的回调方法websocket.onerror function(){setMessageInnerHTML(error);};
//连接成功建立的回调方法websocket.onopen function(){setMessageInnerHTML(连接成功);}
//接收到消息的回调方法websocket.onmessage function(event){setMessageInnerHTML(event.data);}
//连接关闭的回调方法websocket.onclose function(){setMessageInnerHTML(close);}
//监听窗口关闭事件当窗口关闭时主动去关闭websocket连接防止连接还没断开就关闭窗口server端会抛异常。window.onbeforeunload function(){websocket.close();}
//将消息显示在网页上function setMessageInnerHTML(innerHTML){document.getElementById(message).innerHTML innerHTML br/;}
//发送消息function send(){var message document.getElementById(text).value;websocket.send(message);}//关闭连接function closeWebSocket() {websocket.close();}
/script
/html 2). 导入maven坐标
dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-websocket/artifactId
/dependency 3). 定义WebSocket服务端组件 import org.springframework.stereotype.Component;
import javax.websocket.OnClose;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;
import java.util.Collection;
import java.util.HashMap;
import java.util.Map;
/*** WebSocket服务*/
Component
ServerEndpoint(/ws/{sid})
public class WebSocketServer {
//存放会话对象private static MapString, Session sessionMap new HashMap();
/*** 连接建立成功调用的方法*/OnOpenpublic void onOpen(Session session, PathParam(sid) String sid) {System.out.println(客户端 sid 建立连接);sessionMap.put(sid, session);}
/*** 收到客户端消息后调用的方法** param message 客户端发送过来的消息*/OnMessagepublic void onMessage(String message, PathParam(sid) String sid) {System.out.println(收到来自客户端 sid 的信息: message);}
/*** 连接关闭调用的方法** param sid*/OnClosepublic void onClose(PathParam(sid) String sid) {System.out.println(连接断开: sid);sessionMap.remove(sid);}
/*** 群发** param message*/public void sendToAllClient(String message) {CollectionSession sessions sessionMap.values();for (Session session : sessions) {try {//服务器向客户端发送消息session.getBasicRemote().sendText(message);} catch (Exception e) {e.printStackTrace();}}}
} 4). 定义配置类注册WebSocket的服务端组件 import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.server.standard.ServerEndpointExporter;
/*** WebSocket配置类用于注册WebSocket的Bean*/
Configuration
public class WebSocketConfiguration {
Beanpublic ServerEndpointExporter serverEndpointExporter() {return new ServerEndpointExporter();}
} 5). 定义定时任务类定时向客户端推送数据 (体现测试效果*) import com.sky.websocket.WebSocketServer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
Component
public class WebSocketTask {Autowiredprivate WebSocketServer webSocketServer;
/*** 通过WebSocket每隔5秒向客户端发送消息*/Scheduled(cron 0/5 * * * * ?)public void sendMessageToClient() {webSocketServer.sendToAllClient(这是来自服务端的消息 DateTimeFormatter.ofPattern(HH:mm:ss).format(LocalDateTime.now()));}
} 2.3 功能测试
启动服务打开websocket.html页面
浏览器向服务器发送数据 服务器向浏览器间隔5秒推送数据
