Redis整合Spring项目搭建实例

首先我们将使用jedis驱动，进而开始配置我们的Gradle。

group 'com.gkatzioura.spring' version '1.0-SNAPSHOT' apply plugin: 'java' apply plugin: 'eclipse' apply plugin: 'idea' apply plugin: 'spring-boot' buildscript {     repositories {         mavenCentral()     }     dependencies {         classpath("org.springframework.boot:spring-boot-gradle-plugin:1.2.5.RELEASE")     } } jar {     baseName = 'gs-serving-web-content'     version =  '0.1.0' } sourceCompatibility = 1.8 repositories {     mavenCentral() } dependencies {     compile "org.springframework.boot:spring-boot-starter-thymeleaf"     compile 'org.slf4j:slf4j-api:1.6.6'     compile 'ch.qos.logback:logback-classic:1.0.13'     compile 'redis.clients:jedis:2.7.0'     compile 'org.springframework.data:spring-data-redis:1.5.0.RELEASE'     testCompile group: 'junit', name: 'junit', version: '4.11' } task wrapper(type: Wrapper) {     gradleVersion = '2.3' }

紧接着我们将使用Spring注解，继续执行Redis装载配置。

package com.gkatzioura.spring.config; import org.springframework.cache.CacheManager; import org.springframework.cache.annotation.CachingConfigurerSupport; import org.springframework.cache.annotation.EnableCaching; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.data.redis.cache.RedisCacheManager; import org.springframework.data.redis.connection.RedisConnectionFactory; import org.springframework.data.redis.connection.jedis.JedisConnectionFactory; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.serializer.RedisSerializer; import org.springframework.data.redis.serializer.StringRedisSerializer; @Configuration @EnableCaching public class RedisConfig extends CachingConfigurerSupport {     @Bean     public JedisConnectionFactory redisConnectionFactory() {         JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory();         jedisConnectionFactory.setUsePool(true);         return jedisConnectionFactory;     }     @Bean     public RedisSerializer redisStringSerializer() {         StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();         return stringRedisSerializer;     }     @Bean(name="redisTemplate")     public RedisTemplate<String, String> redisTemplate(RedisConnectionFactory cf,RedisSerializer redisSerializer) {         RedisTemplate<String, String> redisTemplate = new RedisTemplate<String, String>();         redisTemplate.setConnectionFactory(cf);         redisTemplate.setDefaultSerializer(redisSerializer);         return redisTemplate;     }     @Bean     public CacheManager cacheManager() {         return new RedisCacheManager(redisTemplate(redisConnectionFactory(),redisStringSerializer()));     } }

下一步将创建缓存接口CacheService。

package com.gkatzioura.spring.cache; import java.util.Date; import java.util.List; public interface CacheService {     public void addMessage(String user,String message);     public List<String> listMessages(String user); }

当然用户既可以增加一条消息也能取回一条消息。因此，在实现过程中，用户相关信息的存在时间将默认设为一分钟。

我们用Redis来继承实现CacheService接口。

package com.gkatzioura.spring.cache.impl; import com.gkatzioura.spring.cache.CacheService; import org.springframework.data.redis.core.ListOperations; import org.springframework.data.redis.core.RedisOperations; import org.springframework.data.redis.core.SetOperations; import org.springframework.stereotype.Service; import javax.annotation.Resource; import java.time.ZonedDateTime; import java.time.temporal.ChronoUnit; import java.util.Date; import java.util.List; @Service("cacheService") public class RedisService implements CacheService {     @Resource(name = "redisTemplate")     private ListOperations<String, String> messageList;     @Resource(name = "redisTemplate")     private RedisOperations<String,String> latestMessageExpiration;     @Override     public void addMessage(String user,String message) {         messageList.leftPush(user,message);         ZonedDateTime zonedDateTime = ZonedDateTime.now();         Date date = Date.from(zonedDateTime.plus(1, ChronoUnit.MINUTES).toInstant());         latestMessageExpiration.expireAt(user,date);     }     @Override     public List<String> listMessages(String user) {         return messageList.range(user,0,-1);     } }

我们的缓存机制将保留每个用户发送的消息列表。为了实现这个功能我们将调用ListOperations接口，同时将每个user作为一个key键值。通过RedisOperations接口，我们可以为key设置特定存在时长。在本例中，主要使用的是 user key。

下一步我们将创建一个controller注入缓存服务。

package com.gkatzioura.spring.controller; import com.gkatzioura.spring.cache.CacheService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; import java.util.List; @RestController public class MessageController {     @Autowired     private CacheService cacheService;     @RequestMapping(value = "/message",method = RequestMethod.GET)     @ResponseBody     public List<String> greeting(String user) {         List<String> messages = cacheService.listMessages(user);         return messages;     }     @RequestMapping(value = "/message",method = RequestMethod.POST)     @ResponseBody     public String saveGreeting(String user,String message) {         cacheService.addMessage(user,message);         return "OK";     } }

最后完成类Application的创建。

package com.gkatzioura.spring; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; @SpringBootApplication public class Application {     public static void main(String[] args) {         SpringApplication.run(Application.class, args);     } }

经过如上步骤，接下来直接运行Application即可。

原文链接：Integrate Redis into a Spring Project（ 译者/丘志鹏 审校/朱正贵 责编/仲浩）

译者简介：邱志鹏，关注大数据、机器学习。

本文为ImapBox编译整理，未经允许不得转载，如需转载请联系market#csdn.net(#换成@)