C#两大知名Redis客户端连接哨兵集群的姿势

本文涉及的产品
云数据库 Tair(兼容Redis),内存型 2GB
Redis 开源版,标准版 2GB
推荐场景:
搭建游戏排行榜
简介: 我的思路是将Redis、Sentinel、Redis Client App链接到同一个网桥网络,这个网桥内的Redis Client App就可以使用ContainerIP访问网桥内任意redis节点。

前言


前面《Docker-Compose搭建Redis高可用哨兵集群》,

我的思路是将Redis、Sentinel、Redis Client App链接到同一个网桥网络,这个网桥内的Redis Client App就可以使用ContainerIP访问网桥内任意redis节点。


b377e0e049c18528c7a1a0b67c33d8de.png


同一网桥网络访问规避了Docker上发生的NAT,端口映射的复杂性,  但实际上并不是最常规做法。


Redis Client App独立组网遇到的问题


很多时候,Redis Client App与Redis-Sentinel独立组网,样对Redis-Sentinel的访问就会涉及Docker宿主机NAT转换、Port映射。


(这里我们就不提Docker Host模式搭建Redis-Sentinel了)


9ee719c988ef02eec929d2ec9d8e476b.png


资料显示 Sentinel,Docker或其他形式的网络地址转换或端口映射应谨慎混合,大意是说节点无法区分收到的信息是否是已经发生Nat转换或端口映射的结果。


为了解决Redis-Sentinel在Docker环境下因为NAT,Forward Port导致的无法正确获知Slaves和正确故障转移的问题。


Redis3.2之后可以强制让Slave声明自己的(IP,Port);强制让Sentinel声明自己的(IP,Port)


# since Redis 3.2.2, to force a replica to announce an arbitrary pair of IP and port to the master. The two configurations directives to use are:
replica-announce-ip <ip>
replica-announce-port <port>


上述配置可以写在Docker Command参数指定或通过Volume redis.conf 加载进redis容器


# you can use the following two Sentinel configuration directives in order to force Sentinel to announce a specific set of IP and port:
sentinel announce-ip <ip>
sentinel announce-port <port>


sentinel.conf的配置只能通过Config加载进sentinel容器。


通过明牌方式通知所有交互对象,redis实例就是在这个(IP,Port)上发生了NAT转换、Port映射。


C#两大客户端访问Redis-Sentinel的方式

归根到底一张图:


bba10418cb4b249e283da8ee27638394.png


  1. Redis Client先询问Sentinels,Sentinel返回Master (IP,Port)


  1. Redis Client再与以上Master (IP,Port)建立连接


Docker部署Redis-Sentinel 并强制声明IP、Port


这里我们采用主动声明方式在Docker上部署了Redis-Sentinel集群, 1Master- 2 Slave- 3Sentinel, 分别占据宿主机6380、6381、6382、 26379、26380、26381端口.


CONTAINER ID        IMAGE                          COMMAND                  CREATED             STATUS                  PORTS                                NAMES
484da8d832f1        redis                          "docker-entrypoint.s…"   2 hours ago         Up 2 hours              6379/tcp, 0.0.0.0:26380->26379/tcp   redis-sentinel-2
50599c15adba        redis                          "docker-entrypoint.s…"   2 hours ago         Up 2 hours              6379/tcp, 0.0.0.0:26379->26379/tcp   redis-sentinel-1
51ce90cc52d7        redis                          "docker-entrypoint.s…"   2 hours ago         Up 2 hours              6379/tcp, 0.0.0.0:26381->26379/tcp   redis-sentinel-3
d58d6973de28        redis                          "docker-entrypoint.s…"   2 hours ago         Up 2 hours              0.0.0.0:6381->6379/tcp               redis-slave-1
b88bd85ac109        redis                          "docker-entrypoint.s…"   2 hours ago         Up 8 seconds            0.0.0.0:6382->6379/tcp               redis-slave-2
3dc26c01a90d        redis                          "docker-entrypoint.s…"   2 hours ago         Up About an hour        0.0.0.0:6380->6379/tcp               redis-master


