WebSocket设置私信在线离线

WebSocket设置在线离线以及优先展示最近聊天的人

1.设置在线状态

主要逻辑:

1.用户连接之后,首先后端执行onOpen,传入用户的id,然后写入到redis中
RedisConfig.java 中加入
    @Beanpublic RedisTemplate<String, String> redisTemplate() {RedisTemplate<String, String> redisTemplate = new StringRedisTemplate(); // 使用StringRedisTemplate作为基础return redisTemplate;}@Beanpublic ValueOperations<String, String> stringValueOperations(RedisTemplate<String, String> redisTemplate) {return redisTemplate.opsForValue();}
    /*** 连接建立成功调用的方法*/@OnOpenpublic void onOpen(Session session,@PathParam("id") String id) {sessionMap.put(session.getId(), session);userMap.put(session.getId(),id);//使用Redis先缓存到数据库
//        System.out.println(id);long timestamp = System.currentTimeMillis();stringRedisTemplate.opsForValue().set(id,"存在"+timestamp);log.info("[onOpen] 新建连接,session={}, 当前在线人数为:{}", session.getId(), userMap.size());this.sendAllMessage(JSONUtil.toJsonStr(Dict.create().set("users", userMap.values())));//广播所有加入的用户}/*** 连接关闭调用的方法*/@OnClosepublic void onClose(Session session) {//离线先删除redis数据库中元素stringRedisTemplate.delete(userMap.get(session.getId()));//因为我关闭了也就是下线了不能送message  退出有一点点延迟userMap.remove(session.getId());//删除当前用户sessionMap.remove(session.getId());log.info("[onClose] 有一连接关闭,session={}, 当前在线人数为:{}", session.getId(), userMap.size());}
2.前端监听变化
    client.onmessage = (msg) => { //WebSocket 对象的事件监听器,用于处理从服务器接收到的消息。if (msg.data) { // 检查接收到的消息是否存在。let json = JSON.parse(msg.data)if (json.users && json.users.length){this.loadOnline(json);return}if (json.content && (json.fromuser === this.fromUser && json.touser === this.toUser)|| json.touser === this.fromUser && json.fromuser === this.toUser) {  // 说明是两者互相发消息this.messages.push(json) //放到消息队列里this.scrollToBottom()  // 滚动页面到最底部}// 加载消息数字 两者通信如果是对面发来的消息 说明当前正在两个人的通信窗口if (this.toUser === json.fromuser) {this.setUnReadNums()  // 把对方消息设为已读,更新未读消息数量} else {  //用户发给对方的// 可能是当前用户发给对方的消息,或者是其他人通信 都 加载当前用户的未读消息数量 每次监听到通信事件就更新未读记录this.loadUnReadNums()}}}
3.查询在线人数
    //查询所有的在线人数loadOnline(json){// 查询用户是否在线request.get('/user/selectAllOnline').then(res => {//过滤掉自己就可以 //实时刷新res.data = res.data.filter(v => (v.id + '_' + v.name) !== this.fromUser)this.$set(this.users, 'USER', res.data)})},
4.后端进行业务逻辑判断
    public List<User> selectAllOnline(User userNo) {List<User> userList = userMapper.selectAll(userNo);for(User user:userList){String key = Integer.toString(user.getId());String value = stringRedisTemplate.opsForValue().get(key);if(value != null){String username = user.getUsername()+"在线";user.setUsername(username);}}return userList;}
5.注意在WebSocket直接写Redis相关操作会报错
解决方案看该帖子:https://blog.csdn.net/weixin_45730605/article/details/135898294?spm=1001.2014.3001.5502

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/653634.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

HarmonyOS鸿蒙 虚拟像素

Android中&#xff0c;有的sp&#xff0c;dp&#xff0c;dpi&#xff0c;px等概念。 dpi&#xff0c;dots per inch&#xff0c;代表屏幕像素密度。是指屏幕上每英寸&#xff08;1英寸 2.54 厘米&#xff09;距离中有多少个像素点。 dp&#xff0c;device independent pixels&…

python222网站实战(SpringBoot+SpringSecurity+MybatisPlus+thymeleaf+layui)-友情链接管理实现

锋哥原创的SpringbootLayui python222网站实战&#xff1a; python222网站实战课程视频教程&#xff08;SpringBootPython爬虫实战&#xff09; ( 火爆连载更新中... )_哔哩哔哩_bilibilipython222网站实战课程视频教程&#xff08;SpringBootPython爬虫实战&#xff09; ( 火…

github连不上

github连不上 错误提示解决方案steam 采用Hosts加速 错误提示 fatal: unable to access ‘https://github.com/Ada-design/qianduan.git/’: Failed to connect to github.com port 443 after 21073 ms: Couldn’t connect to server 解决方案 下载steam https://steampp.ne…

latent-diffusion model环境配置--我转载的

latent-diffusion model环境配置&#xff0c;这可能是你能够找到的最细的博客了_latent diffusion model 训练 autoencoder-CSDN博客 前言 最近在研究diffusion模型&#xff0c;并对目前最火的stable-diffusion模型很感兴趣&#xff0c;又因为stable-diffusion是一种latent-di…

Mysql大数据量分页优化

前言 之前有看过到mysql大数据量分页情况下性能会很差&#xff0c;但是没有探究过它的原因&#xff0c;今天讲一讲mysql大数据量下偏移量很大&#xff0c;性能很差的问题&#xff0c;并附上解决方式。 原因 将原因前我们先做一个试验&#xff0c;我做试验使用的是mysql5.7.2…

Arm AArch64 alignment(对齐)

数据和指令必须与合适的边界保持对齐(alignment)。访问是否对齐会影响ARM核的性能&#xff0c;并且在将代码从早期的体系结构移植到ARMv8-A时可能会出现可移植性问题。出于性能原因&#xff0c;或者在移植代码时&#xff0c;都值得去注意下对齐问题。本文将讲述了ARMv8-A AArch…

shell 函数与数组

一、Shell函数&#xff1a; 函数的数学表达式 sin cos tan 其实就是定义好了计算公式 函数就是一个功能模块&#xff0c;在函数中写好执行的命令即可 使用函数可以避免代码重复&#xff0c;增加可读性&#xff0c; 简化脚本 使用函数可以将大的工程分割为若干小的功能…

迷宫(蓝桥杯省赛C/C++)

题目描述 本题为填空题&#xff0c;只需要算出结果后&#xff0c;在代码中使用输出语句将所填结果输出即可。 下图给出了一个迷宫的平面图&#xff0c;其中标记为 1 的为障碍&#xff0c;标记为 0 的为可以通行的地方。 010000 000100 001001 110000 迷宫的入口为左上角&am…

初识人工智能,一文读懂贝叶斯优化进阶的知识文集(9)

&#x1f3c6;作者简介&#xff0c;普修罗双战士&#xff0c;一直追求不断学习和成长&#xff0c;在技术的道路上持续探索和实践。 &#x1f3c6;多年互联网行业从业经验&#xff0c;历任核心研发工程师&#xff0c;项目技术负责人。 &#x1f389;欢迎 &#x1f44d;点赞✍评论…

[机器学习]简单线性回归——梯度下降法

一.梯度下降法概念 2.代码实现 # 0. 引入依赖 import numpy as np import matplotlib.pyplot as plt# 1. 导入数据&#xff08;data.csv&#xff09; points np.genfromtxt(data.csv, delimiter,) points[0,0]# 提取points中的两列数据&#xff0c;分别作为x&#xff0c;y …

[BUUCTF]-PWN:pwnable_hacknote解析

先看保护 32位&#xff0c;没开pie&#xff0c;got表可修改 看ida 总的来说就是alloc创建堆块&#xff0c;free释放堆块&#xff0c;show打印堆块内容 但alloc处的函数比较特别&#xff0c;他会先申请一个0x8大小的堆来存放与puts相关的指针 完整exp&#xff1a; from pwn …

<网络安全>《9 入侵防御系统IPS》

1 概念 IPS&#xff08; Intrusion Prevention System&#xff09;是电脑网络安全设施&#xff0c;是对防病毒软件&#xff08;Antivirus Programs&#xff09;和防火墙&#xff08;Packet Filter, Application Gateway&#xff09;的补充。 入侵预防系统&#xff08;Intrusio…

数据结构【图的遍历】

数据结构之图 图的类型定义和存储结构图的遍历遍历的定义图的特点图常用的遍历深度优先搜索 DFS&#xff08;DepthFirstSearch&#xff09;算法实现算法效率分析 广度优先搜索 BFS&#xff08;BreadthFirstSearch&#xff09;算法实现算法效率分析 DFS与BFS算法效率比较 图的类…

第八篇【传奇开心果短博文系列】Python的OpenCV技术点案例示例:深度学习

传奇开心果短博文系列 系列短博文目录Python的OpenCV技术点案例示例系列 短博文目录一、前言二、OpenCV深度学习介绍三、OpenCV常用深度学习算法和实现分别示例代码四、归纳总结 系列短博文目录 Python的OpenCV技术点案例示例系列 短博文目录 一、前言 OpenCV深度学习&…

go 面试题分享

1 判断字符串中字符是否全都不同 问题描述 请实现一个算法&#xff0c;确定一个字符串的所有字符【是否全都不同】。这里我们要 求【不允许使用额外的存储结构】。给定一个string&#xff0c;请返回一个bool 值,true代表所有字符全都不同&#xff0c;false代表存在相同的字…

【UVM源码】UVM Config_db机制使用总结与源码解析

UVM Config_db机制使用总结与源码解析 UVM Config_db机制介绍UVM Config_db 机制引入的背景基本介绍使用方法优缺点&#xff1a; UVM Config_db机制使用示例&#xff1a;UVM Config_db使用高阶规则Config_db资源优先级 UVM Config_db 源码解析 UVM Config_db机制介绍 UVM Conf…

idea引入ojdbc包报错

网上下载或者让同事传两个jar过来&#xff0c;ojdbc6-11.2.0.7.0.jar 以及jconn3.0.jar 放入同一个文件夹中&#xff1a; 在此文件夹中cmd如下&#xff1a;回车&#xff0c;进入cmd控制台。 输入如下两个命令&#xff1a; mvn install:install-file -DgroupIdcom.oracle -Dar…

【网络】:网络套接字

网络套接字 一.网络字节序二.端口号三.socket1.常见的API2.封装UdpSocket 网络通信的本质就是进程间通信。 一.网络字节序 我们已经知道,内存中的多字节数据相对于内存地址有大端和小端之分, 磁盘文件中的多字节数据相对于文件中的偏移地址也有大端小端之分,网络数据流同样有大…

React16源码: React中context-stack的源码实现

context-stack 1 ) 概述 在 context 内部有一个概念是 stack 有一个唯一的stack里面保存各种各样的东西 stack的特性 在更新节点的时候&#xff0c;会把相关的信息入栈 在因为stack就是栈&#xff0c;在里面会存储各种各样的信息在更新节点的时候&#xff0c;每一个节点的信息…

可曾听闻Nginx?

目录 一.简介 二.Nginx的优点 三.反向代理 四.负载均衡 五.动静分离 六.总结 说起Nginx&#xff0c;耳边好像经常听到&#xff0c;但是不知道用来干嘛的。最近用到了&#xff0c;所以我就大概总结了基本知识&#xff0c;它经常与一个词出现在一起——反向代理。那接下来…