依賴
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.9.0</version>
<type>jar</type>
<scope>compile</scope>
</dependency>
把 JedisCluster 注入 IoC
package com.example.redis.client;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;
import redis.clients.jedis.JedisPoolConfig;
import java.util.HashSet;
import java.util.Set;
@Configuration
public class AppConfig {
@Bean(name="jedisCluster")
public JedisCluster jedisCluster() {
Set<HostAndPort> nodeSet = new HashSet<>();
nodeSet.add(new HostAndPort("127.0.0.1", 7000));
nodeSet.add(new HostAndPort("127.0.0.1", 7001));
nodeSet.add(new HostAndPort("127.0.0.1", 7002));
nodeSet.add(new HostAndPort("127.0.0.1", 7003));
nodeSet.add(new HostAndPort("127.0.0.1", 7004));
nodeSet.add(new HostAndPort("127.0.0.1", 7005));
JedisCluster jedisCluster = new JedisCluster(nodeSet, 1000, new JedisPoolConfig());
return jedisCluster;
}
}
測(cè)試使用
package com.example.redis.client.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import redis.clients.jedis.JedisCluster;
@RestController
public class TestController {
@Autowired
private JedisCluster jedisCluster;
@RequestMapping("/cluster/set")
public String testSet() {
jedisCluster.set("color", "yellow");
String value = jedisCluster.get("color");
return value;
}
}
