首页 文章 精选 留言 我的

精选列表

搜索[优化],共10000篇文章
优秀的个人博客,低调大师

基于Redis的原子操作优化秒杀逻辑

内容: 对于缓存中间件Redis,相信各位小伙伴或多或少都有听说过,甚至实战过,本文我们将基于SpringBoot整合Redis中间件,并基于其优秀的“单线程”特性和原子操作实现一种“分布式锁”,进而控制“高并发情况下多线程对于共享资源的访问”,最终解决“并发安全”,即“库存超卖”或者“重复秒杀”的问题! (1)按照惯例,首先我们需要加入Redis的第三方依赖,如下所示: org.springframework.bootspring-boot-starter-redis1.3.5.RELEASE复制代码然后,需要在application.properties配置文件中加入Redis服务所在的Host、端口Post、链接密钥Password等信息,如下所示: (2)紧接着,我们还需要自定义注入跟Redis的操作组件相关的Bean配置,在这里主要是自定义注入配置RedisTemplate跟StringRedisTemplate操作组件,并指定其对应的Key、Value的序列化策略: // redis的通用化配置@Configurationpublic class RedisConfig { @Autowired private RedisConnectionFactory redisConnectionFactory; @Bean public RedisTemplate redisTemplate(){ RedisTemplate redisTemplate=new RedisTemplate<>(); redisTemplate.setConnectionFactory(redisConnectionFactory); //TODO:指定Key、Value的序列化策略 redisTemplate.setKeySerializer(new StringRedisSerializer()); redisTemplate.setValueSerializer(new JdkSerializationRedisSerializer()); redisTemplate.setHashKeySerializer(new StringRedisSerializer()); return redisTemplate; } @Bean public StringRedisTemplate stringRedisTemplate(){ StringRedisTemplate stringRedisTemplate=new StringRedisTemplate(); stringRedisTemplate.setConnectionFactory(redisConnectionFactory); return stringRedisTemplate; }}复制代码(3)至此,可以说是做好了充足的准备,接下来我们就可以拿来用了!为了区分之前的秒杀逻辑方法,我们开了一个新的秒杀逻辑方法killItemV3,并采用Redis的原子操作SETNX和EXPIRE方法来实现一种“分布式锁”,进而控制高并发多线程对共享资源的访问,其完整源代码如下所示: //商品秒杀核心业务逻辑的处理-redis的分布式锁@Overridepublic Boolean killItemV3(Integer killId, Integer userId) throws Exception { Boolean result=false; if (itemKillSuccessMapper.countByKillUserId(killId,userId) <= 0){ //TODO:借助Redis的原子操作实现分布式锁-对共享操作-资源进行控制 ValueOperations valueOperations=stringRedisTemplate.opsForValue(); final String key=new StringBuffer().append(killId).append(userId).append("-RedisLock").toString(); final String value=RandomUtil.generateOrderCode(); Boolean cacheRes=valueOperations.setIfAbsent(key,value); if (cacheRes){ stringRedisTemplate.expire(key,30, TimeUnit.SECONDS); try { ItemKill itemKill=itemKillMapper.selectByIdV2(killId); if (itemKill!=null && 1==itemKill.getCanKill() && itemKill.getTotal()>0){ int res=itemKillMapper.updateKillItemV2(killId); if (res>0){ commonRecordKillSuccessInfo(itemKill,userId); result=true; } } }catch (Exception e){ throw new Exception("还没到抢购日期、已过了抢购时间或已被抢购完毕!"); }finally { if (value.equals(valueOperations.get(key).toString())){ stringRedisTemplate.delete(key); } } } }else{ throw new Exception("Redis-您已经抢购过该商品了!"); } return result;}复制代码在上述代码中,我们主要是通过以下几个操作综合实现了“分布式锁”的功能,其中包括 (1)valueOperations.setIfAbsent(key,value);:表示当前的Key如果不存在于缓存中,那么将设置值成功,反之,如果Key已经存在于缓存中了,那么设置值将不成功!通过这一特性,我们可以将“KillId和UserId的一一对应关系~即一个人只能抢到一个商品”组合在一起作为Key! (2)设置了Key,那么就需要在某个时间点去释放,即stringRedisTemplate.expire(key,30, TimeUnit.SECONDS);操作可以辅助实现! (3)然鹅,真正“释放锁”的操作是如下这段代码去实现的,即判断一下当前要释放的锁是否就是之前一开始获取到的锁,如果是,就释放!这一点可以很好的避免误删锁的问题! if (value.equals(valueOperations.get(key).toString())){ stringRedisTemplate.delete(key);}复制代码至此,基于Redis的原子操作实现的分布式锁,进而控制高并发多线程对于共享资源的访问,从而解决秒杀场景下“库存超卖”、“重复秒杀”等问题,下面采用JMeter进行压测,压测的用户列表跟商品的“可秒杀数量total”跟上一篇章是一样的,即total=6本书,用户总共是10个。 点击JMeter的启动按钮,观察控制台的输出信息以及数据库表item_kill和item_kill_success表,可以看到秒杀记录的结果很是令人满意: 即库存为6本的商品~书籍恰好被10个用户中的6个秒杀得到!这种结果其实对于我们、对于用户来讲肯定是皆大欢喜的结局! 虽然演员对于自己的结局很满意,但是导演却察觉到戏中仍然有一些瑕疵!即如果秒杀系统在执行Redis的原子操作SetNX后、执行Expire之前,Redis的节点宕机了,那么此时将很有可能永久进入“Key锁死”的窘境,即重启之后,由于之前的Key没有得到释放,故而这个Key将永远存在于缓存中,即对应的用户将不能秒杀该商品了! 这一点确实是一个隐患! 既然存在隐患,那么我们就得想办法解决了!莫急,下一篇章我们继续! 需要java学习路线图的私信笔者“java”领取哦!另外喜欢这篇文章的可以给笔者点个赞,关注一下,每天都会分享Java相关文章!还有不定时的福利赠送,包括整理的学习资料,面试题,源码等~~

