java实现点赞功能
本文实例为大家分享了java实现点赞功能的具体代码，供大家参考，具体内容如下
实现思路：
将点赞的数据先保存到redis中，然后定时同步到数据库
第一步：
在redis中创建二个hash 用于存储 用户点赞记录及记录点赞数
MAP_USER_LIKED :用户点赞的记录 key:记录id::用户id value:1
MAP_USER_LIKED_COUNT:记录点赞数 key: 记录id value:数量
第二步：
创建枚举类
@Getter
public enum LikeStatusEnum {
LIKE(1,"点赞"),
UNLIKE(0,"取消点赞/未点赞");
private Integer code;
private String msg;
LikeStatusEnum(Integer code,String msg){
this.code = code;
this.msg = msg;
}
}
@Getter
public enum RedisHashEnum {
MAP_USER_LIKED("MAP_USER_LIKED"),
MAP_USER_LIKED_COUNT("MAP_USER_LIKED_COUNT");
private String value;
RedisHashEnum(String value){
this.value =value;
}
}
第三步：
将实现类写好
@Service
public class PostRedisServiceImpl implements PostRedisService {
@Resource
private RedisTemplate redisTemplate;
@Autowired(required = false)
public void setRedisTemplate(RedisTemplate redisTemplate){
RedisSerializer serializer = new StringRedisSerializer();
redisTemplate.setKeySerializer(serializer);
redisTemplate.setValueSerializer(serializer);
redisTemplate.setHashKeySerializer(serializer);
redisTemplate.setHashValueSerializer(serializer);
this.redisTemplate = redisTemplate;
}
/**
* 点赞、取消点赞
*
* @param recordId
* @param userId
*/
@Override
public void saveLikeRedis(String recordId, String userId,Integer status) {
String key =recordId+"::"+userId;
redisTemplate.opsForHash().put(RedisHashEnum.MAP_USER_LIKED,key, status);
}
/**
* 从Redis中删除一条点赞数
*
* @param recordId
* @param userId
*/
@Override
public void deleteLikeFromRedis(String recordId, String userId) {
String key =recordId+"::"+userId;
redisTemplate.opsForHash().delete(RedisHashEnum.MAP_USER_LIKED,key);
}
/**
* 该记录 点赞加1
*
* @param recordId
*/
@Override
public void incrementLikedCount(String recordId) {
redisTemplate.opsForHash().increment(RedisHashEnum.MAP_USER_LIKED_COUNT,recordId,1);
}
/**
* 譔记录 点赞减1
*
* @param recordId
*/
@Override
public void decrementLikeCount(String recordId) {
redisTemplate.opsForHash().increment(RedisHashEnum.MAP_USER_LIKED_COUNT,recordId,-1);
}
}
第四步提供接口：
/**
* 进行点赞、取消点赞
*
* @param vo
*/
@Override
public Result addKudos(KudosVo vo) {
if(vo == null){
return Result.error(ResponseMessage.PARAMERROR);
}
if("1".equals(vo.getStatus())){
// 点赞
postRedisService.saveLikeRedis(vo.getRecordId(),vo.getUserId(), LikeStatusEnum.LIKE.getCode());
// 记录+1
postRedisService.incrementLikedCount(vo.getRecordId());
}else if("0".equals(vo.getStatus())){
// 取消点赞 更新状态
postRedisService.saveLikeRedis(vo.getRecordId(),vo.getUserId(), LikeStatusEnum.UNLIKE.getCode());
// postRedisService.deleteLikeFromRedis(vo.getRecordId(),vo.getUserId());
// 记录 -1
postRedisService.decrementLikeCount(vo.getRecordId());
}
return Result.success(ResponseMessage.SUCCESS);
}
最后定时将redis 中的数据同步到数据库
/**每 5 分钟执行一次
* 将点赞人员同步到库中
* */
// @Transactional(rollbackFor =Exception.class)
@Scheduled(cron = "0 */5 * * * ?")
public void transLikdedFromRedis()throws IOException{
List<RedisLikedUserDTO> dtoList = getLikedUserFromRedis();
dtoList.stream().forEach(x->{
// 通过记录及人员id 查询 该 人员是否点赞
LambdaQueryWrapper<WorkCircleRecord> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(WorkCircleRecord::getDeleteIf,true);
queryWrapper.eq(WorkCircleRecord::getId,x.getRecordId());
queryWrapper.like(WorkCircleRecord::getWorkKudosUserIds,x.getUserId());
WorkCircleRecord record = workCircleRecordMapper.selectOne(queryWrapper);
// 点赞
if(record == null&&"1".equals(x.getStatus())){
// 根据记录id 查询
LambdaQueryWrapper<WorkCircleRecord> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(WorkCircleRecord::getDeleteIf,true);
wrapper.eq(WorkCircleRecord::getId,x.getRecordId());
WorkCircleRecord workCircleRecord = workCircleRecordMapper.selectOne(wrapper);
if(workCircleRecord != null){
// 没有此人员 添加
if(StringUtils.isBlank(workCircleRecord.getWorkKudosUserIds())){
// 没有点赞人员
workCircleRecord.setWorkKudosUserIds(x.getUserId());
SysUser user = sysUserMapper.selectById(x.getUserId());
if(user !=null){
workCircleRecord.setWorkKudosUser(user.getRealname());
}
}else {
// 有点赞人员
String userIds = x.getUserId()+","+workCircleRecord.getWorkKudosUserIds();
workCircleRecord.setWorkKudosUserIds(userIds);
SysUser user = sysUserMapper.selectById(x.getUserId());
String userNames = user.getRealname()+workCircleRecord.getWorkKudosUser();
workCircleRecord.setWorkKudosUser(userNames);
}
workCircleRecordMapper.updateById(workCircleRecord);
}
}else if("0".equals(x.getStatus())) {
// 有记录 并取消点赞
// 根据记录id 查询
LambdaQueryWrapper<WorkCircleRecord> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(WorkCircleRecord::getDeleteIf,true);
wrapper.eq(WorkCircleRecord::getId,x.getRecordId());
WorkCircleRecord workCircleRecord = workCircleRecordMapper.selectOne(wrapper);
// 将此点赞人员去除
if(workCircleRecord !=null){
SysUser user = sysUserMapper.selectById(x.getUserId());
List<String> userIds = Arrays.asList(workCircleRecord.getWorkKudosUserIds().split(","));
List<String> userNames =Arrays.asList(workCircleRecord.getWorkKudosUser().split(","));
userIds.remove(x.getUserId());
userNames.remove(user.getRealname());
workCircleRecord.setWorkKudosUserIds(String.join(",",userIds));
workCircleRecord.setWorkKudosUser(String.join(",",userNames));
workCircleRecordMapper.updateById(workCircleRecord);
}
}
});
}
/**获取 所有点赞的人员
* */
public List<RedisLikedUserDTO> getLikedUserFromRedis() throws IOException{
List<RedisLikedUserDTO> dtoList = new ArrayList<>();
// 通过游标获取所有键值对
Cursor<Map.Entry<Object,Object>> cursor = redisTemplate.opsForHash().scan(RedisHashEnum.MAP_USER_LIKED.getValue(),ScanOptions.NONE);
while (cursor.hasNext()){
Map.Entry<Object,Object> map = cursor.next();
String key = map.getKey().toString();
String[] split = key.split("::");
RedisLikedUserDTO dto = new RedisLikedUserDTO();
dto.setRecordId(split[0]);
dto.setUserId(split[1]);
dto.setStatus(Integer.parseInt(map.getValue().toString()));
dtoList.add(dto);
// 将redis 中的记录删除
redisTemplate.opsForHash().delete(RedisHashEnum.MAP_USER_LIKED.getValue(),key);
}
cursor.close();
return dtoList;
}
/**每 5 分钟执行一次
* 将点赞数同步到库中
* */
@Transactional(rollbackFor =Exception.class)
@Scheduled(cron = "0 */5 * * * ?")
public void transLikedCountFromRedis() throws IOException{
// 获取所有的点赞数
List<RedisLikeCountDTO> dtoList = getLikedCountFromRedis();
// 获取所有的记录id
List<String> recordIdList = dtoList.stream().map(x->x.getRecordId()).collect(Collectors.toList());
if(CollectionUtils.isNotEmpty(recordIdList)){
List<WorkCircleRecord> recordList = workCircleRecordMapper.selectBatchIds(recordIdList);
if(CollectionUtils.isNotEmpty(recordList)){
// 通过id 匹配
dtoList.stream().forEach(x->{
recordList.stream().forEach(k->{
if(x.getRecordId().equals(k.getId())){
Integer num = x.getCount()+k.getWorkKudos();
if(num<0){
k.setWorkKudos(0);
}else {
k.setWorkKudos(num);
}
workCircleRecordMapper.updateById(k);
}
});
});
}
}
}
/** 取出所有的点赞数
* */
public List<RedisLikeCountDTO> getLikedCountFromRedis() throws IOException {
List<RedisLikeCountDTO> dtoList = new ArrayList<>();
Cursor<Map.Entry<Object,Object>> cursor= redisTemplate.opsForHash().scan(RedisHashEnum.MAP_USER_LIKED_COUNT, ScanOptions.NONE);
while (cursor.hasNext()){
Map.Entry<Object,Object> map = cursor.next();
// 获取 点赞数
String key = map.getKey().toString();
RedisLikeCountDTO dto = new RedisLikeCountDTO();
dto.setRecordId(key);
dto.setCount(Integer.parseInt(map.getValue().toString()));
dtoList.add(dto);
redisTemplate.opsForHash().delete(RedisHashEnum.MAP_USER_LIKED_COUNT,key);
}
cursor.close();
return dtoList;
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我们。
相关推荐
-
java实现简单点赞功能
本文实例为大家分享了java实现简单点赞功能的具体代码,供大家参考,具体内容如下 需求分析 分析: 1.必须先登录,否则提示2.第一次点赞(顶),点赞操作,点赞数+1,提示顶成功3.第二次点赞(顶),没有操作,提示今天顶过了 核心问题: 1>怎么区分当前请求时顶成功操作(第一次顶)还是今天已经顶过(第二次顶)2>怎么考虑今天已顶过 ----------------------------------------------核心问题需要区分是第一次顶还是的二次顶,这种请求操作属于有状态请求操作,
-
Java用Cookie限制点赞次数(简版)
本文简单利用Cookie技术来简单的限制点赞次数,并不能杜绝游客的恶意点赞. 好了,不啰嗦了,先来看看基础知识: ajax+springMVC+cookie 中间框架你随意,楼主这里用了springMVC,只要取得HttpServletRequest和HttpServletResponse你就可以操作cookie啦 什么是Cookie cookie 是存储于访问者的计算机中的变量.每当同一台计算机通过浏览器请求某个页面时,就会发送这个 cookie.你可以使用 JavaScript 来创建和取回
-
非常全面的Java SpringBoot点赞功能实现
目录 前言 解决方案 青铜版 白银版 黄金版 源码 总结 前言 最近公司在做一个NFT商城的项目,大致就是一个只买卖数字产品的平台,项目中有个需求是用户可以给商品点赞,还需要获取商品的点赞总数,类似下图 起初感觉这功能很好实现,无非就是加个点赞表嘛,后来发现事情并没有这么简单. 一开始的设计是这样的,一共有三张表:商品表.用户表.点赞表,用户点赞的时候把用户id和商品id加到点赞表中,并给对应的商品点赞数+1.看起来没什么问题,逻辑也比较简单,但是测试的时候缺发现了奇怪的bug,点赞数量有时候会
-
Java刷视频浏览量点赞量的实现代码
说明 这几天班主任一直让我们访问一个网页来观察看视频,增加访问次数.每个班级还有指定的名额...而且经过我的测试,点赞次数是在观看视频一会才出现的.. 可是身为计算机专业的 肯定不想一直点啊 点啊 于是我就有了一个大胆的想法 分析 于是我就查看网页的源代码 这行代码是弹出点赞的时间为18s. 18秒后发生了什么呢 ?继续看 可以看到这个弹出点赞的父div为class="video_mask" 而且默认的显示框类型为none,即不显示. 好吧 废话不多说. 主要看下面的 如果我们点击了t
-
java实现点赞功能
本文实例为大家分享了java实现点赞功能的具体代码,供大家参考,具体内容如下 实现思路: 将点赞的数据先保存到redis中,然后定时同步到数据库 第一步: 在redis中创建二个hash 用于存储 用户点赞记录及记录点赞数MAP_USER_LIKED :用户点赞的记录 key:记录id::用户id value:1MAP_USER_LIKED_COUNT:记录点赞数 key: 记录id value:数量 第二步: 创建枚举类 @Getter public enum LikeStatusEnum {
-
Android中Listview点赞功能的实现
最近这段时间一直在看Android,利用Listview去实现点赞功能,下面给大家介绍下基本思路. 基本思路: 进入界面–>获取数据–> 在Listview中显示–> 通过map集合(position,boolean)保存每一行是否被点击–> 利用实体类去保存相应的对象–> get/set方法进行相应值得改变–> 点击一次,相应的数量加1 只实现了点赞功能,踩和赞基本类似. 具体实现如下: 继承自BaseAdapter package com.gz.test_listv
-
java微信支付功能实现源码
提示:仅微信支付功能模块类,可供参考,可点赞 一.java后台实现源码 package cn.xydx.crowdfunding.controller; import cn.xydx.crowdfunding.util.HttpRequest; import cn.xydx.crowdfunding.util.WXPayUtil; import org.json.JSONObject; import org.springframework.stereotype.Controller; impor
-
SpringBoot实现物品点赞功能
前后端分离项目–二手交易平台小程序 SpringBoot----物品收藏功能实现 SpringBoot----评论回复功能实现(数据库设计) SpringBoot----文件(图片)上传与显示(下载) 点赞 这个功能耗费了我挺多时间,简单实现很简单,就++ – .但是还是感觉这种点赞是一个高频率的请求,而且搜的时候我看都是使用redis做缓存.b站也搜到一个视频来着,也是一样的. 效果: 功能: 首先还是一个先发请求返回数据,但是先数据存到了redis中,然后使用springboot定时任务每隔
-
点赞功能使用MySQL还是Redis
目录 1. 新手常犯的错误 2. 使用Iterator的remove()方法 3. 使用for循环正序遍历 4. 使用for循环倒序遍历 5. 使用Iterator的remove()方法 6. 使用for循环正序遍历 7. 使用for循环倒序遍历 这是最近面试时被问到的1道面试题,本篇博客对此问题进行总结分享. 1. 新手常犯的错误 可能很多新手(包括当年的我,哈哈)第一时间想到的写法是下面这样的: public static void main(String[] args) { List<St
-
java实现收藏功能
本文实例为大家分享了java实现收藏功能的具体代码,供大家参考,具体内容如下 需求分析 分析: 1.要求用户必须登录,否则提示2.第一次点击,表示收藏成功,收藏数+1,显示蓝色星星3.第二次点击,表示取消收藏操作,收藏数-1,显示白色星星-------------------------------------核心问题:当前请求时收藏操作,还是取消收藏操作[这类型的操作,称之为有状态的操作]解决方案:第一次请求过来时,留下一个记号,第二次请求时候,根据记号有无决定收藏还是取消收藏引出新问题:记号
-
php+mysql结合Ajax实现点赞功能完整实例
本文实例讲述了php+mysql结合Ajax实现点赞功能的方法.分享给大家供大家参考.具体如下: 要实现点赞功能,有多种实现方式,这里总结一下利用Ajax,php和mysql来实现点赞的数据的功能.具体步骤如下: 一.页面中的HTML代码部分: <span>0</span> <button onclick="goodplus(1);">good+1</button> <span>0</span> <butto
-
java实现屏幕共享功能实例分析
本文实例讲述了java实现屏幕共享功能的方法.分享给大家供大家参考.具体分析如下: 最近在做软件软件工程的课程设计,做一个用于实验室的屏幕监控系统,参考各种前人代码,最后领悟之后要转换自己的代码,初学者都是这样模仿过来的. 说到屏幕监控系统,有教师端和学生端,教师端就是Server端,学生端就做Client端.系统里比较有趣的一个地方应该算是屏幕广播与屏幕监控吧,其余什么点名签到,锁屏,定时关机的,就相对来说简单点. 屏幕广播,在功能实现上面,说白了,就是教师端的机器不断截取屏幕信息,以图片的形