后端全栈式服务框架，提供接口服务器、web 服务器、websocket 服务器，RPC 服务器、统一调度服务器、消息消费服务器。并具有如下特点：
- 统一开发模式
规范代码编写，采用统一方式编写服务
- 统一安装、启停、更新
采用相同的方式进行系统初始化，服务启动、停止、热更新等
- 统一配置管理
统一采用 zookeeper 或 fs 保存配置,本地零配置。并采用统一方式进行配置安装
- 统一基础框架
对缓存、数据库、消息队列、远程调用(GRPC)、日志归集、加解密等进行统一封装
- 统一日志框架
集成本地日志、远程日志服务，对日志进行统一归集与编排。
- 统一服务治理
集成服务注册、服务发现、负载均衡、流量控制、服务降级、熔断等，并对服务状态进行监控
- 统一认证服务
可集成 SAS 远程认证服务集成，实现请求的访问权限控制、加解密等
- 统一监控报警
集成系统监控、业务监控。对系统的主要指标(带宽、CPU、内存、硬盘、IO)和业务主要指标(QPS、处理时长、异常响应结果)进行统一采集，并存入 influxdb 中，可使用 grafana 进行实时查看。与报警系统(convoy)集成,可实现消息队列、数据库、服务状态等监控，和短信、微信等实时报警
- 多种集群模式
支持集群分组及对等，主备，分⽚等集群模式
-
golang 原生代码实现
-
20+线上项目实践经验
新建文件夹hello,添加main.go文件,输入以下代码:
package main
import (
"github.com/micro-plat/hydra/hydra"
)
func main() {
app := hydra.NewApp(
hydra.WithPlatName("myplat"), //平台名称
hydra.WithSystemName("demo"), //系统名称
hydra.WithClusterName("test"), //集群名称
hydra.WithServerTypes("api"), //服务器类型为http api
hydra.WithRegistry("fs://../")) //使用本地文件系统作为注册中心
app.API("/api",api) //注册服务
app.Start()
}
func api(ctx *hydra.Context) (r interface{}) { //服务实现
return "hello world "
}- 编译生成服务
go install hello
- 安装远程配置及本地服务
./hello install- 运行服务
./hello run- 测试服务
curl http://localhost:8090/hello
{"data":"hello world"}修改代码的服务器类型和注册方式即可
package main
import (
"github.com/micro-plat/hydra/component"
"github.com/micro-plat/hydra/hydra"
)
func main() {
app := hydra.NewApp(
hydra.WithPlatName("myplat"), //平台名称
hydra.WithSystemName("demo"), //系统名称
hydra.WithClusterName("test"), //集群名称
hydra.WithServerTypes("rpc"), //修改为RPC服务器类型
hydra.WithRegistry("fs://../")) //使用本地文件系统作为注册中心
app.RPC("/rpc",rpc) //注册为rpc服务
app.Start()
}
func rpc(ctx *hydra.Context) (r interface{}) {
return "hello world "
}测试上述代码，可在 api 服务中直接调用 RPC 服务
func api(ctx *hydra.Context) (r interface{}) {
_, result, _, err := ctx.RPC.Request("/rpc", nil, nil, true)
if err != nil {
return err
}
return result
}也可以启动多个服务器
package main
import (
"github.com/micro-plat/hydra/hydra"
)
func main() {
app := hydra.NewApp(
hydra.WithPlatName("myplat"), //平台名称
hydra.WithSystemName("demo"), //系统名称
hydra.WithClusterName("test"), //集群名称
hydra.WithServerTypes("api-rpc"), //多个服务器类型，使用"-"分隔
hydra.WithRegistry("fs://../")) //使用本地文件系统作为注册中心
app.API("/api", api)
app.RPC("/rpc", rpc) //注册为rpc服务
app.Start()
}
func rpc(ctx *hydra.Context) (r interface{}) {
return "hello world "
}
func api(ctx *hydra.Context) (r interface{}) {
_, result, _, err := ctx.RPC.Request("/rpc", nil, nil, true)
if err != nil {
return err
}
return result
}编译，安装，并启动,测试服务，可看到如下日志：
[2020/01/06 16:51:56.924002][i][1bfd99afb]初始化 /myplat/demo/api-rpc/test
[2020/01/06 16:51:56.925285][i][8b4b78124]开始启动[API]服务...
[2020/01/06 16:51:56.925598][d][8b4b78124][未启用 jwt设置]
[2020/01/06 16:51:56.925606][d][8b4b78124][未启用 ajax请求限制设置]
[2020/01/06 16:51:56.925583][i][8b4b78124][启用 静态文件]
[2020/01/06 16:51:56.925600][d][8b4b78124][未启用 固定密钥认证]
[2020/01/06 16:51:56.925590][d][8b4b78124][未启用 header设置]
[2020/01/06 16:51:56.925609][d][8b4b78124][未启用 metric设置]
[2020/01/06 16:51:56.925593][d][8b4b78124][未启用 响应格式设置]
[2020/01/06 16:51:56.925604][d][8b4b78124][未启用 远程服务认证]
[2020/01/06 16:51:56.925611][d][8b4b78124][未启用 host设置]
[2020/01/06 16:51:56.925596][d][8b4b78124][未启用 熔断设置]
[2020/01/06 16:51:57.426422][i][8b4b78124]服务启动成功(API,http://192.168.4.121:8090,1)
[2020/01/06 16:51:57.426655][i][ec80eadba]开始启动[RPC]服务...
[2020/01/06 16:51:57.427484][d][ec80eadba][未启用 远程服务认证]
[2020/01/06 16:51:57.427500][d][ec80eadba][未启用 metric设置]
[2020/01/06 16:51:57.427452][d][ec80eadba][未启用 jwt设置]
[2020/01/06 16:51:57.427492][d][ec80eadba][未启用 header设置]
[2020/01/06 16:51:57.427472][d][ec80eadba][未启用 固定密钥认证]
[2020/01/06 16:51:57.427505][d][ec80eadba][未启用 host设置]
[2020/01/06 16:51:57.928270][i][ec80eadba]服务启动成功(RPC,tcp://192.168.4.121:8081,1)
[2020/01/06 16:52:18.287947][i][979a5d210]api.request GET /api from 192.168.4.121
[2020/01/06 16:52:19.290044][i][979a5d210]rpc.request: myplat.demo.test GET /rpc from
[2020/01/06 16:52:19.290626][i][979a5d210]rpc.response: myplat.demo.test GET /rpc 200 644.078µs
[2020/01/06 16:52:19.291206][i][979a5d210]api.response GET /api 200 700.644µs
其它示例请查看以下文档