# README

distributed-worker 分布式调度接入指南

distributed-worker是一个由Go开发高性能分布式调度项目，distributed-worker在分布式环境上调度job功能上，增强系统容错性，支持随时增减服务实例节点，能够加快数据运算，提升系统之间交互效率

安装

参考demo：

distributed-worker-demo

安装依赖包:

go get github.com/ppkg/distributed-worker

初始化代码

	app = core.NewApp(core.WithNacosSchedulerServiceNameOption("distributed-scheduler"), core.WithNacosAddrOption("mse-e52dbdd6-p.nacos-ans.mse.aliyuncs.com:8848"), core.WithNacosNamespaceOption("27fdefc2-ae39-41fd-bac4-9256acbf97bc"), core.WithNacosServiceGroupOption("my-service"))

	// 注册task处理插件
	app.RegisterPlugin(func(ctx *core.ApplicationContext) core.PluginHandler {
		return handler.NewPlus()
	}).RegisterPlugin(func(ctx *core.ApplicationContext) core.PluginHandler {
		return handler.NewMulti()
	})

	// 注册回调通知
	app.RegisterJobNotify(func(ctx *core.ApplicationContext) core.JobNotifyHandler {
		return handler.NewDemoNotify()
	})

	err := app.Run()
	if err != nil {
		fmt.Println("start app got err:", err)
	}