十大中文网站排名,免费做网站凡科,建 导航网站好,商标logo设计软件 免费缓存是大多数应用程序的主要组成部分#xff0c;只要我们设法避免磁盘访问#xff0c;缓存就会保持强劲。 Spring对各种配置的缓存提供了强大的支持 。 您可以根据需要简单地开始#xff0c;然后进行更多可定制的操作。 这将是spring提供的最简单的缓存形式的示例。 Sprin… 缓存是大多数应用程序的主要组成部分只要我们设法避免磁盘访问缓存就会保持强劲。 Spring对各种配置的缓存提供了强大的支持 。 您可以根据需要简单地开始然后进行更多可定制的操作。 这将是spring提供的最简单的缓存形式的示例。 Spring默认带有一个内存缓存它很容易设置。 让我们从gradle文件开始。 group com.gkatzioura
version 1.0-SNAPSHOTbuildscript {repositories {mavenCentral()}dependencies {classpath(org.springframework.boot:spring-boot-gradle-plugin:1.4.2.RELEASE)}
}apply plugin: java
apply plugin: idea
apply plugin: org.springframework.bootrepositories {mavenCentral()
}sourceCompatibility 1.8
targetCompatibility 1.8dependencies {compile(org.springframework.boot:spring-boot-starter-web)compile(org.springframework.boot:spring-boot-starter-cache)compile(org.springframework.boot:spring-boot-starter)testCompile(junit:junit)
}bootRun {systemProperty spring.profiles.active, simple-cache
} 由于同一项目将用于不同的缓存提供程序因此会有多个spring配置文件。 本教程的Spring配置文件将是简单缓存因为我们将使用基于ConcurrentMap的缓存该缓存恰好是默认缓存。 我们将实现一个应用程序该应用程序将从本地文件系统中获取用户信息。 该信息应位于users.json文件中 [{userName:user1,firstName:User1,lastName:First},{userName:user2,firstName:User2,lastName:Second},{userName:user3,firstName:User3,lastName:Third},{userName:user4,firstName:User4,lastName:Fourth}
] 我们还将为要检索的数据指定一个简单的模型。 package com.gkatzioura.caching.model;/*** Created by gkatzioura on 1/5/17.*/
public class UserPayload {private String userName;private String firstName;private String lastName;public String getUserName() {return userName;}public void setUserName(String userName) {this.userName userName;}public String getFirstName() {return firstName;}public void setFirstName(String firstName) {this.firstName firstName;}public String getLastName() {return lastName;}public void setLastName(String lastName) {this.lastName lastName;}
} 然后我们将添加一个将读取信息的bean。 package com.gkatzioura.caching.config;import com.fasterxml.jackson.databind.ObjectMapper;
import com.gkatzioura.caching.model.UserPayload;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Profile;
import org.springframework.core.io.Resource;import java.io.IOException;
import java.io.InputStream;
import java.util.Arrays;
import java.util.Collections;
import java.util.List;/*** Created by gkatzioura on 1/5/17.*/
Configuration
Profile(simple-cache)
public class SimpleDataConfig {Autowiredprivate ObjectMapper objectMapper;Value(classpath:/users.json)private Resource usersJsonResource;Beanpublic ListUserPayload payloadUsers() throws IOException {try(InputStream inputStream usersJsonResource.getInputStream()) {UserPayload[] payloadUsers objectMapper.readValue(inputStream,UserPayload[].class);return Collections.unmodifiableList(Arrays.asList(payloadUsers));}}
} 显然为了访问信息我们将使用实例化的Bean包含所有用户信息。 下一步将是创建一个存储库接口以指定将使用的方法。 package com.gkatzioura.caching.repository;import com.gkatzioura.caching.model.UserPayload;import java.util.List;/*** Created by gkatzioura on 1/6/17.*/
public interface UserRepository {ListUserPayload fetchAllUsers();UserPayload firstUser();UserPayload userByFirstNameAndLastName(String firstName,String lastName);} 现在让我们深入研究将包含所需缓存注释的实现。 package com.gkatzioura.caching.repository;import com.gkatzioura.caching.model.UserPayload;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cache.annotation.CacheEvict;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.context.annotation.Profile;
import org.springframework.stereotype.Repository;import java.util.List;
import java.util.Optional;/*** Created by gkatzioura on 12/30/16.*/
Repository
Profile(simple-cache)
public class UserRepositoryLocal implements UserRepository {Autowiredprivate ListUserPayload payloadUsers;private static final Logger LOGGER LoggerFactory.getLogger(UserRepositoryLocal.class);OverrideCacheable(alluserscache)public ListUserPayload fetchAllUsers() {LOGGER.info(Fetching all users);return payloadUsers;}OverrideCacheable(cacheNames usercache,key #root.methodName)public UserPayload firstUser() {LOGGER.info(fetching firstUser);return payloadUsers.get(0);}OverrideCacheable(cacheNames usercache,key {#firstName,#lastName})public UserPayload userByFirstNameAndLastName(String firstName,String lastName) {LOGGER.info(fetching user by firstname and lastname);OptionalUserPayload user payloadUsers.stream().filter(p- p.getFirstName().equals(firstName)p.getLastName().equals(lastName)).findFirst();if(user.isPresent()) {return user.get();} else {return null;}}} 包含Cacheable的方法将触发缓存填充这与包含CacheEvict的方法将触发缓存逐出相反。 通过使用Cacheable而不是仅指定将存储我们的值的缓存映射我们还可以基于方法名称或方法参数来指定键。 因此我们实现了方法缓存。 例如方法firstUser使用方法名称作为键而方法userByFirstNameAndLastName使用方法参数以创建键。 带有CacheEvict批注的两种方法将清空指定的缓存。 LocalCacheEvict将是处理驱逐的组件。 package com.gkatzioura.caching.repository;import org.springframework.cache.annotation.CacheEvict;
import org.springframework.context.annotation.Profile;
import org.springframework.stereotype.Component;/*** Created by gkatzioura on 1/7/17.*/
Component
Profile(simple-cache)
public class LocalCacheEvict {CacheEvict(cacheNames alluserscache,allEntries true)public void evictAllUsersCache() {}CacheEvict(cacheNames usercache,allEntries true)public void evictUserCache() {}} 由于我们使用非常简单的缓存形式因此不支持驱逐ttl。 因此我们将仅针对此特定情况添加一个调度程序该调度程序将在一定时间后退出缓存。 package com.gkatzioura.caching.scheduler;import com.gkatzioura.caching.repository.LocalCacheEvict;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Profile;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;/*** Created by gkatzioura on 1/7/17.*/
Component
Profile(simple-cache)
public class EvictScheduler {Autowiredprivate LocalCacheEvict localCacheEvict;private static final Logger LOGGER LoggerFactory.getLogger(EvictScheduler.class);Scheduled(fixedDelay10000)public void clearCaches() {LOGGER.info(Invalidating caches);localCacheEvict.evictUserCache();localCacheEvict.evictAllUsersCache();}} 最后我们将使用控制器来调用指定的方法 package com.gkatzioura.caching.controller;import com.gkatzioura.caching.model.UserPayload;
import com.gkatzioura.caching.repository.UserRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;import java.util.List;/*** Created by gkatzioura on 12/30/16.*/
RestController
public class UsersController {Autowiredprivate UserRepository userRepository;RequestMapping(path /users/all,method RequestMethod.GET)public ListUserPayload fetchUsers() {return userRepository.fetchAllUsers();}RequestMapping(path /users/first,method RequestMethod.GET)public UserPayload fetchFirst() {return userRepository.firstUser();}RequestMapping(path /users/,method RequestMethod.GET)public UserPayload findByFirstNameLastName(String firstName,String lastName ) {return userRepository.userByFirstNameAndLastName(firstName,lastName);}} 最后但并非最不重要的一点是我们的Application类应包含两个额外的注释。 为了启用调度程序需要EnableScheduling为了启用缓存需要EnableCaching package com.gkatzioura.caching;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.scheduling.annotation.EnableScheduling;/*** Created by gkatzioura on 12/30/16.*/
SpringBootApplication
EnableScheduling
EnableCaching
public class Application {public static void main(String[] args) {SpringApplication.run(Application.class,args);}} 您可以在github上找到源代码。 翻译自: https://www.javacodegeeks.com/2017/01/spring-boot-cache-abstraction.html
