StackExchange.Redis客户端读写主从配置,以及哨兵配置

今天简单分享一下StackExchange.Redis客户端中配置主从分离以及哨兵的配置。

关于哨兵如果有不了解的朋友,可以看我之前的一篇分享,当然主从复制文章也可以找到。http://www.cnblogs.com/tdws/tag/NoSql/

为什么要有这篇分享呢,是因为我之前也有一些疑问,相信学习Redis的朋友都有过相同的疑问。

在代码中,如何分别操作主从数据库?,也就是说,如何只向主数据库写,而读取只向从服务器读。我目前给出的解决方案就是有关Set命令使用主服务器地址,关于Get的命令使用多个从服务器地址

下面我没有分别给出set和get配置不同服务器地址的代码,给出一个集群的写法吧。如果觉得代码比较突兀,那还是从第一篇,基础配置看一下吧。下面的配置就是个例子。

ConfigurationOptions option = new ConfigurationOptions();

            option.EndPoints.Add("127.0.0.1", 6379);

            option.EndPoints.Add("127.0.0.1", 6380);

            option.EndPoints.Add("127.0.0.1", 6381);

             _redis = ConnectionMultiplexer.Connect(option);

            _db = _redis.GetDatabase();

现在集群配置完了,那么主服务器挂了怎么办,这个时候就是配置哨兵的事情了。当主服务器6379挂掉,自然会有从服务器升为主服务。你依然可以正常操作所有命令。

接下来,又有一个问题出现了。如果你真的将set设置仅为主服务器,get相关都设置为从服务器。当主服务器挂了,即使你配置的哨兵将某个从升为主,但是你的代码或者你代码中的配置文件,并不知道你主从已经切换了呀!

