Java连接redis集群操作存储、删除以及获取值
pom 文件添加:
1 2 3 4 5 6 | <!-- https: //mvnrepository.com/artifact/redis.clients/jedis --> <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version> 2.9 . 0 </version> </dependency> |
实现代码如下:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 | import java.util.HashSet; import java.util.Map; import java.util.Set; import redis.clients.jedis.HostAndPort; import redis.clients.jedis.JedisCluster; public class Redis { private JedisCluster jedisCluster; public Redis() { String redisString = "redisCluster=192.168.100.46:30601,192.168.100.46:30602,192.168.100.46:30603,192.168.100.46:30604,192.168.100.46:30605,192.168.100.46:30606" ; String[] hostArray = redisString.split( "," ); Set<HostAndPort> nodes = new HashSet<HostAndPort>(); //配置redis集群 for (String host : hostArray) { String[] detail = host.split( ":" ); nodes.add( new HostAndPort(detail[ 0 ] , Integer.parseInt(detail[ 1 ])) ); } jedisCluster = new JedisCluster(nodes); } /** * 获取redis中指定key的值,value类型为String的使用此方法 */ public String get(String key) { return jedisCluster.get(key); } /** * 设置redis中指定key的值,value类型为String的使用此方法 */ public void set(String key,String value) { jedisCluster.set(key,value); } /** * 获取redis中指定key的值,对应的value,value类型为MAP的使用此方法 */ public Map<String,String> getMap(String key) { return jedisCluster.hgetAll(key); } /** * 删除redis中指定key的值项 */ public void del(String key) { jedisCluster.del(key); } public static void main(String args[]) { String value = new Redis().get( "CompanyTenantID_10005" ); System.out.println(value); } } |