mercyblitz/java-training-camp

Java Training Camp

Hi there 👋

I’m Mercy Ma(aka "小马哥（mercyblitz）"), an achitecture of Spring Cloud Alibaba, as a member in Apache Dubbo PMC, and working on Open Source projects, Micro-Services infrastructure and Cloud-Native, certificated SUN Java（SCJP、SCWCD、SCBCD）, Oracle OCA and so on.

• 📧 Email: [email protected]
• 😄 Wechat: mercyblitz-1985
• 🏠 Home Page: https://mercyblitz.github.io/

📚 My Books

📼 My Lessons

🗺️ My Open-Sources

🎤 My Presentations

👨‍🏫 My Trainings

java-training-camp's Issues

作业十：动态地替换 Java System Propeties

要求

在 Spring Boot 工程中，动态地替换 Java System Propeties ，避免并发锁阻塞等问题

提示

在 Spring Boot org.springframework.boot.context.event.ApplicationEnvironmentPreparedEvent 阶段替换 Java System Propeties PropertySource，其中它的 name 为 ：org.springframework.core.env.StandardEnvironment#SYSTEM_PROPERTIES_PROPERTY_SOURCE_NAME

第二期 作业九：基于 Redisson 实现分布式服务容错

要求

1. （必须）实现 BulkHead
2. （可选）实现 RateLimiter

提示

1. 利用 RedissonSemaphore 实现
2. 参考 Redisson RateLimiter 实现

第二期 作业二：分析 Zookeeper 设置数据操作(SetData) 的处理流程

内容

1. （必须）使用文字、代码或图形的方式分析 Zookeeper Client SetData 操作的处理流程
2. （可选）使用文字、代码或图形的方式分析 Zookeeper Server SetData 操作的处理流程

提示：参考 FinalRequestProcessor

第四期 作业五：基于MySQL Replication Connection 实现通用同区域优先以及 Zone 多活架构

要求：

• 参考 ReplicationConnectionProxy 实现，结合 Availability Zones Locator API 实现

作业十一：扩展 Spring Initializr 能够生成多模块 Maven

要求

