redis分布式集群搭建介绍

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了redis分布式集群搭建介绍，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含8308字，纯文字阅读大概需要12分钟。

内容图文

Redis集群架构图

redis分布式集群搭建介绍 - 文章图片

上图蓝色为redis集群的节点。

节点之间通过ping命令来测试连接是否正常，节点之间没有主区分，连接到任何一个节点进行操作时，都可能会转发到其他节点。

1、Redis的容错机制

节点之间会定时的互相发送ping命令，测试节点的健康状态，当节点接受到ping命令后，会返回一个pong字符串。

投票机制：如果一个节点A给节点B发送ping没有得到pong返回，会通知其他节点再次给B发送ping，如果集群中有超过一半的节点收不B节点的pong。那么就认为B节点挂了。一般会为每个节点提供一个备份节点，如果挂掉会切换到备份节点。

2、Redis集群存储原理

Redis对于每个存放的key会进行hash操作，生成一个[0-16384]的hash值（先进行

crc 算法再对16384取余）。

集群的情况下，就是把[0-16384]的区间进行拆分，放到不同的redis中。

3、Redis的持久化

Snapshotting：定时的将Redis内存中的数据保存到硬盘中

AOF：将所有的command操作保存到aof中，AOP的同步频率很高，数据即使丢失，粒度也很小，但会在性能上造成影响。

二、集群环境搭建

redis集群管理工具redis-trib.rb依赖ruby环境，首先需要安装ruby环境

安装ruby

yum install ruby
yum install rubygems

安装ruby和redis的接口程序

拷贝redis-3.0.0.gem至/usr/local下

执行：

gem install /usr/local/redis-3.0.0.gem

三、创建Redis集群

在一台服务器上，可以用不同端口号来表示不同redis服务器。

Redis集群最少需要三台服务器，而每台服务器有需要备用服务器，所以最少需要6台服务器。端口规划如下：

主服务器：192.168.100.66 :7001 :7002 :7003

从服务器：192.168.100.66 :7004 :7005 :7006

在/usr/local 创建文件夹用来存放服务器程序

mkdir 7001 7002 7003 7004 7005 7006

如果想让redis支持集群需要修改redis.config配置文件的cluster-enabled yes

本例中我们以端口来区别不同的redis服务，所以还需要修改redis.config的port为对应端口

修改完配置文件，将redis安装目录的bin复制到上面每个目录中。

分别进入7001/bin/ 7002/bin .....

启动服务./redis-server ./redis.conf

查看redis进程：ps -aux|grep redis 如下图则说明启动成功

redis分布式集群搭建介绍 - 文章图片

创建集群：

将之前解压的文件夹的redis-3.0.0/src/redis-trib.rb复制到redis-cluster目录

运行

./redis-trib.rb create --replicas 1 192.168.100.66:7001 192.168.100.66:7002 192.168.100.66:7003 192.168.100.66:7004 192.168.100.66:7005  192.168.100.66:7006

如果执行时报如下错误：

[ERR] Node XXXXXX is not empty. Either the node already knows other nodes (check with CLUSTER NODES) or contains some key in database 0

解决方法是删除生成的配置文件nodes.conf，如果不行则说明现在创建的结点包括了旧集群的结点信息，需要删除redis的持久化文件后再重启redis，比如：appendonly.aof、dump.rdb

如果成功最终输入如下：

redis分布式集群搭建介绍 - 文章图片

查询集群信息：

redis分布式集群搭建介绍 - 文章图片

说明：

./redis-cli -c -h 192.168.101.3 -p 7001 ，其中-c表示以集群方式连接redis，-h指定ip地址，-p指定端口号

cluster nodes 查询集群结点信息

cluster info 查询集群状态信息

redis分布式集群搭建介绍 - 文章图片

hash槽重新分配

第一步：连接上集群

./redis-trib.rb reshard 192.168.101.3:7001（连接集群中任意一个可用结点都行）

第二步：输入要分配的槽数量

redis分布式集群搭建介绍 - 文章图片

输入 500表示要分配500个槽

