java|springboot 整合redis集群 redis|redisCluster|redis|springboot|

【java|springboot 整合redis集群】springboot整合redis集群比较简单，我们直接代码说话：
一引入依赖，配置pom.xml

org.springframework.boot spring-boot-starter org.springframework.boot spring-boot-starter-web org.springframework.boot spring-boot-starter-aop org.springframework.boot spring-boot-starter-test test org.springframework.boot spring-boot-starter-data-redis com.alibaba fastjson 1.2.47

二配置redis集群，配置application.yml文件

server: port: 8081 spring: redis: cluster: nodes: 127.0.0.1:6379,127.0.0.1:6380,127.0.0.1:6381,127.0.0.1:6382,127.0.0.1:6383,127.0.0.1:6384 max-redirects: 500 database: 1 timeout: 3000

三实现代码
redis实现类，RedisServiceImpl.class

package com.redis.cluster.servie.impl; import com.alibaba.fastjson.JSON; import com.redis.cluster.servie.RedisService; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.dao.DataAccessException; import org.springframework.data.redis.connection.RedisConnection; import org.springframework.data.redis.core.RedisCallback; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.serializer.RedisSerializer; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.Assert; import java.util.concurrent.TimeUnit; /** * Created by xiaour.github.com on 2017/11/8. */ @Service("redisService") @Transactional(rollbackFor = Exception.class) public class RedisServiceImpl implements RedisService { private final Logger log = LoggerFactory.getLogger(RedisServiceImpl.class); private static int seconds= 86400; @Autowired private RedisTemplate redisTemplate; @Override public boolean set(final String key, final String value) throws RuntimeException { log.info(key,"Key is not empty."); boolean result = redisTemplate.execute(new RedisCallback() { @Override public Boolean doInRedis(RedisConnection connection) throws DataAccessException { RedisSerializer serializer = redisTemplate.getStringSerializer(); connection.set(serializer.serialize(key), serializer.serialize(value)); return true; } }); return result; } @Override public String get(final String key) throws RuntimeException { log.info(key,"Key is not empty."); String result = redisTemplate.execute(new RedisCallback() { @Override public String doInRedis(RedisConnection connection) throws DataAccessException { RedisSerializer serializer = redisTemplate.getStringSerializer(); byte[] value =https://www.it610.com/article/connection.get(serializer.serialize(key)); return serializer.deserialize(value); } }); return result; }@Override public void del(final String key) throws RuntimeException { log.info(key,"Key is not empty."); redisTemplate.execute(new RedisCallback() { @Override public Long doInRedis(RedisConnection conn) throws DataAccessException { RedisSerializer serializer = redisTemplate.getStringSerializer(); return conn.del(serializer.serialize(key)); } }); }@Override public boolean expire(final String key, long expire) { return redisTemplate.expire(key, expire, TimeUnit.SECONDS); }@Override public boolean setexpire(String key, String value, long expire) throws RuntimeException { log.info(key,"Key is not empty."); boolean result = redisTemplate.execute(new RedisCallback() { @Override public Boolean doInRedis(RedisConnection connection) throws DataAccessException { RedisSerializer serializer = redisTemplate.getStringSerializer(); connection.set(serializer.serialize(key), serializer.serialize(value)); if(expire > 0){ connection.expire(serializer.serialize(key), expire); } return true; } }); return result; }@Override public boolean setObj(final String key, Object obj, long expire)throws RuntimeException { Assert.hasText(key,"Key is not empty."); final String value = https://www.it610.com/article/JSON.toJSONString(obj); Boolean result = redisTemplate.execute(new RedisCallback() { @Override public Boolean doInRedis(RedisConnection connection) throws DataAccessException { RedisSerializer serializer = redisTemplate.getStringSerializer(); connection.set(serializer.serialize(key), serializer.serialize(value)); if(expire > 0){ connection.expire(serializer.serialize(key), expire); } return true; } }); return result; }@Override public T getObj(String key, Class clz) throws RuntimeException { String value = https://www.it610.com/article/this.get(key); if(value == null){ return null; } returnJSON.parseObject(value,clz); }}

接口：RedisController.class

package com.redis.cluster.web; import com.redis.cluster.servie.RedisService; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; /** * Created by Administrator on 2018/10/25. */ @RestController @RequestMapping("/api/redis") public class RedisController { private Logger log = LoggerFactory.getLogger(this.getClass()); @Autowired private RedisService redisService; @GetMapping("/set/{key}/{value}") public String set( @PathVariable("key")String key , @PathVariable("value") String value){ redisService.set(key,value); return "ok"; }@GetMapping("/get/{key}") public String get( @PathVariable("key")String key ){ returnredisService.get(key); } }

四测试：
设置值