0%

一、系统功能

  • 数据同步
    • 数据源管理
    • 任务管理
      • 项目管理
      • 任务管理
      • 任务构建
    • 日志管理
    • 执行器管理
    • 运行报表

二、流程逻辑

1、任务管理平台-执行器通信

2、执行器路由策略

3、datax数据同步流程

4、日志处理

xxl-job内容

admin服务端

启动顺序

  1. XxlJobAdminConfig
  2. XxlJobScheduler
  3. 如下表格内容

执行类型:通过配置bean名称(datax、shell、python、powershell)

XxlJobScheduler

序号 标题 内容 频率 备注
国际化
注册监听器 1、扫描sync_job_registry表
2、更新sync_job_group表
30s
失败监听器 1、扫描fail_job_log
2、重试
3、告警
10s
丢失监听器 60s 执行超过10min则表示失败
任务触发器 线程池
快触发器、慢触发器
日志报告 执行统计
定时任务 5s 定时执行

作为springboot程序:提供JobApiController实现AdminBiz的注册、取消、回调接口

executor执行器

启动顺序

  1. XxlJobConfig
  2. XxlJobSpringExecutor
  3. initJobHandlerMethodRepository
  4. 工厂类启动
  5. 如下表格内容

XxlJobExecutor

序号 标题 内容 频率 备注
初始化日志路径
初始管理平台客户端
日志清理线程 1、扫描文件夹
2、删除过期
1d
回调处理 1、触发器回调线程
2、异常重试线程
30s
netty服务端提供接口 1、启动netty
2、channel监听
3、注册地址到管理平台

停止时有相关处理:资源回收

  1. 释放netty端口
  2. 停止线程池
  3. 停止在运行的线程
  4. 停止日志处理线程
  5. 停止回调线程、重试线程

hexo new “My New Post”
执行新增 blog 会自动添加用户名信息:coauthor

https://github.com/theme-next/hexo-theme-next
使用 next 主题

https://github.com/theme-next/awesome-next#live-preview
next 其他插件

https://github.com/theme-next/theme-next-calendar
日历云插件

https://github.com/theme-next/hexo-generator-searchdb
搜索插件
配置方法:search.xml 路径、开启搜索

https://github.com/hinastory/hexo-tag-details

Where are you from?

I’m from the Earth. Water Planet!

What food do you like?
  1. Sushi
  2. Tempura
  3. Sukiyaki

https://github.com/HunterXuan/hexo-simple-mindmap

https://github.com/cocowool/hexo-image-link

图片测试 sdfdf
sdfsd

https://github.com/aspirewit/hexo-tag-easy-charts

线上编程!!!!应该成功了吧

1
2
3
4
5
6
7
8
9
hello world

Markdown 字体颜色
<font face="黑体">我是黑体字</font>
<font face="微软雅黑">我是微软雅黑</font>
<font face="STCAIYUN">我是华文彩云</font>
<font color=#0099ff size=7 face="黑体">color=#0099ff size=72 face="黑体"</font>
<font color=red size=5>gray</font>
<font color="#4590a3" size="6px">文字</font>

我是黑体字
我是微软雅黑
我是华文彩云
color=#0099ff size=72 face=”黑体”
gray
文字

Markdown 语法-简书版
Markdown 语法-runoob 版

https://github.com/bubkoo/hexo-filter-flowchart

sdfsdff

https://github.com/bubkoo/hexo-filter-sequence

https://mermaid-js.github.io/mermaid/#/n00b-gettingStarted

graph TD A[Client] --> B[Load Balancer] B --> C[Server01] B --> D[Server02]
gantt section A section Completed task :done, des1, 2014-01-06,2014-01-08 Active task :active, des2, 2014-01-09, 3d Future task : des3, after des2, 5d Future task2 : des4, after des3, 5d
sequenceDiagram participant Alice participant Bob Alice->>John: Hello John, how are you? loop Healthcheck John->>John: Fight against hypochondria end Note right of John: Rational thoughts
prevail... John-->>Alice: Great! John->>Bob: How about you? Bob-->>John: Jolly good!

Here is one mermaid diagram:

graph TD A[Client] --> B[Load Balancer] B --> C[Server1] B --> D[Server2]

And here is another:

graph TD A[Client] -->|tcp_123| B(Load Balancer) B -->|tcp_456| C[Server1] B -->|tcp_456| D[Server2]
gitGraph: options { "nodeSpacing": 150, "nodeRadius": 10 } end commit branch newbranch checkout newbranch commit commit checkout master commit commit merge newbranch
classDiagram Class01 <|-- AveryLongClass : Cool Class03 *-- Class04 Class05 o-- Class06 Class07 .. Class08 Class09 --> C2 : Where am i? Class09 --* C3 Class09 --|> Class07 Class07 : equals() Class07 : Object[] elementData Class01 : size() Class01 : int chimp Class01 : int gorilla Class08 <--> C2: Cool label