jedis连接redis集群_redis集群问题

全栈程序员站长

发布于 2022-11-04 15:44:15

5850

发布于 2022-11-04 15:44:15

文章被收录于专栏：全栈程序员必看

启动redis集群

搭建redis集群，搭建具体过程如下 http://blog.csdn.net/lucky_ly/article/details/78703102 启动redis集群。

测试集群搭建在虚拟机的Linux系统下，客户机访问采用的windows环境下。默认情况下redis只允许本机进行访问的。但我们为了方便测试，将redis.conf的bind 改为对应的Linux系统ip，这里为192.168.48.138

使用jedisCluster

package com.redis;

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

import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;

public class RedisClusterTest { 
   
    public static void main(String[] args){
        //创建ip地址集合
        Set<HostAndPort> ips = new HashSet<HostAndPort>();
        ips.add(new HostAndPort("192.168.48.138", 7000));
        ips.add(new HostAndPort("192.168.48.138", 7001));
        ips.add(new HostAndPort("192.168.48.138", 7002));
        ips.add(new HostAndPort("192.168.48.138", 7003));
        ips.add(new HostAndPort("192.168.48.138", 7004));
        ips.add(new HostAndPort("192.168.48.138", 7005));

        JedisCluster cluster = new JedisCluster(ips);
        cluster.set("redisCluster", "pretty good");
        System.out.println(cluster.get("redisCluster"));
    }
}

使用spring装配JedisCluster

<bean class="redis.clients.jedis.JedisCluster" id="jedisCluster">
<constructor-arg>
<set>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.48.138"/>
<constructor-arg name="port" value="7000"/>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.48.138"/>
<constructor-arg name="port" value="7001"/>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.48.138"/>
<constructor-arg name="port" value="7002"/>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.48.138"/>
<constructor-arg name="port" value="7003"/>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.48.138"/>
<constructor-arg name="port" value="7004"/>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.48.138"/>
<constructor-arg name="port" value="7005"/>
</bean>
</set>
</constructor-arg>
</bean>

package ly;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import redis.clients.jedis.JedisCluster;
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:spring.xml")
public class JedisTest {
@Autowired
private  JedisCluster jedisCluster;
@Test
public void clusterTest(){
jedisCluster.set("goodMan", "ly");
System.out.println(jedisCluster.get("one"));
}
}

发布者：全栈程序员栈长，转载请注明出处：https://javaforall.cn/182051.html原文链接：https://javaforall.cn

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2022年10月14日，如有侵权请联系 cloudcommunity@tencent.com 删除

云数据库 Redis