千牛网站上的店铺推广怎么做,企业人事管理系统,关于做一动物网站的界面个,网站建设服务公司案例在当前微服务项目中#xff0c;由于业务模块众多#xff0c;消息服务的使用场景变得异常活跃。而WebSocket由于其自身的可靠性强#xff0c;实时性好#xff0c;带宽占用更小的优势#xff0c;在实时通讯应用场景中独占鳌头#xff0c;加上HTML5标准的普及流行#xff0…在当前微服务项目中由于业务模块众多消息服务的使用场景变得异常活跃。而WebSocket由于其自身的可靠性强实时性好带宽占用更小的优势在实时通讯应用场景中独占鳌头加上HTML5标准的普及流行在前端和后端开发中应用异常广泛。
一.关于WebSocket
1.WebSocket是什么?
WebSocket是基于TCP的一种新的网络协议。它实现了浏览器与服务器全双通信——浏览器和服务器只需要完成一次握手两者之间就可以创建持久性的连接并进行双向数据传输。简单来说它就是html5中的一种新的协议其实质就是对html的长连接的一种升级。
2.与HTTP比较
HTTP是短连接WebSocket是长连接HTTP通信是单向的基于请求响应模式WebSocket支持双向通信HTTP和WebSocket底层都是TCP连接。
3.WebSocket优点
websocket连接只需要建立一次在第一次连接的时候客户端和服务器会交换必要的信息。websocket是双向通信的对比ajax请求还是长轮询他们都是通过客户端发送请求服务器响应的形式完成信息的交换这种模式下服务器处于一种被动的角色。而websocket不存在这个问题websocket的链接一旦建立服务器和客户端都可以互推信息。
二. WebSocket使用
文案基于jdk1.8maven3.8.1springboot2.7.13而编写
1.引入websocket.jar包 !-- websocket模块--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-websocket/artifactId/dependency
2.配置WebSocket
Configuration
public class MyWebSocketConfig {Beanpublic ServerEndpointExporter serverEndpointExporter() {return new ServerEndpointExporter();}}
3.WebSocket连接发送和接收信息
ServerEndpoint(/websocket/test)
Component
public class TestWebSocketInfo {/*** 静态变量用来记录当前在线连接数。应该把它设计成线程安全的。*/private static int ONLINE_COUNT 0;/*** concurrent包的线程安全Set用来存放每个客户端对应的BigScreenWebSocket对象。*/private static CopyOnWriteArraySetTestWebSocketInfo WEB_SOCKET_SET new CopyOnWriteArraySet();/*** 存储新链接标识。*/public static MapString, Object USER_SESSIONS new HashMap(0);/*** 与某个客户端的连接会话需要通过它来给客户端发送数据。*/private Session session;/*** 连接建立成功调用的方法*/OnOpenpublic void onOpen(Session session) throws Exception {this.session session;// 生成唯一IDString uuid String.valueOf(UUID.randomUUID());// 把唯一标识跟客户端绑定USER_SESSIONS.put(uuid, this.session);// 加入set中WEB_SOCKET_SET.add(this);synchronized (this) {// 使用加锁的方式保证请求串行计数TestWebSocketInfo.ONLINE_COUNT;}//需要发送到业务数据onMessage(JSONObject.toJSONString(Hello,Websocket));System.out.println(有新连接加入当前在线人数为 getOnlineCount());}/*** 连接关闭调用的方法*/OnClosepublic void onClose() {// 从set中删除WEB_SOCKET_SET.remove(this);boolean removeFlag WEB_SOCKET_SET.remove(this);// 使用加锁的方式保证请求串行计数if (removeFlag BigScreenWebSocketInfo.ONLINE_COUNT 0) {TestWebSocketInfo.ONLINE_COUNT--;}System.out.println(有一连接关闭当前在线人数为 getOnlineCount());}/*** 收到客户端消息后调用的方法** param message 客户端发送过来的消息*/OnMessagepublic void onMessage(String message) {sendMessage(message);}/*** 发生错误时调用** param session* param error*/OnErrorpublic void onError(Session session, Throwable error) {// 从set中删除USER_SESSIONS.remove(session);// 从set中删除boolean removeFlag WEB_SOCKET_SET.remove(this);USER_SESSIONS.remove(session);// 使用加锁的方式保证请求串行计数if (removeFlag BigScreenWebSocketInfo.ONLINE_COUNT 0) {TestWebSocketInfo.ONLINE_COUNT--;}System.out.println(发生错误);error.printStackTrace();}public void sendMessage(String message) {try {for (TestWebSocketInfo item : WEB_SOCKET_SET) {// 判断链接是否关闭if (item.session.isOpen()) {synchronized (item.session) {item.session.getBasicRemote().sendText(message);}}}} catch (Exception e) {e.printStackTrace();}}public static synchronized int getOnlineCount() {return ONLINE_COUNT;}
}
4.功能测试
当服务端开发完成之后可以使用https://wstool.js.org/该网址自主连接测试
