当前位置:首页 > 科技  > 软件

我们一起聊聊如何编写一个 Java memcached 客户端

来源: 责编: 时间:2024-07-03 10:08:28 237观看
导读非常喜欢读开源项目,每次读源码,都会觉得自己修炼某种武学功法,期待修炼完成后,可以大杀四方。从2012年开始,陆续阅读了 Cobar、Druid、Xmemcached、RocketMQ、MetaQ、Canal、ShardingJdbc、Sofa-Jraft 等开源项目。这篇文

非常喜欢读开源项目,每次读源码,都会觉得自己修炼某种武学功法,期待修炼完成后,可以大杀四方。fmZ28资讯网——每日最新资讯28at.com

从2012年开始,陆续阅读了 Cobar、Druid、Xmemcached、RocketMQ、MetaQ、Canal、ShardingJdbc、Sofa-Jraft 等开源项目。fmZ28资讯网——每日最新资讯28at.com

这篇文章,聊聊笔者阅读 Xmemcached 源码的心得体会,希望对大家有所帮助。fmZ28资讯网——每日最新资讯28at.com

图片图片fmZ28资讯网——每日最新资讯28at.com

1、Xmemcached 简介

XMemcached 是一个 Java memcached 客户端。fmZ28资讯网——每日最新资讯28at.com

可能有的同学对 Memcached  并不熟悉,它和 Redis 一样都是分布式内存缓存系统,用于加速动态 Web 应用程序,通过减少数据库负载来提高性能 。fmZ28资讯网——每日最新资讯28at.com

笔者当时服务于一家彩票公司,公司的核心系统订单服务、调度中心、业务网关都使用 XMemcached 操作 memcached 。fmZ28资讯网——每日最新资讯28at.com

基于一个非常朴素的好奇心:“如何用 Java 编写一个缓存客户端 ?”  笔者花了接近两个月的时间将 Xmemcached 源码浏览了一次。fmZ28资讯网——每日最新资讯28at.com

浏览完源码后,笔者有三点心得:fmZ28资讯网——每日最新资讯28at.com

  • 设计模式
  • 网络命令编解码
  • 一致性哈希算法

2、设计模式

下图是 Xmemcached 的使用范例:fmZ28资讯网——每日最新资讯28at.com

图片图片fmZ28资讯网——每日最新资讯28at.com

我们可以清晰的发现流程分为三个部分 :fmZ28资讯网——每日最新资讯28at.com

  • 客户端构造器通过 servers 参数创建客户端 ;
  • 通过客户端调用 set、 get、 delete 方法 ;
  • 关闭客户端。

MemcachedClient 接口定义了基本的缓存操作方法,比如 get、set、add 、cas 方法,而 XmemcachedClient 是 MemcachedClient 的实现类。fmZ28资讯网——每日最新资讯28at.com

真正创建客户端对象 XmemcachedClient 是通过构造器 XMemcachedClientBuilder 来实现的,这是一个非常典型的设计模式:Builder 模式 fmZ28资讯网——每日最新资讯28at.com

Builder 模式是一种创建型设计模式,它允许你分步骤创建复杂对象。与直接构造对象不同,Builder 模式通过一个构建过程,逐步设置对象的不同部分,从而使对象的创建过程更加灵活和可控。fmZ28资讯网——每日最新资讯28at.com

图片图片fmZ28资讯网——每日最新资讯28at.com

我们在配置 构造器 XMemcachedClientBuilder 时,可以配置序列化对象、命令工厂、服务器列表等配置。fmZ28资讯网——每日最新资讯28at.com

最后,调用构造器的 build 方法创建 MemcachedClient 对象,见下图:fmZ28资讯网——每日最新资讯28at.com

图片图片fmZ28资讯网——每日最新资讯28at.com

下面是 XMemcached 的主要类的 UML 图:fmZ28资讯网——每日最新资讯28at.com

图片图片fmZ28资讯网——每日最新资讯28at.com

3 网络命令编解码

在网络编程中,一个重要的步骤是对发送的数据包进行编码、对接受的数据包进行解码fmZ28资讯网——每日最新资讯28at.com

1)发送命令,进行编码)fmZ28资讯网——每日最新资讯28at.com

因为 Xmemcached 使用了自研的网络通讯框架 ,每次发送命令时,都会调用命令的 encode 方法,将命令对象转换成 IoBuffer 对象通过网络发送。fmZ28资讯网——每日最新资讯28at.com

下图是  TextGetOneCommand 的 encode 方法 :fmZ28资讯网——每日最新资讯28at.com

图片图片fmZ28资讯网——每日最新资讯28at.com

2)接收命令,进行解码fmZ28资讯网——每日最新资讯28at.com

当通讯框架收到响应字节数组时,可能收到的数据包并不完整,在收到数据包时,通过 decode 方法判断数据包是否完整,当数据完整之后,将同步请求的 countDownLatch 计数减 1 。fmZ28资讯网——每日最新资讯28at.com

图片图片fmZ28资讯网——每日最新资讯28at.com

当笔者理解了网络命令编解码的技巧之后,后来用 Netty 写了个分库分表 proxy 轮子时,在设计 MySQL 命令包编解码就使用了类似的技巧。fmZ28资讯网——每日最新资讯28at.com

图片图片fmZ28资讯网——每日最新资讯28at.com

4 一致性 Hash 算法

一致性 Hash 算法非常典型的应用就是缓存集群,它能够很大程度上(注意不是完全解决)解决余数哈希的增加服务器导致缓存失效的问题。fmZ28资讯网——每日最新资讯28at.com

