JAVA中 redisTemplate 和 jedis的配合使用操作

@Configuration

@EnableCaching

public class RedisConfig extends CachingConfigurerSupport {

   /**

    * redis模板，存储关键字是字符串，值是Jdk序列化

    * @param factory

    * @return

    * @Description:

    */

   @Bean

   public RedisTemplate<?, ?> redisTemplate(RedisConnectionFactory factory) {

     RedisTemplate<?, ?> redisTemplate = new RedisTemplate<>();

     redisTemplate.setConnectionFactory(factory);

     //key序列化方式;但是如果方法上有Long等非String类型的话，会报类型转换错误；

     RedisSerializer<String> redisSerializer = new StringRedisSerializer(); //Long类型不可以会出现异常信息;

     redisTemplate.setKeySerializer(redisSerializer);

     redisTemplate.setHashKeySerializer(redisSerializer);

     //默认使用JdkSerializationRedisSerializer序列化方式;会出现乱码，改成StringRedisSerializer

     StringRedisSerializer stringSerializer = new StringRedisSerializer();

     redisTemplate.setKeySerializer(stringSerializer);

     redisTemplate.setValueSerializer(stringSerializer);

     redisTemplate.setHashKeySerializer(stringSerializer);

     redisTemplate.setHashValueSerializer(stringSerializer);

     return redisTemplate;

   }

}

< dependency >

   < groupId >org.springframework.data</ groupId >

   < artifactId >spring-data-redis</ artifactId >

   < version >2.3.0.RELEASE</ version >

</ dependency >

< dependency >

   < groupId >redis.clients</ groupId >

   < artifactId >jedis</ artifactId >

   < version >3.3.0</ version >

</ dependency >

import org.springframework.data.redis.connection.RedisClusterConfiguration;

import org.springframework.data.redis.connection.RedisNode;

import org.springframework.data.redis.connection.RedisStandaloneConfiguration;

import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;

import org.springframework.data.redis.core.RedisTemplate;

import org.springframework.data.redis.core.ValueOperations;

import java.util.Collections;

import java.util.List;

import java.util.Objects;

public class RedisTest {

   public static void main(String[] args) {

     //单机模式

     RedisStandaloneConfiguration rsc = new RedisStandaloneConfiguration();

     rsc.setPort( 6379 );

     rsc.setPassword( "123456" );

     rsc.setHostName( "192.168.1.1" );

     //集群模式

     RedisClusterConfiguration rcc = new RedisClusterConfiguration();

     rcc.setPassword( "123456" );

     List<RedisNode> nodes = Collections.singletonList( new RedisNode( "192.168.1.1" , 6379 ));

     rcc.setClusterNodes(nodes);

     RedisTemplate<String, String> template = new RedisTemplate<>();

     //单机模式

     JedisConnectionFactory fac = new JedisConnectionFactory(rsc);

     //集群模式

     //JedisConnectionFactory fac = new JedisConnectionFactory(rcc);

     fac.afterPropertiesSet();

     template.setConnectionFactory(fac);

     template.setDefaultSerializer( new StringRedisSerializer());

     template.afterPropertiesSet();

     ValueOperations<String, String> op = template.opsForValue();

     final String key = "123_tmp" ;

     final String value = "abc" ;

     template.delete(key);

     op.set(key, value);

     assert Objects.equals(op.get(key), value);

   }

}

< dependency >

   < groupId >org.springframework.data</ groupId >

   < artifactId >spring-data-redis</ artifactId >

   < version >1.8.9.RELEASE</ version >

</ dependency >

< dependency >

   < groupId >redis.clients</ groupId >

   < artifactId >jedis</ artifactId >

   < version >2.9.0</ version >

</ dependency >

import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;

import org.springframework.data.redis.core.RedisTemplate;

import org.springframework.data.redis.core.ValueOperations;

import redis.clients.jedis.JedisPoolConfig;

import redis.clients.jedis.JedisShardInfo;

import java.util.Objects;

public class RedisTest {

   public static void main(String[] args) {

     RedisTemplate<String, String> template = new RedisTemplate<>();

     JedisConnectionFactory fac = new JedisConnectionFactory( new JedisPoolConfig());

     JedisShardInfo shardInfo = new JedisShardInfo( "192.168.1.1" , 6379 );

     shardInfo.setPassword( "123456" );

     fac.setShardInfo(shardInfo);

     template.setConnectionFactory(fac);

     template.setDefaultSerializer( new StringRedisSerializer());

     template.afterPropertiesSet();

     ValueOperations<String, String> op = template.opsForValue();

     final String key = "123_tmp" ;

     final String value = "abc" ;

     template.delete(key);

     op.set(key, value);

     assert Objects.equals(op.get(key), value);

   }

}

JedisConnectionFactory fac = new JedisConnectionFactory( new JedisPoolConfig());

     fac.setPort( 6379 );

     fac.setPassword( "123456" );

     fac.setHostName( "192.168.1.1" );

     fac.afterPropertiesSet();