java访问redis集群服务器

继续上篇REDIS集群通过java代码访问

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-redis</artifactId>
<version>1.3.5.RELEASE</version>
</dependency>

package com.terry.redis;

import java.util.HashSet;
import java.util.Set;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;
@Configuration
public class RedisConfiguration {

@Bean
public JedisCluster getRedisCluster() {
Set<HostAndPort>  jedisClusterNodes = new HashSet<HostAndPort>();
jedisClusterNodes.add(new HostAndPort("192.168.2.113",7000));
jedisClusterNodes.add(new HostAndPort("192.168.2.113",7001));
jedisClusterNodes.add(new HostAndPort("192.168.2.113",7002));
JedisCluster jc = new JedisCluster(jedisClusterNodes,5000,1000);
return jc;
}
}

package com.terry.action;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import redis.clients.jedis.JedisCluster;

@RestController
@RequestMapping("/redis")
public class RedisAction {

@Autowired
private JedisCluster jedisCluster;

@RequestMapping("/set/{key}/{value}")
public String set(@PathVariable("key") String key,@PathVariable("value") String value) {
String result = "NO";
try {
result = jedisCluster.set(key, value);
System.out.println(result);
} catch (Exception e) {
e.printStackTrace();
}
return result;
}
@RequestMapping("/get/{key}")
public String get(@PathVariable("key") String key) {
String value = jedisCluster.get(key);
return value;
}
}