使用spring-data-redis集群redis,

发布网友发布时间：2022-04-11 14:01

共2个回答

懂视网时间：2022-04-11 18:22

Spring-data-redis是spring大家族的一部分，提供了在srping应用中通过简单的配置访问redis服务，对reids底层开发包(Jedis, JRedis, and RJC)进行了高度封装。

一、安装redis服务

1、下载安装redis服务，安装完成后会自动启动redis服务

sudo apt-get install redis-server

2、下载完成后，我们可以通过命令检查redis服务进程

ps -aux|grep redis

结果如下图所示：

3、也可以检查Redis服务的状态

netstat -nlt|grep 6379

#结果如下：
# tcp 0 0 127.0.0.1:6379 0.0.0.0:* LISTEN

4、通过命令检查redis服务状态

sudo /etc/init.d/redis-server status
# 结果如下：redis-server is running

二、配置redis

# 编辑redis配置文件
sudo vim /etc/redis/redis.conf

# 在vim中设置redis访问密码
requirepass 123456

# 在vim中注释bind，设置允许远程访问，redis默认只允许本机访问
#bind 127.0.0.1

# 重启redis服务
sudo /etc/init.d/redis-server restart

# 客户端访问redis服务
sudo redis-cli

# 客户端登录并访问redis服务
sudo redis-cli -a youpassword

# 远程客户端登录并访问redis服务
sudo redis-cli -a youpassword -h 192.168.1.22

三、编写java代码

1、cache接口定义

public interface Cache {

 /**
 * 添加
 * @param key
 * @param value
 */
 void put(Object key, Object value);
 
 /**
 * 得到key的值
 * @param key
 * @return
 */
 Object get(Object key);

 /**
 * 移除key
 * @param key
 * @return
 */
 Object remove(Object key);

}

2、cache接口实现

import org.springframework.dao.DataAccessException;
import org.springframework.data.redis.connection.RedisConnection;
import org.springframework.data.redis.connection.RedisListCommands;
import org.springframework.data.redis.connection.RedisStringCommands;
import org.springframework.data.redis.connection.RedisZSetCommands;
import org.springframework.data.redis.connection.jedis.JedisConverters;
import org.springframework.data.redis.core.Cursor;
import org.springframework.data.redis.core.RedisCallback;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ScanOptions;
import org.springframework.data.redis.core.types.Expiration;
import org.springframework.data.redis.serializer.RedisSerializer;
import redis.clients.jedis.Jedis;

public class DefaultRedisCache implements Cache {

 private final static Logger logger = LoggerFactory.getLogger(DefaultRedisCache.class);

 private RedisTemplate redisTemplate;

 //秒
 private final static Long DEFAULT_EXPIRE = 12 * 60 * 60L;

 public DefaultRedisCache(RedisTemplate redisTemplate) {
 this.redisTemplate = redisTemplate;
 }

 @Override
 public void put(final Object key, final Object value) {
 put(key, value, DEFAULT_EXPIRE);
 }

 @Override
 public Object get(final Object key) {
 return redisTemplate.execute(new RedisCallback() {
  @Override
  public Object doInRedis(RedisConnection connection) throws DataAccessException {

  RedisSerializer<Object> serializer = getRedisSerializer();

  byte[] keyByte = serializer.serialize(key);
  if(keyByte == null){
   return null;
  }
  byte[] bytes = connection.get(keyByte);

  if (bytes == null) {
   return null;
  }

  return serializer.deserialize(bytes);
  }
 });
 }

 @Override
 public Object remove(final Object key) {
 return redisTemplate.execute(new RedisCallback() {
  @Override
  public Object doInRedis(RedisConnection connection) throws DataAccessException {

  RedisSerializer<Object> serializer = getRedisSerializer();

  if (key == null) {
   return null;
  }

  byte[] bytes = serializer.serialize(key);

  return connection.del(bytes);
  }
 });
 }

3、配置applicationContext-cache-test.xml文件

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 xmlns:p="http://www.springframework.org/schema/p" xmlns:context="http://www.springframework.org/schema/context"
 xsi:schemaLocation="http://www.springframework.org/schema/beans
		http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

 <context:property-placeholder location="classpath:redis-config.properties" ignore-unresolvable="true"/>

 <!-- jedis pool配置 -->
 <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
 <property name="maxTotal" value="${commons.cache.redis.maxTotal}" />
 <property name="maxIdle" value="${commons.cache.redis.maxIdle}" />
 <property name="maxWaitMillis" value="${commons.cache.redis.maxWait}" />
 <property name="testOnBorrow" value="${commons.cache.redis.testOnBorrow}" />
 <property name="testOnReturn" value="${commons.cache.redis.testOnReturn}" />
 </bean>

 <!-- spring data redis -->
 <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
 <property name="usePool" value="true"></property>
 <property name="hostName" value="${commons.cache.redis.host}" />
 <property name="port" value="${commons.cache.redis.port}" />
 <property name="password" value="${commons.cache.redis.password}" />
 <property name="timeout" value="${commons.cache.redis.timeout}" />
 <!--<property name="database" value="${commons.cache.redis.default.db}"></property>-->
 <property name="poolConfig" ref="jedisPoolConfig" />
 </bean>

 <bean id="redisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate">
 <property name="connectionFactory" ref="jedisConnectionFactory" />
 </bean>
 
 <!-- 自定义缓存工厂接口 -->
 <bean id="cacheFactory" class="com.xxx.cache.factory.CacheFactory" p:redisTemplate-ref="redisTemplate"/>
</beans>

4、配置redis-config.properties文件

# jedis pool配置
commons.cache.redis.maxTotal=1000
commons.cache.redis.maxIdle=600
commons.cache.redis.maxWait=1000
commons.cache.redis.testOnBorrow=true
commons.cache.redis.testOnReturn=true

# spring data redis 配置
commons.cache.redis.host=192.168.1.230
commons.cache.redis.port=6379
commons.cache.redis.password=123456
commons.cache.redis.timeout=1000

5、测试

@ContextConfiguration(locations = {
 "classpath:applicationContext-cache-test.xml"
})
@RunWith(SpringJUnit4ClassRunner.class)
public class CacheTest extends BaseTest{

 @Autowired
 private Cache cache;

 @Test
 public void redisTest() {

 // 添加key为username的值到redis缓存里
 cache.put("username","nathan");

 // 获取值
 Object username = cache.get("username");
 System.out.println("cache.get = " + username);

 // 删除值
// cache.remove("username");
// Object delResult = cache.get("username");
// System.out.println("cache.remove = " + delResult);
 }

}

更多redis知识请关注redis入门教程栏目。

热心网友时间：2022-04-11 15:30

用的是什么集群方式，JedisSentinelPool 还是ShardedJedisPool。
如果用的是前者，配置是需要连接sentinel端口的（默认26379），不是连接redis端口（6379）。
或者把spring相关配置文件贴出来一下。


<bean id="jedisShardInfo1" class="redis.clients.jedis.JedisShardInfo">
<constructor-arg name="host" value="127.0.0.1" />
<constructor-arg name="port" value="6379 />
</bean>

<bean id="jedisShardInfo2" class="redis.clients.jedis.JedisShardInfo">
<constructor-arg name="host" value="127.0.0.1" />
<constructor-arg name="port" value="6380" />
</bean>

<bean id="shardedJedisPool" class="redis.clients.jedis.ShardedJedisPool">
<constructor-arg index="0" ref="jedisPoolConfig" />
<constructor-arg index="1">
<list>
<ref bean="jedisShardInfo1" />
<ref bean="jedisShardInfo2" />
</list>
</constructor-arg>
</bean>


<bean id="jedisSentinelPool" class="redis.clients.jedis.JedisSentinelPool">
<constructor-arg index="0" value="mymaster" />
<constructor-arg index="1">
<set>
<value>127.0.0.1:26379</value>
<value>127.0.0.1:26380</value>
<value>127.0.0.1:26381</value>
</set>
</constructor-arg>
<constructor-arg index="2" ref="jedisPoolConfig" />
</bean>