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

前言

前面《Docker-Compose搭建Redis高可用哨兵集群》,
我的思路是将Redis、Sentinel、Redis Client App链接到同一个网桥网络,这个网桥内的Redis Client App就可以使用ContainerIP访问网桥内任意redis节点。

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

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

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

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

资料显示 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的方式

归根到底一张图:

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

  2. 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确认集群信息

存在测试键值: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-Sentinelpublic  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 masterConfigurationOptions 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-Sentinelpublic 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}");}}
}

执行输出:

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

本文纯手写+测试,期待你的反馈。

  • https://redis.io/topics/sentinel

  • https://redis.io/topics/replication

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/310537.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Docker之Dockerfile详解

使用Dockerfile创建镜像 Dockerfile是一个文本格式的配置文件&#xff0c;我们可以利用Dockerfile来快速的创建一个自定义的镜像。 基本结构 Dockerfile由一行命令语句组成&#xff0c;并且支持以#开头的注释一般包括四个部分&#xff1a;基础镜像信息&#xff0c;维护者信息…

[剑指offer]面试题34:丑数

面试题34&#xff1a;丑数 题目&#xff1a;我们把只包含因子2、3和5的数称作丑数&#xff08;Ugly Number&#xff09;。求按从小到大的顺序的第1500个丑数。例如6、8都是丑数&#xff0c;但14不是&#xff0c;因为它包含因子7。习惯上我们把1当做第一个丑数。 ❖ 逐个判断每…

创业的N种死法

点击蓝字关注&#xff0c;回复“职场进阶”获取职场进阶精品资料一份互联网的江湖一直流传着大佬们的创业传奇。马云上厕所几分钟敲定几千万美金融资。王石走投无路靠倒卖玉米赚到上百万从此逆袭。扎克伯格为了获得哈佛美女照片&#xff0c;开发一个小玩意从此改变了世界。传奇…

Docker容器实战思维

Docker成功的基础 Docker的实现用到的基础技术&#xff08;cgroups, namespace&#xff0c;分层文件系统&#xff09;在Docker之前已经存在很多年&#xff0c;并且 Linux Containers&#xff08;LXC&#xff09;也在很多企业的环境中得到了大量的应用实践&#xff0c;并得到明…

[剑指offer]面试题35:第一个只出现一次的字符

面试题35&#xff1a;第一个只出现一次的字符 题目&#xff1a;在字符串中找出第一个只出现一次的字符。如输入"abaccdeff"&#xff0c;则输出’b’。 代码如下: char FirstNotRepeatingChar(char *pString) {if (pString nullptr) return \0;const int tableSize…

dotNET Core 3.X 请求处理管道和中间件的理解

理解 dotNET Core 中的管道模型&#xff0c;对我们学习 dotNET Core 有很大的好处&#xff0c;能让我们知其然&#xff0c;也知其所以然&#xff0c;这样在使用第三方组件或者自己写一些扩展时&#xff0c;可以避免入坑&#xff0c;或者说避免同样的问题多次入坑。本文分为以下…

数据结构与算法--实现Singleton模式

题目&#xff1a;设计一个类&#xff0c;我们只生成该类的一个实例。 只生成一个实例的类就是实现Singleton&#xff08;单例&#xff09;模式的类型。本题其实主要考察我们设计模式&#xff0c;因为面试的时候先来一个简单的&#xff0c;并且喜欢面设计模式相关的题目&#x…

[剑指offer]面试题37:两个链表的第一个公共结点

面试题37&#xff1a;两个链表的第一个公共结点 题目&#xff1a;输入两个链表&#xff0c;找出它们的第一个公共结点。链表结点定义如下&#xff1a; struct ListNode {int val;ListNode *next;ListNode(int x) : val(x), next(NULL) {} };思路: 两个链表长度分别为L1C、L2C&…

了解.NET中的垃圾回收

原文来自互联网&#xff0c;由长沙DotNET技术社区编译。尽管这是一篇来自2009年的古老的文章&#xff0c;但或许能够对你理解GC产生一些作用。 了解.NET中的垃圾回收一旦了解了.NET的垃圾收集器是如何工作的&#xff0c;那么可能会触及.NET应用程序的一些更为神秘的问题时&…

数据结构与算法--数组:二维数组中查找

