- Execution file
package org.blog.test;
import com.lambdaworks.redis.RedisClient;
import lombok.extern.slf4j.Slf4j;
import org.blog.test.service.RedisService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
@SpringBootApplication
@Slf4j
public class LettuceApplication implements CommandLineRunner {
public static void main(String[] args) {
SpringApplication.run(LettuceApplication.class, args);
}
@Bean
public RedisClient redisClient() {
return RedisClient.create("redis://localhost");
}
@Autowired
private RedisService redisService;
@Override
public void run(String... args) throws Exception {
log.info("redisService.ping() : {}", redisService.ping());
log.info("redisService.set(\"key\", \"hello redis~!!\") : {}", redisService.set("key", "hello redis~!!"));
log.info("redisService.get(\"key\") : {}", redisService.get("key"));
}
}
- redisService
package org.blog.test.service;
import com.lambdaworks.redis.RedisClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class RedisServiceImpl implements RedisService {
@Autowired
private RedisClient redisClient;
@Override
public String ping() {
return redisClient.connect().sync().ping();
}
@Override
public String get(String key) {
return redisClient.connect().sync().get(key);
}
@Override
public String set(String key, String value) {
return redisClient.connect().sync().set(key, value);
}
}
- output
2017-03-31 21:28:30.035 INFO 4376 --- [ main] org.blog.test.LettuceApplication : redisService.ping() : PONG
2017-03-31 21:28:30.059 INFO 4376 --- [ main] org.blog.test.LettuceApplication : redisService.set("key", "hello redis~!!") : OK
2017-03-31 21:28:30.080 INFO 4376 --- [ main] org.blog.test.LettuceApplication : redisService.get("key") : hello redis~!!
댓글 없음 :
댓글 쓰기