第三步：输入接收槽的结点id

redis分布式集群搭建介绍 - 文章图片

这里准备给7007分配槽，通过cluster nodes查看7007结点id为15b809eadae88955e36bcdbb8144f61bbbaf38fb

输入：15b809eadae88955e36bcdbb8144f61bbbaf38fb

第四步：输入源结点id

redis分布式集群搭建介绍 - 文章图片

这里输入all

第五步：输入yes开始移动槽到目标结点id

redis分布式集群搭建介绍 - 文章图片

添加从节点

集群创建成功后可以向集群中添加节点，下面是添加一个slave从节点。

添加7008从结点，将7008作为7007的从结点。

./redis-trib.rb add-node --slave --master-id 主节点id 添加节点的ip和端口集群中已存在节点ip和端口

执行如下命令：

./redis-trib.rb add-node --slave --master-id cad9f7413ec6842c971dbcc2c48b4ca959eb5db4 192.168.101.3:7008 192.168.101.3:7001

cad9f7413ec6842c971dbcc2c48b4ca959eb5db4 是7007结点的id，可通过cluster nodes查看。

redis分布式集群搭建介绍 - 文章图片

注意：如果原来该结点在集群中的配置信息已经生成cluster-config-file指定的配置文件中（如果cluster-config-file没有指定则默认为nodes.conf），这时可能会报错：

[ERR] Node XXXXXX is not empty. Either the node already knows other nodes (check with CLUSTER NODES) or contains some key in database 0

解决方法是删除生成的配置文件nodes.conf，删除后再执行./redis-trib.rb add-node指令

查看集群中的结点，刚添加的7008为7007的从节点：

redis分布式集群搭建介绍 - 文章图片

删除结点：

./redis-trib.rb del-node 127.0.0.1:7005 4b45eb75c8b428fbd77ab979b85080146a9bc017

删除已经占有hash槽的结点会失败，报错如下：

[ERR] Node 127.0.0.1:7005 is not empty! Reshard data away and try again.

需要将该结点占用的hash槽分配出去（参考hash槽重新分配章节）。

测试:

Maven:
<dependencies>
    <dependency>
        <groupId>redis.clients</groupId>
        <artifactId>jedis</artifactId>
        <version>2.7.0</version>
    </dependency>
    <!-- https://mvnrepository.com/artifact/junit/junit -->
    <dependency>
        <groupId>junit</groupId>
        <artifactId>junit</artifactId>
        <version>4.12</version>
        <scope>test</scope>
    </dependency>
    <!-- https://mvnrepository.com/artifact/org.springframework/spring-test -->
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-test</artifactId>
        <version>4.3.10.RELEASE</version>
        <scope>test</scope>
    </dependency>
</dependencies>

普通测试：

@Test
public void redisClusterTest1(){
    JedisPoolConfig config=new JedisPoolConfig();
    config.setMaxTotal(30);
    config.setMaxIdle(2);

    Set<HostAndPort> jedisNode=new HashSet<HostAndPort>();
    jedisNode.add(new HostAndPort("192.168.100.66",7001));
    jedisNode.add(new HostAndPort("192.168.100.66",7002));
    jedisNode.add(new HostAndPort("192.168.100.66",7003));
    jedisNode.add(new HostAndPort("192.168.100.66",7004));
    jedisNode.add(new HostAndPort("192.168.100.66",7005));
    jedisNode.add(new HostAndPort("192.168.100.66",7006));

    JedisCluster jc=new JedisCluster(jedisNode,config);
    jc.set("name","老王");
    String value=jc.get("name");
    System.out.println(value);
}

Spring测试：

