#### Version 0.9.3

* Opt: 完善config模块，优化config注入模式
* Opt: 增加ConfigHandle函数定义,用于应用自定义config加载实现(如从redis\mysql等源读取配置)
* feature: 新增LoadFileConfig用于逐步替换原LoadConfig,主要用于读取xml\json\yaml格式配置文件
* feature: 新增LoadConfigHandler用于应用自定义配置加载方式的注入
* 2019-12-20 09:00 at ShangHai

Author: devfeel

config.go

@@ -30,10 +30,12 @@ type (
 			HandlerData string `xml:"handlerdata,attr" yaml:"handlerdata"`
 		} `xml:"tasks>task" yaml:"tasks"`
 	}
+
+	ConfigHandle func(configSource string) (*AppConfig, error)
 )
 
 //初始化配置文件（xml）
-func InitConfig(configFile string) *AppConfig {
+func XmlConfigHandler(configFile string) *AppConfig {
 	realFile, exists := lookupFile(configFile)
 	if !exists {
 		panic("Task:Config:InitConfig 配置文件[" + configFile + "]无法解析 - 无法寻找到指定配置文件")
@@ -56,7 +58,7 @@ func InitConfig(configFile string) *AppConfig {
 }
 
 //初始化配置文件（json）
-func InitJsonConfig(configFile string) *AppConfig {
+func JsonConfigHandler(configFile string) *AppConfig {
 	realFile, exists := lookupFile(configFile)
 	if !exists {
 		panic("Task:Config:InitConfig 配置文件[" + configFile + "]无法解析 - 无法寻找到指定配置文件")
@@ -78,7 +80,7 @@ func InitJsonConfig(configFile string) *AppConfig {
 }
 
 //初始化配置文件（yaml）
-func InitYamlConfig(configFile string) *AppConfig {
+func YamlConfigHandler(configFile string) *AppConfig {
 	realFile, exists := lookupFile(configFile)
 	if !exists {
 		panic("Task:Config:InitConfig 配置文件[" + configFile + "]无法解析 - 无法寻找到指定配置文件")

example/loadfromconfig/main.go

@@ -32,13 +32,13 @@ func main() {
 	RegisterTask(service)
 
 	//step 3: load config file
-	service.LoadConfig("d:/gotmp/dottask/task.conf")
+	service.LoadFileConfig("c:/gotmp/dottask/task.conf")
 
 	fmt.Println(time.Now().String(), " => Begin Task")
 	//step 4: start all task
 	service.StartAllTask()
 
-	fmt.Println(service.PrintAllCronTask())
+	fmt.Println(service.PrintAllTasks())
 
 	for {
 		time.Sleep(time.Hour)

example/loadfromjson/task.go

@@ -30,13 +30,14 @@ func main() {
 		RegisterHandler("Loop_Config", Loop_Config).
 
 		//step 3: load config file
-		LoadConfig("d:/gotmp/task/task.json.conf", ConfigType_Json).
+		LoadFileConfig("c:/gotmp/task/task.json.conf", ConfigType_Json).
 
 		//step 4: start all task
 		StartAllTask()
 
-	fmt.Println(service.PrintAllCronTask())
+	fmt.Println(service.PrintAllTasks())
 
-	for true {
+	for {
+		time.Sleep(time.Hour)
 	}
 }

example/loadfromyaml/task.go

@@ -29,13 +29,14 @@ func main() {
 		RegisterHandler("Loop_Config", Loop_Config).
 
 		//step 3: load config file
-		LoadConfig("d:/gotmp/task/task.yaml", ConfigType_Yaml).
+		LoadFileConfig("d:/gotmp/task/task.yaml", ConfigType_Yaml).
 
 		//step 4: start all task
 		StartAllTask()
 
-	fmt.Println(service.PrintAllCronTask())
+	fmt.Println(service.PrintAllTasks())
 
-	for true {
+	for {
+		time.Sleep(time.Hour)
 	}
 }

tasks.go

@@ -3,6 +3,7 @@ package task
 import (
 	"encoding/json"
 	"fmt"
+	"os"
 	"runtime/debug"
 	"strconv"
 	"sync"
@@ -99,21 +100,35 @@ func (service *TaskService) SetOnEndHandler(handler TaskHandle) {
 }
 
 // LoadConfig 如果指定配置文件，初始化配置
+// Deprecated: Use the LoadFileConfig instead
 func (service *TaskService) LoadConfig(configFile string, confType ...interface{}) *TaskService {
+	return service.LoadFileConfig(configFile, confType...)
+}
+
+// LoadFileConfig 如果指定配置文件，初始化配置
+func (service *TaskService) LoadFileConfig(configFile string, confType ...interface{}) *TaskService {
 	cType := ConfigType_Xml
 	if len(confType) > 0 && confType[0] == ConfigType_Json {
 		cType = ConfigType_Json
 	}
 	if len(confType) > 0 && confType[0] == ConfigType_Yaml {
 		cType = ConfigType_Yaml
 	}
+	var config *AppConfig
 	if cType == ConfigType_Json {
-		service.Config = InitJsonConfig(configFile)
+		config = JsonConfigHandler(configFile)
 	} else if cType == ConfigType_Yaml {
-		service.Config = InitYamlConfig(configFile)
+		config = YamlConfigHandler(configFile)
 	} else {
-		service.Config = InitConfig(configFile)
+		config = XmlConfigHandler(configFile)
 	}
+	service.applyConfig(config)
+	return service
+}
+
+// applyConfig apply task config with AppConfig
+func (service *TaskService) applyConfig(config *AppConfig) *TaskService {
+	service.Config = config
 	if service.logger == nil {
 		if service.Config.Global.LogPath != "" {
 			service.SetLogger(NewFileLogger(service.Config.Global.LogPath))
@@ -155,6 +170,18 @@ func (service *TaskService) LoadConfig(configFile string, confType ...interface{
 	return service
 }
 
+// LoadConfigHandler load config handler and init task config
+func (service *TaskService) LoadConfigHandler(configHandler ConfigHandle, configSource string) *TaskService {
+	config, err := configHandler(configSource)
+	if err != nil {
+		panic("Task:LoadConfigHandler 配置源[" + configSource + "]解析失败: " + err.Error())
+		os.Exit(1)
+	} else {
+		service.applyConfig(config)
+	}
+	return service
+}
+
 // RegisterHandler register handler by name
 func (service *TaskService) RegisterHandler(name string, handler TaskHandle) *TaskService {
 	service.handlerMutex.Lock()

version.MD

@@ -1,5 +1,12 @@
 ## devfeel/dottask
 
+#### Version 0.9.3
+* Opt: 完善config模块，优化config注入模式
+* Opt: 增加ConfigHandle函数定义,用于应用自定义config加载实现(如从redis\mysql等源读取配置)
+* feature: 新增LoadFileConfig用于逐步替换原LoadConfig,主要用于读取xml\json\yaml格式配置文件
+* feature: 新增LoadConfigHandler用于应用自定义配置加载方式的注入
+* 2019-12-20 09:00 at ShangHai
+
 #### Version 0.9.2
 * Opt: CounterOutputHttpHandler、TaskOutputHttpHandler输出UI优化
 * About HttpOutput: