1- # Go 分布式任务调度系统
1+ # Go 鍒嗗竷寮忎换鍔¤皟搴︾郴缁?
22
3- ## 📋 快速导航
4- - [ 核心特性 ] ( #核心特性 ) - 系统主要功能和优势
5- - [ 核心理念 ] ( #核心理念 ) - 设计思想和架构原则
6- - [ 项目结构 ] ( #项目结构 ) - 代码组织和目录说明
3+ ## 馃搵 蹇�熷鑸?
4+ - [ 鏍稿績鐗规�(#鏍稿績鐗规�? - 绯荤粺涓昏鍔熻兘鍜屼紭鍔?
5+ - [ 鏍稿績鐞嗗康 ] ( #鏍稿績鐞嗗康 ) - 璁捐鎬濇兂鍜屾灦鏋勫師鍒?
6+ - [ 椤圭洰缁撴瀯 ] ( #椤圭洰缁撴瀯 ) - 浠g爜缁勭粐鍜岀洰褰曡鏄?
77- [ 澶氳瑷�SDK鏀寔] ( #澶氳瑷�sdk鏀寔 ) - Python/Node.js/Go SDK浣跨敤鎸囧崡
8- - [ 核心组件 ] ( #核心组件 ) - 调度器/ Worker/客户端详解
8+ - [ 鏍稿績缁勪欢 ] ( #鏍稿績缁勪欢 ) - 璋冨害鍣? Worker/瀹㈡埛绔瑙?
99- [ 浜や簰娴佺▼] ( #浜や簰娴佺▼ ) - 绯荤粺缁勪欢闂撮�氫俊娴佺▼
10- - [ 快速开始 ] ( #快速开始 ) - 快速部署和使用指南
11- - [ 高级功能 ] ( #高级功能 ) - Web UI调试/负载均衡等进阶特性
12- - [ TODO] ( #todo ) - 未来规划和待办事项
10+ - [ 蹇�熷紑濮媇(#蹇�熷紑濮? - 蹇�熼儴缃插拰浣跨敤鎸囧崡
11+ - [ 楂樼骇鍔熻兘 ] ( #楂樼骇鍔熻兘 ) - Web UI璋冭瘯/璐熻浇鍧囪 绛夎繘闃剁壒鎬?
12+ - [ TODO] ( #todo ) - 鏈潵瑙勫垝鍜屽緟鍔炰簨椤?
1313---
1414### Web UI
1515![ Web UI 鐣岄潰] ( ./image/show.png )
1616
1717
18- 这是一个基于 Go 语言实现的轻量级分布式任务调度系统,支持 WebSocket 实时通信、负载均衡、方法文档化和 Web UI 调试功能。旨在通过将任务分发到多个 Worker 节点并行处理,从而解决单台计算机在处理计算密集型或 I/O 密集型任务时可能遇到的性能瓶颈问题。
18+ 杩欐槸涓�涓熀浜? Go 璇█瀹炵幇鐨勮交閲忕骇鍒嗗竷寮忎换鍔¤皟搴︾郴缁燂紝鏀寔 WebSocket 瀹炴椂閫氫俊銆佽礋杞藉潎琛°�佹柟娉曟枃妗e寲鍜? Web UI 璋冭瘯鍔熻兘銆傛棬鍦ㄩ�氳繃灏嗕换鍔″垎鍙戝埌澶氫釜 Worker 鑺傜偣骞惰澶勭悊锛屼粠鑰岃В鍐冲崟鍙拌绠楁満鍦ㄥ鐞嗚绠楀瘑闆嗗瀷鎴? I/O 瀵嗛泦鍨嬩换鍔℃椂鍙兘閬囧埌鐨勬�ц兘鐡堕闂銆?
1919
20- ## 核心特性
20+ ## 鏍稿績鐗规�?
2121
22- - 🚀 ** 实时通信 ** :基于 WebSocket 的调度器与 Worker 通信
23- - ⚖️ ** 负载均衡 ** :智能任务分配,支持多 Worker 负载均衡
24- - 📚 ** 方法文档化 ** :支持为注册的方法添加详细文档说明
25- - 🎯 ** Web UI 调试 ** :内置 Web 界面,支持实时监控和方法调试
22+ - 馃殌 ** 瀹炴椂閫氫俊 ** 锛氬熀浜? WebSocket 鐨勮皟搴﹀櫒涓? Worker 閫氫俊
23+ - 鈿栵笍 ** 璐熻浇鍧囪 ** 锛氭櫤鑳戒换鍔″垎閰嶏紝鏀寔澶? Worker 璐熻浇鍧囪
24+ - 馃摎 ** 鏂规硶鏂囨。鍖? * 锛氭敮鎸佷负娉ㄥ唽鐨勬柟娉曟坊鍔犺缁嗘枃妗h鏄?
25+ - 馃幆 ** Web UI 璋冭瘯 ** 锛氬唴缃? Web 鐣岄潰锛屾敮鎸佸疄鏃剁洃鎺у拰鏂规硶璋冭瘯
2626- 馃攧 ** 鑷姩閲嶈繛** 锛歐orker 鏂嚎鑷姩閲嶈繛鏈哄埗
27- - 💓 ** 心跳检测 ** :实时监控 Worker 节点状态
28- - 🛡️ ** 并发安全 ** :解决 WebSocket 并发写入问题
27+ - 馃挀 ** 蹇冭烦妫�娴? * 锛氬疄鏃剁洃鎺? Worker 鑺傜偣鐘舵�?
28+ - 馃洝锔? ** 骞跺彂瀹夊叏 ** 锛氳В鍐? WebSocket 骞跺彂鍐欏叆闂
2929
3030## 鏍稿績鐞嗗康
3131
32- 本项目的核心理念是将复杂的任务分解为更小的、可独立执行的工作单元,并通过一个中心化的调度器(Scheduler)将这些工作单元分发给一组工作节点(Worker)。客户端(Client)可以向调度器提交任务请求,并获取任务执行结果。
32+ 鏈」鐩殑鏍稿績鐞嗗康鏄皢澶嶆潅鐨勪换鍔″垎瑙d负鏇村皬鐨勩�佸彲鐙珛鎵ц鐨勫伐浣滃崟鍏冿紝骞堕�氳繃涓�涓腑蹇冨寲鐨勮皟搴﹀櫒锛圫cheduler锛夊皢杩欎簺宸ヤ綔鍗曞厓鍒嗗彂缁欎竴缁勫伐浣滆妭鐐癸紙Worker锛夈�傚鎴风锛圕lient锛夊彲浠ュ悜璋冨害鍣ㄦ彁浜や换鍔¤姹傦紝骞惰幏鍙栦换鍔℃墽琛岀粨鏋溿�?
3333
3434杩欑鏋舵瀯鐨勪紭鍔垮湪浜庯細
3535
36- * ** 可伸缩性 ** :可以通过增加 Worker 节点的数量来提高系统的整体处理能力
37- * ** 灵活性 ** :不同的 Worker 可以执行不同类型的任务,方便横向扩展特定功能
38- * ** 容错性 ** :单个 Worker 节点的故障不会影响整个系统的运行
39- * ** 可观测性 ** :通过 Web UI 实时监控系统状态和调试方法
36+ * ** 鍙几缂╂�? * 锛氬彲浠ラ�氳繃澧炲姞 Worker 鑺傜偣鐨勬暟閲忔潵鎻愰珮绯荤粺鐨勬暣浣撳鐞嗚兘鍔?
37+ * ** 鐏垫椿鎬? * 锛氫笉鍚岀殑 Worker 鍙互鎵ц涓嶅悓绫诲瀷鐨勪换鍔★紝鏂逛究妯悜鎵╁睍鐗瑰畾鍔熻兘
38+ * ** 瀹归敊鎬? * 锛氬崟涓? Worker 鑺傜偣鐨勬晠闅滀笉浼氬奖鍝嶆暣涓郴缁熺殑杩愯
39+ * ** 鍙娴嬫�? * 锛氶�氳繃 Web UI 瀹炴椂鐩戞帶绯荤粺鐘舵�佸拰璋冭瘯鏂规硶
4040
4141## 椤圭洰缁撴瀯
4242
4343```
4444鈹溾攢鈹� examples/ // 绀轰緥浠g爜
45- │ ├── client/ // 客户端示例
46- │ │ └── main.go
47- │ ├── scheduler/ // 调度器示例
48- │ │ └── main.go
49- │ └── worker/ // Worker 示例
50- │ └── main.go
45+ 鈹? 鈹溾攢鈹� client/ // 瀹㈡埛绔ず渚?
46+ 鈹? 鈹? 鈹斺攢鈹� main.go
47+ 鈹? 鈹溾攢鈹� scheduler/ // 璋冨害鍣ㄧず渚?
48+ 鈹? 鈹? 鈹斺攢鈹� main.go
49+ 鈹? 鈹斺攢鈹� worker/ // Worker 绀轰緥
50+ 鈹? 鈹斺攢鈹� main.go
5151鈹溾攢鈹� go-sdk/ // Go SDK
52- │ ├── scheduler/ // 客户端与调度器交互的 SDK
53- │ │ ├── client.go
54- │ │ └── retry_client.go
55- │ └── worker/ // Worker 与调度器交互的 SDK
56- │ ├── call.go
57- │ └── worker.go
52+ 鈹? 鈹溾攢鈹� scheduler/ // 瀹㈡埛绔笌璋冨害鍣ㄤ氦浜掔殑 SDK
53+ 鈹? 鈹? 鈹溾攢鈹� client.go
54+ 鈹? 鈹? 鈹斺攢鈹� retry_client.go
55+ 鈹? 鈹斺攢鈹� worker/ // Worker 涓庤皟搴﹀櫒浜や簰鐨? SDK
56+ 鈹? 鈹溾攢鈹� call.go
57+ 鈹? 鈹斺攢鈹� worker.go
5858鈹溾攢鈹� python-sdk/ // Python SDK
59- │ ├── scheduler/ // Python 客户端 SDK
60- │ ├── worker/ // Python Worker SDK
61- │ └── examples/ // Python 示例代码
59+ 鈹? 鈹溾攢鈹� scheduler/ // Python 瀹㈡埛绔? SDK
60+ 鈹? 鈹溾攢鈹� worker/ // Python Worker SDK
61+ 鈹? 鈹斺攢鈹� examples/ // Python 绀轰緥浠g爜
6262鈹溾攢鈹� node-sdk/ // Node.js SDK
63- │ ├── scheduler/ // Node.js 客户端 SDK
64- │ ├── worker/ // Node.js Worker SDK
65- │ └── examples/ // Node.js 示例代码
63+ 鈹? 鈹溾攢鈹� scheduler/ // Node.js 瀹㈡埛绔? SDK
64+ 鈹? 鈹溾攢鈹� worker/ // Node.js Worker SDK
65+ 鈹? 鈹斺攢鈹� examples/ // Node.js 绀轰緥浠g爜
6666鈹溾攢鈹� image/ // 椤圭洰鐩稿叧鍥剧墖
6767鈹溾攢鈹� go.mod // Go 妯″潡鏂囦欢
68- ├── go.sum // Go 模块校验和文件
68+ 鈹溾攢鈹� go.sum // Go 妯″潡鏍¢獙鍜屾枃浠?
6969鈹溾攢鈹� index.html // Web UI 鐣岄潰锛堝祵鍏ュ湪 scheduler.go 涓級
70- └── scheduler.go // 调度器核心逻辑实现(包含 Web UI)
70+ 鈹斺攢鈹� scheduler.go // 璋冨害鍣ㄦ牳蹇冮�昏緫瀹炵幇锛堝寘鍚? Web UI锛?
7171```
7272
7373## 澶氳瑷� SDK 鏀寔
7474
75- 本项目提供多种编程语言的 SDK,方便不同技术栈的开发者使用:
75+ 鏈」鐩彁渚涘绉嶇紪绋嬭瑷�鐨?SDK锛屾柟渚夸笉鍚屾妧鏈爤鐨勫紑鍙戣�呬娇鐢細
7676
7777### 馃悕 Python SDK
7878
7979** 瀹夎鏂瑰紡** :
8080``` bash
81- # 从 PyPI 安装
82- pip install go-server-sdk==2.0.1
81+ # 浠? PyPI 瀹夎
82+ pip install go-server-sdk==1.5.6
8383
84- # 或安装最新版本
84+ # 鎴栧畨瑁呮渶鏂扮増鏈?
8585pip install go-server-sdk
8686
87- # 从源码安装(开发用)
87+ # 浠庢簮鐮佸畨瑁咃紙寮�鍙戠敤锛?
8888cd python-sdk
8989pip install -e .
9090```
9191
92- ** 快速使用 * * :
92+ ** 蹇�熶娇鐢? * :
9393``` python
94- # 客户端调用
94+ # 瀹㈡埛绔皟鐢?
9595from scheduler import SchedulerClient
9696
9797client = SchedulerClient(" http://localhost:8080" )
@@ -120,9 +120,9 @@ worker.start()
120120npm install go-server-sdk
121121```
122122
123- ** 快速使用 * * :
123+ ** 蹇�熶娇鐢? * :
124124``` javascript
125- // 客户端调用
125+ // 瀹㈡埛绔皟鐢?
126126const { SchedulerClient } = require (' go-server-sdk' );
127127
128128const client = new SchedulerClient (' http://localhost:8080' );
@@ -151,9 +151,9 @@ worker.start();
151151go get github.com/go-enols/go-server
152152```
153153
154- ** 快速使用 * * :
154+ ** 蹇�熶娇鐢? * :
155155``` go
156- // 客户端调用
156+ // 瀹㈡埛绔皟鐢?
157157import " github.com/go-enols/go-server/worker"
158158
159159result := worker.Call (" http://localhost:8080" , " add" , map [string ]any{
@@ -171,19 +171,19 @@ worker.Start()
171171
172172## 鏍稿績缁勪欢
173173
174- ### 1. 调度器 (Scheduler)
174+ ### 1. 璋冨害鍣? (Scheduler)
175175** 鏂囦欢** : ` scheduler.go ` , ` scheduler/ `
176176
177177** 涓昏鍔熻兘** :
178- - 🌐 ** Web UI 管理界面 ** : 提供实时监控和调试功能
179- - 📡 ** WebSocket 通信 ** : 与 Worker 节点建立持久连接
178+ - 馃寪 ** Web UI 绠$悊鐣岄潰 ** : 鎻愪緵瀹炴椂鐩戞帶鍜岃皟璇曞姛鑳?
179+ - 馃摗 ** WebSocket 閫氫俊 ** : 涓? Worker 鑺傜偣寤虹珛鎸佷箙杩炴帴
180180- 鈿栵笍 ** 璐熻浇鍧囪 ** : 鏍规嵁 Worker 璐熻浇鏅鸿兘鍒嗛厤浠诲姟
181- - 💓 ** 健康检查 ** : 定期检测 Worker 节点状态
181+ - 馃挀 ** 鍋ュ悍妫�鏌? * : 瀹氭湡妫�娴? Worker 鑺傜偣鐘舵�?
182182- 馃搳 ** 浠诲姟绠$悊** : 璺熻釜浠诲姟鐘舵�佸苟杩斿洖缁撴灉
183183
184184** API 绔偣** :
185185- ` GET / ` - Web UI 绠$悊鐣岄潰
186- - ` GET /api/status ` - 获取系统状态
186+ - ` GET /api/status ` - 鑾峰彇绯荤粺鐘舵�?
187187- ` POST /api/execute ` - 鎵ц浠诲姟
188188- ` GET /api/result/{taskId} ` - 鑾峰彇浠诲姟缁撴灉
189189- ` WS /api/worker/connect ` - Worker 杩炴帴绔偣
@@ -192,11 +192,11 @@ worker.Start()
192192** 鏂囦欢** : ` worker/ ` , ` examples/worker/ `
193193
194194** 涓昏鍔熻兘** :
195- - 🔌 ** 自动连接 ** : 自动连接到调度器并注册方法
196- - 📚 ** 方法文档 ** : 支持为注册方法添加详细文档
197- - 🔄 ** 自动重连 ** : 连接断开时自动重连
198- - 💓 ** 心跳保持 ** : 定期发送心跳维持连接
199- - 🛡️ ** 并发安全 ** : 解决 WebSocket 并发写入问题
195+ - 馃攲 ** 鑷姩杩炴帴 ** : 鑷姩杩炴帴鍒拌皟搴﹀櫒骞舵敞鍐屾柟娉?
196+ - 馃摎 ** 鏂规硶鏂囨。 ** : 鏀寔涓烘敞鍐屾柟娉曟坊鍔犺缁嗘枃妗?
197+ - 馃攧 ** 鑷姩閲嶈繛 ** : 杩炴帴鏂紑鏃惰嚜鍔ㄩ噸杩?
198+ - 馃挀 ** 蹇冭烦淇濇寔 ** : 瀹氭湡鍙戦�佸績璺崇淮鎸佽繛鎺?
199+ - 馃洝锔? ** 骞跺彂瀹夊叏 ** : 瑙e喅 WebSocket 骞跺彂鍐欏叆闂
200200
201201** 绀轰緥鏂规硶娉ㄥ唽** :
202202``` go
@@ -206,14 +206,14 @@ worker.RegisterMethod("add", addNumbers,
206206 " 杩斿洖: number" )
207207```
208208
209- ### 3. 客户端 (Client)
209+ ### 3. 瀹㈡埛绔? (Client)
210210** 鏂囦欢** : ` scheduler/ ` , ` examples/client/ `
211211
212212** 涓昏鍔熻兘** :
213213- 馃摛 ** 浠诲姟鎻愪氦** : 鍚戣皟搴﹀櫒鎻愪氦浠诲姟璇锋眰
214- - 🔍 ** 状态查询 ** : 查询任务执行状态
214+ - 馃攳 ** 鐘舵�佹煡璇? * : 鏌ヨ浠诲姟鎵ц鐘舵�?
215215- 馃摜 ** 缁撴灉鑾峰彇** : 鑾峰彇浠诲姟鎵ц缁撴灉
216- - 🔄 ** 重试机制 ** : 支持自动重试失败的请求
216+ - 馃攧 ** 閲嶈瘯鏈哄埗 ** : 鏀寔鑷姩閲嶈瘯澶辫触鐨勮姹?
217217
218218** 浣跨敤绀轰緥** :
219219``` go
@@ -225,27 +225,27 @@ worker.Call("http://localhost:8080", "add", map[string]any{
225225
226226## 浜や簰娴佺▼
227227
228- 1 . ** 启动调度器 ** : 调度器启动并监听端口 8080,提供 Web UI 和 API 服务
229- 2 . ** Worker 注册 ** : Worker 节点通过 WebSocket 连接到调度器并注册可用方法
230- 3 . ** 任务提交 ** : 客户端通过 API 或 Web UI 提交任务请求
231- 4 . ** 负载均衡 ** : 调度器根据 Worker 负载选择最优节点执行任务
228+ 1 . ** 鍚姩璋冨害鍣? * : 璋冨害鍣ㄥ惎鍔ㄥ苟鐩戝惉绔彛 8080锛屾彁渚? Web UI 鍜? API 鏈嶅姟
229+ 2 . ** Worker 娉ㄥ唽 ** : Worker 鑺傜偣閫氳繃 WebSocket 杩炴帴鍒拌皟搴﹀櫒骞舵敞鍐屽彲鐢ㄦ柟娉?
230+ 3 . ** 浠诲姟鎻愪氦 ** : 瀹㈡埛绔�氳繃 API 鎴? Web UI 鎻愪氦浠诲姟璇锋眰
231+ 4 . ** 璐熻浇鍧囪 ** : 璋冨害鍣ㄦ牴鎹? Worker 璐熻浇閫夋嫨鏈�浼樿妭鐐规墽琛屼换鍔?
2322325 . ** 浠诲姟鎵ц** : Worker 鎺ユ敹浠诲姟骞舵墽琛岀浉搴旂殑涓氬姟閫昏緫
2332336 . ** 缁撴灉杩斿洖** : Worker 灏嗘墽琛岀粨鏋滆繑鍥炵粰璋冨害鍣紝璋冨害鍣ㄥ啀杩斿洖缁欏鎴风
2342347 . ** 瀹炴椂鐩戞帶** : 閫氳繃 Web UI 瀹炴椂鏌ョ湅绯荤粺鐘舵�佸拰璋冭瘯鏂规硶
235235
236- ## 快速开始
236+ ## 蹇�熷紑濮?
237237
238238### 鍓嶆彁鏉′欢
239239
240- - Go 1.19+ (请根据 ` go.mod ` 文件中的版本安装 )
240+ - Go 1.19+ (璇锋牴鎹? ` go.mod ` 鏂囦欢涓殑鐗堟湰瀹夎 )
241241
242- ### 1. 启动调度器
242+ ### 1. 鍚姩璋冨害鍣?
243243
244244``` bash
245- # 方式一:直接运行
245+ # 鏂瑰紡涓�锛氱洿鎺ヨ繍琛?
246246go run go-sdk/examples/scheduler/main.go
247247
248- # 方式二:构建后运行
248+ # 鏂瑰紡浜岋細鏋勫缓鍚庤繍琛?
249249go build -o scheduler ./go-sdk/examples/scheduler
250250./scheduler
251251```
@@ -262,23 +262,23 @@ Web UI available at: http://localhost:8080
262262go run go-sdk/examples/worker/main.go
263263```
264264
265- Worker 启动后会自动连接到调度器并注册方法。
265+ Worker 鍚姩鍚庝細鑷姩杩炴帴鍒拌皟搴﹀櫒骞舵敞鍐屾柟娉曘�?
266266
267267### 3. 浣跨敤 Web UI
268268
269- 打开浏览器访问 ` http://localhost:8080 ` ,你可以:
269+ 鎵撳紑娴忚鍣ㄨ闂? ` http://localhost:8080 ` 锛屼綘鍙互锛?
270270
271271- 馃搳 ** 瀹炴椂鐩戞帶** : 鏌ョ湅 Worker 鐘舵�併�佹柟娉曞垪琛ㄥ拰浠诲姟缁熻
272272- 馃敡 ** 鏂规硶璋冭瘯** : 閫夋嫨鏂规硶銆佽緭鍏ュ弬鏁般�佹墽琛屽苟鏌ョ湅缁撴灉
273- - 📚 ** 查看文档 ** : 查看每个方法的详细文档说明
273+ - 馃摎 ** 鏌ョ湅鏂囨。 ** : 鏌ョ湅姣忎釜鏂规硶鐨勮缁嗘枃妗h鏄?
274274
275- ### 4. 使用客户端 API
275+ ### 4. 浣跨敤瀹㈡埛绔? API
276276
277277``` bash
278278go run go-sdk/examples/client/main.go
279279```
280280
281- 或者直接调用 API:
281+ 鎴栬�呯洿鎺ヨ皟鐢?API锛?
282282``` bash
283283curl -X POST http://localhost:8080/api/execute \
284284 -H " Content-Type: application/json" \
@@ -289,39 +289,39 @@ curl -X POST http://localhost:8080/api/execute \
289289
290290### Web UI 璋冭瘯
291291
292- Web UI 提供了强大的调试功能:
292+ Web UI 鎻愪緵浜嗗己澶х殑璋冭瘯鍔熻兘锛?
293293
2942941 . ** 鏂规硶閫夋嫨** : 浠庝笅鎷夊垪琛ㄤ腑閫夋嫨瑕佽皟璇曠殑鏂规硶
295- 2 . ** 参数输入 ** : 以 JSON 格式输入方法参数
295+ 2 . ** 鍙傛暟杈撳叆 ** : 浠? JSON 鏍煎紡杈撳叆鏂规硶鍙傛暟
2962963 . ** 瓒呮椂璁剧疆** : 璁剧疆浠诲姟鎵ц瓒呮椂鏃堕棿
2972974 . ** 瀹炴椂缁撴灉** : 鏌ョ湅浠诲姟鎵ц鐘舵�佸拰杩斿洖缁撴灉
298- 5 . ** 错误处理 ** : 显示详细的错误信息
298+ 5 . ** 閿欒澶勭悊 ** : 鏄剧ず璇︾粏鐨勯敊璇俊鎭?
299299
300300### 璐熻浇鍧囪
301301
302- 调度器会自动根据以下策略进行负载均衡:
302+ 璋冨害鍣ㄤ細鑷姩鏍规嵁浠ヤ笅绛栫暐杩涜璐熻浇鍧囪 锛?
303303- 閫夋嫨褰撳墠浠诲姟鏁版渶灏戠殑 Worker
304- - 确保 Worker 支持请求的方法
305- - 实时更新 Worker 负载状态
304+ - 纭繚 Worker 鏀寔璇锋眰鐨勬柟娉?
305+ - 瀹炴椂鏇存柊 Worker 璐熻浇鐘舵�?
306306
307- ### 方法文档化
307+ ### 鏂规硶鏂囨。鍖?
308308
309- 在注册方法时可以添加详细文档:
309+ 鍦ㄦ敞鍐屾柟娉曟椂鍙互娣诲姞璇︾粏鏂囨。锛?
310310``` go
311311worker.RegisterMethod (" methodName" , handler,
312312 " 鏂规硶鎻忚堪" ,
313313 " 鍙傛暟璇存槑" ,
314- " 返回值说明 " )
314+ " 杩斿洖鍊艰鏄? )
315315```
316316
317317## TODO
318318
319- - [ ] 支持调度器集群模式
320- - [ ] 添加任务优先级
321- - [ ] 支持任务队列持久化
319+ - [ ] 鏀寔璋冨害鍣ㄩ泦缇ゆā寮?
320+ - [ ] 娣诲姞浠诲姟浼樺厛绾?
321+ - [ ] 鏀寔浠诲姟闃熷垪鎸佷箙鍖?
322322- [ ] 娣诲姞鏇村鐩戞帶鎸囨爣
323323- [ ] 鏀寔鏂规硶鐗堟湰绠$悊
324324
325325## 璐$尞
326326
327- 欢迎提交 Pull Request 或 Issue。
327+ 娆㈣繋鎻愪氦 Pull Request 鎴?Issue銆?
0 commit comments