# task

**Repository Path**: haoshijing/task

## Basic Information

- **Project Name**: task
- **Description**: No description available
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: main
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2026-03-08
- **Last Updated**: 2026-03-08

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# Delay Task Platform (Maven Multi-Module)

## 模块说明

- `delay-task-api`: 对外 SDK API + 管理 API
- `delay-task-scheduler`: 两层调度（DB 预加载 + Redis 到期派发）
- `delay-task-executor`: 消费触发消息并回调业务，失败重试
- `delay-task-core`: 领域模型、DTO、重试策略
- `delay-task-infra`: MySQL/Redis/Kafka 基础设施实现

## 快速启动

1. 启动依赖：MySQL、Redis、Kafka
2. 执行建表脚本：`sql/schema.sql`
3. 修改三个服务的 `application.yml` 数据源配置
4. 打包：

```bash
mvn clean package -DskipTests
```

5. 分别启动：

```bash
java -jar delay-task-api/target/delay-task-api-1.0.0-SNAPSHOT.jar
java -jar delay-task-scheduler/target/delay-task-scheduler-1.0.0-SNAPSHOT.jar
java -jar delay-task-executor/target/delay-task-executor-1.0.0-SNAPSHOT.jar
```

## 关键接口

- `POST /api/v1/tasks` 提交任务
- `POST /api/v1/tasks/{taskId}/cancel` 取消任务
- `GET /api/v1/tasks/{taskId}` 查询任务
- `POST /admin/v1/tasks/{taskId}/retry-now` 管理台手动重触发

## 说明

这是一个可运行的 MVP 骨架，适合继续扩展：
- 分库分表（ShardingSphere）
- 完整 attempt 记录持久化
- 签名验签与多租户鉴权
- 监控告警（Prometheus/Grafana）