最新要闻
- 通讯!估值1000亿 消息称国产内存厂商寻求IPO上市:4年前量产首款DDR4芯片
- 张颂文用小米13 Ultra拍照!网友建议加上水印
- 【天天时快讯】巴西总统认为电子游戏是垃圾 让年轻人学会暴力杀戮
- 长达10年维护落幕:微软提醒Office 2013已停止支持
- 当前速看:郑渊洁称维权生活像吃苍蝇:21年只成功37个商标 还有673个没成
- 联想刘军:今年将是大客户市场的 “大年”
- 浑厚悠扬!三号楼的钟声……
- 每日热议!房玄龄杜如晦被谁重用_房玄龄杜如晦
- 新消息丨微软苏菲要换代了!Surface Pro 10/Go 4新品曝光:外形/配置大变
- 【环球报资讯】最新研究:黄河上游区域性干旱能“算来”
- 这个火车站客流暴增,原因竟是……
- 全球信息:雪莲子的功效与副作用 雪莲子的功效与作用及食用方法
- 世界播报:真我11系列拍摄样张首秀:长焦恐怖 可见月亮纹理
- 【热闻】没人比我更懂外星人?马斯克:如果找到外星人 我立马发推
- 环球热资讯!ZV-E10同款传感器:索尼FX10视频机即将发布
- 环球快资讯:熊孩子躲袋子里玩误被司机碾压 路人合力抬车救援:网友吐槽家长心大
广告
手机
iphone11大小尺寸是多少?苹果iPhone11和iPhone13的区别是什么?
警方通报辅警执法直播中被撞飞:犯罪嫌疑人已投案
- iphone11大小尺寸是多少?苹果iPhone11和iPhone13的区别是什么?
- 警方通报辅警执法直播中被撞飞:犯罪嫌疑人已投案
- 男子被关545天申国赔:获赔18万多 驳回精神抚慰金
- 3天内26名本土感染者,辽宁确诊人数已超安徽
- 广西柳州一男子因纠纷杀害三人后自首
- 洱海坠机4名机组人员被批准为烈士 数千干部群众悼念
家电
微资讯!使用etcd实现Master的选举功能
【资料图】
背景
说起master选举,最开始想到的可能就是zookeeper,但有些场景zookeeper的使用过于繁重和复杂,又由于etcd是基于Raft的分布式K/V存储,强一致性的K/V读写是核心。所以造就了etcd可以用于master的选举的场景。
原理
etcd clientv3 concurrency对选举进行了封装
import github.com/coreos/etcd/clientv3/concurrency
上篇文章介绍了etcd使用txn实现分布式锁,而节点选举也要依靠Txn进行创建key的CAS操作zookeeper是利用创建临时有序节点的方式,etcd也同样的是在prefix path下创建相应的key,并且key的revision也是有序。同样也是通过watch机制进行通知。
应用
//封装type etcdLeader struct {sess *concurrency.Session //会话 客户端的租约会话,会做KeepAliveelec *concurrency.Election //选举}func Campaign(ctx context.Context, client *clientv3.Client, prefix, value string) (*etcdLeader, error) {if value == "" {value = fmt.Sprintf("%s-%d", MyHostName, timestampMs())}s, err := concurrency.NewSession(client)if err != nil {return nil, fmt.Errorf("failed to generate session: %v", err)}prefix = "/openresty/" + "-concurrency/" + strings.TrimPrefix(prefix, "/")elec := concurrency.NewElection(s, prefix)return &etcdLeader{sess: s,elec: elec,}, elec.Campaign(ctx, value) // blocked until elected}//elec.Campaign 会参加选举,直到它被选中、发生错误或上下文被取消// 调用elec.Proclaim 常用来检测当前主节点是否生效func (l *etcdLeader) Proclaim(ctx context.Context, value string) error {if l.elec == nil {return fmt.Errorf("already closed")}if value == "" {value = fmt.Sprintf("%s-%d", MyHostName, timestampMs())}return l.elec.Proclaim(ctx, value)}//调用elec.Resign 退出masterfunc (l *etcdLeader) Resign(ctx context.Context) error {if l.elec == nil {return nil}defer l.sess.Close()defer func() {l.elec = nill.sess = nil}()return l.elec.Resign(ctx)}
测试
//模拟进程处理func process(processID string) {cli, err := getEtcdCli("open") //获得cliif err != nil {fmt.Println(err)panic(processID)}ctx := context.Background()maintainer, err := Campaign(context.Background(), cli, "process", "") //会阻塞,直到该节点选为masterif err != nil {fmt.Println("process " + processID + " Campaign err" + err.Error())return}fmt.Println(processID + "is maintainer")ticker := time.NewTicker(time.Second)count := 0defer ticker.Stop()for {select {case <-ctx.Done():err = maintainer.Resign(context.Background()) //超时退出if err != nil {fmt.Printf("error occured when resign lfe_sync: %v", err)}returncase <-ticker.C:err = maintainer.Proclaim(ctx, "") if err != nil {fmt.Printf("error occured when proclaim lfe_sync: %v", err)maintainer.Resign(ctx)return}count++//do sthfmt.Println("processID ", processID+" ", count)if count == 5 { //主动退出err = maintainer.Resign(context.Background())if err != nil {fmt.Printf("error occured when resign lfe_sync: %v", err)}return}}}}
总结与思考
如果从Campaign源码可以看出,比起上一篇利用txn实现分布式锁的实现,选主增加watch机制,减少轮训获取锁的过程。在本场景中选主和分布式锁的使用并没有什么差别,只是选主减少轮训,性能更好。本次代码地址:https://github.com/zhaoshoucheng/hodgepodge/blob/main/etcd/master.go
关键词:
-
当前快播:【Jmeter】Request1输出作为Request2输入-后置处理器
【Jmeter】基础介绍-详细接上文,继续介绍Jmeter,本文关注点为如何解决上文中提到的第一个问题,即:需...
来源: 环球新动态:IDEA编译Spring源码教程
微资讯!使用etcd实现Master的选举功能
Rust 知识积累(6)
当前快播:【Jmeter】Request1输出作为Request2输入-后置处理器
世界热文:详解数据结构中栈的定义和操作
通讯!估值1000亿 消息称国产内存厂商寻求IPO上市:4年前量产首款DDR4芯片
张颂文用小米13 Ultra拍照!网友建议加上水印
【天天时快讯】巴西总统认为电子游戏是垃圾 让年轻人学会暴力杀戮
长达10年维护落幕:微软提醒Office 2013已停止支持
当前速看:郑渊洁称维权生活像吃苍蝇:21年只成功37个商标 还有673个没成
联想刘军:今年将是大客户市场的 “大年”
浑厚悠扬!三号楼的钟声……
每日热议!房玄龄杜如晦被谁重用_房玄龄杜如晦
全球快资讯:springboot 中使用 RabbitMQ 配置使用优先级队列
查看Unity3D中默认的变量名与按键的映射
时隔6年后,我又回到博客园了
环球看点!更新整理了一大波热门免费可用的API大全
微动态丨ChatGPT闲谈——火出圈的为什么是 OpenAI?
新消息丨微软苏菲要换代了!Surface Pro 10/Go 4新品曝光:外形/配置大变
【环球报资讯】最新研究:黄河上游区域性干旱能“算来”
这个火车站客流暴增,原因竟是……
全球信息:雪莲子的功效与副作用 雪莲子的功效与作用及食用方法
世界播报:真我11系列拍摄样张首秀:长焦恐怖 可见月亮纹理
【热闻】没人比我更懂外星人?马斯克:如果找到外星人 我立马发推
环球热资讯!ZV-E10同款传感器:索尼FX10视频机即将发布
环球快资讯:熊孩子躲袋子里玩误被司机碾压 路人合力抬车救援:网友吐槽家长心大
环球速看:一大众轿车高速路恶意别车!S形行驶10公里:官方已介入调查
每日焦点!诺诚健华宣布奥布替尼成为中国首个且唯一获批针对边缘区淋巴瘤的BTK抑制剂
田园变游园
中国联通跌5.6% 民生证券在其年内高点推荐
全球简讯:再获殊荣!华为云GaussDB喜提“科技进步一等奖”
当前最新:开发者必读!常用的二维码生成器 API 推荐
第六章 面向对象编程
当前短讯!【备忘录设计模式详解】C/Java/JS/Go/Python/TS不同语言实现
全球讯息:JavaScript 九九乘法表
每日快看:墨水人_墨水
即时:今日描写冬季的古诗名句_描写冬季的古诗
仙剑系列首款开放世界游戏!《仙剑世界》公布首支预告
每日看点!用科技诠释豪华!一文看懂AITO问界M9有多少硬核“黑科技”
环球信息:西安一极氪001全国首烧?极氪回应:初步排除电池起火
全球最新:价格崩了!全新日产天籁直降4.9万:不到14万可买合资中型轿车
全球快报:上海车展宝马Mini展台被曝区别对待 冰激淋只给外国人免费吃
进程处于临界区是什么状态?进程处于临界区可以调度吗?
iu14D2N.tmp是什么意思?iu14D2N.tmpiu14D2N.tmp可以删除吗?
miui开发版内测和公测哪个好?miui开发版内测更新频率是多长时间?
拆机版单反是什么意思?拆机版单反与套机的区别是什么?
苹果IPAD用哪个助手好?苹果ipad型号大全及价格表
当前速读:后台性能测试规范
世界聚焦:福建省练习题
Oracle 备忘清单_开发速查表分享
环球速讯:我想听张惠妹的歌_渴了 张惠妹演唱歌曲
今热点:蜂巢能源“龙鳞甲汽车电池”亮相:续航超1000km 热失控不起火
全球报道:清热降火 一朵泡一杯!徽春堂金丝皇菊10.9元大促(2袋约50朵)
华为智能驾驶总裁:华为智能驾驶体验明显好于特斯拉
小米13 Ultra京东全版本卖断货!很多米粉跟员工要F码
【天天快播报】加量还减价!小米平板6 Pro预售战报出炉:2023年双平台预售量新高
到2028年AIoT平台市场价值249亿美元
环球速讯:前端跨域解决方案——JSONP
最新消息:系统之家win7纯净版官网下载_系统之家win7纯净版官网
环球焦点!昆明高新区持续优化知识产权创新环境
“吉林一号”卫星传图!从太空视角俯瞰春耕锦绣画卷
【世界新要闻】“四驱性能 两驱能耗、价格”降维打击!哈弗枭龙MAX千岛湖试驾
当前时讯:4499元!Redmi X 85英寸电视上市:120Hz高刷、3+32GB大存储
曝iPhone 15 Pro Max独占潜望长焦:苹果选了两家供应商
天天速讯:日本报告称:新电池专利中国在数量上领先 日美在质量上更佳
2023年最新微信小程序抓包教程
当前速递!【读财报】上市险企2022年年报:5家偿付率均下滑 中国平安归母净利润及内含价值位列第一
全球要闻:特斯拉称今年是一个独特的机遇:降价利润依然可控 我们成本领先
世界视点!湖北巴东发现罕见白麂:古代称为“瑞兽”
女子晒衣服不慎10楼跌落悬挂2楼 现场可怕:官方提醒提高安全意识
当前聚焦:2999元 索尼首款专业开放式监听耳机MDR-MV1发布:沉浸感无敌
当前消息!别吐槽网速慢了!2023年第一季度全球宽带最快城市在我国北京
学好虚拟化,首先要学Linux
【焦点热闻】多地展开公司债发行人自查自纠 四大事项成关注重点
这下跟安卓真没区别!iOS 17确定支持第三方应用商店 苹果被逼
环球热门:12-240四摄8焦段!小米13 Ultra影像功能深度解析
李想吐槽变色天窗玻璃如同卫生间隐私膜 理想汽车坚持用电动遮阳帘
看点:学系统集成项目管理工程师(中项)系列09_收尾管理
全球观热点:索尼发布4K HDR旗舰监视器:双液晶面板 峰值亮度4000尼特
每日热文:GPT-4可能对经济领域的近期影响,以及远期对全球可能产生的深远影响。
天天百事通!去年我是怎么解决团队问题的
新日2022年净利同比暴增1326.25%!卖了257万辆电动自行车
焦点热文:在上海车展逛了两天 愣是找不出一辆值得写的油车!
世界今日报丨爷青回!电影《灌篮高手》今日上映:等了20多年的全国大赛开打
焦点快看:等等党赢了!华为Mate 50系列官方降价:最高便宜800元
AutoGPT是什么?超简单安装使用教程
今日精选:微信小程序、uniapp、vue生命周期钩子函数
【全球新视野】PS5 Pro为期不远 索尼PS5完全不缺货:黄牛被逼低价清仓
环球微动态丨03 设置工作环境与环境(二)GRUB二级引导器
环球观点:新能源车不好卖!宁德时代一线工人:做四休三想加班 没活干盼着忙起来
热议:高性能HBM显存芯片:被韩国企业垄断了
5999元安卓影像之王 小米13 Ultra优化跟上了:1天内两次升级MIUI14
全球观察:关于shell变量值的截取-通过分隔符-去除前后匹配到的内容
高毅资产冯柳、重阳投资裘国根“相逢”海康威视
环球快播:华为“黑科技”悉数上车!AITO全尺寸旗舰SUV问界M9开订:50-60万元
宝马喊话“我们的家在中国” 网友神点评:求生欲太强
夏季空调开启前 这些准备工作必须做到位
当前通讯!估计雷军都没想到 小米摄影手柄被用在了友商手机上
A卡大面积降价后 NVIDIA终于坐不住了:RTX 4090/4080破发
世界热讯:牛顿迭代法求方程根