• 开发实践 笔记

Spring Boot 2 升 3：两条命令搞定 95%，AI 收尾

一年多前，我在另一个迁移项目里尝试过 OpenRewrite，做了可行性验证，最终评估下来方案不合适，那个项目转而采用了 AI 的方式。顺着那次探索写了个系列，然后就搁置了。最近真正的迁移计划提上日程，翻出来一看——当时踩过的坑、记下来的 …

• 笔记

使用 Sdkman 在 M1 Mac 上 安装 Graalvm Jdk

SDKMAN 是一款管理多版本 SDK 的工具，可以实现在多个版本间的快速切换。安装和使用非常简单：

• 云原生

使用 Flomesh 进行 Dubbo 服务治理

写在最前

和上一篇《使用 Flomesh 强化 Spring Cloud 服务治理》一样，这次同样是在无代码侵入的情况下对 Dubbo 服务治理的提升。

更多治理场景陆续添加中，有兴趣的可关注 …

• 云原生

使用 Flomesh 强化 Spring Cloud 服务治理

写在最前

这篇是关于如何使用 Flomesh 服务网格来强化 Spring Cloud 的服务治理能力，降低 Spring Cloud 微服务架构落地服务网格的门槛，实现“自主可控”。

文档在 github 上持续更新，欢迎大家一起讨论 …

• 翻译

使用 Quarkus 和 MicroProfile 实现微服务特性

Quarkus 的文章之前写过三篇了，讲过了 Quarkus 的小而快。

• Hello, Quarkus
• 应"云"而生的 Java 框架 Quarkus：构建本机可执行文件
• 谁说 Java 不能用来跑 …

• 笔记 云原生

Quarkus：谁说 Java 不能用来跑 Serverless？

想到这个标题的时候，我第一时间想到的就是星爷的《唐伯虎点秋香》的这一幕。

当讨论起世界上最好的开发语言是什么的时候，Java 的粉丝们总会遇到这种场景：

吹：“Java 语法简单，容易上手！” 黑：“Java 启动慢，性能差，耗资源！” …

• 教程 笔记

应“云”而生的 Java 框架：构建本机可执行文件

电影《功夫》中，火云邪神有句话：“天下武功无坚不摧，唯快不破。”

在 上一篇文章 中，我们写了第一个 Quarkus 应用，并尝试着构建了 legacy-jar 和 fast-jar。

今天来看一下 Quarkus 构建出来的本机可执 …

• 笔记

应“云”而生的 Java 框架：Hello, Quarkus

Wikipedia上有关 Quarkus 的信息还很少，只有一句简单的介绍：

Quarkus 是专为 OpenJDK HotSpot 和 GraalVM 定制的全栈 Kubernetes 原生 Java 应用程序框架。与如 Spring …

• 笔记

带你了解 Ribbon 负载均衡器的实现

Spring Cloud 中 Ribbon有在 Zuul 和 Feign 中使用，当然也可以通过在RestTemplate的 bean 定义上添加@LoadBalanced注解方式获得一个带有负载均衡更能的RestTemplate。

不过实 …

• 笔记

Java 中的 Mysql 时区问题

(Photo by Andrea Piacquadio from Pexels)

话说工作十多年，mysql 还真没用几年。起初是外企银行，无法直接接触到 DB；后来一直从事架构方面，也多是解决问题为主。

这次搭建海外机房，围绕时区大家做 …

• 笔记 云原生

加速云原生的 Java 开发

今天来说说日常在Kubernetes开发Java项目遇到的问题.

当我们新建一个项目的时候, 总是面临需要新建manifest, 平时都是copy+paste+modify. 能否以变成的方式来生成?

开发时的步骤也比较繁琐: docker …

• 资讯

Spring Boot 2.2.0 发布

译自: https://spring.io/blog/2019/10/16/spring-boot-2-2-0

组件升级

• Spring AMQP 2.2
• Spring Batch 4.2
• Spring Data Moore
• Spring …

• 笔记

如何选择Kafka Topic的分区数

在kafka中, topic的分区是并行计算的单元. 在producer端和broker端, 可以同时并发的写数据到不同的分区中. 在consumer端, Kafka总是将某个分区分配个一个consumer线程. 因此同一个消费组内的并行度 …

• 源码解析

Spring Boot源码分析 - Configuration注解

@Configuration注解

@Configuration注解指示一个类声明一个或多个@Bean方法, 并且可以由Spring容器处理, 以在运行时为这些bean生成bean定义和服务请求.

使用 …

• 笔记

Zuul网关Ribbon重试

相关配置

