1. 程式人生 > >Spring 使用RedisTemplate操作Redis

Spring 使用RedisTemplate操作Redis

 

首先新增依賴:

<!-- https://mvnrepository.com/artifact/redis.clients/jedis -->
        <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>2.9.0</version>
        </dependency>

        <!--
https://mvnrepository.com/artifact/org.springframework.data/spring-data-redis --> <dependency> <groupId>org.springframework.data</groupId> <artifactId>spring-data-redis</artifactId> <version>2.1.3.RELEASE</version> </
dependency>

 

建立:SpringConfig 

package the_mass.redis;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
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.core.StringRedisTemplate;

@Configuration  //配置
@ComponentScan("the_mass.redis")  //掃描那個包
public class SpringConfig {

    @Bean
    RedisConnectionFactory redisConnectionFactory(){ //獲取連線工廠
        return new JedisConnectionFactory();          //返回
}

    @Bean
    RedisTemplate redisTemplate(){      //模板
        return new StringRedisTemplate(redisConnectionFactory());  //使用連線工廠返回
    }

}


建立:RedisService
package the_mass.redis;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.connection.RedisConnection;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisOperations;
import org.springframework.stereotype.Service;

import java.nio.charset.StandardCharsets;

@Service
public class RedisService {

    @Autowired
    RedisConnectionFactory factory; //通過Redis連線的執行緒安全工廠

    @Autowired
    RedisOperations redisOperations; //通過公共介面RedisOperations


    public void testRedis() {
        RedisConnection connection = factory.getConnection();
        byte[] bytes = connection.get("hello".getBytes());
        System.out.println(new String(bytes, StandardCharsets.UTF_8));
    }

    public void testRedisTemplate() {
        Object hello = redisOperations.opsForValue().get("hello");
        System.out.println(hello);
    }

}

 

建立:JedisDemo

package the_mass.redis;

import redis.clients.jedis.Jedis;

public class JedisDemo {
    public void execute() {

        Jedis jedis = new Jedis(); //建立客戶端

        Boolean hello = jedis.exists("hello");
        System.out.println(hello);


        String s = jedis.get("hello");
        System.out.println(s);

        jedis.set("hello", "wrold:23");

        Long hello1 = jedis.exists("hello", "hello:123");
        System.out.println(hello1);


    }
}

 

測試:

package the_mass.redis;

import org.springframework.context.annotation.AnnotationConfigApplicationContext;

public class Main {
    public static void main(String[] args) {
        AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(SpringConfig.class);

        RedisService redisService = context.getBean(RedisService.class);
        redisService.testRedis();
        redisService.testRedisTemplate();
    }
}

 

 

注意:首先記得 設定值,不然會報空指標異常