方便可靠的异步任务处理系统
利用UTask业务方将不需要实现一套队列 + 脚本的架构, 直接实现http接口, 即可完成异步任务的执行, 跟踪和监控
可以广泛应用于各种异步任务的场景, 如:
- 游戏平台支付成功后通知游戏发货
- 定时通知游戏开启或者关闭一个活动
- 电商平台中下单后15分钟未付款时关闭订单
PPT: UTask.pdf
- 异步调用HTTP接口
- 延迟调用
- 定时调用
- 异常重试机制
- 日志查询和监控
- 分布式部署
- 服务接入SDK
TaskerRPC任务类型TaskerPHP函数任务类型TaskStorerKafka实现SdkPHP接入SDK
git clone https://github.com/meixiu/utask配置文件在config目录下, 参考注释进行基本的参数配置
config/local.yaml: 本地开发环境config/dev.yaml: dev开发环境
go run utask.go -c=config/dev.yaml- 启动测试第三方服务接口
cd example/third
go run main.go- 推送一条测试任务
go run push-get.go
go run push-post.go- Prometheus 部署
prometheus.yml配置
scrape_configs:
# The job name is added as a label `job=<job_name>` to any timeseries scraped from this config.
- job_name: 'uTask'
# metrics_path defaults to '/metrics'
# scheme defaults to 'http'.
scrape_interval: 3s
static_configs:
- targets: ['docker.for.mac.localhost:8020']
部署
docker run \
-p 9090:9090 \
-v /data/prom:/etc/prometheus \
prom/prometheus
- Grafana部署
docker run \
-d \
-p 3000:3000 \
--name=grafana \
-e "GF_SERVER_ROOT_URL=https://grafana.server.name" \
-e "GF_SECURITY_ADMIN_PASSWORD=secret" \
grafana/grafana
- http get请求任务: example/push-get.go
- http post请求任务: example/push-post.go
- http 任务认证: example/third/api/api.go
- TODO