我们需要进行如下步骤,使用一致性哈希(Consistent Hashing)将键值对映射到 memcached 服务器上。fmZ28资讯网——每日最新资讯28at.com

图片图片fmZ28资讯网——每日最新资讯28at.com

  • 计算 memcached 服务器(节点)的哈希值,并将其配置到 0~2^32 的圆上。
  • 用同样的方法计算存储数据的键的哈希值,并映射到圆上。
  • 从键的哈希值对应的位置开始顺时针查找,将数据保存到找到的第一个服务器上。
  • 如果超过 2^32 仍然找不到服务器,就会保存到第一台 memcached 服务器上。

下图,我们新增一台 memcached 服务器 node5 。fmZ28资讯网——每日最新资讯28at.com

图片图片fmZ28资讯网——每日最新资讯28at.com

假如是我们使用余数分布式算法,保存键的服务器会发生很大变化从而影响缓存的命中率,但一致性哈希算法仅仅如图中所示 node2 和 node 5 之间小部分黄色区域会有影响。fmZ28资讯网——每日最新资讯28at.com

KetamaMemcachedSessionLocator.java 实现了一致性哈希算法, 使用的 Hash 算法是 KETAMA HASH 算法。fmZ28资讯网——每日最新资讯28at.com

1、根据服务器列表生成 Hash 环 ,存储容器 TreeMapfmZ28资讯网——每日最新资讯28at.com

图片图片fmZ28资讯网——每日最新资讯28at.com

2、通过 key 得到 TreeMap 的 tailMap,然后找到 firstKeyfmZ28资讯网——每日最新资讯28at.com

图片图片fmZ28资讯网——每日最新资讯28at.com

5 写到最后

阅读 Xmemcached 源码,让笔者的眼界大大提升,比如序列化方式、构造器 Builder 设计模式、一致性哈希算法、通讯命令编解码、failover 设计等等。fmZ28资讯网——每日最新资讯28at.com

比较可惜的是,笔者当时能力有限,并没有完全理解自研网络框架 yanf4j 。fmZ28资讯网——每日最新资讯28at.com

尽管如此,当读完 Xmemcached 源码后,笔者对于“如何用 Java 编写一个缓存客户端 ?” 这个问题,脑海里已经有了概念,当笔者对于 Netty 更加熟悉之后,这个问题也就变得不是问题了。fmZ28资讯网——每日最新资讯28at.com

本文链接:http://www.28at.com/showinfo-26-98411-0.html我们一起聊聊如何编写一个 Java memcached 客户端

声明:本网页内容旨在传播知识,若有侵权等问题请及时与本网联系,我们将在第一时间删除处理。邮件:2376512515@qq.com

上一篇: 如何正确使用上线部署,泳道、预发布到底如何理解?

下一篇: K8s 也有设计模式?你知道吗?

标签:
  • 热门焦点
  • 掘力计划第 20 期:Flutter 混合开发的混乱之治

    在掘力计划系列活动第20场,《Flutter 开发实战详解》作者,掘金优秀作者,Github GSY 系列目负责人恋猫的小郭分享了Flutter 混合开发的混乱之治。Flutter 基于自研的 Skia 引擎
  • Flowable工作流引擎的科普与实践

    一.引言当我们在日常工作和业务中需要进行各种审批流程时,可能会面临一系列技术和业务上的挑战。手动处理这些审批流程可能会导致开发成本的增加以及业务复杂度的上升。在这
  • 大厂卷向扁平化

    来源:新熵作者丨南枝 编辑丨月见大厂职级不香了。俗话说,兵无常势,水无常形,互联网企业调整职级体系并不稀奇。7月13日,淘宝天猫集团启动了近年来最大的人力制度改革,目前已形成一
  • 阿里瓴羊One推出背后,零售企业迎数字化新解

    作者:刘旷近年来随着数字经济的高速发展,各式各样的SaaS应用服务更是层出不穷,但本质上SaaS大多局限于单一业务流层面,对用户核心关切的增长问题等则没有提供更好的解法。在Saa
  • iQOO 11S评测:行业唯一的200W标准版旗舰

    【Techweb评测】去年底,iQOO推出了“电竞旗舰”iQOO 11系列,作为一款性能强机,该机不仅全球首发2K 144Hz E6全感屏,搭载了第二代骁龙8平台及144Hz电竞
  • 超级标准版旗舰!iQOO 11S全球首发iQOO超算独显芯片

    上半年已接近尾声,截至目前各大品牌旗下的顶级旗舰都已悉数亮相,而下半年即将推出的顶级旗舰已经成为了数码圈爆料的主流,其中就包括全新的iQOO 11S系
  • iQOO 11S或7月上市:搭载“鸡血版”骁龙8Gen2 史上最强5G Soc

    去年底,iQOO推出了“电竞旗舰”iQOO 11系列,作为一款性能强机,iQOO 11不仅全球首发2K 144Hz E6全感屏,搭载了第二代骁龙8平台及144Hz电竞屏,同时在快充
  • 英特尔Xe HPG游戏显卡:拥有512EU,单风扇版本

    据10 月 30 日外媒 TheVerge 消息报道,英特尔 Xe HPG Arc Alchemist 的正面实被曝光,不仅拥有 512 EU 版显卡,还拥有 128EU 的单风扇版本。另外,这款显卡 PCB
  • 电博会与软博会实现"线下+云端"的双线融合

    在本次“电博会”与“软博会”双展会利好条件的加持下,既可以发挥展会拉动人流、信息流、资金流实现快速交互流动的作用,继而推动区域经济良性发展;又可以聚
Top