配置文件：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
    <!-- 连接池配置 -->
    <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
        <!-- 最大连接数 -->
        <property name="maxTotal" value="30" />
        <!-- 最大空闲连接数 -->
        <property name="maxIdle" value="10" />
        <!-- 每次释放连接的最大数目 -->
        <property name="numTestsPerEvictionRun" value="1024" />
        <!-- 释放连接的扫描间隔（毫秒） -->
        <property name="timeBetweenEvictionRunsMillis" value="30000" />
        <!-- 连接最小空闲时间 -->
        <property name="minEvictableIdleTimeMillis" value="1800000" />
        <!-- 连接空闲多久后释放, 当空闲时间>该值 且 空闲连接>最大空闲连接数 时直接释放 -->
        <property name="softMinEvictableIdleTimeMillis" value="10000" />
        <!-- 获取连接时的最大等待毫秒数,小于零:阻塞不确定的时间,默认-1 -->
        <property name="maxWaitMillis" value="1500" />
        <!-- 在获取连接的时候检查有效性, 默认false -->
        <property name="testOnBorrow" value="true" />
        <!-- 在空闲时检查有效性, 默认false -->
        <property name="testWhileIdle" value="true" />
        <!-- 连接耗尽时是否阻塞, false报异常,ture阻塞直到超时, 默认true -->
        <property name="blockWhenExhausted" value="false" />
    </bean>
    <!-- redis集群 -->
    <bean id="jedisCluster" class="redis.clients.jedis.JedisCluster">
        <constructor-arg index="0">
            <set>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg index="0" value="192.168.100.66"></constructor-arg>
                    <constructor-arg index="1" value="7001"></constructor-arg>
                </bean>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg index="0" value="192.168.100.66"></constructor-arg>
                    <constructor-arg index="1" value="7002"></constructor-arg>
                </bean>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg index="0" value="192.168.100.66"></constructor-arg>
                    <constructor-arg index="1" value="7003"></constructor-arg>
                </bean>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg index="0" value="192.168.100.66"></constructor-arg>
                    <constructor-arg index="1" value="7004"></constructor-arg>
                </bean>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg index="0" value="192.168.100.66"></constructor-arg>
                    <constructor-arg index="1" value="7005"></constructor-arg>
                </bean>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg index="0" value="192.168.100.66"></constructor-arg>
                    <constructor-arg index="1" value="7006"></constructor-arg>
                </bean>
            </set>
        </constructor-arg>
        <constructor-arg index="1" ref="jedisPoolConfig"></constructor-arg>
    </bean>
</beans>

测试类：

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration({"classpath:spring-config.xml"})
public class RedisClusterTest {
    @Autowired
    private JedisCluster jedisCluster;
    @Test
    public void redisClusterTest2(){
        jedisCluster.set("username","小明啦啦");
        String name=jedisCluster.get("username");
        System.out.println(name);
    }
}

更多redis知识请关注redis数据库教程栏目。

以上就是redis分布式集群搭建介绍的详细内容。

内容总结

以上是互联网集市为您收集整理的redis分布式集群搭建介绍全部内容，希望文章能够帮你解决redis分布式集群搭建介绍所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/588318.html

来源：【匿名】

【上一篇】Redis锁的简单应用介绍【下一篇】redis可以做什么？

更多 ►

【redis分布式集群搭建介绍】教程文章相关的互联网学习教程文章

Redisson实现分布式锁---原理有关Redisson作为实现分布式锁，总的分3大模块来讲。1、Redisson实现分布式锁原理 2、Redisson实现分布式锁的源码解析 3、Redisson实现分布式锁的项目代码（可以用于实际项目中）本文只介绍Redisson如何实现分布式锁的原理。其它的会在接下来的博客讲，最后有关Redisson实现分布式锁的项目代码的博客中会放上项目源码到GitHub上。一、高效分布式锁当我们在设计分布式锁的时候，我们应该考虑分布式锁至...

Redis实现的分布式锁和分布式限流【代码】【图】

随着现在分布式越来越普遍，分布式锁也十分常用，我的上一篇文章解释了使用zookeeper实现分布式锁（传送门），本次咱们说一下如何用Redis实现分布式锁和分布限流。　　Redis有个事务锁，就是如下的命令，这个命令的含义是将一个value设置到一个key中，如果不存在将会赋值并且设置超时时间为30秒，如何这个key已经存在了，则不进行设置。SET key value NX PX 30000　　这个事务锁很好的解决了两个单独的命令，一个设置set key value...

