前言RabbitMQ已经提供了非常丰富的api以及支持延时队列的实现死信队列延时插件等当然这也足够我们使用了我的项目中对RabbitMQ的封装以及扩展我觉得非常的方便接下来和大家分享一下我个人觉得主要封装了消息的唯一Id延时发送消息处理参数的泛型化多线程异步发送消息的强大机制自定义的MqHelperjavaSlfjpublicclassRabbitMqHelperprivatefinalRabbitTemplaterabbitTemplateprivatefinalMessagePostProcessorprocessornewBasicIdMessageProcessorprivatefin
一Seata分布式解决方案TCC模式TCC模式理论TCC模式和AT模式很相似第一阶段都是独立事务执行完了直接提交不同的是TCC模式不用去加锁也不用生成快照因此性能上会更好TCC模式的第二阶段是基于人工编码的方式来实现数据恢复的不像AT是自动实现的人工编码的方式需要实现三个方法分别是tryconfirmcanceltry用来进行资源的检测和预留也就是说我需要修改某个资源的时候先把这个资源预留下来等到第二阶段的时候在对这个资源进行一个具体的操作cancel如果第二阶段需要进行回滚就执行cancelcancel是对预留资源的一个释放可以理解为对try的反向操作confirm完成资源业务操作这里要求t
2024-01-11 20:20 1000 0 分布式事务
前言在Online学习平台中当用户观看视频时用户离开再次观看时我们如何对上次的播放进度进行保存完成续播呢接下来就由我来揭开这神秘的面纱我参与了整个学习中心的功能开发其中有很多的学习辅助功能都很有特色比如视频播放的进度记录我们网站的课程是以录播视频为主为了提高用户的学习体验需要实现视频续播功能这个功能本身并不复杂只不过有如下要求首先续播时间误差要控制在秒以内而且要做到用户突然断开甚至切换设备后都可以继续上一次播放要达成这个目的使用传统的手段显然是不行的首先要做到切换设备后还能续播用户的播放进度必须保存在服务端而不是客户端其次用户突然断开或者切换设备续播的时间误差不能超过秒那播放进度的记录频率就需
前言我的项目一用户登录时基于JWT登录的如果有对JWT不了解的同学可以看我之前总结的这篇文章JWT令牌认证解析流程及如何使用httpcqkjavacnhtmlJWT令牌认证解析流程及如何使用下面我来结合项目中的代码总结一下项目中登录流程的实现登录login入口uploaddcbeceabafacecdebpng生成tokenjavaprivateStringgenerateTokenLoginUserDTOdetail生成accesstokenStringtokenjwtToolcreateTokendetail生成refreshtoken将refreshtoken的JTI保存到RedisSt
前言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
前言只要使用到缓存无论是本地缓存还是使用Redis做缓存那么就会存在数据同步不一致的问题uploadcaaedbbacbfefedpng先读取缓存缓存数据有则立即返回结果如果缓存中没有数据则从数据库中读取数据把读取到的数据同步到缓存中提供下次读请求返回数据这样的作法是大多数人使用缓存的方式这样能有效减轻数据库压力但是如果修改删除数据因为缓存无法感知到数据在数据库中的修改这样就会造成数据库中的数据与缓存中数据不一致那么该如何解决呢有下面种解决方案先更新缓存再更新数据库先更新数据库再更新缓存先删除缓存后更新数据库先更新数据库后删除缓存下面我们一一来看下每个方案的可行性正文一先更新缓存再更新数据库这
大家好我是小蔡CountDownLatch有何作用我们知道AQS是专属于构造锁和同步器的一个抽象工具类基于它Java构造出了大量的常用同步工具如ReentrantLockSemaphoreReentrantReadWriteLockSynchronousQueue等等我们今天的主角CountDownLatch同样如此CountDownLatch倒时器允许N个线程阻塞在同一个地方直至所有线程的任务都执行完毕CountDownLatch有一个计数器可以通过countDown方法对计数器的数目进行减一操作也可以通过await方法来阻塞当前线程直到计数器的值为CountDownLatch闭锁倒计时锁用
