WebSocket服务端配置类

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.stereotype.Service;
import org.springframework.web.socket.config.annotation.EnableWebSocket;
import org.springframework.web.socket.server.standard.ServerEndpointExporter;/*** websocket配置类* @author daiyg* @date 2021/8/24 17:19*/
@Service
@Configuration
@EnableWebSocket
public class WebSocketConfig {@Beanpublic ServerEndpointExporter serverEndpointExporter(){return new ServerEndpointExporter();}
}

服务端代码

import com.caso.common.core.utils.StringUtils;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.stereotype.Component;import javax.websocket.*;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ConcurrentHashMap;/*** @author daiyg* @date 2021/8/24 18:15*/
@Component
@ServerEndpoint(value = "/websocket/{id}/{key}", subprotocols = {"protocol"})
public class WebSocketServer {private static int onlineCount = 0;private static ConcurrentHashMap<String, WebSocketServer> webSocketSet = new ConcurrentHashMap<>();private static  ConcurrentHashMap<String, List<String>> map = new ConcurrentHashMap<>();//与某个客户端的连接会话，需要通过它来给客户端发送数据private Session session;private static Logger log = LogManager.getLogger(WebSocketServer.class);private String id = "";private String key= "";/*** 连接建立成功调用的方法*/@OnOpenpublic void onOpen(@PathParam(value = "id") String id,@PathParam("key") String key, Session session) {this.session = session;this.id = id;//接收到发送消息的人员编号this.key = key;if ("1".equals(id)) {log.info("非门岗用户连接！");} else {List<String> ids = new ArrayList<>();ids = map.get(id);if(StringUtils.isEmpty(ids)){ids = new ArrayList<>();}ids.add(key);map.put(id,ids);webSocketSet.put(key, this);     //加入set中}addOnlineCount();           //在线数加1log.info("用户" + id + "连接成功！当前在线人数为" + getOnlineCount());try {sendMessage("连接成功");} catch (IOException e) {log.error("websocket IO异常");}}/*** 连接关闭调用的方法*/@OnClosepublic void onClose() {//删除map中值List<String> keys = map.get(this.id);for (int i = 0; i < keys.size(); i++) {if(this.key.equals(keys.get(i))){keys.remove(i);i--;}}webSocketSet.remove(this.key);  //从set中删除subOnlineCount();           //在线数减1log.info("有一连接关闭！当前在线人数为" + getOnlineCount());}/*** 收到客户端消息后调用的方法** @param message 客户端发送过来的消息*/@OnMessagepublic void onMessage(String message) {log.info("来自客户端的消息:" + message);}/*** @param session* @param error*/@OnErrorpublic void onError(Session session, Throwable error) {log.error("发生错误");try {session.close();} catch (IOException e) {e.printStackTrace();}error.printStackTrace();}/*** 服务端主动推送消息** @param message* @throws IOException*/public void sendMessage(String message) throws IOException {this.session.getBasicRemote().sendText(message);}/*** 发送信息给指定ID用户，如果用户不在线则返回不在线信息给自己** @param message* @param personKeys* @throws IOException*/public static void sendtoUser(String message, String[] personKeys) throws IOException {//获取人员集合for (String personKey : personKeys) {//获取map中对应的链接if (map.get(personKey) != null && StringUtils.isNotEmpty(map.get(personKey))) {//遍历给连接人发送信息for(String s : map.get(personKey)){webSocketSet.get(s).sendMessage(message);}} else {//如果用户不在线则返回不在线信息给自己log.error("当前用户不在线：" + personKey);}}}/*** 发送信息给所有人** @param* @throws IOException*/public void sendtoAll(String message) throws IOException {for (String key : webSocketSet.keySet()) {try {webSocketSet.get(key).sendMessage(message);} catch (IOException e) {e.printStackTrace();}}}public static synchronized int getOnlineCount() {return onlineCount;}public static synchronized void addOnlineCount() {WebSocketServer.onlineCount++;}public static synchronized void subOnlineCount() {WebSocketServer.onlineCount--;}}

java实现WebSocket服务端相关推荐

基于Redisson实现的延时队列RedissonDelayedQueue实现websocket服务端心跳监听
简介基于Redis的Redisson分布式延迟队列(Delayed Queue)结构的 RDelayedQueue. Java对象在实现了RQueue接口的基础上提供了向队列按要求延迟添加项目的功能 ...
websocket服务端和html客户端进行二进制数据交互
一.概念和理论理解 1.HTTP HTTP 是基于请求响应式的,即通信只能由客户端发起,服务端做出响应,无状态,无连接. 无状态:每次连接只处理一个请求,请求结束后断开连接. 无连接:对于事务处理没有 ...
推广下自己的JAVA开源游戏服务端框架
Carmelo是基于Java的游戏服务端框架,适合于页游和手游.它的主要特点是: 利用Netty实现高效的NIO通信,同时支持TCP/HTTP协议完善的三层架构模型,易扩展通用.完善的sessio ...
Android搭建WebSocket服务端
WebSocket简介 WebSocket协议是基于TCP的一种新的网络协议.它实现了浏览器与服务器全双工(full-duplex)通信--允许服务器主动发送信息给客户端.全双工就是指客户端和服务端可 ...
基于springboot的websocket服务端和客户端demo（简单易上手）
jdk 1.8 1.导入maven依赖  <dependency><groupId>org.springframewo ...
Spring boot 实现 WebSocket服务端
Spring boot 实现 WebSocket服务端这里写目录标题 Spring boot 实现 WebSocket服务端声明准备工作 1. 配置 2. WebSocket服务类 3. 编写客 ...
Java：socket服务端，socket服务端支持多连接，socket客户端，socket客户端支持发送和接受
一.Java之socket服务端新建一个Java工程命名给他先创建一个类在类里面我们做一个main 这里面也需要,创建套接字,IP号,端口号但是java中有一个类 Serve ...
Qt WebSocket服务端的简单Demo
WebSocket服务端:QWebSocketServer 目录 WebSocket服务端:QWebSocketServer **背景**: **QWebSocketServer 简单使用介绍:** ...
python 3.5.2页面_Python 3.5.2实现websocket服务端
最近由于一个项目需要,写了一个简易的websocket服务端程序,其间也参考了网上的很多资料,我将用接下来的几个篇幅说明是怎么实现的,及遇到的一系列埂. 参考 (包括且不限于如下地址) 涉及到的模块 ...

java实现WebSocket服务端

WebSocket服务端

WebSocket服务端配置类

服务端代码

java实现WebSocket服务端相关推荐

最新文章

热门文章