org.springframework.boot
spring-boot-starter-websocket
加入配置类
@Configuration
public class WebSocketConfig {
/**
-
注入ServerEndpointExporter，
-
这个bean会自动注册使用了@ServerEndpoint注解声明的Websocket endpoint
*/
@Bean
public ServerEndpointExporter serverEndpointExporter() {
return new ServerEndpointExporter();
}
}
加入连接发送消息方法
@Component
@ServerEndpoint(“/websocket/{userName}”)
// 此注解相当于设置访问URL
public class WebSocket {
private Session session;
private static CopyOnWriteArraySet webSockets = new CopyOnWriteArraySet<>();
private static Map<String, Session> sessionPool = new HashMap<String, Session>();
private final static Logger logger = LoggerFactory.getLogger(LoginIntercept.class);
@OnOpen
public void onOpen(Session session, @PathParam(value = “userName”) String userName) {
this.session = session;
webSockets.add(this);
if (sessionPool.containsKey(userName)) {
sessionPool.put(userName + String.valueOf(session.getId()), session);
} else {
sessionPool.put(userName, session);
}
logger.info(“【websocket消息】有新的连接，总数为:” + webSockets.size());
}
@OnClose
public void onClose() {
webSockets.remove(this);
logger.info(“【websocket消息】连接断开，总数为:” + webSockets.size());
}
@OnMessage
public void onMessage(String message) {
logger.info(“【websocket消息】收到客户端消息:” + message);
}
/**
-
功能描述: 此为广播消息
-
@param: [message] (消息)
-
@return: void ()
*/
public void sendAllMessage(String message) {
for (WebSocket webSocket : webSockets) {
logger.info(“【websocket消息】广播消息:” + message);
try {
if (webSocket.session.isOpen()) {
webSocket.session.getAsyncRemote().sendText(message);
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
/**
-
功能描述:此为单点消息 (发送文本) 现在可以发送给多客户端
-
@param: [userName, message] (接收人,发送消息)
-
@return: void ()
*/
public void sendTextMessage(String userName, String message) {
// 遍历sessionPool
for (String key : sessionPool.keySet()) {
// 存在当前用户
if (key.toString().indexOf(userName) != -1) {
Session session = sessionPool.get(key);
if (session != null && session.isOpen()) {
try {
session.getAsyncRemote().sendText(message);
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
}
/**
-
功能描述: 此为单点消息 (发送文本) 现在可以发送给多客户端
-
@param: [userName, message] (接收人,发送消息)
-
@return: void ()
*/
public void sendObjMessage(String userName, Object message) {
// 遍历sessionPool
for (String key : sessionPool.keySet()) {
// 存在当前用户
if (key.toString().indexOf(userName) != -1) {
Session session = sessionPool.get(key);
if (session != null && session.isOpen()) {
try {
session.getAsyncRemote().sendObject(message);
} catch (Exception e) {
e.printStackTrace();
}
}
}
自我介绍一下，小编13年上海交大毕业，曾经在小公司待过，也去过华为、OPPO等大厂，18年进入阿里一直到现在。
深知大多数前端工程师，想要提升技能，往往是自己摸索成长或者是报班学习，但对于培训机构动则几千的学费，着实压力不小。自己不成体系的自学效果低效又漫长，而且极易碰到天花板技术停滞不前！
因此收集整理了一份《2024年Web前端开发全套学习资料》，初衷也很简单，就是希望能够帮助到想自学提升又不知道该从何学起的朋友，同时减轻大家的负担。
既有适合小白学习的零基础资料，也有适合3年以上经验的小伙伴深入学习提升的进阶课程，基本涵盖了95%以上前端开发知识点，真正体系化！
由于文件比较大，这里只是将部分目录截图出来，每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频，并且会持续更新！
如果你觉得这些内容对你有帮助，可以扫码获取！！（备注：前端）
最后
前端校招精编面试解析大全点击这里免费获取完整版pdf查看文章来源：https://www.toymoban.com/news/detail-852650.html
75883)]
由于文件比较大，这里只是将部分目录截图出来，每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频，并且会持续更新！
如果你觉得这些内容对你有帮助，可以扫码获取！！（备注：前端）
最后
前端校招精编面试解析大全点击这里免费获取完整版pdf查看
文章来源地址https://www.toymoban.com/news/detail-852650.html
到了这里，关于springboot业务功能实战（四）告别轮询，websocket的集成使用的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