优秀的个人博客,低调大师

HBase优化之路-合理的使用编码压缩

为什么要讨论HBase编码压缩 编码+压缩能够成倍的减少数据的磁盘占用空间,节省可观的存储费用 编码+压缩通常情况下可以提高系统吞吐率,让系统可以做更多的功 默认建表不启用编码或者压缩,对初学者不友好 了解HBase编码 举个栗子,我们有一张物流表叫"express",记录物流订单的流转详情。如下面表格:rowkey包含两个部分,用#号分割,左边是物流订单号,右边是物流信息的更新时间点。表包含两个列,一个物流状态,一个是物流描述信息 rowkey 状态列 描述信息列 10324224#2019-04-21 10:51 已发货 包裹正在等待揽收 10324224#2019-04-21 19:46 已揽件 [嘉兴市]平湖南桥的xxx已揽收 10324224#2019-04-21 19:46 运输中 [嘉兴市]快件已从平湖南桥出发,准备发往嘉兴中转部 10324224#2

优秀的个人博客,低调大师

内存优化篇-String/char[]/byte[]的选择

Java基本数据类型的大小 type size(bits) bytes boolean 8 1 byte 8 1 char 16 2 short 16 2 int 32 4 long 64 8 float 32 4 double 64 8 Java引用的大小 在 32 位的 JVM 上,一个对象引用占用 4 个字节;在 64 位JVM上,占用 8 个字节。 使用 8 个字节是为了能够管理大于 4G 的内存,如果你的程序不需要访问大于 4G 的内存, 可通过-XX:+UseCompressedOops选项,开启指针压缩。从Java 1.6.0_23开始,这个选项默认是开的。 Java对象头的大小 在32位JVM中,对象头的大小为8个字节(4字节的Mark Word+4字节的Klass Pointer). 在64位JVM上,占用16个字节(8字节的Mark Word+8字节的Klass Pointer),因为开启UseCompressedOops,所以实际占用12个字节(8字节的Mark Word+4字节的Klass Pointer) 。参考klass pointer 接下来的内容都基于64位的JVM来展开 Java对象的大小 1、任意Java对象都包含至少12个字节的Object Header。 2、JVM分配内存以8字节为基本单位,如果不满小于8字节,则向8字节的倍数补齐。参考8 byte alignment 思考 Object object = new Object(); 占用多少内存? 数组的大小如何计算? 验证 添加Maven依赖 <dependency> <groupId>org.openjdk.jol</groupId> <artifactId>jol-core</artifactId> <version>0.9</version> </dependency> import org.openjdk.jol.info.ClassLayout; /** * Created by jianpingpan on 2019/1/17. */ public class BasicClass { public static void main(String[] args) throws Exception { System.out.println(ClassLayout.parseClass(Object.class).toPrintable()); System.out.println(ClassLayout.parseClass(String.class).toPrintable()); System.out.println(ClassLayout.parseClass(byte[].class).toPrintable()); System.out.println(ClassLayout.parseClass(char[].class).toPrintable()); } } byte[] 和char[]的 object header为16个字节是因为有4个字节的数组长度。 String / char[] /byte[] 内存大小计算 String a = new String("abc"); String b = new String("abcd"); String c = new String("abc"); 第一行占用JVM内存的大小: 对象大小 = 12字节(object header)+ 4字节 (hash)+ 4字节(数组引用vlaue[]) + 4字节 (padding) 16字节+3*2字节+2字节padding (数组value[]) = 48字节 假设要缓存的字符个数为N。 String的内存大小计算公式 = 40+N*2 +padding char数组的内存大小计算公式=16+N*2+padding 如果用byte数组来存储字符串数据,占用的内存大小X需要分2种情况讨论: 1、如果需要存储的字符全在ASCII码中,一个字符用一个byte就可以存储 (编码方式可选ISO-8859-1/GBK/UTF-8): X = 16+N+padding 2、如果需要存储的字符范围不能被ASCII码覆盖,则需要根据字符范围确定合适的存储方式。 如需要要存储字符集为ASCII+中文字符,则可使用GBK编码: 16+N+padding<X < 16+N*2+padding 如果字符集不能被ASCII码覆盖,并且包含非中文字符,则使用UTF-8编码: 16+N+padding<X<16+6*N+padding 结论: 由此可见,char数组占用的内存大小小于String占用的内存大小。 若存储的字符范围以ASCII码为主,使用byte数组存储优于char数组。 实际使用场景 那么在缓存中可以直接用char[]或byte[]替换String么? 把 Set<String> set = new HashSet<>(); 替换成 Set<byte[]> set = new HashSet<>(); 会怎样呢? 很明显,contains方法、get方法都会失效。因为每个byte[]的hashCode不一样。 我们用下面的这个ByteArray/CharArray封装byte[],再用ByteArray替换String。 /** * Created by jianpingpan on 2019/1/23. */ public class ByteArray { byte[] bytes; public ByteArray(byte[] bytes){ this.bytes = bytes; } @Override public int hashCode() { if(null == bytes){ return 0; } return new String(bytes).hashCode(); } @Override public boolean equals(Object obj) { if(obj == null){ return false; } return hashCode()==obj.hashCode(); } } (CharArray的实现方式同ByteArray,只是把byte[] bytes 替换成 char[] chars即可) ByteArray占用的内存大小= 12字节(object header+ 4字节(数组引用bytes[]) + 16字节+N字节+padding (数组bytes[]) = 32字节+N字节+padding CharArray占用的内存大小= 12字节(object header+ 4字节(数组引用bytes[]) + 16字节+2*N字节+padding (数组bytes[]) = 32字节+2*N字节+padding 其中,N为数组中元素的个数。 例子 以存储100万条长度为32位的MD5字符串为例且内容互不相同字符串为例(假设字符串中的字符均为字母、数字、下划线)。 可以用classmexer来计算内存使用量 。 import com.javamex.classmexer.MemoryUtil; /** * Created by jianpingpan on 2019/1/25. */ public class StringTest { public static void main(String[] args){ String s="cfcd208495d565ef66e7dff9f98764da"; ByteArray b = new ByteArray(s.getBytes()); CharArray c = new CharArray(s.toCharArray()); long stringBytes = MemoryUtil.deepMemoryUsageOf(s); long byteArrayBytes = MemoryUtil.deepMemoryUsageOf(b); long charArrayBytes = MemoryUtil.deepMemoryUsageOf(c); System.out.println("stringBytes:"+stringBytes); System.out.println("byteArrayBytes:"+byteArrayBytes); System.out.println("charArrayBytes:"+charArrayBytes); } } 用String存储,每条记录占用的空间为 40+32*2 = 104字节 用ByteArray存储,每条记录占用的空间为 32+32 = 64字节 用CharArray存储,每条记录占用的空间为 32+32*2 = 96字节 参考文档: http://btoddb-java-sizing.blogspot.com/2012/01/object-sizes.html https://stackoverflow.com/questions/26357186/what-is-in-java-object-header/26416983 http://openjdk.java.net/groups/hotspot/docs/HotSpotGlossary.html

优秀的个人博客,低调大师

单元测试优化的实践(Generative Testing)

首先为什么要写单元测试? 因为对于任何一个软件来说,“满足需求”是他存在的必要条件,也是软件的价值体现。单元测试一定是为它服务的。所以很容易知道写单元测试的两个动机:驱动(如:TDD)和验证功能实现。另外,软件需求“易变”的特征决定了修改代码成为必然,在这种情况下,单元测试能保护已有的功能不被破坏。 基于以上两点共识,我们看看传统的单元测试有什么特征? 基于用例的测试(By Example) 单元测试最常见的套路就是Given、When、Then三部曲。 Given:初始状态或前置条件 When:行为发生 Then:断言结果 编写时,我们会精心准备(Given)一组输入数据,然后在调用行为后,断言返回的结果与预期相符。这种基于用例的测试方式在开发(包括TDD)过程中十分好用。因为它清晰地定义了输入输出,而且大部分情况下体量都很小、容易理解。 但这样的测试方式也有坏处。 第一点在于测试的意图。用例太过具体,我们就很容易忽略自己的测试意图。比如我曾经看过有人在写计算器kata程序的时候,将其中的一个测试命名为“return 3 when add 1 and 2”,这样的命名其实掩盖了测试用例背后的真实意图——传入两个整型参数,调用add方法之后得到的结果应该是两者之和。我们常说测试即文档,既然是文档就应该明确描述待测方法的行为,而不是陈述一个例子。 第二点在于测试完备性。因为省事省心并且回报率高,我们更乐于写happy path的代码。尽管出于职业道德,我们也会找一个明显的异常路径进行测试,不过这还远远不够。 为了辅助单元测试改善这两点。我这里介绍另一种测试方式——生成式测试(Generative Testing,也称Property-Based Testing)。这种测试方式会基于输入假设输出,并且生成许多可能的数据来验证假设的正确性。 生成式测试 对于第一个问题,我们换种思路思考一下。假设我们不写具体的测试用例,而是直接描述意图,那么问题也就迎刃而解了。想法很美好,但如何实践Given、When、Then呢?答案是让程序自动生成入参并验证结果。这也就引出“生成式测试”的概念——我们先声明传入数据可能的情况,然后使用生成器生成符合入参情况的数据,调用待测方法,最后进行验证。 Given阶段 Clojure 1.9(Alpha)新内置的Clojure.spec可以很轻松地做到这点: ;; 定义输入参数的可能情况:两个整型参数 (s/def ::add-operators (s/cat :a int? :b int?)) ;; 尝试生成数据 (gen/generate (s/gen ::add-operators)) ;; 生成的数据 -> (1 -122) 首先,我们尝试声明两个参数可能出现的情况或者称为规格(specification),即参数a和b都是整数。然后调用生成器产生一对整数。整个分析和构造的过程中,都没有涉及具体的数据,这样会强制我们揣摩输入数据可能的模样,而且也能避免测试意图被掩盖掉——正如前面所说,return 3 when add 1 and 2并不代表什么,return the sum of two integers才具有普遍意义。 Then阶段 数据是生成了,待测方法也可以调用,但是Then这个断言阶段又让人头疼了,因为我们根本没法预知生成的数据,也就无法知道正确的结果,怎么断言? 拿定义好的加法运算为例: (defn add [a b] (+ a b)) 我们尝试把断言改成一个全称命题: 任取两个整数a、b,a和b加起来的结果总是a、b之和。 借助test.check,我们在Clojure可以这样表达: (def test-add (prop/for-all [a (gen/int) b (gen/int)] (= (add a b) (+ a b)))) 不过,我们把add方法的实现(+ a b)写到了断言里,这几乎丧失了单元测试的基本意义。换一种断言方式,我们使用加法的逆运算进行描述: 任取两个整数,把a和b加起来的结果减去a总会得到b。 (def test-add (prop/for-all [a (gen/int) b (gen/int)] (= (- (add a b) a) b)))) 我们通过程序陈述了一个已知的真命题。变换以后,就可以使用quick-check对多组生成的整数进行测试。 ;; 随机生成100组数据测试add方法 (tc/quick-check 100 test-add) ;; 测试结果 -> {:result true, :num-tests 100, :seed 1477285296502} 测试结果表明,刚才运行了100组测试,并且都通过了。理论上,程序可以生成无数的测试数据来验证add方法的正确性。即便不能穷尽,我们也获得一组统计上的数字,而不仅仅是几个纯手工挑选的用例。 至于第二个问题,首先得明确测试是无法做到完备的。很多指导方法保证使用较少的用例做到有效覆盖,比如:等价类、边界值、判定表、因果图、pairwise等等。但是在实际使用过程当中,依然存在问题。举个例子,假如我们有一个接收自然数并直接返回这个参数的方法identity-nat,那么对于输入参数而言,全体自然数都互为等价类,其中的一个有效等价类可以是自然数1;假定入参被限定在整数范围,我们很容易找到一个无效等价类,比如-1。 用Clojure测试代码表现出来: (deftest test-with-identity-nat (testing "identity of natural integers" (is (= 1 (identity-nat 1)))) (testing "throw exception for non-natural integers" (is (thrown? RuntimeException (identity-nat -1))))) 不过如果有人修改了方法identity-nat的实现,单独处理入参为0的情况,这个测试还是能够照常通过。也就是说,实现发生改变,基于等价类的测试有可能起不到防护作用。当然你完全可以反驳:规则改变导致等价类也需要重新定义。道理确实如此,但是反过来想想,我们写测试的目的不正是构建一张安全网吗?我们信任测试能在代码变动时给予警告,但此处它失信了,这就尴尬了。 如果使用生成式测试,我们规定: 任取一个自然数a,在其上调用identity-nat的结果总是返回a。 (def test-identity-nat (prop/for-all [a (s/gen nat-int?)] (= a (identity-nat a)))) (tc/quick-check 100 test-identity-nat) -> {:result false, :seed 1477362396044, :failing-size 0, :num-tests 1, :fail [0], :shrunk {:total-nodes-visited 0, :depth 0, :result false, :smallest [0]}} 这个测试尝试对100组生成的自然数(nat-int?)进行测试,但首次运行就发现代码发生过变动。失败的数据是0,而且还给出了最小失败集[0]。拿着这个最小失败集,我们就可以快速地重现失败用例,从而修正。 当然也存在这样的可能:在一次运行中,我们的测试无法发现失败的用例。但是,如果100个测试用例都通过了,至少表明我们程序对于100个随机的自然数都是正确的,和基于用例的测试相比,这就如同编织出一道更加紧密的安全网——网孔越小,漏掉的情况也越少。 Clojure语言之父Rich Hickey推崇Simple Made Easy哲学,受其影响生成式测试在Clojure.spec中有更为简约的表达。以上述为例: (s/fdef identity-nat :args (s/cat :a nat-int?) ; 输入参数的规格 :ret nat-int? ; 返回结果的规格 :fn #(= (:ret %) (-> % :args :a))) ; 入参和出参之间的约束 (stest/check `identity-nat) fdef宏定义了方法identity-nat的规格,默认情况下会基于参数的规格生成1000组数据进行生成式测试。除了这一好处,它还提供部分类型检查的功能。 再谈TDD 如果对软件测试、接口测试、自动化测试、性能测试、LR脚本开发、面试经验交流。感兴趣可以175317069,群内会有不定期的发放免费的资料链接,这些资料都是从各个技术网站搜集、整理出来的,如果你有好的学习资料可以私聊发我,我会注明出处之后分享给大家。 TDD(测试驱动开发)是一种驱动代码实现和设计的过程。我们说要先有测试,再去实现;保证实现功能的前提下,重构代码以达到较好的设计。整个过程就好比演绎推理,测试就是其中的证明步骤,而最终实现的功能则是证明的结果。 对于开发人员而言,基于用例的测试方式是友好的,因为它能简单直接地表达实现的功能并保证其正确性。一旦进入红、绿、重构的节(guai)奏(quan),开发人员根本停不下来,仿佛遁入一种心流状态。只不过问题是,基于用例驱动出来的实现可能并不是恰好通过的。我们常常会发现,在写完上组测试用例的实现之后,无需任何改动,下组测试照常能运行通过。换句话说,实现代码可能做了多余的事情而我们却浑然不知。在这种情况下,我们可以利用生成式测试准备大量符合规格的数据探测程序,以此检查程序的健壮性,让缺陷无处遁形。 凡是想到的情况都能测试,但是想不到情况也需要测试,这才是生成式测试的价值所在。有人把TDD概念化为“展示你的功能”(Show your work),而把生成式测试归纳为“检查你的功能“(Check your work),我深以为然。 小结 回到我们写单元测试的动机上: 1、驱动和验证功能实现; 2、保护已有的功能不被破坏。 基于用例的单元测试和生成式测试在这两点上是相辅相成的。我们可以借助它们尽可能早地发现更多的缺陷,避免它们逃逸到生产环境。 Clojure.spec是Clojure内置的一个新特性,它允许开发人员将数据结构用类型和其他验证条件(例如允许的取值范围)进行封装。这种数据结构一旦建立,Clojure就能利用这种规格来为程序员提供大量的便利:自动生成的测试代码、合法性验证、析构数据结构等等。Clojure.spec提供方法很有前景,它可以让开发者在需要的时候,就能从类型和取值范围中获益。 另外,除了Clojure,其它语言也有相应的生成式测试的框架,你不妨在自己的项目中试一试。

资源下载

更多资源
腾讯云软件源

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题,腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构,目前腾讯云软件源站支持公网访问和内网访问。

Nacos

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称,一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集,帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Spring

Spring

Spring框架(Spring Framework)是由Rod Johnson于2002年提出的开源Java企业级应用框架,旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念,提供核心容器、应用上下文、数据访问集成等模块,支持整合Hibernate、Struts等第三方框架,其适用范围不仅限于服务器端开发,绝大多数Java应用均可从中受益。

Rocky Linux

Rocky Linux

Rocky Linux(中文名:洛基)是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版,作为CentOS稳定版停止维护后与RHEL(Red Hat Enterprise Linux)完全兼容的开源替代方案,由社区拥有并管理,支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性,采用模块化包装和SELinux安全架构,默认包含GNOME桌面环境及XFS文件系统,支持十年生命周期更新。

用户登录
用户注册