<!--redis-->
<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-redis</artifactId>
  <version>${boot.version}</version>
</dependency>

spring:
  application:
    name: spring-boot-redis
  redis:
    host: 192.168.145.132
    port: 6379
    timeout: 20000
    cluster:
      nodes: 192.168.211.134:7000,192.168.211.134:7001,192.168.211.134:7002
      maxRedirects: 6
    pool:
      max-active: 8
      min-idle: 0
      max-idle: 8
      max-wait: -1

@Configuration
public class RedisConfig {

  @Bean
  public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory connectionFactory) {
   RedisTemplate<Object, Object> template = new RedisTemplate<>();
   template.setConnectionFactory(connectionFactory);

   //使用Jackson2JsonRedisSerializer來序列化和反序列化redis的value值
   Jackson2JsonRedisSerializer serializer = new Jackson2JsonRedisSerializer(Object.class);

   ObjectMapper mapper = new ObjectMapper();
   mapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
   mapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
   serializer.setObjectMapper(mapper);

   template.setValueSerializer(serializer);
   //使用StringRedisSerializer來序列化和反序列化redis的key值
   template.setKeySerializer(new StringRedisSerializer());
   template.afterPropertiesSet();
   return template;
  }
}

@Service
public class PersonService {

  @Autowired
  private PersonRepo personRepo;

  /**
   * @Cacheable 應(yīng)用到讀取數(shù)據(jù)的方法上，先從緩存中讀取，如果沒有再從DB獲取數(shù)據(jù)，然后把數(shù)據(jù)添加到緩存中
  * unless 表示條件表達式成立的話不放入緩存
   * @param username
   * @return
   */
  @Cacheable(value = "user", key = "#root.targetClass + #username", unless = "#result eq null")
  public Person getPersonByName(String username) {
    Person person = personRepo.getPersonByName(username);
    return person;
  }

  /**
  * @CachePut 應(yīng)用到寫數(shù)據(jù)的方法上，如新增/修改方法，調(diào)用方法時會自動把相應(yīng)的數(shù)據(jù)放入緩存
   * @param person
   * @return
   */
  @CachePut(value = "user", key = "#root.targetClass + #result.username", unless = "#person eq null")
  public Person savePerson(Person person) {
    return personRepo.savePerson(person);
  }

  /**
  * @CacheEvict 應(yīng)用到刪除數(shù)據(jù)的方法上，調(diào)用方法時會從緩存中刪除對應(yīng)key的數(shù)據(jù)
   * @param username
   * @return
   */
  @CacheEvict(value = "user", key = "#root.targetClass + #username", condition = "#result eq true")
  public boolean removePersonByName(String username) {
    return personRepo.removePersonByName(username) > 0;
  }

  public boolean isExistPersonName(Person person) {
    return personRepo.existPersonName(person) > 0;
  }
}

@Component
@Path("personMgr")
public class PersonMgrResource {

  @Autowired
  private PersonService personService;

  @GET
  @Path("getPersonByName")
  @Produces(MediaType.APPLICATION_JSON)
  public JsonResp getPersonByName(@QueryParam("username") String username) {
    Person person = personService.getPersonByName(username);
    return JsonResp.success(person);
  }

  @POST
  @Path("removePersonByName")
  @Produces(MediaType.APPLICATION_JSON)
  public JsonResp removePersonByName(@QueryParam("username") String username) {
    if (personService.removePersonByName(username)) {
      return JsonResp.success();
    }
    return JsonResp.fail("系統(tǒng)錯誤！");
  }

  @POST
  @Path("savePerson")
  @Produces(MediaType.APPLICATION_JSON)
  public JsonResp savePerson(Person person) {
    if (personService.isExistPersonName(person)) {
      return JsonResp.fail("用戶名已存在！");
    }
    if (personService.savePerson(person).getId() > 0) {
      return JsonResp.success();
    }
    return JsonResp.fail("系統(tǒng)錯誤！");
  }
}