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

docs: state kafka-only production channel

Browse Source
This commit is contained in:
lingniu
2026-07-01 12:37:17 +08:00
parent fd76bfdf61
commit afed6cd4f3
2 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
README.md
View File

@@ -99,7 +99,7 @@ Redis 最新状态查询不在默认 Maven reactor 中；需要时使用 `-Popti
## 核心原则 ## 核心原则
1. **接入与业务落库分离**：协议接入应用只负责收、解析、校验、规整和投递 Kafka；`vehicle-history-app` 写入 TDengine 历史与 RAW JSON，`vehicle-analytics-app` 将 JT808 `daily_mileage_km` 写入 MySQL `vehicle_stat_metric` 1. **接入与业务落库分离**：协议接入应用只负责收、解析、校验、规整和投递 Kafka；`vehicle-history-app` 写入 TDengine 历史与 RAW JSON，`vehicle-analytics-app` 将 JT808 `daily_mileage_km` 写入 MySQL `vehicle_stat_metric`
2. **Kafka 唯一消息通道**：生产链路不提供 RabbitMQ、RocketMQ 或其他 MQ 后端；接入、历史、统计统一通过 Kafka Envelope 解耦 2. **Kafka 唯一消息通道**：生产链路只支持 Kafka；接入、历史、统计统一通过 Kafka Envelope 解耦
3. **协议即插拔**：每个 `protocol-*` / `inbound-*` 都可独立开关（`lingniu.ingest.<name>.enabled`） 3. **协议即插拔**：每个 `protocol-*` / `inbound-*` 都可独立开关（`lingniu.ingest.<name>.enabled`）
4. **顺序保证**：同一 VIN 严格有序（Disruptor hash + Kafka 分区 key） 4. **顺序保证**：同一 VIN 严格有序（Disruptor hash + Kafka 分区 key）
5. **幂等消费**：Envelope 带 `eventId`，下游去重 5. **幂等消费**：Envelope 带 `eventId`，下游去重

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

@@ -178,12 +178,15 @@ class MavenModuleProfileTest {
.contains("vehicle-history-app/ TDengine 历史查询 + RAW JSON") .contains("vehicle-history-app/ TDengine 历史查询 + RAW JSON")
.contains("vehicle-analytics-app/ JT808 每日里程指标消费") .contains("vehicle-analytics-app/ JT808 每日里程指标消费")
.contains("协议接入应用只负责收、解析、校验、规整和投递 Kafka") .contains("协议接入应用只负责收、解析、校验、规整和投递 Kafka")
.contains("生产链路不提供 RabbitMQ、RocketMQ 或其他 MQ 后端") .contains("生产链路只支持 Kafka")
.contains("`vehicle-analytics-app` 将 JT808 `daily_mileage_km` 写入 MySQL `vehicle_stat_metric`") .contains("`vehicle-analytics-app` 将 JT808 `daily_mileage_km` 写入 MySQL `vehicle_stat_metric`")
.contains("mvn -pl :gb32960-ingest-app,:jt808-ingest-app,:yutong-mqtt-app,:vehicle-history-app,:vehicle-analytics-app -am package -Dmaven.test.skip=true") .contains("mvn -pl :gb32960-ingest-app,:jt808-ingest-app,:yutong-mqtt-app,:vehicle-history-app,:vehicle-analytics-app -am package -Dmaven.test.skip=true")
.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("RabbitMQ")
.doesNotContain("RocketMQ")
.doesNotContain("其他 MQ 后端")
.doesNotContain("mvn clean install -DskipTests") .doesNotContain("mvn clean install -DskipTests")
.doesNotContain("-DskipTests") .doesNotContain("-DskipTests")
.doesNotContain("Caffeine 内存降级") .doesNotContain("Caffeine 内存降级")