kelvins

README

kelvins

go/golang微服务框架

支持特性

注册服务，发现服务，grpc/http gateway，cron，queue，http/gin服务，插拔式配置加载，双orm支持，mysql，mongo支持，事件总线，日志，异步任务池，
Prometheus/pprof监控，进程优雅重启，应用自定义配置，启动flag参数指定，应用hook，工具类（由kelvins-io/common支持），全局变量vars，在线应用负载均衡，启动命令

即将支持

限流，熔断，异常接入sentry，kelvins-tools工具箱（一键生成应用，运维部署等）

软件环境

go 1.13.15

运行环境变量

etcd集群地址
ETCDV3_SERVER_URLS

笔者自己环境的配置（仅做参考） 
export ETCDCTL_API=3
export ETCDV3_SERVER_URL=http://10.211.55.4:2379,http://10.211.55.7:2379
如果自己搭建etcd集群最少需要两个节点（一主一从）本地搭建参考：https://gitee.com/cristiane/micro-mall-api/blob/master/%E5%BE%AE%E5%95%86%E5%9F%8EETCD%E9%83%A8%E7%BD%B2.pdf

GO_ENV

运行环境标识，可选值有：dev，test，release，prod；分别对应开发环境，测试环境，预发布/灰度环境，prod正式环境，本地配置export GO_ENV=dev就好

新版本的kelvins不再依赖GO_ENV

目前最新版支持的配置文件

配置文件默认就在项目根目录下/etc/app.ini文件，大多数micro-mall-开头的项目已经包含了所需的配置文件，根据自己本地的配置修改即可

截止最新版kelvins，全部支持的项目配置（./etc/app.ini）内容
除了必要的配置项外，其余配置都是你不配置kelvins就不会去加载初始&当然对应的功能也不能用
服务配置：端口，传输协议等

**必要配置项：
kelvins-server
日志：级别，路径等
kelvins-logger

--自选配置项：
MySQL：连接配置信息
kelvins-mysql
Redis：连接配置信息
kelvins-redis
MongoDB：连接配置信息
kelvins-mongodb
队列功能需要的Redis配置
kelvins-queue-redis
队列功能-阿里云队列（在阿里云购买的amqp）
kelvins-queue-ali-amqp
队列功能-amqp协议（也就是自己搭建的rabbitmq）
kelvins-queue-amqp
队列功能，事件订阅功能（阿里云）
kelvins-queue-ali-rocketmq
队列消费者配置
kelvins-queue-server
异步任务池
kelvins-gpool
++自定义配置项，根据项目本身而定
micro-mall-api/etc/app.ini#EmailConfig就属于自定义配置项

--启动flag参数
说明：flag参数优先级高于配置文件中同名配置参数，flag参数均可不指定，默认从进程运行目录/etc/app.ini加载，日志文件路径默认在进程运行目录/logs
-logger_level 日志级别
-logger_path 日志文件路径
-conf_file 配置文件（ini文件）路径
-s start 启动进程
-s restart 重启当前进程
-s stop 停止当前进程

APP注册参考

请在你的应用main.go中注册application

package main

import (
	"crypto/tls"
	"gitee.com/cristiane/micro-mall-pay/startup"
	"gitee.com/kelvins-io/kelvins"
	"gitee.com/kelvins-io/kelvins/app"
)

const APP_NAME = "micro-mall-pay"

func main() {
	application := &kelvins.GRPCApplication{
		Application: &kelvins.Application{
			LoadConfig: startup.LoadConfig,
			SetupVars:  startup.SetupVars,
			Name:       APP_NAME,
		},
		TlsConfig: &tls.Config{
			// 配置应用证书，仅仅对grpc,http类应用支持
		},
		RegisterGRPCServer: startup.RegisterGRPCServer,
		RegisterGateway:    startup.RegisterGateway,
		RegisterHttpRoute:  startup.RegisterHttpRoute,
	}
	app.RunGRPCApplication(application)
}

更新日志

时间	内容	贡献者	备注
2020-8-27	预览版上线	https://gitee.com/cristiane	支持gRPC，HTTP，crontab，queue类应用
2020-9-10	增加MongoDB支持	https://gitee.com/cristiane	基于配置加载MongoDB来初始化应用
2020-9-13	支持Redis队列	https://gitee.com/cristiane	基于配置加载queue-Redis来初始化应用
2020-11-24	v2	https://gitee.com/cristiane	若干更新
2021-4-5	支持应用优雅重启，退出	https://gitee.com/cristiane	基于操作系统信号，各平台有差异
2021-4-19	支持gin	https://gitee.com/cristiane	允许将gin http handler注册到应用
2021-7-9	兼容Windows	https://gitee.com/cristiane	修复Windows平台应用不能启动问题
2021-8-1	应用退出执行函数优化	https://gitee.com/cristiane	应用退出时异常处理
2021-8-1	应用支持负载均衡	https://gitee.com/cristiane	针对gRPC，http应用；同一应用多实例自动负载均衡
2021-8-7	启动命令	https://gitee.com/cristiane	-s启动参数，支持启动进程，重启进程，停止进程

业务应用

micro-mall-api系列共计16个服务：https://gitee.com/cristiane/micro-mall-api

###技术交流 QQ群：578859618

邮件：1225807604@qq.com

Documentation

Index

• Constants
• Variables
• type Application
• type CronApplication
• type CronJob
• type GRPCApplication
• type HTTPApplication
• type QueueApplication