使用 Redis 实现分布式锁（转）

原文链接：http://www.oschina.net/translate/redis-distlock英文原文：Distributed locks with Redis 原文：http://www.cnblogs.com/iamcui/p/4441490.html

用redlock实现redis的分布式锁【代码】

本文是一个demo，利用多进程，来模拟使用redis分布式锁的使用场景。本机需要安装redis,python3.7下运行代码。# -*- coding: utf-8 -*- import os import arrow import redis from multiprocessing import Pool from redlock.lock import RedLockHOT_KEY = ‘count‘ r = redis.Redis(host=‘localhost‘, port=6379)def seckilling():name = os.getpid()v = r.get(HOT_KEY)if int(v) > 0:print (name, ‘ decr redis.‘)r.decr(HOT...

15 redis-分布式锁【图】

1 概念分布式锁：是进程级别的锁，用于控制多个进程对同一资源的访问。实现方式：1. 数据库乐观锁；2. 基于Redis的分布式锁；3. 基于ZooKeeper的分布式锁可靠性要求：互斥性。在任意时刻，只有一个客户端能持有锁。不会发生死锁。即使有一个客户端在持有锁的期间崩溃而没有主动解锁，也能保证后续其他客户端能加锁。具有容错性。只要大部分的Redis节点正常运行，客户端就可以加锁和解锁。加锁和解锁必须是同一个客户端，客户端自己...

Redisson实现分布式锁源码解读【代码】【图】

文章目录一、分布式锁的概念和使用场景二、将redis官网对于分布式锁（红锁）的定义和Redisson实现做概括性总结三、基于Redisson的分布式实现方案四、加锁过程分析五、锁重入过程分析六、未获取到锁的线程继续获取锁七、锁释放过程分析八、易混淆概念一、分布式锁的概念和使用场景分布式锁是控制分布式系统之间同步访问共享资源的一种方式。　　在分布式系统中，常常需要协调他们的动作。如果不同的系统或是同一个系统的不同主...

redis分布式共享锁模拟抢单的实现【代码】【图】

本篇内容主要讲解的是redis分布式锁，并结合模拟抢单的场景来使用，内容节点如下：jedis的nx生成锁如何删除锁模拟抢单动作1.jedis的nx生成锁对于分布式锁的生成通常需要注意如下几个方面：创建锁的策略：redis的普通key一般都允许覆盖，A用户set某个key后，B在set相同的key时同样能成功，如果是锁场景，那就无法知道到底是哪个用户set成功的；这里jedis的setnx方式为我们解决了这个问题，简单原理是：当A用户先set成功了，那B用户s...

使用 Redis 实现分布式系统轻量级协调技术【代码】【图】

在分布式系统中，各个进程（本文使用进程来描述分布式系统中的运行主体，它们可以在同一个物理节点上也可以在不同的物理节点上）相互之间通常是需要协调进行运作的，有时是不同进程所处理的数据有依赖关系，必须按照一定的次序进行处理，有时是在一些特定的时间需要某个进程处理某些事务等等，人们通常会使用分布式锁、选举算法等技术来协调各个进程之间的行为。因为分布式系统本身的复杂特性，以及对于容错性的要求，这些技术通常...

redis实现分布式锁【代码】

jedis原生方式　　相关依赖 <dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>2.9.2</version></dependency><dependency><groupId>org.apache.commons</groupId><artifactId>commons-pool2</artifactId><version>2.5.0</version></dependency>　　代码如下package jedisLock;import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.jedis.Jed...

使用Redis的分布式Java锁【代码】

通过优锐课的java学习分享中，了解有关分布式锁定以及如何在项目中实现它的更多信息！什么是分布式锁定？在多线程程序中，不同的线程可能需要访问相同的资源。但是，允许所有线程同时访问资源可能导致争用情况，错误和其他意外行为。为了确保没有两个线程可以同时访问同一资源，并确保以可预测的顺序对资源进行操作，程序员使用一种称为锁的机制。每个线程首先获取锁，然后对资源进行操作，最后将锁释放给其他线程。在Java中，由于...

