J Micro Business
jmicro 的业务能力聚合模块,用于承载通用的业务侧自动配置与扩展能力。当前内置了系统配置(JMicroConfig)、对 Flyway 的轻量级扩展,以及可选的 OpenID Connect 服务器(Cas)能力。
目录
模块特性
- 继承 Spring Boot 默认自动配置体系,通过
META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports注册。 - 内置 系统配置(JMicroConfig)能力(可选,默认关闭,见下文),提供以键值对方式管理、持久化与动态刷新系统运行配置的能力,支持默认值加载、类型化表单(TEXT/SWITCH/SELECT 等)、配置变更事件与基于 Caffeine 的缓存。
- 内置 Flyway 扩展(可选依赖,见下文),在校验失败时提供可选的自动清理能力,适合开发、测试环境的快速重建。
- 内置 OpenID Connect 服务器(Cas)能力(可选,默认关闭,见下文),提供 JWKS、Well-known 配置与授权/令牌端点,复用
micro-auth的 OIDC 基础能力(com.jiangtj.micro.auth.oidc)。 - 内置 图片上传能力(合并自原
micro-pic-upload-starter,见下文),位于包com.jiangtj.micro.business.pic,提供本地 / 阿里云 OSS / 华为云 OBS / MinIO / EasyImages 2.0 / RustFS 等多种上传方式,各服务商配置统一由系统配置(JMicroConfig)提供。
使用方法
添加依赖
<dependency>
<groupId>com.jiangtj.micro</groupId>
<artifactId>micro-business</artifactId>
</dependency>
建议配合
micro-dependenciesBOM 使用,省略版本号(见根 README)。
系统配置 JMicroConfig(可选)
系统配置能力位于包 com.jiangtj.micro.business.config,默认不开启,需显式配置 jmicro.config.enabled=true 才生效。它通过 JMicroConfigService 集中管理配置项,支持从 JMicroConfigLoader 加载默认值、通过 JMicroConfigSaver 持久化覆盖值,并在变更时发布 JMicroConfigUpdateEvent / JMicroConfigRefreshEvent 事件。
默认实现提供了 InMemoryJMicroConfigSaver(基于 ConcurrentHashMap 的内存存储),并通过 @ConditionalOnMissingBean 注册,使用者可自定义 JMicroConfigSaver Bean 接入数据库等持久化方案。
配置属性
# 开启系统配置能力(默认 false)
jmicro.config.enabled=true
# 配置文件路径(默认 upload)
jmicro.config.file-path=upload
# 覆盖默认配置值的键值对
jmicro.config.kv.site-name=JMicro
jmicro.config.kv.max-upload-size=10MB
jmicro:
system:
config:
enabled: true
file-path: upload
kv:
site-name: JMicro
max-upload-size: 10MB
工作机制
- 启动时
JMicroConfigService收集所有JMicroConfigLoader提供的SystemItemInfo作为默认配置,再应用jmicro.config.kv中的覆盖值。 - 取值:
getValue(key)/isTrue(key)优先读取JMicroConfigSaver中的覆盖值,未命中则回退到默认值;结果经 Caffeine 缓存加速,可通过refreshConfig()主动失效缓存。 - 写值:
updateConfig(key, value)会做值格式校验(valueFormatter),保存到JMicroConfigSaver并发布JMicroConfigUpdateEvent;deleteConfig(key)删除覆盖值并回退默认值,同时发布事件。 getAllConfig()返回排序后的配置视图(按分组group.order与order),并对secret=true的项做脱敏(******),对带formatter的项生成formatedValue。- bcrypt 支持(通过 formatter 实现):使用
BCryptUtils.encodeFormatter写入明文时若非 bcrypt 哈希则哈希后持久化,已是哈希则透传,避免二次哈希。读取校验明文可用BCryptUtils.matches(raw, stored)。(BCryptUtils位于micro-auth,包com.jiangtj.micro.auth) getConfigByTag(tag)可按标签筛选配置项。
结构化配置(JSON 类型)
SystemItemType.JSON 用于表达对象、集合、Map 等嵌套结构。持久化仍是单个 key -> String,值为 JSON 文本;写入时会校验并规范化成紧凑单行,因此可以直接写在 jmicro.config.kv.* 中。
class MyConfigLoader : JMicroConfigLoader {
override fun load() = listOf(
SystemItemInfo(
key = "my.site.dirs",
name = "目录映射",
type = SystemItemType.JSON.name,
value = """{"a":{"path":"/a"}}""",
// 声明目标类型:写入校验 + 生成前端 schema
jsonType = JsonUtils.jsonMapper.typeFactory
.constructMapType(LinkedHashMap::class.java, String::class.java, Dir::class.java),
// 可选:只脱敏 JSON 内的指定字段
secretPaths = listOf("a.accessKey"),
)
)
}
读取:
| 方法 | 说明 |
|---|---|
getObject(key, Class) |
反序列化为单个对象 |
getList(key, Class) |
反序列化为集合 |
getMap(key, Class) |
反序列化为 Map<String, V> |
getJson(key) |
返回 JSON 树,供接口层直接透传 |
getConfigField(key, "a.b") |
按路径读取子字段,支持 a.b 与 JSON Pointer /a/b |
写入(字段级,底层是读取-修改-写回整项;多实例部署需由 JMicroConfigSaver 提供版本号/锁来避免并发覆盖):
| 方法 | 说明 |
|---|---|
updateConfigField(key, path, value) |
更新任意路径字段 |
updateMapEntry / removeMapEntry |
维护 Map 结构 |
addListElement / updateListElement / removeListElement |
维护数组结构 |
- 写入时会用
jsonType校验值能否反序列化为目标类型,不合法抛MicroConfigException。 getAllConfig()会通过JsonSchemaGenerator为jsonType生成schema(Map生成additionalProperties、集合生成items),前端可据此渲染表单或 key-value/数组编辑器。secretPaths非空时按路径把值替换为******(此时不再整体脱敏);写入时值为******的字段会用旧值回填,避免把掩码写进持久化存储。
扩展指南
- 实现
JMicroConfigLoader并注册为 Bean,可在启动时贡献一组默认配置项(含名称、分组、类型、表单渲染信息等)。 - 实现
JMicroConfigSaver并注册为 Bean(覆盖默认的内存实现),可将覆盖值持久化到数据库、配置中心等。 - 监听
JMicroConfigUpdateEvent/JMicroConfigRefreshEvent可感知配置变化并做相应处理。
Flyway 扩展(可选)
Flyway 相关依赖在 micro-business 中是可选(optional)的,模块本身不会强制传递 Flyway。若要启用 Flyway 扩展,需在使用方自行引入 Flyway 依赖:
<dependency>
<groupId>com.jiangtj.micro</groupId>
<artifactId>micro-business</artifactId>
</dependency>
<!-- 可选能力:需自行引入 Flyway -->
<dependency>
<groupId>org.flywaydb</groupId>
<artifactId>flyway-core</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-flyway</artifactId>
</dependency>
未引入 Flyway 时,MicroFlywayAutoConfiguration 因 @ConditionalOnClass(Flyway.class) 不会生效,模块可正常用于无 Flyway 的场景。
配置属性
# 是否在校验失败后自动清理并重新迁移
jmicro.flyway.clean-on-validation-error=true
micro:
flyway:
clean-on-validation-error: true
clean-on-validation-error 默认为 false。建议仅在开发或测试环境启用该能力,避免误删生产数据。
工作机制
当 Flyway 在执行 migrate 时发生 FlywayValidateException:
clean-on-validation-error=false:直接抛出异常,行为与 Spring Boot 默认一致。clean-on-validation-error=true:自动执行clean后重新migrate。
如果你需要完全关闭 Flyway,可继续使用 Spring Boot 的配置:
spring.flyway.enabled=false
OpenID Connect 服务器(可选,默认关闭)
OIDC 服务器能力位于包 com.jiangtj.micro.business.cas,默认不开启,需显式配置 jmicro.oidc.server.enabled=true 才生效。它依赖 micro-auth 提供的 OIDC 基础能力(com.jiangtj.micro.auth.oidc)与 JJWT 运行时,并通过 OidcKeyService 实现 jjwt 的 Locator<Key> 接口与 micro-auth 解耦。
该能力当前提供 Servlet 自动配置入口(OidcServerServletAutoConfiguration,基于 Spring MVC 的 RouterFunction),并通过 @ConditionalOnWebApplication(type = SERVLET) 限定;仅当 jmicro.oidc.server.enabled=true 且为 Servlet Web 应用类型时注册。
添加依赖
<dependency>
<groupId>com.jiangtj.micro</groupId>
<artifactId>micro-business</artifactId>
</dependency>
<!-- OIDC 服务器依赖的 OIDC 基础能力(由 micro-business 传递) -->
<dependency>
<groupId>com.jiangtj.micro</groupId>
<artifactId>micro-auth</artifactId>
</dependency>
配置属性
# 开启 OpenID Connect 服务器(默认 false)
jmicro.oidc.server.enabled=true
# 基础 URL(用于 Well-known 中的 issuer 等)
jmicro.oidc.server.base-url=http://localhost:17001
# KID 前缀(可选,默认不添加)
jmicro.oidc.server.kid-prefix=
# Well-known 配置端点(默认 /oidc/.well-known/openid-configuration)
jmicro.oidc.server.well-known=/oidc/.well-known/openid-configuration
# 是否展示 Well-known 配置端点(默认 true)
jmicro.oidc.server.show-well-known=true
# JWKS URI 端点(默认 /oidc/jwks)
jmicro.oidc.server.jwks-uri=/oidc/jwks
# 授权端点(默认 /oidc/auth)
jmicro.oidc.server.authorization-endpoint=/oidc/auth
# 令牌端点(默认 /oidc/token)
jmicro.oidc.server.token-endpoint=/oidc/token
# 客户端配置列表
jmicro.oidc.server.clients[0].client-id=client1
jmicro.oidc.server.clients[0].client-secret=secret1
jmicro.oidc.server.clients[0].callback-uri[0]=http://localhost:17001/callback
对应配置类:OidcServerProperties(jmicro.oidc.server.*)与 OidcServerClientProperties(客户端条目)。
工作机制
OidcServerAutoConfiguration:在enabled=true时注册OidcKeyService(启动时生成/刷新密钥),并实现 jjwtLocator<Key>,供micro-auth的OidcLocator通过类型查找复用。OidcServerServletAutoConfiguration(Servlet):注册OidcEndpointService与其RouterFunction,对外暴露 Well-known、JWKS、授权、令牌端点;并提供OidcRedirectAuth钩子(默认TODO,需使用者自定义userInfo()实现以返回当前用户信息)。- 密钥使用 ES384(EC P-384) 算法生成,JWKS 与 ID Token 均基于该密钥;KID 在启动时生成(可由
kid-prefix添加前缀区分实例)。 - 授权端点仅支持 授权码模式(authorization_code),并支持 PKCE(S256) 或 client_secret 两种客户端校验方式;令牌端点校验授权码、
code_verifier或client_secret,校验通过后签发带 KID 的 ES384 ID Token(同时作为 access_token),有效期 24 小时,授权码使用 Caffeine 缓存 15 分钟过期。 - 未开启或依赖缺失时,相关自动配置因条件注解不生效,模块可正常用于无 OIDC 服务器的场景。
扩展指南
OidcRedirectAuth默认实现为TODO,实际接入时需提供自定义 Bean 实现userInfo(),返回授权成功后注入令牌的用户声明。- 密钥与 KID 由
OidcKeyService在启动时刷新,可通过kid-prefix区分多实例。
图片上传(合并自 micro-pic-upload-starter)
图片上传能力的包为 com.jiangtj.micro.business.pic,提供简单易用的图片上传服务,配置好参数即可将图片转换为可访问 URL。各服务商依赖为可选(compileOnly),使用时需自行引入对应 SDK;本地上传无需额外依赖。
功能特性
- 支持多种图片格式(jpg、jpeg、png、gif、webp)
- 自动生成随机文件名
- 可配置上传路径与目录映射
- 使用官方 SDK,安全可靠
目前支持以下服务商上传图片:
- 本地上传
- 阿里云 OSS
- 华为云 OBS
- MinIO (aka S3)
- EasyImages 2.0
- RustFS (aka S3)
通用配置
图片上传只有一个启动配置 jmicro.pic.upload.enable(默认 true),用于开关上传能力;其余配置统一由系统配置项提供,使用前需开启 jmicro.config.enabled=true:
jmicro.config.enabled=true
# 关闭图片上传能力(默认 true)
jmicro.pic.upload.enable=true
通用配置项(由 PicUploadConfigLoader 在启动时注册):
| 配置项 | 类型 | 默认值 | 说明 |
|---|---|---|---|
jmicro.pic.upload.provider |
文本 | local |
默认上传服务商,可选:local, ali, hw, minio, easyimages, rustfs |
jmicro.pic.upload.allowed-extensions |
文本 | jpg,jpeg,png,gif,webp,bmp,svg,avif |
默认允许的文件类型,逗号分隔 |
jmicro.pic.upload.max-file-size |
文本 | 10MB |
默认最大文件大小,支持 10MB、1KB 或字节数 |
jmicro.pic.upload.dirs |
JSON |
{} |
目录映射 Map<String, Dir>,其中 path 必填 |
jmicro.config.kv.jmicro.pic.upload.provider=minio
jmicro.config.kv.jmicro.pic.upload.max-file-size=5MB
jmicro.config.kv.jmicro.pic.upload.dirs={"target-name":{"path":"/common","provider":"ali","maxFileSize":"10MB"}}
// 运行期修改(立即生效,无需重启)
jmicroConfigService.updateConfig("jmicro.pic.upload.provider", "local")
jmicroConfigService.updateMapEntry("jmicro.pic.upload.dirs", "avatar", mapOf("path" to "/avatar"))
各服务商(local / ali / hw / minio / easyimages / rustfs)的配置项统一由系统配置(JMicroConfig)提供,使用前需开启 jmicro.config.enabled=true;未开启时对应服务商的上传服务不会注册。配置项定义在各自的 *ConfigItem 枚举中(jmicroConfigService.getValue(key) 读取),可通过 jmicro.config.kv.* 提供值,也可在运行期通过 JMicroConfigService.updateConfig(key, value) 动态修改(上传时实时读取)。各服务商并可能需要引入对应 SDK:
| Provider | 配置来源 | 说明 |
|---|---|---|
local |
系统配置项 jmicro.pic.upload.local.* |
本地磁盘上传,无需额外 SDK |
ali |
系统配置项 ali.oss.* |
阿里云 OSS |
hw |
系统配置项 hw.obs.* |
华为云 OBS |
minio |
系统配置项 minio.* |
兼容 S3 的 MinIO |
easyimages |
系统配置项 easyimages.api.* |
EasyImages 2.0(纯 HTTP API,无需 SDK) |
rustfs |
系统配置项 jmicro.rustfs.* |
兼容 S3 的 RustFS(需 jmicro.rustfs.enable=true) |
各服务商配置
MinIO
<dependency>
<groupId>io.minio</groupId>
<artifactId>minio</artifactId>
<version>8.5.17</version>
</dependency>
jmicro.config.enabled=true
jmicro.config.kv.minio.endpoint=http://localhost:9000
jmicro.config.kv.minio.access-key=access-key
jmicro.config.kv.minio.secret-key=secret-key
jmicro.config.kv.minio.bucket=bucket
# 是否允许匿名读取(默认 false)
jmicro.config.kv.minio.is-allow-get-object=false
Ali OSS
<dependency>
<groupId>com.aliyun.oss</groupId>
<artifactId>aliyun-sdk-oss</artifactId>
<version>3.18.1</version>
</dependency>
阿里云 OSS 的配置项由系统配置(JMicroConfig)提供,需先开启 jmicro.config.enabled=true;未开启时不会注册 ali 上传服务。配置项定义见 AliOSSConfigItem,可通过配置文件 kv 提供默认值,也可在运行期通过 JMicroConfigService.updateConfig(key, value) 动态修改(每次上传时读取最新配置):
# 开启系统配置(阿里云 OSS 配置项的载体)
jmicro.config.enabled=true
jmicro.config.kv.ali.oss.endpoint=https://oss-cn-hangzhou.aliyuncs.com
jmicro.config.kv.ali.oss.region=cn-hangzhou
jmicro.config.kv.ali.oss.bucket-name=bucket-name
jmicro.config.kv.ali.oss.url=https://bucket-name.oss-cn-hangzhou.aliyuncs.com
# 你需要配置密钥,也可以从系统环境中读取(不配置时使用 SDK 的默认环境变量凭证)
#jmicro.config.kv.ali.oss.access-key-id=access-key-id
#jmicro.config.kv.ali.oss.secret-access-key=secret-access-key
Huawei OBS
<dependency>
<groupId>com.huaweicloud</groupId>
<artifactId>esdk-obs-java-bundle</artifactId>
<version>3.23.9.1</version>
</dependency>
jmicro.config.enabled=true
jmicro.config.kv.hw.obs.end-point=https://obs.cn-north-1.myhuaweicloud.com
jmicro.config.kv.hw.obs.bucket-name=bucket-name
jmicro.config.kv.hw.obs.key=key
jmicro.config.kv.hw.obs.secret=secret
EasyImages 2.0
jmicro.config.enabled=true
jmicro.config.kv.easyimages.api.url=http://localhost:40061/api/index.php
jmicro.config.kv.easyimages.api.token=token
RustFS
<dependency>
<groupId>software.amazon.awssdk</groupId>
<artifactId>s3</artifactId>
<version>2.42.41</version>
</dependency>
jmicro.config.enabled=true
# 开启 RustFS 上传能力(默认 false)
jmicro.config.kv.jmicro.rustfs.enable=true
jmicro.config.kv.jmicro.rustfs.endpoint=http://localhost:9000
jmicro.config.kv.jmicro.rustfs.access-key=access-key
jmicro.config.kv.jmicro.rustfs.secret-key=secret-key
jmicro.config.kv.jmicro.rustfs.bucket=bucket
jmicro.config.kv.jmicro.rustfs.is-allow-get-object=false
本地上传(local)
无需引入额外 SDK,配置 provider=local 并指定目录路径与访问 URL 即可:
jmicro.config.enabled=true
jmicro.config.kv.jmicro.pic.upload.provider=local
# 本地存储根路径(系统配置项默认值为系统临时目录)
jmicro.config.kv.jmicro.pic.upload.local.upload-path=/data/uploads
# 上传文件的可访问 URL 前缀(由你的静态资源映射暴露)
jmicro.config.kv.jmicro.pic.upload.local.url=/files
# 目录映射(系统配置项 jmicro.pic.upload.dirs 的 JSON 配置)
jmicro.config.kv.jmicro.pic.upload.dirs={"target-name":{"path":"/uploads"}}
在代码中使用
@RestController
@RequestMapping("/api/upload")
public class UploadController {
private final PicUploadService picUploadService;
public UploadController(PicUploadService picUploadService) {
this.picUploadService = picUploadService;
}
@PostMapping("/image")
public PicUploadResult uploadImage(@RequestParam("target") String target, @RequestParam("file") MultipartFile file) throws IOException {
return picUploadService.upload(target, file);
}
}
返回结果
上传成功后返回的 PicUploadResult 对象包含以下信息:
originalFileName:原始文件名fileName:新文件名fileUrl:文件访问路径thumbnailUrl:缩略图路径(如果存在)
扩展指南
新增业务能力时,请在 com.jiangtj.micro.business 下建立子包,遵循项目约定:
- 包级
package-info.java标注@NullMarked - 通过
@AutoConfiguration暴露自动配置,并在META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports中注册 - 可选能力使用
compileOnly+runtimeOnly声明依赖,避免强制传递给使用者 - 当前已注册能力的子包:
flyway:Flyway 自动清理扩展(MicroFlywayAutoConfiguration)config:系统配置能力(JMicroConfigAutoConfiguration)cas:OpenID Connect 服务器能力(OidcServerAutoConfiguration、OidcServerServletAutoConfiguration)pic:图片上传能力(PicUploadAutoConfiguration及ali/hw/minio/easyimages/local子包)