- 資訊首頁(yè) > 開(kāi)發(fā)技術(shù) > 編程語(yǔ)言 >
- SpringBoot實(shí)現物品點(diǎn)贊功能
這個(gè)功能耗費了我挺多時(shí)間，簡(jiǎn)單實(shí)現很簡(jiǎn)單，就++ – .但是還是感覺(jué)這種點(diǎn)贊是一個(gè)高頻率的請求，而且搜的時(shí)候我看都是使用redis做緩存。b站也搜到一個(gè)視頻來(lái)著(zhù)，也是一樣的。
首先還是一個(gè)先發(fā)請求返回數據，但是先數據存到了redis中，然后使用springboot定時(shí)任務(wù)每隔一定時(shí)間將數據存到mysql中。這樣可以防止redis掛掉之后數據丟失。
MySQL使用了一張表和另外幾張表的一個(gè)字段，一張存放點(diǎn)贊信息，就是誰(shuí)點(diǎn)贊了誰(shuí)在啥時(shí)候。字段存放點(diǎn)贊數量。就是物品信息表。評論表這些。
-
redis，使用的是hash數據結構，redis_liked存放點(diǎn)贊數據，redis_liked_count存放點(diǎn)贊數量數據。
對于 “1：：字符串：：1 ” 這個(gè)是一種存放方式，前面1為objid就是被點(diǎn)贊物品或者評論id，字符串為微信openid每個(gè)用戶(hù)唯一id,后面1為類(lèi)型區分點(diǎn)贊的是物品還是主評論，子評論。
對于 "\"0\"" 這個(gè)數據則是點(diǎn)贊的狀態(tài)，1為點(diǎn)贊0為取消點(diǎn)贊對于"1::1"這個(gè)前面1是objid就是物品或者子、主評論id,后面則是區別是哪個(gè)類(lèi)型。“0”就是點(diǎn)贊數量。
前端就發(fā)like或者取消unlike請求
package com.w.wx.controller;
import com.w.wx.domain.Msg;
import com.w.wx.service.impls.RedisServiceImpl;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@Slf4j
@RestController
@RequestMapping("/wx/liked")
public class LikedContro {
@Autowired
private RedisServiceImpl redisService;
/**
* 保存點(diǎn)贊數據到redis
* 點(diǎn)贊數+1
* 同一個(gè)不能點(diǎn)贊兩次
* @param objId
* @param openid
* @param type
* @return
*/
@RequestMapping("like")
public Msg saveLikedToRedis(Integer objId,String openid , String type){
redisService.incrementLikedCount(objId, type, openid);
redisService.saveLikedToRedis(objId,openid,type);
int oneInfoCount = redisService.getOneInfoCount(objId, type);
return Msg.success().add("count",oneInfoCount);
}
@RequestMapping("unlike")
public Msg decrementLikedCount(Integer objId,String openid,String type){
redisService.decrementLikedCount(objId,type,openid);
redisService.unlikeFromRedis(objId,openid,type);
int oneInfoCount = redisService.getOneInfoCount(objId, type);
return Msg.success().add("count",oneInfoCount);
}
//恢復redis
@RequestMapping("restore")
public Msg restoreRedisCountInfo(){
redisService.savaInfoFromDb2Re(0);
redisService.savaInfoFromDb2Re(1);
redisService.savaInfoFromDb2Re(2);
return Msg.success();
}
}
操作redis代碼
package com.w.wx.service.impls;
import com.w.wx.mapper.LikedMapper;
import com.w.wx.domain.Liked;
import com.w.wx.service.ImagesService;
import com.w.wx.service.RedisService;
import com.w.wx.utils.RedisKeyUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.Cursor;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ScanOptions;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
@Service
@Slf4j
public class RedisServiceImpl implements RedisService {
@Autowired
private RedisTemplate redisTemplate;
@Autowired
private LikedServiceImpl likedService;
@Autowired
private ImagesService imagesService;
/**
* 保存數據到redis
* @param objId
* @param openid
* @param type
*/
@Override
public void saveLikedToRedis(Integer objId, String openid,String type) {
imagesService.addLikedNotice(objId, openid,type);
String likedKey = RedisKeyUtils.getLikedKey("" + objId, openid,type);
redisTemplate.opsForHash().put(RedisKeyUtils.MAP_KEY_USER_LIKED,likedKey, "1");
}
/**
* 取消點(diǎn)贊
* @param objId
* @param openid
* @param type
*/
@Override
public void unlikeFromRedis(Integer objId, String openid,String type) {
String likedKey = RedisKeyUtils.getLikedKey("" + objId, openid,type);
redisTemplate.opsForHash().put(RedisKeyUtils.MAP_KEY_USER_LIKED,likedKey, "0");
}
/**
* 刪除數據，沒(méi)有用到
* @param objId
* @param openid
* @param type
*/
@Override
public void deleteFromRedis(Integer objId, String openid,String type) {
String key = RedisKeyUtils.getLikedKey("" + objId, openid,type);
redisTemplate.opsForHash().delete(RedisKeyUtils.MAP_KEY_USER_LIKED, key);
}
/**
* 自增，點(diǎn)贊數++
* @param objId
* @param type
* @param openid
* @return
*/
@Override
public Long incrementLikedCount(Integer objId,String type, String openid) {
String key = RedisKeyUtils.getLikedKey("" + objId,type);
String likedKey = RedisKeyUtils.getLikedKey("" + objId, openid,type);
//根據定時(shí)器時(shí)長(cháng)有延遲
// if(likedMapper.selectByObjIdAndOpenid(objId,openid,Integer.valueOf(type)).getLikeStatus()==0){
// redisTemplate.opsForHash().increment(RedisKeyUtils.MAP_KEY_USER_LIKED_COUNT, key, 1);
// }
//防止重復點(diǎn)贊
if("0".equals(redisTemplate.opsForHash().get(RedisKeyUtils.MAP_KEY_USER_LIKED,likedKey))
|| redisTemplate.opsForHash().get(RedisKeyUtils.MAP_KEY_USER_LIKED,likedKey) == null){
return redisTemplate.opsForHash().increment(RedisKeyUtils.MAP_KEY_USER_LIKED_COUNT, key, 1);
}
return null;
}
@Override
public void decrementLikedCount(Integer objId,String type, String openid) {
String key = RedisKeyUtils.getLikedKey("" + objId,type);
String likedKey = RedisKeyUtils.getLikedKey("" + objId, openid,type);
// if(likedMapper.selectByObjIdAndOpenid(objId,openid,Integer.valueOf(type)).getLikeStatus()==1){
// redisTemplate.opsForHash().increment(RedisKeyUtils.MAP_KEY_USER_LIKED_COUNT, key, -1);
// }
if("1".equals(redisTemplate.opsForHash().get(RedisKeyUtils.MAP_KEY_USER_LIKED,likedKey))){
redisTemplate.opsForHash().increment(RedisKeyUtils.MAP_KEY_USER_LIKED_COUNT, key, -1);
}
}
/**
* 獲取redis中存放的點(diǎn)贊數據然后存放到mysql做持久化
* @return
*/
@Override
public List<Liked> getLikedDataFromRedis() {
Cursor<Map.Entry<Object, Object>> cursor = redisTemplate.opsForHash().scan(RedisKeyUtils.MAP_KEY_USER_LIKED, ScanOptions.NONE);
List<Liked> list = new ArrayList<>();
while (cursor.hasNext()){
Map.Entry<Object, Object> entry = cursor.next();
String key = (String) entry.getKey();
String[] split = key.split("::");
int status = Integer.parseInt((String) entry.getValue());
Liked like = new Liked();
like.setObjId(Integer.valueOf(split[0]));
like.setUserOpenid(split[1]);
like.setType(Integer.valueOf(split[2]));
like.setLikeStatus(status);
list.add(like);
//存到 list 后從 Redis 中刪除
// redisTemplate.opsForHash().delete(RedisKeyUtils.MAP_KEY_USER_LIKED, key);
}
return list;
}
//獲取redis中點(diǎn)贊數量
@Override
public Cursor<Map.Entry<Object, Object>> getLikedCountFromRedis() {
Cursor<Map.Entry<Object, Object>> cursor = redisTemplate.opsForHash().scan(RedisKeyUtils.MAP_KEY_USER_LIKED_COUNT, ScanOptions.NONE);
//redisTemplate.opsForHash().delete(RedisKeyUtils.MAP_KEY_USER_LIKED_COUNT);
return cursor;
}
@Override
public int getOneInfoCount(Integer objId, String type) {
String key = RedisKeyUtils.getLikedKey("" + objId,type);
return (int)redisTemplate.opsForHash().get(RedisKeyUtils.MAP_KEY_USER_LIKED_COUNT,key);
}
public void saveCountInfo(Integer objId,Integer type,Integer count){
String key = RedisKeyUtils.getLikedKey("" + objId,""+type);
redisTemplate.opsForHash().put(RedisKeyUtils.MAP_KEY_USER_LIKED_COUNT,key,count);
}
//redis掛掉后通過(guò)mysql中數據恢復redis
@Override
public void savaInfoFromDb2Re(Integer type) {
List<Map<String,Object>> likeds = likedService.selectLikedInfoByType(type);
if (likeds.isEmpty()||likeds.equals("")){
return;
}
Iterator<Map<String,Object>> it = likeds.listIterator();
while(it.hasNext()){
Map<String,Object> map = it.next();
Integer objId = (Integer) map.get("objId");
Integer count = Integer.parseInt(map.get("num_liked").toString());
log.info("objId:"+objId+"count:"+count+"type:"+type);
saveCountInfo(objId,type,count);
}
}
}
操作mysql代碼
package com.w.wx.service.impls;
import com.w.wx.mapper.CommentsInfoMapper;
import com.w.wx.mapper.CommentsReplyMapper;
import com.w.wx.mapper.GoodsMapper;
import com.w.wx.mapper.LikedMapper;
import com.w.wx.domain.CommentsInfo;
import com.w.wx.domain.Liked;
import com.w.wx.service.LikedService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.Cursor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.sql.Timestamp;
import java.util.*;
@Service
@Slf4j
public class LikedServiceImpl implements LikedService {
@Autowired
private RedisServiceImpl redisService;
@Autowired
private LikedMapper likedMapper;
@Autowired
private CommentsInfoMapper commentsInfoMapper;
@Autowired
private CommentsReplyMapper commentsReplyMapper;
@Autowired
private GoodsMapper goodsMapper;
/**
* 將緩存中點(diǎn)贊記錄持久化到數據庫
*/
@Override
@Transactional
public void transLikedFromRedisToDB() {
List<Liked> likeds = redisService.getLikedDataFromRedis();
for (Liked like : likeds) {
Date date = new Date();
Timestamp timestamp = new Timestamp(date.getTime());
//首先判斷之前是否有
Liked liked = likedMapper.selectByObjIdAndOpenid(like.getObjId(),like.getUserOpenid(),like.getType());
if(liked==null ){
//沒(méi)有則新增
like.setCreateTime(timestamp);
likedMapper.insert(like);
}else{
//有則更新
likedMapper.updateByPrimaryKey(liked.getLikeId(),like.getLikeStatus(),timestamp);
}
}
}
/**
* 將點(diǎn)贊數量持久化到數據庫
*/
@Override
@Transactional
public void transLikedCountFromRedisToDB() {
Cursor<Map.Entry<Object, Object>> cursor = redisService.getLikedCountFromRedis();
while (cursor.hasNext()){
Map.Entry<Object, Object> map = cursor.next();
String key = (String)map.getKey();
//分離出objId和type
String[] split = key.split("::");
int type =Integer.parseInt(split[1]);
int objId = Integer.parseInt(split[0]);
int likeNum = (Integer) map.getValue();
if ( type == 1){
//為主評論
commentsInfoMapper.updateByPrimaryKey(objId,likeNum);
}else if(type == 2){
//為子評論
commentsReplyMapper.updateByPrimaryKey(objId,likeNum);
}else{
//為物品
goodsMapper.updateGoodsLikeSum(objId,likeNum);
}
}
}
@Override
public List<Map<String,Object>> selectLikedInfoByType(Integer type) {
return likedMapper.selectLikedInfoByType(type);
}
}
工具類(lèi)
package com.w.wx.utils;
public class RedisKeyUtils {
//保存用戶(hù)點(diǎn)贊數據的key
public static final String MAP_KEY_USER_LIKED = "redis_liked";
//保存用戶(hù)被點(diǎn)贊數量的key
public static final String MAP_KEY_USER_LIKED_COUNT = "redis_liked_count";
/**
* 拼接被點(diǎn)贊的用戶(hù)id和點(diǎn)贊的人的id作為key。格式 222222::333333::1
* @param likedUserId 被點(diǎn)贊的人id
* @param likedPostId 點(diǎn)贊的人的id
* @return
*/
public static String getLikedKey(String likedUserId, String likedPostId,String type){
StringBuilder builder = new StringBuilder();
builder.append(likedUserId);
builder.append("::");
builder.append(likedPostId);
builder.append("::");
builder.append(type);
return builder.toString();
}
public static String getLikedKey(String likedUserId,String type){
StringBuilder builder = new StringBuilder();
builder.append(likedUserId);
builder.append("::");
builder.append(type);
return builder.toString();
}
}
定時(shí)任務(wù)配置類(lèi)
package com.w.wx.config;
import com.w.wx.utils.LikeTask;
import org.quartz.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class QuartzConfig {
private static final String LIKE_TASK_IDENTITY = "LikeTaskQuartz";
@Bean
public JobDetail quartzDetail(){
return JobBuilder.newJob(LikeTask.class).withIdentity(LIKE_TASK_IDENTITY).storeDurably().build();
}
@Bean
public Trigger quartzTrigger(){
SimpleScheduleBuilder scheduleBuilder = SimpleScheduleBuilder.simpleSchedule()
// .withIntervalInSeconds(5) //設置時(shí)間周期單位秒
.withIntervalInHours(2) //兩個(gè)小時(shí)執行一次
.repeatForever();
return TriggerBuilder.newTrigger().forJob(quartzDetail())
.withIdentity(LIKE_TASK_IDENTITY)
.withSchedule(scheduleBuilder)
.build();
}
}
定時(shí)任務(wù)工具類(lèi)
package com.w.wx.utils;
import com.w.wx.service.LikedService;
import com.w.wx.service.impls.LikedServiceImpl;
import lombok.extern.slf4j.Slf4j;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.quartz.QuartzJobBean;
import java.text.SimpleDateFormat;
import java.util.Date;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
@Slf4j
@Component
public class LikeTask extends QuartzJobBean {
@Autowired
LikedServiceImpl likedService;
private SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@Override
protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException {
log.info("LikeTask-------- {}", sdf.format(new Date()));
//將 Redis 里的點(diǎn)贊信息同步到數據庫里
likedService.transLikedFromRedisToDB();
likedService.transLikedCountFromRedisToDB();
}
}
參考：
還有好多，第一頁(yè)搜出來(lái)的基本都看過(guò)，第一次搞真心不會(huì )。。。
f12去看看csdn點(diǎn)贊，會(huì )發(fā)現點(diǎn)文章的贊會(huì )有點(diǎn)贊量的返回。點(diǎn)評論的贊就沒(méi)
嗶哩嗶哩就看不懂了?。?！
到此這篇關(guān)于SpringBoot物品點(diǎn)贊功能實(shí)現的文章就介紹到這了,更多相關(guān)SpringBoot點(diǎn)贊內容請搜索腳本之家以前的文章或繼續瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
免責聲明：本站發(fā)布的內容（圖片、視頻和文字）以原創(chuàng )、來(lái)自本網(wǎng)站內容采集于網(wǎng)絡(luò )互聯(lián)網(wǎng)轉載等其它媒體和分享為主，內容觀(guān)點(diǎn)不代表本網(wǎng)站立場(chǎng)，如侵犯了原作者的版權，請告知一經(jīng)查實(shí)，將立刻刪除涉嫌侵權內容，聯(lián)系我們QQ:712375056，同時(shí)歡迎投稿傳遞力量。
Copyright ? 2009-2022 56dr.com. All Rights Reserved. 特網(wǎng)科技 特網(wǎng)云 版權所有 特網(wǎng)科技 粵ICP備16109289號
域名注冊服務(wù)機構:阿里云計算有限公司（萬(wàn)網(wǎng)） 域名服務(wù)機構：煙臺帝思普網(wǎng)絡(luò )科技有限公司（DNSPod） CDN服務(wù)：阿里云計算有限公司 百度云 中國互聯(lián)網(wǎng)舉報中心 增值電信業(yè)務(wù)經(jīng)營(yíng)許可證B2
建議您使用Chrome、Firefox、Edge、IE10及以上版本和360等主流瀏覽器瀏覽本網(wǎng)站
