1、引入pom
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-websocket</artifactId></dependency><dependency> <groupId>org.apache.tomcat.embed</groupId> <artifactId>tomcat-embed-websocket</artifactId></dependency>2、配置webSocket类
import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.web.socket.server.standard.ServerEndpointExporter;@Configurationpublic class WebSocketConfig { /** * ServerEndpointExporter 作用 * 这个Bean会主动注册应用@ServerEndpoint注解申明的websocket endpoint * * @return */ @Bean public ServerEndpointExporter serverEndpointExporter() { return new ServerEndpointExporter(); }}3、编写webSocket服务
@ServerEndpoint(value = "/api/applet/websocket")@Componentpublic class AppletWebSocket { /** * 动态变量，用来记录以后在线连接数 */ private volatile static int onlineCount = 0; /** * concurrent包的线程平安Set，用来寄存每个客户端对应的MyWebSocket对象。 */ private volatile static CopyOnWriteArraySet<AppletWebSocket> webSocketSet = new CopyOnWriteArraySet<AppletWebSocket>(); /** * 与某个客户端的连贯会话，须要通过它来给客户端发送数据 */ private Session session; /** * 用户标识 */ private Long userId; /** * 连贯建设胜利调用的办法 * 每次新建链接时，查问该用户的状态 */ @OnOpen public void onOpen(Session session, @PathParam("token") String token) throws IOException, EncodeException { this.session = session; webSocketSet.add(this); addOnlineCount(); } /** * 连贯敞开调用的办法 */ @OnClose public void onClose() { webSocketSet.remove(this); subOnlineCount(); } /** * 收到客户端音讯后调用的办法 * * @param message 客户端发送过去的音讯 */ @OnMessage public void onMessage(String message, Session session) { try { sendMessage(message)); } catch (IOException e) { System.out.println(e); } } /** * 产生谬误时调用 */ @OnError public void onError(Session session, Throwable error) { System.out.println("产生谬误"); error.printStackTrace(); } public void sendMessage(String message) throws IOException { this.session.getBasicRemote().sendText(message); } /** * 群发自定义音讯 */ public static void sendInfo(String message) throws IOException { for (AppletWebSocket item : webSocketSet) { try { item.sendMessage(message); } catch (IOException e) { continue; } } } public static synchronized int getOnlineCount() { return onlineCount; } public static synchronized void addOnlineCount() { AppletWebSocket.onlineCount++; } public static synchronized void subOnlineCount() { AppletWebSocket.onlineCount--; } public CopyOnWriteArraySet<AppletWebSocket> getWebSocketSet() { return webSocketSet; } public Long getUserId() { return userId; } public Session getSession() { return session; }}4、测试接口是否失常
关上在线测试网址：http://coolaf.com/tool/chattest
输出本人的服务地址，记得url是以ws://结尾的
测试失常即可在本人的程序中援用，具体已业务规定为准。
5、集体倡议
AppletWebSocket类中须要退出用户标识，不便零碎被动推送信息时，辨别用户。
可启动多个socket服务。
6、经验的坑
1）本地能够失常连贯，公布到服务器显示404
请依照一下状况查看：
a. nginx配置查看
location /websocket/applet { #websocket 配置 proxy_connect_timeout 4s; proxy_read_timeout 7200s; #超过7200秒（两小时）内没通信则断连 proxy_send_timeout 12s; proxy_set_header Upgrade $http_upgrade; proxy_set_header Connection "upgrade"; proxy_pass http://localhost:8587/websocket/applet;}b. 请ping下你的域名，查看是否指向你服务器的ip地址
win + R 关上dos窗口ping 你的域名我就是这种状况，始终报404，然而我其余接口没问题，查看之后发现是我的www.51bishe.site应用了cdn减速，指向的是减速的地址，导致统一报404.
如果应用域名不行，能够应用ip地址的形式进行测试，放大排查范畴。
c. 如果你的服务器用的是https的加密协议，记得你的soket申请地址是以wss://结尾。
本文由博客一文多发平台 OpenWrite 公布！