hydra是一个分布式高可用服务框架

hydra是一个分布式高可用服务框架

hydra

后端全栈式服务框架，提供接口服务器、web 服务器、websocket 服务器，RPC 服务器、统一调度服务器、消息消费服务器。并具有如下特点：

统一开发模式

规范代码编写，采用统一方式编写服务

统一安装、启停、更新

采用相同的方式进行系统初始化，服务启动、停止、热更新等

统一配置管理

统一采用 zookeeper 或 fs 保存配置,本地零配置。并采用统一方式进行配置安装

统一基础框架

对缓存、数据库、消息队列、远程调用(GRPC)、日志归集、加解密等进行统一封装

统一日志框架

集成本地日志、远程日志服务，对日志进行统一归集与编排。

统一服务治理

集成服务注册、服务发现、负载均衡、流量控制、服务降级、熔断等，并对服务状态进行监控

统一认证服务

可集成 SAS 远程认证服务集成，实现请求的访问权限控制、加解密等

统一监控报警

集成系统监控、业务监控。对系统的主要指标(带宽、CPU、内存、硬盘、IO)和业务主要指标(QPS、处理时长、异常响应结果)进行统一采集，并存入 influxdb 中，可使用 grafana 进行实时查看。与报警系统(convoy)集成,可实现消息队列、数据库、服务状态等监控，和短信、微信等实时报警

多种集群模式

支持集群分组及对等，主备，分⽚等集群模式

golang 原生代码实现 20+线上项目实践经验

示例

一. api 示例

新建文件夹hello,添加main.go文件,输入以下代码:

package mainimport ( "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"}

二. RPC 示例

修改代码的服务器类型和注册方式即可

package mainimport ( "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 mainimport ( "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

其它示例请查看以下文档

hydra 微服务开发入门

hydra 微服务开发规范

构建 API 服务一

构建 API 服务二

构建消息消费服务(MQC)

构建任务调度服务(CRON)

构建远程调用服务(RPC)

构建静态文件服务

构建 websocket 服务(WS)

安全认证(jwt,数字摘要，远程认证)

性能指标收集(metric)

日志配置与管理

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。