曳凡-CSDN博客

原创 RocketMq 高可用性解析（二）消费高可用

1、引言RocketMq 主要的三大流程就是消息的发送，消息的存储和消息的消费了。消息的发送和消息的消费都是在 RocketMq 的client模块中，而消息的存储则是在 broker 模块中。在消费端消费消息时，可能会发生消息消费失败的情况。造成这种情况的原因主要有三点broker 异常了消费端异常了broker 和消费端的网络异常了而 RocketMq 解决消费端消息消费失败的方式主要有两种：重试-死信机制Rebalance 机制其中重试-死信机制就是为了防止因为网络抖动造成消

2022-04-07 10:38:37 830 1

原创从 ThreadLocal 到 TransmittableThreadLocal 的深度剖析

引言ThreadLocal 相信大家都用过，我们在需要变量只生效于线程单位时，使用 TheadLocal 能很好的帮我们把变量在不同线程中隔离开来。本篇文章主要分析一下 ThreadLocal, InheritableThreadLocal, TransmittableThreadLocal。这三者是依次推进的关系，InheritableThreadLocal对ThreadLocal做了拓展，TransmittableThreadLocal对InheritableThreadLocal做了拓展。那接下

2022-03-28 10:56:29 1179

原创 RocketMq 高可用性解析（一）存储高可用

引言RocketMq 作为一个成熟的消息中间件，自身保证了高可用性。学习RocketMq中的高可用性可以帮助我们自己在平时编写代码时能够编写处高可用的代码。对于RocketMq，高可用主要在这四块进行保证消息发送的高可用：在消息发送时可能会遇到网络问题、Broker 宕机等情况导致消息没有发送成功消息存储的高可用：在 RocketMQ 中消息存储时Broker发生故障导致消息没有保存下来消息消费的高可用：可能由于网络原因导致，也可能由于业务逻辑错误导致消息一直消费失败集群管理的高可用：整一个

2022-03-24 12:52:15 3384

原创 OpenFeign调用服务的核心原理解析

引言OpenFeign在分布式服务中运用非常广泛，他和RPC所要达到的效果一致，就是为了简化远程服务调用的操作，通过使用OpenFeign可以使得调用远程服务就像调用本地服务一样方便。但是其和RPC在实现上还是不太一样，不一样的地方主要还是调用的方式，OpenFeign是内部实现了rest服务调用，从而一个本地服务调用远程服务的接口时，主要还是通过rest服务调用的方式，那么对于服务端的要求就是其服务需要将这个接口通过rest暴露出来，不然OpenFeign将无法工作；而RPC则不需要服务端将该接口以r

2022-03-19 17:06:45 6630 3

原创 @Sync 注解导致系统OOM 原理探索

引论今天发现了一篇讲多线程避坑的文章，是一位技术大佬写的，我也是非（zou）常（ma）认（guan）真（hua）的看完了这篇文章（文章链接如下），其中的第8点吸引了我，平时都是直接用的，并没有去真正了解他是如何实现的，这居然都有坑。我截取了文章的部分内容如下：我当时觉得不应该呀，因为公司中也确实有挺过地方是直接使用@Async注解的，也从来没有因为线程太多而造成OOM情况，但是大佬也不太可能会欺骗我们，带着这个问题我去研究了一下@Async的实现。探索@Async注解大家应该用的挺多了吧，该注解使

2022-03-10 20:59:13 1867 1

原创 Spring 如何控制 bean 注入，全靠了这个注解

前言在 spring 工程中经常能看到在服务配置中添加了某些服务配置后，这个服务就能用了，例如在yaml文件中配置了下面的配置后，oauth2在校验token时就不会去调动本地的服务，而是会调用token-info-uri中设置的uri来获取token的校验结果security: oauth2: resource: token-info-uri: client: client-id: client-secret:这是如何做到的呢？答案就是@C

2022-03-02 10:35:10 1563 1