#如果路由转发请求发生超时(连接超时或处理超时), 只要超时时间的设置小于Hystrix的命令超时时间,那么它就会自动发起重试. 默认为false. 或者对指定响应状态码进行重试
zuul.retryable = true …

• 笔记

Hystrix工作原理三

异常处理

Hystrix异常类型

• HystrixRuntimeException
• HystrixBadRequestException
• HystrixTimeoutException
• RejectedExecutionException …

• 笔记

Hystrix工作原理二

隔离策略

线程和线程池

客户端(库, 网络调用等)在各自的线程上运行. 这种做法将他们与调用线程隔开, 因此调用者可以从一个耗时的依赖调用"离开(walk away)"

Hystrix使用单独的, 每个依赖的线程池作为约 …

• 笔记

Hystrix工作原理一

运行时的流程图

1. 构建HystrixCommand或者HystrixObservableCommand对象

   第一步是构建一个HystrixCommand或HystrixObservableCommand对象来代表对依赖服务所做的请求。 …

• 笔记

初识 Netflix Zuul

嵌入式的zuul代理

使用了Netfilx OSS的其他组件:

• Hystrix 熔断
• Ribbon 负责发送外出请求的客户端, 提供软件负载均衡功能
• Trubine 实时地聚合细粒度的metrics数据
• Archaius …

• 笔记

ConfigurationProperties到底需不需要getter

为什么要讨论这个问题, 工作中一个同事写的类使用了ConfigurationProperties, 只提供了标准的setter方法. 属性的访问, 提供了定制的方法. 可以参考EurekaClientConfigBean.

他使用的是 …

• 笔记

SpringBoot源码 - 启动

SpringBoot Application启动部分的源码阅读.

SpringApplication

常用的SpringApplication.run(Class, Args)启动Spring应用, 创建或者更新 …

• 笔记

Java序列化工具性能对比

最近在调整系统的性能, 系统中正使用Jackson作为序列化工具. 做了下与fastJson, Avro, ProtoStuff的序列化吞吐对比.

由于只是做横向对比, 没有优化系统或者JVM任何参数. 服务器一般都用Linux, 在 …

• 源码解析

Spring Cloud - Eureka Client源码分析

准备做个Spring Cloud源码分析系列, 作为Spring Cloud的源码分析笔记.

这一篇是Eureka的客户端.

客户端

两种方式, 最终的实现基本一样.

显示指定服务发现的实现类型

使用@EnableEurekaClient注 …

• 笔记

Kafka发送不同确认方式的性能差异

背景

Kafka的性能众所周知，Producer支持acknowledge模式。即Kafka会想Producer返回消息发送的结果。但是在Java Client中，acknowledge的确认有两种：同步和异步。 同步是通过调用 …

• 笔记

Kafka 恰好一次发送和事务消费示例

核心思想

• 生产端一致性: 开启幂等和事务, 包含重试, 发送确认, 同一个连接的最大未确认请求数.
• 消费端一致性: 通过设置读已提交的数据和同时处理完成每一条消息之后手动提交offset.

生产端

public class …

• 笔记

Kafka Producer配置解读

按照重要性分类, 基于版本0.11.0.0

高

bootstrap.servers

一组host和port用于初始化连接. 不管这里配置了多少台server, 都只是用作发现整个集群全部server信息. 这个配置不需要包含集群所有的机器信 …

• 笔记

JSON Patch

JSON Path是在使用Kubernetes API的过程中首次使用的. 使用API做扩缩容的时候, 发送整个Deployment的全文不是个明智的做法, 虽然可行. 因此便使用了JSON Patch.

JsonObject item = …

• 笔记

暴力停止ExecutorService的线程

停止，stop，这里说的是真的停止。如何优雅的结束，这里就不提了。

这里要用Thread.stop()。众所周知，stop()方法在JDK中是废弃的。

该方法天生是不安全的。使用thread.stop()停止一个线程，导致释放（解锁）所有 …

• 笔记

私有构造函数捕获模式

《Java并发编程实践》的注解中有提到这一概念。

The private constructor exists to avoid the race condition that would occur if the copy …

• 笔记

Docker 快速构建 Cassandra 和 Java 操作

搭建Cassandra

使用docker创建Cassandra，方便快捷

docker pull cassandra:latest
docker run -d --name cassandra -p 9042:9042 cassandra …

• 笔记

MetaspaceSize的坑

这几天生产上有台机器的Metaspace一直在告警，Metaspace使用达到了97%。使用-XX:MetaspaceSize=512m，告警也还在在持续，查看MC只有81536.0，显然这个参数没起作用。

也有人遇到类似的问题，并在 …

• 笔记

一个Tomcat类加载问题