Constants

const (
	AppTypeGrpc  = 1
	AppTypeCron  = 2
	AppTypeQueue = 3
	AppTypeHttp  = 4
)

const (
	Version = "1.4.0"
)

Variables

var AccessLogger log.LoggerContextIface

AccessLogger is a global vars for application to log access log

var AliRocketMQSetting *setting.AliRocketMQSettingS

AliRocketMQSetting is maps config section "kelvins-queue-ali-rocketmq"

var AppCloseCh = make(chan struct{})

AppCloseCh is app shutdown notice

var BusinessLogger log.LoggerContextIface

BusinessLogger is a global vars for application to log business log

var ErrLogger log.LoggerContextIface

ErrLogger is a global vars for application to log err msg.

var FrameworkLogger log.LoggerContextIface

FrameworkLogger is a global var for Framework log

var GORM_DBEngine *gorm.DB

GORM_DBEngine is a global vars for mysql connect.

var GPool *goroutine.Pool

GPool is goroutine pool

var GPoolSetting *setting.GPoolSettingS

GPoolSetting is maps config section "kelvins-gpool"

var LoggerSetting *setting.LoggerSettingS

LoggerSetting is maps config section "kelvins-logger"

var MongoDBClient *qmgo.QmgoClient

MongoDBClient is qmgo-client for mongodb.

var MongoDBSetting *setting.MongoDBSettingS

MongoDBSetting is maps config section "kelvins-mongodb"

var MysqlSetting *setting.MysqlSettingS

MysqlSetting is maps config section "kelvins-mysql"

var PIDFile string

PIDFile is process pid

var QueueAMQPSetting *setting.QueueAMQPSettingS

QueueAMQPSetting is maps config section "kelvins-queue-amqp"

var QueueAliAMQPSetting *setting.QueueAliAMQPSettingS

QueueAliAMQPSetting is maps config section "kelvins-queue-amqp"

var QueueRedisSetting *setting.QueueRedisSettingS

QueueRedisSetting is maps config section "kelvins-queue-redis"

var QueueServerSetting *setting.QueueServerSettingS

QueueServerSetting is maps config section "kelvins-queue-server"

var RPCAuthSetting *setting.RPCAuthSettingS

ServerAuthSetting is maps config section "kelvins-auth"

var RedisConn *redis.Pool

RedisConn is a global vars for redis connect.

var RedisSetting *setting.RedisSettingS

MysqlSetting is maps config section "kelvins-redis"

var ServerName string

ServerName is server name

var ServerSetting *setting.ServerSettingS

ServerSetting is maps config section "kelvins-server"

var XORM_DBEngine xorm.EngineInterface

XORM_DBEngine is a global vars for mysql connect.

Types

type Application

type Application struct {
	Name           string
	Type           int32
	LoggerRootPath string
	LoggerLevel    string
	LoadConfig     func() error
	SetupVars      func() error
	StopFunc       func() error
}

Application ...

type CronApplication

type CronApplication struct {
	*Application
	CronLogger           *log.LoggerContext
	Cron                 *cron.Cron
	GenCronJobs          func() []*CronJob
	EventServer          *event.EventServer
	RegisterEventHandler func(event.EventServerIface) error
}

CronApplication ...

type CronJob

type CronJob struct {
	Name string // Job unique name
	Spec string // Job specification
	Job  func() // Job func
}

CronJob warps job define.

type GRPCApplication

type GRPCApplication struct {
	*Application
	Port                     int64
	GRPCServer               *grpc.Server
	HealthServer             *health.Server
	DisableHealthCheck       bool
	RegisterHealthServer     func(*health.Server) // execute in the coroutine
	NumServerWorkers         uint32
	GatewayServeMux          *runtime.ServeMux
	Mux                      *http.ServeMux
	HttpServer               *http.Server
	TlsConfig                *tls.Config
	GKelvinsLogger           *log.LoggerContext
	GSysErrLogger            *log.LoggerContext
	UnaryServerInterceptors  []grpc.UnaryServerInterceptor
	StreamServerInterceptors []grpc.StreamServerInterceptor
	ServerOptions            []grpc.ServerOption
	RegisterGRPCServer       func(*grpc.Server) error
	RegisterGateway          func(context.Context, *runtime.ServeMux, string, []grpc.DialOption) error
	RegisterHttpRoute        func(*http.ServeMux) error
	EventServer              *event.EventServer
	RegisterEventProducer    func(event.ProducerIface) error
}

GRPCApplication ...

type HTTPApplication

type HTTPApplication struct {
	*Application
	Port                  int64
	TraceLogger           *log.LoggerContext
	TlsConfig             *tls.Config
	Mux                   *http.ServeMux
	HttpServer            *http.Server
	RegisterHttpRoute     func(*http.ServeMux) error
	RegisterHttpGinEngine func() (*gin.Engine, error) // can over RegisterHttpRoute
	EventServer           *event.EventServer
	RegisterEventProducer func(event.ProducerIface) error
}

HTTPApplication ...

type QueueApplication

type QueueApplication struct {
	*Application
	QueueLogger          *log.LoggerContext
	QueueServer          *queue.MachineryQueue
	EventServer          *event.EventServer
	GetNamedTaskFuncs    func() map[string]interface{}
	RegisterEventHandler func(event.EventServerIface) error
}

QueueApplication ...