原创从动态代理到 Mybatis 插件原理

前言Mybatis 可以算是大家日常工作中最常碰到的框架工具了，有了 Mybatis 我们在对数据库操作时不用再像jdbc那样还需要关注如何连接数据，数据获取后连接如何处理等一系列和数据无关的操作。所以笔者这里也算是更加理解了" 一个优秀的框架能够使开发者更加关注于自身的业务逻辑上"这句话的含义。使得 Mybatis 优秀的不仅仅是他的功能上，还体现在他的扩展性上。 Mybatis 提供了一种插件的功能，可以使得 Mybatis添加在ParameterHandler，使得在参数解析后，组成sql前可

2021-11-15 16:31:04 473 1

原创 Java8 Stream 的深度理解

前言在java8中，stream流式处理极大的简化了我们的功能代码，其中用来筛选数据的filter也是我们用的非常多的，本篇文章用来记录stream运用时的思考，会不断更新，但是这篇文章不是讲解stream是如何使用的，如果想要学习stream的同学，可以戳这里简化stream执行语句平时大家在写流式数据处理来筛选数据时一般都会这样写list.stream().filter(a-> {具体筛选条件}).collect(Collectors.toList());这样的写法非常好理解，但是会存

2021-11-12 19:02:06 458 1

原创 Spring Oauth2 Token处理原理

前言相信大家在开始时经常会分不清spring security和spring oauth2的区别，对于spring security都知道是鉴权，授权服务。而oauth2的提出是为了解决第三方软件登入时的授权问题，所以oauth2可以理解为资源授权服务。例如我们在打开王者荣耀游戏时，这时候系统会提醒我们使用qq还是微信登入，这时就是王者荣耀这个第三方软件申请qq或者微信的授权来登入对应的账号。上面就是Oauth2中授权中最严谨的授权码模式流程，这篇文章主要是想分享一下客户端（也就是王者荣耀）在得到to

2021-11-10 17:07:11 1949 2

原创揭开Spring Security 责任链秘密

前言Spring Security是一个优秀的安全管理框架，同时他很多地方支持可定制化。基于Spring Security,我们就可以做出供自己业务场景下的安全管理需求，例如在SaaS服务下的多租户权限控制。而Spring Security中最重要的实现方式，最重要的设计模式，那便非责任链模式莫属了。配置初始化在配置初始化前，都需要有一个机制来触发配置的初始化，道理很简单，因为我们不是所有场景下都需要用到Spring Security，只是在我们需要用到这个框架的时候，才需要去触发他。Spring S

2021-11-09 19:02:49 1133 1

原创 mysql性能调优 explain详解

0. 前言大家在日常工作中一定都会用到数据库，而数据库的执行效率也一定是大家所格外关心的事。经常会有业务程序在执行数据的增删改查的时候速度非常慢（可以通过mysql的慢sql日志去查看有哪些sql执行时间特别长，具体慢sql的超时时间可以通过设置long_query_time参数）。在查到哪些sql语句后，这时我们就需要去分析对应的这条sql语句为什么会执行速度慢。mysql为此提供了一个十分强大的命令–explain。1.explain参数简介其实我们在分析sql语句的具体执行效率时只需要关心一下这

2021-07-16 13:11:52 311

原创如何获取特定注解的Bean对象(@Qualifier注解的妙用)

1、问题引出面向切面编程使得我们对于一个接口可以有多种实现。在spring源码中更是将接口编码做到极致。但是我们在获取对应接口的实现Bean时，该如何获取限定的Bean呢？我以Spring的某一源码为例。spring中的负载均衡是通过在RestTemplate对象上添加@LoadBalanced注解来实现的。例如只要我们在RestTemplate添加上了@LoadBalanced注解，那么这个RestTemplate对象就拥有了负载均衡的能力。对于类对象添加能力的方式，相比大家都应该了解，是通过动

2021-06-19 20:19:03 1024

空空如也

空空如也