数组 数组最简单的是数据结构&#xff0c;占据一整块连续的内存并按照顺序存储数据&#xff0c;创建数组时候&#xff0c;我们需要首先指定数组的容量大小&#xff0c;然后根据大小分配内存。即使我们只在数组中存储一个元素&#xff0c;亚需要为所有数据预先分配内存&#xf…

[剑指offer]面试题41:和为s的两个数字VS和为s的连续正数序列

面试题41&#xff1a;和为s的两个数字VS和为s的连续正数序列 题目一&#xff1a;输入一个递增排序的数组和一个数字s&#xff0c;在数组中查找两个数&#xff0c;使得它们的和正好是s。如果有多对数字的和等于s&#xff0c;输出任意一对即可。 代码如下: bool FindNumbersWit…

数字化演化历史

回顾历史&#xff0c;帮助我们展望未来&#xff0c;在数字化技术出现之前&#xff0c;人类历史几千年的历史中&#xff0c;人类社会中&#xff0c;人类的大脑是唯一可以作信息处理的。比如我们发明了汽车&#xff0c;需要人来开车&#xff1b;发明了飞机&#xff0c;需要人来驾…

数据结构与算法--字符串:字符串替换

数据结构与算法–字符串&#xff1a;字符串替换 字符串的优化 由于字符串在编程时候使用的评率非常高&#xff0c;为了优化&#xff0c;很多语言都对字符串做了特殊的规定。下面我们讨论java中字符串的特性java中的字符数组以’\0’ 结尾&#xff0c;我们可以利用这个特性来找…

[剑指offer]面试题42:翻转单词顺序 VS左旋转字符串

面试题42&#xff1a;翻转单词顺序 VS左旋转字符串 题目一&#xff1a;输入一个英文句子&#xff0c;翻转句子中单词的顺序&#xff0c;但单词内字符的顺序不变。为简单起见&#xff0c;标点符号和普通字母一样处理。例如输入字符串"I am a student."&#xff0c;则输…

数据结构与算法--经典10大排序算法(动图演示)【建议收藏】

十大经典排序算法总结&#xff08;动图演示&#xff09; 算法分类 十大常见排序算法可分为两大类&#xff1a; 比较排序算法&#xff1a;通过比较来决定元素的位置&#xff0c;由于时间复杂度不能突破O(nlogn)&#xff0c;因此也称为非线性时间比较类排序非比较类型排序&…

如何查找,修复和避免C#.NET中内存泄漏的8个最佳实践

原文来自互联网&#xff0c;由长沙DotNET技术社区编译。本文来源&#xff1a;https://michaelscodingspot.com/find-fix-and-avoid-memory-leaks-in-c-net-8-best-practices/从事大型企业项目的任何人都知道内存泄漏就像是大型酒店中的老鼠。当它们很少时&#xff0c;您可能不会…

[剑指offer]面试题47:不用加减乘除做加法

面试题47&#xff1a;不用加减乘除做加法 题目&#xff1a;写一个函数&#xff0c;求两个整数之和&#xff0c;要求在函数体内不得使用、-、、四则运算符号。 代码如下: int add(int num1, int num2) {int sum, carry;do{sum (num1 ^ num2);carry (num1 & num2) <&l…

ASP.NET Core技术研究-探秘依赖注入框架

ASP.NET Core在底层内置了一个依赖注入框架&#xff0c;通过依赖注入的方式注册服务、提供服务。依赖注入不仅服务于ASP.NET Core自身&#xff0c;同时也是应用程序的服务提供者。毫不夸张的说&#xff0c;ASP.NET Core通过依赖注入实现了各种服务对象的注册和创建&#xff0c;…

Redis遍历方式思考--字典扩容方式

全量遍历keys 工作中线上Redis维护&#xff0c;有时候我们需要查询特定前缀的缓存key列表来手动处理数据。可能是修改值&#xff0c;删除key。那么怎么才能快速的从海量的key中查找到对应的前缀匹配项。Redis提供了一下简单的指令&#xff0c;例如keys用来满足特定正则下的key…

[剑指offer]面试题48:不能被继承的类

面试题48&#xff1a;不能被继承的类 题目&#xff1a;用C设计一个不能被继承的类。 ❖ 常规的解法&#xff1a;把构造函数设为私有函数 很多人都能够想到&#xff0c;在 C中子类的构造函数会自动调用父类的构造函数&#xff0c;子类的析构函数也会自动调用父类的析构函数。 …