进入任意Sentinel节点,使用sentinel master mymaster确认集群信息


9eff495a4835c89bac51e048b7ddee3e.png


存在测试键值:testKey:hello Redis-sentinel!


StackExchange.Redis & CSRedisCore连接Redis哨兵


老牌StackExchange.Redis 今年才真正支持Sentinel, Github上有关Sentinel的Issue、PR历时久远,PR像便秘一样最近才关闭。


https://github.com/StackExchange/StackExchange.Redis/pull/692#issuecomment-375298108

https://github.com/StackExchange/StackExchange.Redis/pull/1067


CSRedisCore得到真传,很早就支持连接哨兵,而且编程写法更简单,清晰。

话不多说:


using StackExchange.Redis;
using System;
namespace ConsoleApp
{
    class Program
    {
        static void Main(string[] args)
        {
            var sw = new Stopwatch();
            sw.Start();
            UseStackExchangeRedis();
            sw.Stop();
            Console.WriteLine("连接+查询测试key,耗时"+sw.ElapsedMilliseconds);
            sw.Reset();
            sw.Start();
            UseCSRedisCore();
            sw.Stop();
            Console.WriteLine("连接+查询测试key,耗时" + sw.ElapsedMilliseconds);
            Console.ReadKey();
        }
       // StackExchange.Reids连接Redis-Sentinel
        public  static void  UseStackExchangeRedis()
        {
            ConfigurationOptions sentinelOptions = new ConfigurationOptions();
            sentinelOptions.EndPoints.Add("180.76.*.*", 26379);
            sentinelOptions.EndPoints.Add("180.76.*.*", 26380);
            sentinelOptions.EndPoints.Add("180.76.*.*", 26381);
            sentinelOptions.TieBreaker = "";
            sentinelOptions.CommandMap = CommandMap.Sentinel;
            sentinelOptions.AbortOnConnectFail = false;
            // Connect!
            ConnectionMultiplexer sentinelConnection = ConnectionMultiplexer.Connect(sentinelOptions);
            // Get a connection to the master
            ConfigurationOptions redisServiceOptions = new ConfigurationOptions();
            redisServiceOptions.ServiceName = "mymaster1";   //master名称
            redisServiceOptions.Password = "redis_pwd";     //master访问密码
            redisServiceOptions.AbortOnConnectFail = true;
            ConnectionMultiplexer masterConnection = sentinelConnection.GetSentinelMasterConnection(redisServiceOptions);
            var db  = masterConnection.GetDatabase();
            var value= db.StringGet("testKey");
            Console.WriteLine($"[Use StackExchange-Redis] The remote redis-sentinel test key value:{value}");
        }
    // CSRedisCore连接Redis-Sentinel
        public static  void UseCSRedisCore()
        {
            var csredis = new CSRedis.CSRedisClient("mymaster1,password=redis_pwd",
                    new[] { "180.76.*.*:26379", "180.76.*.*:26380", "180.76.*.*:26381" });
            var value = csredis.Get("testKey");
            Console.WriteLine($"[Use CSRedisCore] The remote redis-sentinel test key value:{value}");
        }
    }
}


执行输出:


e097e029428e09b3d2a32067a9134193.png


StackExchange.Redis更能体现连接的实质过程:先查询,再连接。

CSRedisCore 小白写法,无感知。


总结输入


本文记录两个内容:


1. Redis-Sentinel在Docker环境因NAT,Forward_Port触发的问题, 以及Redis官方给出的方案

2. C# Redis客户端连接Redis-Sentinel集群Gthub:


https://github.com/zaozaoniao/Redis-sentinel-with-docker-compose本文纯手写+测试,期待你的反馈。