下面简单给出sentinel哨兵的连接以及订阅主从切换事件的代码。(发布订阅相关文章请看这里http://www.cnblogs.com/tdws/p/5827704.html)

private static readonly ConnectionMultiplexer _sentinel;

        static ISubscriber sub;

        static ISubscriber sentinelsub; 



ConfigurationOptions sentineloption = new ConfigurationOptions();

            sentineloption.TieBreaker = "";//sentinel模式一定要写

            sentineloption.EndPoints.Add("127.0.0.1", 5000);

            sentineloption.CommandMap = CommandMap.Sentinel;

            sentineloption.ServiceName = "mymaster";

            _sentinel = ConnectionMultiplexer.Connect(sentineloption);

            option.CommandMap = CommandMap.Sentinel;

            sentinelsub= _sentinel.GetSubscriber();

注意这段sentinel配置代码 同样放在(追加上就行)我们初始化_redis时的静态构造函数中。

其中的sentinelsub是我们订阅消息的对象。

订阅消息的方法

public  void SubSentinel()

        {

            sentinelsub.Subscribe("+switch-master", (channel, message) =>

            {

                

                Console.WriteLine((string)message);

            });

        }

我们订阅redis为我们提供的名称为 +switch-master 的channel。

这个时候,你可以在应用程序中的某处调用SubSentinel方法,其实就是注册一下你订阅了这个事件。

你可以在订阅事件中打上断点,然后手动关闭主服务器,主从成功由我们配置的sentinel哨兵切换后,断点会进来。

现在你看一下返回的message,其中包含了哨兵的地址和新的master服务器的地址。

下一步就是根据你所获取的message,修改你的配置文件,或者直接修改所有set命令所使用的 主服务器地址为 message中的主服务器地址。

从而你的读写操作都不会受到影响或者挂掉。

 

相关文章:

  • Redis到底该如何利用(一)?

  • Redis到底该如何利用(二)?

  • Redis 3.0.0正式版发布,高性能 K/V 服务

  • 用Docker构建分布式Redis集群

  • 推荐–个通用缓存接口抽象类库:CacheManager

  • asp.net core 使用 Redis 和 Protobuf 进行 Session 缓存

  • C#使用Redis集群缓存

  • Azure Redis 缓存的 ASP.NET 会话状态提供程序

  • 搜狐视频Redis私有云cachecloud开源了

  • 在.Net项目中使用Redis作为缓存服务

  • Redis集群~StackExchange.redis连接Twemproxy代理服务器

  • Redis集群~StackExchange.redis连接Sentinel服务器并订阅相关事件


原文地址:http://www.cnblogs.com/tdws/p/5836122.html


.NET社区新闻,深度好文,微信中搜索dotNET跨平台或扫描二维码关注

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

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

相关文章

Windows7下如何设置MyEclipse2014字体大小

转载自 Windows7下如何设置MyEclipse2014字体大小Java开发工具MyEclipse2014,安装完毕后发现字体过小,并且对眼睛不好,该如何设置这个开发工具里整体字体大小。设置MyEclipse字体大小,具体实现看下面详细描述双击“MyEclipse Pr…

项目的包结构 mybatis三剑客

mybatis三剑客 1.mybatis generator 数据库自动生成pojo对象类 xml 是dao接口的实现 service调用dao mybatis gentenrator generatorConfig.xml 直接复制 讲解一下 datasource.properties 直接复制 讲解一下 修改一下dao的实现mapper createTime 和 updateT…

css img 适配尺寸_CSS容易使人蒙圈的几个经典问题

本文摘自这一年来自己在工作中经历的几个比较好的CSS问题(不一定复杂,但个人觉得都挺值得一说),同时也准备了2个JS问题一、CSS篇1.1 元素默认蓝色边框input标签元素(如button、text 、areatext)的一些事件(如click、focus等),在很多浏览器下默…

怎样增强MyEclipse的代码自动提示功能

转载自 怎样增强MyEclipse的代码自动提示功能 MyElipse的默认代码提示功能隐藏了许多细节,需要开发者手动设置,一起来设置吧,让你的myeclpse更强大 一般在Eclipse ,MyEclipse代码里面,打个foreach,switch等…

第一篇:Dapper快速学习

我们都知道ORM全称叫做Object Relationship Mapper,也就是可以用object来map我们的db,而且市面上的orm框架有很多,其中有一个框架叫做dapper,而且被称为the king of ORM。 一:为什么选择Dapper 1. 性能优越&#xff1a…

配置spring、SpringMVC,mybatis进行整合

springframwork的官网 spring-projects/spring-mvc-showcase https://github.com/spring-projects/spring-mvc-showcase spring-projects/greenhouse https://github.com/spring-projects/greenhouse spring-projects/spring-boot spring-boot https://github.com/sprin…

对应node版本_安装Node.js教程

小编首先下载Node.js,首先打开浏览器,然后输入https://nodejs.org/en/,进入nodejs官网,然后按照下图中红色箭头指示步骤2,这个是nodejs8.12版本,下面Recommended For Most Users,这个就是推荐大家使用的版本&#xff0…

Asp.net Core 使用MyCat分布式数据库,实现读写分离

简介   MyCat2.0版本很快就发布了,关于MyCat的动态和一些问题,大家可以加一下MyCat的官方QQ群:106088787。我们今天主要介绍一下,在我们的Asp.net Core中如何使用Mycat,这源于一个大神(Amamiya Yuuko&…

如何在MyEclipse中显示行数

转载自 如何在MyEclipse中显示行数如何在MyEclipse中显示行数呢?myeclipse在默认情况下不显示行数时,用户可以自己设置显示行数,行数可以帮助我们方便的查看代码。首先,打开windows菜单然后选择preference,进入首选项…

logback日志配置

直接复制讲一下好了 比较简单 logback 可以看到执行的sql了 mybatis执行的sql了 <?xml version"1.0" encoding"UTF-8"?> <configuration scan"true" scanPeriod"60 seconds" debug"false"><!-- 打印日…

旅游系统_数字洛江智慧旅游系统助力提升旅游安全水平

长期以来&#xff0c;景区客流监测工作都是个“老大难”问题。为进一步提升旅游安全监管水平&#xff0c;今年洛江区将该项工作列入民办实事项目&#xff0c;投入96万元&#xff0c;大力推进智慧旅游项目建设。日前&#xff0c;洛江区智慧旅游系统正式上线运行&#xff0c;该智…

如何在 ASP.NET MVC 中集成 AngularJS

介绍 当涉及到计算机软件的开发时&#xff0c;我想运用所有的最新技术。例如&#xff0c;前端使用最新的 JavaScript 技术&#xff0c;服务器端使用最新的基于 REST 的 Web API 服务。另外&#xff0c;还有最新的数据库技术、最新的设计模式和技术。 当选择最新的软件技术时&am…

ftp相关配置

ftp # 图片上传的会再讲的 #ftp的相关配置 #ftp.server.ip你的FTP服务器ip地址 ftp.server.ip127.0.0.1 ftp.usermmallftp ftp.passftppassword #ftp.server.http.prefixhttp://img.happymmall.com/.ftp.server.http.prefixftp://mmallftp:ftppassword127.0.0.1:21/img/ #ftp.…

MyEclipse web项目导入Eclipse,详细说明

转载自 MyEclipse web项目导入Eclipse&#xff0c;详细说明最近导入一个MyEclipse的项目&#xff0c;具体是&#xff1a;spring4.1的web项目&#xff0c;同时遇到了一些问题&#xff0c;总结一下。 1、进入项目目录&#xff0c;找到.project文件&#xff0c;打开。 增加一个&…

matlab盒子分形维数_分形:盒子维数

今天主要想说的是&#xff0c;分形中的差分盒子维数的原理&#xff0c;基于分形的基础概念就不在这里说啦.分形维数可以用于定量描述图像表面的空间复杂程度&#xff0c;能够定量的表现图像的纹理特征. 采用不同的维数进行纹理特征描述时&#xff0c;精度有所区别&#xff0c;我…

Eclipse中看不到jsp的页面效果

转载自 Eclipse中看不到jsp的页面效果eclipse打开jsp后&#xff0c;在文件下面部分应该有”design"视图的&#xff0c;你点击一下看看。还是没有的话&#xff0c;在JSP文件上点点右键,"open with"选"webpage editor"&#xff0c;然后下面应该有“des…

唤醒幻数据包禁用会怎么样_如何利用splashtop实现远程开机、远程唤醒电脑

Splashtop商业版和个人版提供了局域网唤醒计算机(WoL)功能&#xff0c;您可以按照下面的指引进行设置。首先&#xff0c;请确保完全满足以下三个条件&#xff0c;否则&#xff0c;远程唤醒无法工作。计算机 BIOS支持WoL并且该选项已启用。Windows或Mac计算机的操作系统中已正确…

第二篇:Dapper中的一些复杂操作和inner join应该注意的坑

上一篇博文中我们快速的介绍了dapper的一些基本CURD操作&#xff0c;也是我们manipulate db不可或缺的最小单元&#xff0c;这一篇我们介绍下相对复杂 一点的操作&#xff0c;源码分析暂时就不在这里介绍了。 一&#xff1a;table sql 为了方便&#xff0c;这里我们生成两个表…

eclipse安装、使用hibernate插件方法

转载自 eclipse安装、使用hibernate插件方法hibernate插件安装方法&#xff1a; http://download.jboss.org/jbosside/updates/stable 点击eclipse的help菜单里的“Install New Software”点击“Add”&#xff0c;输入下面的内容&#xff0c;一路“NEXT”即可 hibernate更新网…