评论优化

Author: cachecats

java/comments_service/server/pom.xml

@@ -70,6 +70,11 @@
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-starter-openfeign</artifactId>
         </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-redis</artifactId>
+        </dependency>
     </dependencies>
 
     <build>

java/comments_service/server/src/main/java/com/solo/coderiver/comments/CommentsApplication.java

@@ -2,6 +2,7 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cache.annotation.EnableCaching;
 import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
 import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
 import org.springframework.cloud.openfeign.EnableFeignClients;
@@ -11,6 +12,7 @@
 @EnableDiscoveryClient
 @EnableSwagger2
 @EnableFeignClients(basePackages = "com.solo.coderiver.user.client")
+@EnableCaching
 public class CommentsApplication {
 
     public static void main(String[] args) {

java/comments_service/server/src/main/java/com/solo/coderiver/comments/service/CommentsInfoService.java

@@ -1,6 +1,5 @@
 package com.solo.coderiver.comments.service;
 
-import com.solo.coderiver.comments.dataobject.CommentsInfo;
 import com.solo.coderiver.comments.dto.CommentsInfoDTO;
 
 import java.util.List;

java/comments_service/server/src/main/java/com/solo/coderiver/comments/service/impl/CommentsInfoServiceImpl.java

@@ -7,7 +7,11 @@
 import com.solo.coderiver.comments.service.CommentsInfoService;
 import com.solo.coderiver.user.client.UserClient;
 import com.solo.coderiver.user.common.UserInfoForComments;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.cache.annotation.CacheEvict;
+import org.springframework.cache.annotation.CachePut;
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.stereotype.Service;
 import org.springframework.util.StringUtils;
 
@@ -16,6 +20,7 @@
 import java.util.stream.Collectors;
 
 @Service
+@Slf4j
 public class CommentsInfoServiceImpl implements CommentsInfoService {
 
     @Autowired
@@ -25,13 +30,16 @@ public class CommentsInfoServiceImpl implements CommentsInfoService {
     UserClient userClient;
 
     @Override
+    @CacheEvict(cacheNames = "comments", key = "#dto.ownerId")
     public CommentsInfoDTO save(CommentsInfoDTO dto) {
         CommentsInfo result = repository.save(CommentsConverter.DTO2Info(dto));
         return CommentsConverter.info2DTO(result);
     }
 
     @Override
+    @Cacheable(cacheNames = "comments", key = "#ownerId")
     public List<CommentsInfoDTO> findByOwnerId(String ownerId) {
+        log.info("取了数据库----------");
         List<CommentsInfo> infoList = repository.findByOwnerId(ownerId);
         List<CommentsInfoDTO> list = CommentsConverter.infos2DTOList(infoList)
                 .stream()

java/comments_service/server/target/classes/com/solo/coderiver/comments/CommentsApplication.class

@@ -11,6 +11,7 @@
 import org.springframework.data.redis.core.Cursor;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.data.redis.core.ScanOptions;
+import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.stereotype.Service;
 
 import java.util.ArrayList;