在上一篇,我们简单搭建了rocketMq双master的集群,沿用这个思路,这一篇我们用代码来模拟一下rocketMq集群故障情况下完成自动切换的效果。

1、启动两个节点的broker和nameserver

第一台机器,192.168.111.133,启动的过程和信息如下,

第一台机器,192.168.9.147,启动的过程和信息如下,

看到如上信息,说明两个节点成功启动,然后我们看看代码的具体实现,使用之前的代码,这里主要是为了模拟出在故障的情况下,我们在发送消息时是否可以在容忍的时间[rocketMq故障自动切换的时间]里可以自动完整故障转移,下面直接上代码,

2、发送消息的接口,

@Autowi

rocketMq双master集群模式下故障演练相关推荐

  1. linux环境下rocketMq双master集群搭建

    为什么要使用集群 在生产环境中,经常会有意外的情况发生,对于rocketmq也不例外,单节点情况下,如果出现网络闪断,服务器掉电或宕机之类的,如果服务器不能及时恢复,很可能造成丢消息的情况,因此,集群 ...

  2. RSF-Center,集群模式下-协调数据结构

    为什么80%的码农都做不了架构师?>>>    RSF是一个轻量化的分布式服务框架.支持点对点调用,也支持分布式调用.典型的应用场景是,将同一个服务部署在多个Server上提供 re ...

  3. strom-1.1.0模拟单词统计功能,Spout编写,Bolt编写,TopologyDriver编写,本地模式运行,集群模式运行,集群模式下看输出结果

    统计文本中的单词出现的频率,其中文本内容如下: 创建项目 项目结构如下: 创建pom.xml,代码如下: <?xml version="1.0" encoding=" ...

  4. 如何访问集群中指定的服务器,【Nacos源码之配置管理 六】集群模式下服务器之间是如何互相感知的...

    前言 我们用Nacos当配置中心的时候,上一篇文章中 [Nacos源码之配置管理 五]为什么把配置文件Dump到磁盘中 知道了,所有的配置文件都会Dump到服务器的本地磁盘中, 那么集群模式下: 服务 ...

  5. 关于Redis集群模式下,使用mget通过keys批量获取value时的解决方案

    关于Redis集群模式下,使用mget通过keys批量获取value时的解决方案 今天在做项目的时候,需要使用到mget命令,通过一个批量的key去获取对应的value集合,但是取值的时候,报了这个错 ...

  6. RocketMQ的各种集群模式的搭建和消息可靠性保证和服务可用性描述

    RocketMQ集群搭建的特点 NameServer是一个几乎无状态的节点,可直接启动集群部署.节点之间没有任何信息同步,并且集群的NameServer之间都不知道彼此的存在. Broker部署相对复 ...

  7. zookeeper专题:zookeeper集群模式下,leader选举流程分析

    文章目录 Zookeeper 集群模式一共有三种类型的角色 1. zookeeper启动时leader选举流程 1.1 加载配置文件,设置基本信息 1.2 指定快速选举算法,启动多级队列.线程 1.3 ...

  8. quartz集群模式下qrtz_triggers表trigger_state变ERROR分析

    最近在正式环境新增了一个定时任务,项目启动后,新增的任务总是跑一两次就不跑了,排查发现trigger_state变为ERROR了. 一.Quartz重要表含义 1)qrtz_calendars:以Bl ...

  9. redis分布式锁 在集群模式下如何实现_收藏慢慢看系列:简洁实用的Redis分布式锁用法...

    在微服务中很多情况下需要使用到分布式锁功能,而目前比较常见的方案是通过Redis来实现分布式锁,网上关于分布式锁的实现方式有很多,早期主要是基于Redisson等客户端,但在Spring Boot2. ...

最新文章

  1. 深度学习的分布式训练--数据并行和模型并行
  2. Spring boot模板引擎
  3. php zval_copy_static_var(),深入理解 PHP7 中全新的 zval 容器和引用计数机制
  4. NAnt简单介绍和我第一个例子
  5. easyui-combobox的取值问题
  6. 微软System Center Operations Manager 2012(SCOM )安装图文教程
  7. 201521123004《软件工程》个人阅读作业1
  8. .NET应用程序中异步调用Web Service的几种方法 come from: veryhappy(wx.net)
  9. 大话数据结构第一章理解
  10. 用python实现队列的循环左移和右移的实验原理_python的移位操作实现详解
  11. 如何成为一名优秀的初级开发者?
  12. 联想17TV语音遥控教程 语音点播更方便
  13. Mac 电脑下搭建DOSBox汇编环境
  14. QTP11 5 HP UFT 11 5 下载地址
  15. 查看html源代码编码,查看网页源代码全是乱码,但前台页面可以正常显示
  16. 社会软件力量:六度分隔理论
  17. jetson nano 基础设置
  18. UEBA案例分析系列之数据泄露检测
  19. Teamcenter Folder
  20. 已拦截跨源请求:同源策略禁止读取位于...的远程资源。(原因:CORS 请求未能成功)。

热门文章

  1. Android(Fragment和Activity之间通信)
  2. 在 SQLite3 中使用回调函数
  3. Android EditText中插入图片并响应点击事件
  4. document.ready和window.onload的区别
  5. QDir的mkdir和mkpath区别
  6. 十恶不赦到底是哪十恶?
  7. [转]转一篇不错的文章:ORM 在电子商务系统中的应用
  8. Archiva 2.2.3 安装运行的时候出现协议版本错误
  9. my questions of C#
  10. 英特尔携手ATT和爱立信进行DIRECTV NOW流媒体直播服务的5G试验