背景

一个Tomcat实例中运行了三个应用，其中一个对接了Apereo的CAS系统。现在要求另外两个系统也对接CAS系统，问题就出现了：

应用启动后打开其中两个应用的任何一个，登录完成后系统都没有问题。唯独首选打开第三个，其他两个报错 …

• 笔记

Scala笔记：用函数字面量块调用高阶函数

这里会用到几个概念高阶函数、函数字面量、参数组

高阶函数

high-order function 函数的一种，简单来说它包含了一个函数类型的参数或者返回值。

所谓的高阶是跟一阶函数相比，深入一下：

1. 一个或多个参数是函数，并返回一个值。 …

• 笔记

GreenPlum JDBC和C3P0数据源

在网上搜索GreenPlum（GPDB）的数据源配置的时候，发现搜索结果都是用postgresql的配置。

import com.mchange.v2.c3p0.DataSources;

import …

• 笔记

Scala笔记：def vs Val

先说原理：

val修饰的在定义的时候执行

def修饰的在调用的时候执行

直观的例子：

//注释的行为REPL输出
def test: () => Int = {
    println("def called") …

• 笔记

Key长度对Redis性能影响

最近Redis的使用中用的到key可能比较长，但是Redis的官方文档没提到key长度对性能的影响，故简单做了个测试。

环境

Redis和测试程序都是运行在本地，不看单次的性能，只看不同的长度堆读写性能的影响。

测试方法

使用长度分别为 …

• 笔记

遍历 Collection 时删除元素

其实标题我想用《为什么foreach边循环边移除元素要用Iterator？》可是太长。

不用Iterator，用Collection.remove()，会报ConcurrentModificationException错误。

for( …

• 笔记

Java Volatile关键字

volatile通过保证对变量的读或写都是直接从内存中读取或直接写入内存中，保证了可见性；但是volatile并不足以保证线程安全，因为无法保证原子性，如count++操作：

1. 将值从内存读入寄存器中
2. 进行加1操作，内存保存到寄存器中
3. 结果 …

• 笔记

Mybatis报错“Result Maps Collection Already Contains Value for ***”

这是工作中遇到的一个问题：测试环境部署出错，报了下面的问题。

Caused by: java.lang.IllegalArgumentException: Result Maps collection already contains …

• 笔记

消费时offset被重置导致重复消费

这是实际使用时遇到的问题：kafka api的版本是0.10，发现有重复消费问题；检查log后发现在commit offset的时候发生超时。

Auto offset commit failed for group test: Commit …

• 笔记

TheadPoolExecutor源码分析

TheadPoolExecutor源码分析

ThreadPoolExecutor是多线程中经常用到的类，其使用一个线程池执行提交的任务。

实现

没有特殊需求的情况下，通常都是用Executors类的静态方法如 …

• 笔记

Kafka Java生产者模型

Producer初始化

初始化KafkaProducer实例，同时通过Config数据初始化MetaData、NetWorkClient、Accumulator和Sender线程。启动Sender线程。

MetaData信息

记录 …

• 笔记

Redis清理缓存

最近有个需求需要主动的去清理部分缓存，考虑的原子性的问题，用Lua脚本进行实现。

Lua脚本

local count = 0
for _,k in ipairs(redis.call('KEYS', ARGV[1])) …

• 笔记

探索Rabbitmq的Java客户端

AMQPConnection

实例初始化

创建Connection时会通过FrameHandlerFacotry创建一个SocketFrameHandler，SocketFrameHandler对Socket进行了封装。

public …

• 笔记

深入剖析 HashSet 和 HashMap 实现

HashSet是一个包含非重复元素的集合，如何实现的，要从底层实现代码看起。

背景

首先非重复元素如何定义，看Set的描述：

More formally, sets contain no pair of elements e1 and …

• 笔记

多线程下的单例模式+反汇编

多线程下的单例模式的实现，顺便做了反汇编。

public class MySingleton {
    private static MySingleton INSTANCE;

    private MySingleton() { …

• 笔记

使用Kryo替换spring Amqp的Java序列化

spring amqp的原生并没有对Kryo加以支持，Kryo的优点就不多说了。

git地址：https://github.com/addozhang/spring-kryo-messaeg-converter

public class …

• 笔记

Rabbitmq延迟队列实现

• 笔记

关于SLF4J

Spring的功能越来越强大，同时也越来越臃肿。比如想快速搭建一个基于Spring的项目，解决依赖问题非常耗时。Spring的项目模板的出现就解决了这个问题，通过这个描述文件，可以快速的找到你所需要的模板。

第一次认识SLF4J就是在这些项 …