1. 生成标准模块：api、data、core 和 web
2. 生成根项目的 pom.xml
3. (可选）生成 api 等模块各自的 pom.xml 文件
4. （可选）生成 Java 代码到 web 模块中

第三期 作业二：搭建 MySQL Group Replication 集群

要求

1. 基于 MySQL Group Replication 搭建三台 MySQL 服务器
2. (可选）可以基于 Docker 或者传统的 MySQL 搭建

提示

1. 参考官方 Blog Setting up MySQL Group Replication with MySQL Docker images

第二期 作业四：理解并完成 Spring 事务传播机制与 EJB 规范的联系

要求

1. （必须）阅读 EJB 2.1 规范章节《17.6.2 Container-Managed Transaction Demarcation for Session and Entity Beans》，并且文档描述 Spring 事务传播行为：

• Mandatory
• Never

2. （必须）找到对应的 Spring 实现源码，并且说明规范与代码之间的联系。

3. （可选）补充 NOT_SUPPORTED、REQUIRED 和 REQUIRED_NEW 的内容。

提示：参考 spring-tx AbstractPlatformTransactionManager

第三期 作业九：完成 ELK Cluster + Spring Boot 应用日志 + Kafka

要求

1. （必须）ELK Cluster （案例）

2. (可选）完成 ELK Cluster + Spring Boot 应用日志 + Kafka

第四期 作业二：回顾 Spring Cloud Commons 服务注册与发现通用逻辑

要求
1.（可选）@EnableDiscoveyClient 实现，了解它与 AutoRegistrationConfiguration 之间的关系

2.（可选）掌握 Registration 与 ServiceInstance 以及 ServiceRegistry 和 具体实现，如 Eureka、Consul 等。

第四期 作业四：基于 Spring 6.0+ HTTP Interface 实现通用同区域优先以及 Zone 多活架构

要求：

• Spring Cloud LoadBalancer 整合 Spring 6+ HTTP Interface（必须）
• Spring 6.0+ HTTP Interface 实现通用同区域优先以及 Zone 多活架构（可选）

第三期 作业四：部署 Apache Kafka 多实例集群

要求

1. 本地部署（物理机和虚拟机均可）

第三期 作业六：完成 Istio 官方示例 Bookinfo 本地部署

要求

1. （必须）参考Istio 官方示例 Bookinfo 本地部署（案例）

2. (可选）自学部分 Kubernetes 基础

第二期 作业七：配置验证

要求

实现客户端与服务端的配置版本控制，提供合法性校验等手段，确保客户端配置是合法有效的

提示

1. 配置服务器：简单的 REST 内存型数据（推荐使用 Spring Boot Web）

2. 配置结构设计

• 配置内容
• 配置元信息
  • 配置内容 MD5 加密 checksum
  • 配置时间(创建、修改）
  • 配置媒体类型（JSON、XML）

3. 客户端和服务器之间使用 REST 通讯（可使用 Spring RestTemplate）

• （必须）配置获取
• （可选）配置增加
• （可选）配置删除
• （可选）配置变更

参考嵌入式 Web 服务器： https://github.com/nacos-group/nacos-spring-project/blob/develop/nacos-spring-samples/nacos-embedded-webserver

第二期 作业一：使用 SOFAJRAFT 实现状态机

内容

1. （必须）补充官方 exmaple ElectionBootstrap 增加 Follower 节点日志信息，参考 Leader 事件实现
2. （可选）补充官方 exmaple counter 增加 CounterOperation 的操作符，比如 DECREMENT，实现 decrementAndGet 方法，类似于 Atomic 类

第三期 作业一：Eureka Server 支持 JGroup 广播复制（已注册服务实例）

要求

1. 基于 JGroup 广播当前 Eureka Server 已注册的服务实例到其他节点
   • 掌握 PeerAwareInstanceRegistry 注册等操作
   • 掌握 EurekaBootstrap 与 EurekaServerContext 的关系
2. （可选）Eureka Server 改造 Spring Boot 支持 Tomcat Tribes 模块

提示

1. 利用 Shopizer 工程 实现

第三期 作业七：完成 Apache Dubbo Mesh 官方示例

要求

1. （必须）参考 Apache Dubbo 官方示例（案例）

2. (可选）自学部分 Kubernetes 基础

作业六：Micrometer 整合 Redis Spring

要求

Redis Spring API 监控指标注册到 MeterRegistry

监控目标

ValueOpertions 中的 set 方法

监控指标

必须

● set 方法执行时间（Timer）：response time
● set 方法调用次数（Counter）：count

可选

● set 方法成功率（Guage）：success rate

参考实现

https://github.com/microsphere-projects/microsphere-spring-projects/tree/main/microsphere-spring/microsphere-spring-redis

提示

使用动态代理的方式拦截 Spring Redis RedisConnection 接口，因为该接口是所有的 Redis 命令的底层实现。

第三期 作业八：完成 etcd 集群本地部署

要求

1. （必须）参考 etcd 官方示例（案例）

2. (可选）基于 Docker Composite 实现 etcd 集群部署

作业八：基于 Byte Buddy 实现 Spring WebMVC Controller 拦截日志

要求

针对 com.acme.biz.api.interfaces.UserRegistrationService 接口实现类 - com.acme.biz.web.service.InMemoryUserRegistrationService，redefine registerUser 方法，增加日志功能，如某个 User 被注册

进阶实现

针对 com.acme.biz.web.mvc.controller.UserRegistrationController 来实现以上功能

第三期 作业五：完成 Spring Cloud Gateway 与 gRPC 整合

要求

1. （必须）参考官方 Blog，本次重新部署案例Spring Cloud Gateway and gRPC
   

2. (可选）将 Shopizer 项目 中的 shopizer-security-service 服务，能够被 api-gateway 通过 gRPC 调用

第四期 作业一：回顾第二期 JRAFT RPC 框架和第三期 Eureka Server Group 复制实现

要求

1.（可选）第二期 JRAFT RPC 框架（代码）

2.（可选）第三期 Eureka Server Group 复制实现（代码）

第二期 作业三：基于 Apache Curator 实现分布式配置管理

要求

1. (必须）基于 Apache Curator 对 Zookeeper 操作，以及对 Spring Environment（PropertySources）整合，实现分布式配置管理

2. （可选）基于 1 的基础上，实现在 Spring 场景下的配置变换监听。
   提示：基于 Spring ApplicationEvent 来实现，参考：https://github.com/nacos-group/nacos-spring-project/tree/develop/nacos-spring-context

3. （可选）基于 1 的基础上，实现配置元数据管理，如：增加配置媒体类型，Content-Type: text/properties、text/json，增加 Content-Length（流媒体）

第二期 作业五：理解并完成 ShardingSphere 5.x 对 JTA 事务支持

要求

1. （必须）ShardingSphere 5.x 是如何支持 JTA （分布式）事务

2. （可选）ShardingSphere 5.x 是如何整合 JTA 框架 Atomikos

提示：参考代码：https://github.com/apache/shardingsphere

作业一：Spring Cloud Open Feign 包装 POJO API 模型

要求

基于 Spring Cloud Open Feign 隐形包装 POJO 成为 API 模型，实现接口编程友好性目的。
最简化 @FeignClient 初始化

知识回顾

Java 动态代理

@FeignClient 工作原理

现状分析

UserRegistrationService 接口对应服务端 Endpoint：http://127.0.0.1:8080/user/register

@FeignClient("${user-registration.service.name}")
@RequestMapping("/user")
public interface UserRegistrationService {

    @PostMapping(value = "/register",produces = "application/json;v=3.0")
    Boolean registerUser(@RequestBody @Validated @Valid User user) throws UserException;

}

@FeignClient 指向的应用名称：${user-registration.service.name}

激活 FeignClient

@EnableFeignClients

提示

• 通过扩展 Encoder 和 Decoder 控制 POJO 的解析
• 通过调用请求头控制新老版本的切换

提交

可基于 https://github.com/mercyblitz/java-training-camp 项目二次开发，请在下方评论中提交自己的 GitHub代码仓库。

作业七：基于 Micrometer 搭建微服务监控平台

具体要求

1. 创建自定义的 Metrics

Metrics 名称（自由发挥）
必须 Tags：

• 应用
• 服务实例 ID
• 应用环境：TEST、STAGING、PROD

可选 Tags 自己决定

2. 将 Metrics 导出到 InfluxDB

搭建 InfluxDB 环境
创建 InfluxDB 数据库
通过 Spring Boot Influx Client 导出

3. 将 Grafana 添加 InfluxDB 数据源

4. 在 Grafana 展示自定义 Metrics

a. 熟悉 InfluxDB SQL 语法
b. 理解不同 Metrics 类型在图形化界面的展示
c. 导出模板 JSON 文件

5. 高阶：可选实现

替代 Spring Boot InfluxMetricsExportAutoConfiguration 实现，提供断点续传的能力的 InfluxDB 的推送，具体而言：

1. 将 Metrics 导出到以本地文件的 MeterRegistry 实现（类似于日志实现）
2. 独立 Metrics 上报进程
   1. 将本地文件 Metrics 数据同步到 InfluxDB（可参考独立进程）
   2. 实现调度任务，可记录上次成功提交的数据的偏移量（类似 Kafka Offset）

第四期 作业六：使用 Docker 本地搭建一套 Redis Cluster 集群

要求：

• 参考 Redis Cluster 官方文档，在本地搭建 N 个 Cluster 节点，能够正常工作

第三期 作业三：将 Shopizer 项目中的数据表 LANGUAGE 分表

要求

1. 基于 Apache ShardingSphere 对 LANGUAGE 分表
2. 基于 Shopizer 项目 mybatis-generator 模块来构建

提示

1. 关联 issue #13

第二期 作业六：RPC 框架新增分布式事务支持

要求

1. （必须）提供分布式事务扩展接口，整合分布式事务框架 - Seata

提示：Seata 对 Dubbo 支持，基于 Dubbo Filter 接口

第二期 作业八：学习 antlr4 并编写 MySQL DML 语句解析

要求

利用 antlr4 语法分析，解析 MySQL 数据库中的 DML 语句：

1. INSERT（必须）
2. UPDATE（可选）
3. DELETE（可选）

提示

该作业与一期内容呼应，JDBC 服务容错性和可观测性

作业九：Spring Cloud Gateway 稳定性设计

题目一：网关监控设计

要求：Spring Cloud Gateway 整合 Micrometer 实现指标监控

题目二：网关链路跟踪设计

要求：Spring Cloud Gateway 整合 Spring Cloud Sleuth 实现链路跟踪

提示：可基于 Spring WebFlux 实现通用化

第三期 作业十：完成 VictoriaMetrics 集群版本收集 Spring Boot 应用

要求

1.（必须）VictoriaMetrics 集群部署 （文档）

2.（可选）将 Prometheus 拉取 Spring Boot 应用 Metrics，再将底层存储到 VictoriaMetrics

3.（可选）VictoriaMetrics 整合 Grafana

第四期 作业三：本地部署 K8s 服务 MongoDB

要求

1. 参考课件中的案例，在本地部署一次，达到理解 K8s 运维和操作方法。