相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务,基于高可靠双机热备架构及可无缝扩展的集群架构,满足高读写性能场景及容量需弹性变配的业务需求。 产品详情:https://www.aliyun.com/product/kvstore &nbsp; &nbsp; ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库&nbsp;ECS 实例和一台目标数据库&nbsp;RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&amp;RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
相关文章
|
3月前
|
NoSQL Redis 数据安全/隐私保护
Redis 最流行的图形化界面下载及使用超详细教程(带安装包)! redis windows客户端下载
文章提供了Redis最流行的图形化界面工具Another Redis Desktop Manager的下载及使用教程,包括如何下载、解压、连接Redis服务器以及使用控制台和查看数据类型详细信息。
254 6
Redis 最流行的图形化界面下载及使用超详细教程(带安装包)! redis windows客户端下载
|
3月前
|
NoSQL Redis 数据库
Redis 图形化界面下载及使用超详细教程(带安装包)! redis windows下客户端下载
文章提供了Redis图形化界面工具的下载及使用教程,包括如何连接本地Redis服务器、操作键值对、查看日志和使用命令行等功能。
231 0
Redis 图形化界面下载及使用超详细教程(带安装包)! redis windows下客户端下载
|
3月前
|
NoSQL Redis 数据库
Redis 连接
10月更文挑战第19天
39 0
|
19天前
|
NoSQL 应用服务中间件 API
Redis是如何建立连接和处理命令的
本文主要讲述 Redis 是如何监听客户端发出的set、get等命令的。
150 12
|
1月前
|
存储 NoSQL Redis
redis主从集群与分片集群的区别
主从集群通过主节点处理写操作并向从节点广播读操作,从节点处理读操作并复制主节点数据,优点在于提高读取性能、数据冗余及故障转移。分片集群则将数据分散存储于多节点,根据规则路由请求,优势在于横向扩展能力强,提升读写性能与存储容量,增强系统可用性和容错性。主从适用于简单场景,分片适合大规模高性能需求。
45 5
|
2月前
|
监控 NoSQL 网络协议
【Azure Redis】部署在AKS中的应用,连接Redis高频率出现timeout问题
查看Redis状态,没有任何异常,服务没有更新,Service Load, CPU, Memory, Connect等指标均正常。在排除Redis端问题后,转向了AKS中。 开始调查AKS的网络状态。最终发现每次Redis客户端出现超时问题时,几乎都对应了AKS NAT Gateway的更新事件,而Redis服务端没有任何异常。因此,超时问题很可能是由于NAT Gateway更新事件导致TCP连接被重置。
|
2月前
|
数据库连接 数据库 C#
Windows下C# 通过ADO.NET方式连接南大通用GBase 8s数据库(上)
Windows下C# 通过ADO.NET方式连接南大通用GBase 8s数据库(上)
|
2月前
|
数据库连接 数据库 C#
Windows下C# 通过ADO.NET方式连接南大通用GBase 8s数据库(下)
本文接续前文,深入讲解了在Windows环境下使用C#和ADO.NET操作南大通用GBase 8s数据库的方法。通过Visual Studio 2022创建项目,添加GBase 8s的DLL引用,并提供了详细的C#代码示例,涵盖数据库连接、表的创建与修改、数据的增删查改等操作,旨在帮助开发者提高数据库管理效率。
|
3月前
|
NoSQL 网络协议 算法
Redis 客户端连接
10月更文挑战第21天
50 1
|
4月前
|
JSON NoSQL Java
redis的java客户端的使用(Jedis、SpringDataRedis、SpringBoot整合redis、redisTemplate序列化及stringRedisTemplate序列化)
这篇文章介绍了在Java中使用Redis客户端的几种方法,包括Jedis、SpringDataRedis和SpringBoot整合Redis的操作。文章详细解释了Jedis的基本使用步骤,Jedis连接池的创建和使用,以及在SpringBoot项目中如何配置和使用RedisTemplate和StringRedisTemplate。此外,还探讨了RedisTemplate序列化的两种实践方案,包括默认的JDK序列化和自定义的JSON序列化,以及StringRedisTemplate的使用,它要求键和值都必须是String类型。
redis的java客户端的使用(Jedis、SpringDataRedis、SpringBoot整合redis、redisTemplate序列化及stringRedisTemplate序列化)