假如你现在还在为自己的技术担忧，假如你现在想提升自己的工资，假如你想在职场上获得更多的话语权，假如你想顺利的度过35岁这个魔咒，假如你想体验BAT的工作环境，那么现在请我们一起开启提升技术之旅吧，详情请点击

记得链接之前关闭防火墙，或者把本端口号添加到防火墙例外

[root@localhost-0723 bin]# service iptables stop-A INPUT -m state --state ESTABLISHED,RELATED -j ACCEPT-A INPUT -p icmp -j ACCEPT-A INPUT -i lo -j ACCEPT-A INPUT -m state --state NEW -m tcp -p tcp --dport 22 -j ACCEPT-A INPUT -m state --state NEW -m tcp -p tcp --dport 8080 -j ACCEPT-A INPUT -m state --state NEW -m tcp -p tcp --dport 6379 -j ACCEPT-A INPUT -m state --state NEW -m tcp -p tcp --dport 6380 -j ACCEPT-A INPUT -m state --state NEW -m tcp -p tcp --dport 7001 -j ACCEPT-A INPUT -m state --state NEW -m tcp -p tcp --dport 7002 -j ACCEPT-A INPUT -m state --state NEW -m tcp -p tcp --dport 7003 -j ACCEPT-A INPUT -m state --state NEW -m tcp -p tcp --dport 7004 -j ACCEPT-A INPUT -m state --state NEW -m tcp -p tcp --dport 7005 -j ACCEPT-A INPUT -m state --state NEW -m tcp -p tcp --dport 7006 -j ACCEPT-A INPUT -j REJECT --reject-with icmp-host-prohibited-A FORWARD -j REJECT --reject-with icmp-host-prohibitedCOMMIT~                                                                               "/etc/sysconfig/iptables" 22L, 1079C 已写入                   [root@localhost-0723 bin]# service iptables restartiptables：应用防火墙规则：                                 [确定][root@localhost-0723 bin]#

 

一，使用redis命令行客户端连接

[root@localhost redis-cluster]# ./redis1/redis-cli -p 7001 -c127.0.0.1:7001> get a-> Redirected to slot [15495] located at 192.168.37.131:7003(nil)192.168.37.131:7003>

一定要加-c参数,节点之间就可以互相跳转

二，使用jedis连接

2.1，创建JedisCluster类连接redis集群。

 

package com.pc.jedis.test; import java.util.HashSet;import java.util.Set; import redis.clients.jedis.HostAndPort;import redis.clients.jedis.JedisCluster; /** * Jedis集群测试 *  * @author Switch * @data 2017年2月11日 * @version V1.0 */public class JedisClusterTest {    public static void main(String[] args) {        // 创建并填充节点信息        Set
     
       nodes = new HashSet<>();        nodes.add(new HostAndPort("192.168.37.131", 7001));        nodes.add(new HostAndPort("192.168.37.131", 7002));        nodes.add(new HostAndPort("192.168.37.131", 7003));        nodes.add(new HostAndPort("192.168.37.131", 7004));        nodes.add(new HostAndPort("192.168.37.131", 7005));        nodes.add(new HostAndPort("192.168.37.131", 7006));         // 创建JedisCluster对象        JedisCluster jedisCluster = new JedisCluster(nodes);         // 使用jedisCluster操作redis        String key = "jedisCluster";        String setResult = jedisCluster.set(key, "hello redis!");        System.out.println(setResult);         String getResult = jedisCluster.get(key);        System.out.println(getResult);         // 关闭jedisCluster（程序执行完后才能关闭，内部封装了连接池）        jedisCluster.close();    }}
     

 

 

2.2，applicationContext.xml

 

 

测试代码

private ApplicationContext applicationContext;    @Before    public void init() {        applicationContext = new ClassPathXmlApplicationContext(                "classpath:applicationContext.xml");    }    // redis集群    @Test    public void testJedisCluster() {        JedisCluster jedisCluster = (JedisCluster) applicationContext                .getBean("jedisCluster");        jedisCluster.set("name", "zhangsan");        String value = jedisCluster.get("name");        System.out.println(value);    }