一、評論功能：
注意要先登錄之后才能進行評論，所有把評論加入到登錄攔截器當中
@Overridepublic void addInterceptors(InterceptorRegistry registry) {//攔截test接口，后續實際遇到需要攔截的接口時，在配置為真正的攔截接口registry.addInterceptor(loginInterceptor).addPathPatterns("/test").addPathPatterns("/comments/create/change");}
- 在登錄攔截器LoginInterceptor里面存入了用戶信息：
//登錄成功 放行//我希望再controller中 直接獲取用戶的信息 怎么獲取UserThreadLocal.put(sysUser);
- 后續在評論的實現類里面可以用gei方法獲取到 用戶信息 充當評論人
//這里直接在線程里面找到登錄時候保存的用戶信息SysUser sysUser = UserThreadLocal.get();
1.根據文章id查詢評論
@Overridepublic Result commentsByArticleId(Long id) {/*** 1.根據文章id 查詢評論列表 從comments表中查詢-* 2.根據作者的id 查詢作者的信息* 3.判斷 如果 level = 1 要去查詢它有沒有子評論* 4.如果 有 根據評論id 進行查詢（parent_id）*/LambdaQueryWrapper<Comment> queryWrapper = new LambdaQueryWrapper<>();queryWrapper.eq(Comment::getArticleId,id);queryWrapper.eq(Comment::getLevel,1);List<Comment> comments = commentMapper.selectList(queryWrapper);List<CommentVo> commentVoList = copyList(comments);return Result.success(commentVoList);}
private List<CommentVo> findCommentsByParentId(Long id) {LambdaQueryWrapper<Comment> queryWrapper = new LambdaQueryWrapper<>();queryWrapper.eq(Comment::getParentId,id);queryWrapper.eq(Comment::getLevel,2);List<Comment> comments = commentMapper.selectList(queryWrapper);return copyList(comments);}
將pojo —> vo的方法，這里有個小巧思，分為level大于1和等于1的情況，當level等于1時，說明可能是樓主，會有子評論
private List<CommentVo> copyList(List<Comment> comments) {List<CommentVo> commentVoList = new ArrayList<>();for (Comment comment : comments) {commentVoList.add(copy(comment));}return commentVoList;}private CommentVo copy(Comment comment) {CommentVo commentVo = new CommentVo();BeanUtils.copyProperties(comment,commentVo);commentVo.setId(String.valueOf(comment.getId()));//作者信息Long authorId = comment.getAuthorId();UserVo userVo = this.sysUserService.findUserVoById(authorId);commentVo.setAuthor(userVo);//子評論Integer level = comment.getLevel();if( 1 == level){Long id = Long.valueOf(comment.getId());List<CommentVo> commentVoList = findCommentsByParentId(id);commentVo.setChildrens(commentVoList);}//to User 給誰評論if(level >1){Long toUid = comment.getToUid();UserVo toUserVo = this.sysUserService.findUserVoById(toUid);commentVo.setToUser(toUserVo);}return commentVo;}
精度損失問題
當數據庫用的是分布式id的時候，前端會出現精度損失問題，導致找不到正確的id 此時需要在實體類中,添加相關注解，把id轉為string，（分布式id 比較長，傳到前端 會有精度損失，必須轉為string類型，進行運輸，就不會有問題了
//防止前端精度損失 把id轉為string@JsonSerialize(using = ToStringSerializer.class)private Long id;
二、發布文章
也需要登錄過后才能發布文章，
registry.addInterceptor(loginInterceptor).addPathPatterns("/test").addPathPatterns("/comments/create/change").addPathPatterns("/articles/publish");
@Overridepublic Result publish(ArticleParam articleParam) {/*** 1.發布文章 目的 構建Article對象* 2.作者id 當前的登錄用戶* 3.標簽 要將標簽加入到 關聯表中* 4.body 內容存儲**/SysUser sysUser = UserThreadLocal.get();//登錄的用戶id就是作者id 而登錄的用戶 可以去線程中找Article article = new Article();article.setAuthorId(Long.valueOf(sysUser.getId()));article.setWeight(Article.Article_Common);article.setViewCounts(0);article.setTitle(articleParam.getTitle());article.setSummary(articleParam.getSummary());article.setCommentCounts(0);article.setCreateDate(System.currentTimeMillis());article.setCategoryId(Long.valueOf(articleParam.getCategory().getId()));//插入之后會生成一個文章idthis.articleMapper.insert(article);//tagList<TagVo> tags = articleParam.getTags();if(tags!=null){for (TagVo tag : tags) {Long articleId = Long.valueOf(article.getId());ArticleTag articleTag = new ArticleTag();articleTag.setTagId(Long.valueOf(tag.getId()));articleTag.setArticleId(articleId);articleTagMapper.insert(articleTag);}}//bodyArticleBody articleBody = new ArticleBody();articleBody.setArticleId(Long.valueOf(article.getId()));articleBody.setContent(articleParam.getBody().getContent());articleBody.setContentHtml(articleParam.getBody().getContentHtml());articleBodyMapper.insert(articleBody);article.setBodyId(Long.valueOf(articleBody.getId()));articleMapper.updateById(article);//方法1 articleVo
// ArticleVo articleVo = new ArticleVo();
// articleVo.setId(article.getId());
// return Result.success(articleVo);//方法2Map<String,String> map = new HashMap<>();map.put("id",article.getId().toString());//返回字符串避免精度損失問題return Result.success(map);}
三、AOP日志
對于 IoC 的一種補充，面向切面編程，簡化程序的一種方式
IoC 簡化代碼量，AOP 實現解耦合的
讓代碼變得松散，靈活，更方便擴展和維護
日志輸出和業務計算混合在一起，耦合在一起，不方便維護
解耦合，把日志輸出和業務計算的代碼進行分離
最終程序運行的時候，結果還要合到一起
1.在需要記錄日志的controller上添加注解
@PostMapping//加上此注解 代表要對此接口記錄日志@LogAnnotation(module="文章",operator="獲取文章列表")public Result listArticle(@RequestBody PageParams pageParams){return articleService.listArticle(pageParams);}
2.創建aop包，并且創建annotation類
package com.mszlu.blog.common.aop;import java.lang.annotation.*;//Type 代表可以放在類上面 Method代表可以放在方法上面
//ElementType.Type ElementType.METHOD
@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface LogAnnotation {String module() default "";String operator() default "";
}3.開花AOP創建LogAspect類
package com.mszlu.blog.common.aop;import com.alibaba.fastjson.JSON;
import com.mszlu.blog.common.aop.LogAnnotation;
import com.mszlu.blog.utils.HttpContextUtils;
import com.mszlu.blog.utils.IpUtils;
import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.aspectj.lang.reflect.MethodSignature;
import org.springframework.stereotype.Component;import javax.servlet.http.HttpServletRequest;
import java.lang.reflect.Method;@Component//讓spring識別到
@Aspect//切面 定義了通知和切點的關系
@Slf4j
public class LogAspect {@Pointcut("@annotation(com.mszlu.blog.common.aop.LogAnnotation)")public void pt(){}@Around("pt()")public Object log(ProceedingJoinPoint joinPoint) throws Throwable {long beginTime = System.currentTimeMillis();//執行方法Object result = joinPoint.proceed();//執行時長(毫秒)long time = System.currentTimeMillis() - beginTime;//保存日志recordLog(joinPoint, time);return result;}private void recordLog(ProceedingJoinPoint joinPoint, long time) {MethodSignature signature = (MethodSignature) joinPoint.getSignature();Method method = signature.getMethod();LogAnnotation logAnnotation = method.getAnnotation(LogAnnotation.class);log.info("=====================log start================================");log.info("module:{}",logAnnotation.module());log.info("operator:{}",logAnnotation.operator());//請求的方法名String className = joinPoint.getTarget().getClass().getName();String methodName = signature.getName();log.info("request method:{}",className + "." + methodName + "()");// //請求的參數Object[] args = joinPoint.getArgs();String params = JSON.toJSONString(args[0]);log.info("params:{}",params);//獲取request 設置IP地址HttpServletRequest request = HttpContextUtils.getHttpServletRequest();log.info("ip:{}", IpUtils.getIpAddr(request));log.info("excute time : {} ms",time);log.info("=====================log end================================");}}四、上傳圖片
@RestController
@RequestMapping("upload")
public class UploadController {@Autowiredprivate QiniuUtils qiniuUtils;@PostMapping()public Result upload(@RequestParam("image")MultipartFile file){//原始文件名稱 比如aa.pngString originalFilename = file.getOriginalFilename();String fileName = UUID.randomUUID()+toString()+"."+ StringUtils.substringAfterLast(originalFilename,".");//上傳文件 上傳在哪兒?//七牛云 云服務器 按量付費 幅度快 把圖片發到離用戶最近的服務器上//降低 我們自身應用服務器的寬帶消耗boolean upload = qiniuUtils.upload(file,fileName);if(upload){return Result.success(QiniuUtils.url+fileName);}return Result.fail(20001,"上傳失敗");}
我們用的平臺是七牛云 首先先要導入依賴：
<dependency><groupId>com.qiniu</groupId><artifactId>qiniu-java-sdk</artifactId><version>[7.7.0, 7.7.99]</version></dependency>
- QiniuUtils
@Component
public class QiniuUtils {public static final String url = "http://t0oltruo7.hn-bkt.clouddn.com/";@Value("${qiniu.accessKey}")private String accessKey;@Value("${qiniu.accessSecretKey}")private String accessSecretKey;public boolean upload(MultipartFile file,String fileName){//構造一個帶指定 Region 對象的配置類Configuration cfg = new Configuration(Region.huanan());//...其他參數參考類注釋UploadManager uploadManager = new UploadManager(cfg);//...生成上傳憑證，然后準備上傳String bucket = "danb24";//默認不指定key的情況下，以文件內容的hash值作為文件名try {byte[] uploadBytes = file.getBytes();Auth auth = Auth.create(accessKey, accessSecretKey);String upToken = auth.uploadToken(bucket);Response response = uploadManager.put(uploadBytes, fileName, upToken);//解析上傳成功的結果DefaultPutRet putRet = JSON.parseObject(response.bodyString(), DefaultPutRet.class);return true;} catch (Exception ex) {ex.printStackTrace();}return false;}
}注意點
- url就是你在七牛云創建的域名 “http://t0oltruo7.hn-bkt.clouddn.com/”;
- accessKey和SecretKey在七牛云中獲得 并且配置在在properties或者直接賦值（不推薦）
qiniu.accessKey=NnneEoseKEAqkNNFuaMYWIBU7gn0xdVUbGuBjmGU
qiniu.accessSecretKey=G5NBjBLd3OdttFet71AGxjbpahwduNpom_amLe1G- bucket 修改為自己的文件名
- 也可以在配置文件中限制上傳文件的值
#上傳文件總的最大值
spring.servlet.multipart.max-request-size=20MB
#單個文件的最大值
spring.servlet.multipart.max-file-size=2MB
統一緩存處理（優化）
1.cache包下Cache
package com.mszlu.blog.common.cache;import java.lang.annotation.*;//
@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface Cache {long expire() default 1 * 60 * 1000;//緩存標識KeyString name() default "";}
2.cache包下CacheAspect
package com.mszlu.blog.common.cache;import com.alibaba.fastjson.JSON;
import com.mszlu.blog.vo.Result;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.codec.digest.DigestUtils;
import org.apache.commons.lang3.StringUtils;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.Signature;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;import java.lang.reflect.Method;
import java.time.Duration;
//aop定義了一個切面 切面定義了切點和通知的關系
@Aspect
@Component
@Slf4j
public class CacheAspect {@Autowiredprivate RedisTemplate<String, String> redisTemplate;//切點@Pointcut("@annotation(com.mszlu.blog.common.cache.Cache)")public void pt(){}//環繞@Around("pt()")public Object around(ProceedingJoinPoint pjp){try {Signature signature = pjp.getSignature();//類名String className = pjp.getTarget().getClass().getSimpleName();//調用的方法名String methodName = signature.getName();Class[] parameterTypes = new Class[pjp.getArgs().length];Object[] args = pjp.getArgs();//參數String params = "";for(int i=0; i<args.length; i++) {if(args[i] != null) {params += JSON.toJSONString(args[i]);parameterTypes[i] = args[i].getClass();}else {parameterTypes[i] = null;}}if (StringUtils.isNotEmpty(params)) {//加密 以防出現key過長以及字符轉義獲取不到的情況params = DigestUtils.md5Hex(params);}Method method = pjp.getSignature().getDeclaringType().getMethod(methodName, parameterTypes);//獲取Cache注解Cache annotation = method.getAnnotation(Cache.class);//緩存過期時間long expire = annotation.expire();//緩存名稱String name = annotation.name();//先從redis獲取String redisKey = name + "::" + className+"::"+methodName+"::"+params;String redisValue = redisTemplate.opsForValue().get(redisKey);if (StringUtils.isNotEmpty(redisValue)){log.info("走了緩存~~~,{},{}",className,methodName);return JSON.parseObject(redisValue, Result.class);}Object proceed = pjp.proceed();redisTemplate.opsForValue().set(redisKey,JSON.toJSONString(proceed), Duration.ofMillis(expire));log.info("存入緩存~~~ {},{}",className,methodName);return proceed;} catch (Throwable throwable) {throwable.printStackTrace();}return Result.fail(-999,"系統錯誤");}}
-------svm支持向量機)
