shishengliang/lingniu-vehicle-ingest
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

docs: align readme with redis session runtime

Browse Source
This commit is contained in:
lingniu
2026-07-01 09:00:10 +08:00
parent 7c51c83220
commit a321b6351d
2 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
README.md
View File

@@ -21,7 +21,7 @@
| 消息队列 | **Kafka**（vin 分区，保证单车有序） | | 消息队列 | **Kafka**（vin 分区，保证单车有序） |
| 线上消息格式 | **Protobuf**，调试走 JSON | | 线上消息格式 | **Protobuf**，调试走 JSON |
| MQTT 客户端 | Eclipse Paho 1.2.5 | | MQTT 客户端 | Eclipse Paho 1.2.5 |
| 会话缓存 | Redis 生产索引 + Caffeine 内存降级 | | 会话索引 | Redis |
| 熔断/限流 | Resilience4j 2 | | 熔断/限流 | Resilience4j 2 |
| 可观测 | Micrometer + Prometheus + OpenTelemetry | | 可观测 | Micrometer + Prometheus + OpenTelemetry |
| 冷存 | S3 / OSS / 本地 | | 冷存 | S3 / OSS / 本地 |
@@ -36,7 +36,7 @@ lingniu-vehicle-ingest/
│ │ ├── ingest-api/ SPI + sealed 领域事件 + 注解 │ │ ├── ingest-api/ SPI + sealed 领域事件 + 注解
│ │ ├── ingest-codec-common/ 公共编解码工具（BCD/CRC/BCC/bit utils） │ │ ├── ingest-codec-common/ 公共编解码工具（BCD/CRC/BCC/bit utils）
│ │ ├── ingest-core/ Pipeline / Dispatcher / Disruptor / Session 桥 │ │ ├── ingest-core/ Pipeline / Dispatcher / Disruptor / Session 桥
│ │ ├── session-core/ 设备会话 + 鉴权 + Token + Redis/Memory SessionStore │ │ ├── session-core/ 设备会话 + 鉴权 + Token + Redis SessionStore
│ │ ├── vehicle-identity/ 跨协议车辆身份解析 + MySQL 外部标识绑定 │ │ ├── vehicle-identity/ 跨协议车辆身份解析 + MySQL 外部标识绑定
│ │ └── observability/ metrics / tracing / health │ │ └── observability/ metrics / tracing / health
│ ├── protocols/ │ ├── protocols/
@@ -52,7 +52,7 @@ lingniu-vehicle-ingest/
│ │ ├── sink-archive/ 原始报文冷存 │ │ ├── sink-archive/ 原始报文冷存
│ │ └── event-file-store/ 可选兼容索引（旧 Parquet/DuckDB 路径，仅 -Poptional-event-file-store 显式构建） │ │ └── event-file-store/ 可选兼容索引（旧 Parquet/DuckDB 路径，仅 -Poptional-event-file-store 显式构建）
│ ├── services/ │ ├── services/
│ │ ├── event-history-service/ Kafka 全字段事件消费 + 历史查询/导出 │ │ ├── event-history-service/ Kafka 全字段事件消费 + 历史查询
│ │ ├── vehicle-state-service/ Kafka 全字段事件消费 + Redis 热状态查询（optional-latest-state profile） │ │ ├── vehicle-state-service/ Kafka 全字段事件消费 + Redis 热状态查询（optional-latest-state profile）
│ │ └── vehicle-stat-service/ Kafka 全字段事件消费 + 可配置日统计 │ │ └── vehicle-stat-service/ Kafka 全字段事件消费 + 可配置日统计
│ └── apps/ │ └── apps/

3
modules/apps/vehicle-history-app/src/test/java/com/lingniu/ingest/historyapp/MavenModuleProfileTest.java
View File

@@ -112,6 +112,7 @@ class MavenModuleProfileTest {
.contains("Spring Boot " + projectProperty(pom, "spring-boot.version")) .contains("Spring Boot " + projectProperty(pom, "spring-boot.version"))
.contains("Netty " + projectProperty(pom, "netty.version")) .contains("Netty " + projectProperty(pom, "netty.version"))
.contains("Eclipse Paho " + projectProperty(pom, "paho-mqtt.version")) .contains("Eclipse Paho " + projectProperty(pom, "paho-mqtt.version"))
.contains("session-core/ 设备会话 + 鉴权 + Token + Redis SessionStore")
.contains("protocol-jsatl12/ 苏标主动安全报警附件（optional-attachments profile）") .contains("protocol-jsatl12/ 苏标主动安全报警附件（optional-attachments profile）")
.contains("event-file-store/ 可选兼容索引（旧 Parquet/DuckDB 路径，仅 -Poptional-event-file-store 显式构建）") .contains("event-file-store/ 可选兼容索引（旧 Parquet/DuckDB 路径，仅 -Poptional-event-file-store 显式构建）")
.contains("vehicle-state-service/ Kafka 全字段事件消费 + Redis 热状态查询（optional-latest-state profile）") .contains("vehicle-state-service/ Kafka 全字段事件消费 + Redis 热状态查询（optional-latest-state profile）")
@@ -120,6 +121,8 @@ class MavenModuleProfileTest {
.doesNotContain("Spring Boot 3.4") .doesNotContain("Spring Boot 3.4")
.doesNotContain("Netty 4.1") .doesNotContain("Netty 4.1")
.doesNotContain("HiveMQ MQTT Client") .doesNotContain("HiveMQ MQTT Client")
.doesNotContain("Caffeine 内存降级")
.doesNotContain("Redis/Memory SessionStore")
.doesNotContain("Parquet + DuckDB 文件型明细库") .doesNotContain("Parquet + DuckDB 文件型明细库")
.doesNotContain("车辆状态/日统计消费"); .doesNotContain("车辆状态/日统计消费");
} }