（九）Net Core项目使用Session及用Redis做分布式【代码】【图】

一、简介1、因为Net Core默认是没有启动Session功能的，如果需要使用，需要通过代码开启。2、本篇说明如果启用默认Session实现，即Session存到内存中。3、本篇扩展说明如何用Redis做Sessoin服务器，实现分布式。二、开启默认Session功能1、编写一个api，先写Session，再读取Session返回。2、Startup未启动Session功能，查看效果，报错。3、在Startup中添加两处启用Session代码，查看效果，正常。这里有知识点，UseSession需要写在...

Redis中的Java分布式缓存【代码】

为什么在分布式Java应用程序中使用缓存？今天学习了两节优锐课讲解分布式缓存的内容，收获颇多，分享给大家。在提高应用程序的速度和性能时，每毫秒都是至关重要的。例如，根据Google的一项研究，如果网站在3秒或更短时间内无法加载，则有53％的移动用户会离开该网站。缓存是使你的分布式应用程序更快的最重要的技术之一。你可以将信息存储到计算机的CPU中越近，访问信息的速度就越快。从CPU缓存中加载数据要比从RAM中加载数据快得...

分布式中使用Redis实现Session共享(二)【代码】【图】

上一篇介绍了一些redis的安装及使用步骤，本篇开始将介绍redis的实际应用场景,先从最常见的session开始，刚好也重新学习一遍session的实现原理。在阅读之前假设你已经会使用nginx+iis实现负载均衡搭建负载均衡站点了，这里我们会搭建两个站点来验证redis实现的session是否能共享。阅读目录Session实现原理session共享实现方案问题拓展总结回到顶部Session实现原理　　session和cookie是我们做web开发中常用到的两个对象，它们之间会...

如何用redis实现分布式锁【代码】

引子redis作为一个强大的key/value数据库，其实还可以用来实现轻量级的分布式锁。1.实现方案1最早官方在SETNX命令页给了一个实现：acquire lock: SETNX lock.foo <current Unix time + lock timeout + 1> release lock: DEL lock.fooacquire lock when time expired: GETSET lock.foo <current Unix timestamp + lock timeout + 1>不过这个方案有漏洞，就是release lock用的DEL命令不支持cas删除（delete if current value equals ...

分布式 Dubbo+Zookeeper+springmvc+mybatis+shiro+restful+activemq+redis【图】

1. 项目核心代码结构截图650) this.width=650;" src="/upload/getfiles/default/2022/11/11/20221111061017181.jpg" /><modules>  <module>jeesz-utils</module>  <module>jeesz-config</module>  <module>jeesz-framework</module>  <module>jeesz-core-cms<...

首页 / REDIS / redis分布式集群搭建介绍

redis分布式集群搭建介绍

内容导读

内容图文

内容总结

内容备注

内容手机端

【redis分布式集群搭建介绍】教程文章相关的互联网学习教程文章

Redisson实现分布式锁---原理【代码】【图】

Redis实现的分布式锁和分布式限流【代码】【图】

使用 Redis 实现分布式锁（转）

用redlock实现redis的分布式锁【代码】

15 redis-分布式锁【图】

Redisson实现分布式锁源码解读【代码】【图】

redis分布式共享锁模拟抢单的实现【代码】【图】

使用 Redis 实现分布式系统轻量级协调技术【代码】【图】

redis实现分布式锁【代码】

使用Redis的分布式Java锁【代码】

（九）Net Core项目使用Session及用Redis做分布式【代码】【图】

Redis中的Java分布式缓存【代码】

分布式中使用Redis实现Session共享(二)【代码】【图】

如何用redis实现分布式锁【代码】

分布式 Dubbo+Zookeeper+springmvc+mybatis+shiro+restful+activemq+redis【图】

REDIS - 相关标签

分布式 - 相关标签

集群 - 相关标签

REDIS - 技术教程分类

REDIS - 最新教程

REDIS - 最热教程