asp图片网站源码,nas wordpress外网,php网站开发实验总结,asp个人网站SpringBoot之WebSocket服务搭建 文章目录 SpringBoot之WebSocket服务搭建1.创建SpringBoot工程2. pom.xml中引入依赖3. application.yml配置4. 主启动类5. 编写MyWebSocket服务类6. 编写测试页面 WebSockets 彻底改变了 Web#xff0c;将笨拙、缓慢的实时交互转变为时尚、低延…SpringBoot之WebSocket服务搭建 文章目录 SpringBoot之WebSocket服务搭建1.创建SpringBoot工程2. pom.xml中引入依赖3. application.yml配置4. 主启动类5. 编写MyWebSocket服务类6. 编写测试页面 WebSockets 彻底改变了 Web将笨拙、缓慢的实时交互转变为时尚、低延迟的体验使其成为动态、用户友好型应用程序的首选。 1.创建SpringBoot工程 在Intellij IDEA工具中使用SpringBoot项目初始化向导新建一个工程,如工程名为yuan-websocket-demo 2. pom.xml中引入依赖
?xml version1.0 encodingUTF-8?
project xmlnshttp://maven.apache.org/POM/4.0.0xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsdparentgroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-parent/artifactIdversion2.3.0.RELEASE/version/parentmodelVersion4.0.0/modelVersionartifactIdyuan-websocket-demo/artifactIddependenciesdependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-websocket/artifactId/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-thymeleaf/artifactId/dependency!-- https://mvnrepository.com/artifact/com.alibaba/fastjson --dependencygroupIdcom.alibaba/groupIdartifactIdfastjson/artifactIdversion1.2.68/version/dependency/dependencies/project3. application.yml配置
server:port: 2001max-http-header-size: 8192
spring:thymeleaf:cache: false4. 主启动类 主启动类中标注开启WebSoket的注解EnableWebSocket package org.yuan;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.web.servlet.ServletComponentScan;
import org.springframework.web.socket.config.annotation.EnableWebSocket;/*** p* Description: br* p* Author:jinshengyuan br* Datetime: 2020-05-29 15:00* /p**/
SpringBootApplication
EnableWebSocket
ServletComponentScan
public class MyWebSocketApplication {public static void main(String[] args) {SpringApplication.run(MyWebSocketApplication.class, args);}
}
5. 编写MyWebSocket服务类
package org.yuan.mysoket;import org.springframework.stereotype.Component;import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;
import java.util.concurrent.CopyOnWriteArraySet;
Component
ServerEndpoint(/myChat)
public class MyWebSocket {private static int onLineCount 0;//记录在线连接数应该做成线程安全的//线程安全set,用来存储每个客户的MyWebSocket对象private static CopyOnWriteArraySetMyWebSocket myWebSockets new CopyOnWriteArraySet();//与某个客户端的连接会话需要通过它来给客户发送数据private Session session;/*** p* Description: 连接建立成功后调用的方法br* p* Author:jinshengyuan br* Datetime: 2020/5/28 22:25* /p** return* since 2020/5/28 22:25*/OnOpenpublic void onOpen(Session session) {System.out.println(连接了哦);this.session session;myWebSockets.add(this);addOnlineCount();System.out.println();}/*** p* Description: 关闭会话连接br* p* Author:jinshengyuan br* Datetime: 2020/5/28 22:39* /p** param* param* return* since 2020/5/28 22:39*/OnClosepublic void onClose(Session session) {myWebSockets.remove(this);subOnlineCount();}/*** p* Description: 发送消息br* p* Author:jinshengyuan br* Datetime: 2020/5/28 22:39* /p* since 2020/5/28 22:39*/OnMessagepublic void onMessage(String message, Session session) {System.out.println(来自客户端的消息 message);for (MyWebSocket socket : myWebSockets) {try {socket.sendMessage(message);} catch (IOException e) {e.printStackTrace();continue;}}}public void sendMessage(String message) throws IOException {this.session.getBasicRemote().sendText(message);}OnErrorpublic void onError(Session session, Throwable error) {System.out.println(发送消息失败);error.printStackTrace();}public static synchronized void addOnlineCount() {MyWebSocket.onLineCount;}public static synchronized void subOnlineCount() {MyWebSocket.onLineCount--;}public static synchronized int getOnLineCount() {return onLineCount;}
}
6. 编写测试页面
index.html如下
!--Lincense: Public Domain
--htmlheadmeta http-equivContent-Type contenttext/html; charsetutf-8titleweb_socket/titlescript typetext/javascriptvar ws;function init() {// Connect to Web Socket.// Change host/port here to your own Web Socket server.ws new WebSocket(ws://localhost:2001/myChat);// Set event handlers.ws.onopen function() {output(onopen);};ws.onmessage function(e) {// e.data contains received string.output(onmessage: e.data);};ws.onclose function() {output(onclose);};ws.onerror function() {output(onerror);};}function onSubmit() {var input document.getElementById(input);// You can send message to the Web Socket using ws.send.ws.send(input.value);output(send: input.value);input.value ;input.focus();}function onCloseClick() {ws.close();}function output(str) {var log document.getElementById(log);var escaped str.replace(//, amp;).replace(//, lt;).replace(//, gt;).replace(//, quot;); // log.innerHTML escaped br log.innerHTML;}/script
/headbody onloadinit();form onsubmitonSubmit(); return false;input typetext idinputinput typesubmit valueSendbutton onclickonCloseClick(); return false;close/button/formdiv idlog/div
/body/html 启动SpringBoot应用后,浏览器中输入地址进行测试http://localhost:2001
