zookeeper问题求教

现在是这样,一个 master 节点负责为任务分配 slave 执行,slave 负责执行,然后忽然 master 挂了,备用节点这个时候上线。这个时候需要让 slave 陷入等待,等待新的 master 上线后才能更新任务状态到 zk。


怎么实现就是让 master 挂了,备用节点还没上线的这段时间里,slave 不会去更新任务状态到 zk。


我想的是:当 slave 监听到 master 下线事件,就开始执行 while 循环等待,然后监听 master 上线的事件,监听到上线事件就结束等待


可是不知道代码怎么写,在 while 循环里监听?有老哥会这方面的可以教教我么?

#Keep#
全部评论
可以把slave想象成客户端,进行幂等时间重试机制, 2S 4S 8S 16S。。。或者自己设定
点赞 回复 分享
发布于 2020-03-08 12:44

相关推荐

#牛客AI配图神器#上来自我介绍,个人信息、在校所学专业、毕业时间、为什么学习大数据。询问出生年份。(没懂为什么专门问这个)介绍项目,离线数仓的五层是怎么设计的,DataX做首日的全量采集、Maxwell做后续每日的增量采集,Flume传输数据,Kafka起缓存作用,解耦各个组件。大数据竞赛拿了全国一等奖,那么这个竞赛中做的是什么业务?学校主修课是什么,大数据是否是自学?介绍一下简历中的离线数仓。说一下Maxwell的底层实现原理。讲一下Hive On Spark引擎的特点。介绍一下简历中的实时数仓。说一下checkpoint机制和精准一次。Docker的常用命令。Doris需要更新数据吗,怎么更新数据的,是用update吗?Doris在项目中的作用。Kafka的偏移量需要手动维护吗。项目的数据来自哪里,是真实的数据吗?数据量有多少,能达到什么级别,有一亿条数据吗?HBase在项目中是怎么使用的,为什么维表存到HBase中?为什么没有存到Redis中?FastJson了解吗,说一下。SpringBoot的拦截器和过滤器的区别。现在是否在校?反问工作压力大吗?公司有食堂吗?(我在想没食堂 可以买拼好饭吃😋)刚才回答的内容还算可以吗?(面试官:回答得没问题,学生能学到这个程度,已经可以了)写面经攒人品,希望能一把过#数仓面试##数据开发##数仓开发#
查看19道真题和解析
点赞 评论 收藏
分享
评论
点赞
1
分享

创作者周榜

更多
牛客网
牛客企业服务