第一节基于Redis实现延时队列一基础知识httpcqkjavacnhtml基于Redis实现延时队列一基础知识第二节开始设计uploadcaaddbbfbacbfdpng经过第一节的学习我们已经有了相应的了解下面我们来代码实现首先清楚这几个点我们存放的对象有哪些以及容器对象Job实体类DelayJob对象延时任务实体类容器Job池用于存放Job对象JobPoolHash结构kjobIdvjobJob桶用于存放Job延时任务对象还有任务的状态重试次数等等JobBucketZSet结构大keybucketName小keyjobscore延时终点时间戳用于排序核心Job队列用于处理Timer从桶中
前言说到线程池八股文背的很熟的肯定知道无非就这几个考点线程池三大核心参数corePoolSizemaximumPoolSizeworkQueue的含义线程池核心线程数制定策略建议通过ThreadPoolExecutor的构造函数来声明避免使用Executors创建线程池事故还原javaListStationDataitemsgetFromDbListCompletableFutureAppMapStationDatacompletableFuturesitemsstreammapitemCompletableFuturesupplyAsyncAppMapStationDatadatamappe
前言根据上一节课的了解我们知道我们优惠卷是有不同的规则的优惠券规则从类型来说就种每满减例如每满减折扣例如满打折最大不超过无门槛例如直接抵扣元满减例如满减优惠类型discountType对应到数据库的字段就是discounttype另外优惠券描述中基本都会包含下列字段优惠门槛thresholdAmount也就是优惠的基本条件例如满优惠值discountValue也就是具体折扣例如减打折最大优惠maxDiscountValue最大折扣限制折扣金额对应的数据库表结构如下uploadabaceecaadfpng因此各种各样的优惠券其规则都可以用上述个字段标示而规则根据优惠类型discountType来
2024-02-01 12:54 1568 0 策略模式 异步 CountDownLatch CompletableFuture
前言RabbitMQ已经提供了非常丰富的api以及支持延时队列的实现死信队列延时插件等当然这也足够我们使用了我的项目中对RabbitMQ的封装以及扩展我觉得非常的方便接下来和大家分享一下我个人觉得主要封装了消息的唯一Id延时发送消息处理参数的泛型化多线程异步发送消息的强大机制自定义的MqHelperjavaSlfjpublicclassRabbitMqHelperprivatefinalRabbitTemplaterabbitTemplateprivatefinalMessagePostProcessorprocessornewBasicIdMessageProcessorprivatefin
前言我的项目一用户登录时基于JWT登录的如果有对JWT不了解的同学可以看我之前总结的这篇文章JWT令牌认证解析流程及如何使用httpcqkjavacnhtmlJWT令牌认证解析流程及如何使用下面我来结合项目中的代码总结一下项目中登录流程的实现登录login入口uploaddcbeceabafacecdebpng生成tokenjavaprivateStringgenerateTokenLoginUserDTOdetail生成accesstokenStringtokenjwtToolcreateTokendetail生成refreshtoken将refreshtoken的JTI保存到RedisSt
ThreadLocal的使用以及内存泄漏问题引言ThreadLocal在Java多线程编程中扮演着重要的角色它提供了一种线程局部存储机制允许每个线程拥有独立的变量副本从而有效地避免了线程间的数据共享冲突ThreadLocal的主要用途在于当需要为每个线程维护一个独立的上下文变量时比如每个线程的事务ID用户登录信息数据库连接等可以减少对同步机制如synchronized关键字或Lock类的依赖提高系统的执行效率和简化代码逻辑但是我们在使用ThreadLocal时经常因为使用不当导致内存泄漏此时就需要我们去探究一下ThreadLocal在哪些场景下会出现内存泄露哪些场景下不会出现内存泄露出现内存泄
前言Servlet之前每一次Http请求都由一个线程从头到尾处理Servlet之后提供了异步处理请求可以先释放容器分配给请求的线程与相关资源减轻系统负担从而增加服务的吞吐量在springboot应用中可以有种方式实现现异步接口至于ResponseBodyEmitterSseEmitterStreamingResponseBody不在本文介绍内之后新写文章介绍AsyncContextCallableWebAsyncTaskDeferredResult第一中AsyncContext是Servlet层级的比较原生的方式本文不对此介绍一般都不使用它太麻烦了本文着重介绍后面三种方式特别说明服务端的异步或
2023-12-30 21:36 1059 0 多线程 优化RT(响应时间) 线程池
说一下线程池的核心参数uploadecbabfeadfedepngcorePoolSize核心线程数目maximumPoolSize最大线程数目核心线程救急线程的最大数目keepAliveTime生存时间救急线程的生存时间生存时间内没有新任务此线程资源会释放unit时间单位救急线程的生存时间单位如秒毫秒等workQueue当没有空闲核心线程时新来任务会加入到此队列排队队列满会创建救急线程执行任务threadFactory线程工厂可以定制线程对象的创建例如设置线程名字是否是守护线程等handler拒绝策略当所有线程都在繁忙workQueue也放满时会触发拒绝策略线程池的执行原理uploadfda
