构建六大服务器及混合服务器
-------------
[github.com/micro-plat/hydra](https://github.com/micro-plat/hydra)
本示例通过最简单的代码，介绍构建6类服务器及组合服务器的方法
一、构建api server
二、构建mqc server
三、构建cron server
四、构建rpc server
五、构建ws server
六、构建web server
七、混合服务器
### 一、构建api server
对外提供http api 服务
```go
package main
import (
"github.com/micro-plat/hydra"
"github.com/micro-plat/hydra/hydra/servers/http"
)
func main() {
app := hydra.NewApp(
hydra.WithServerTypes(http.API),
)
//注册服务
app.API("/hello", hello)
app.Start()
}
func hello(ctx hydra.IContext) interface{} {
return "success"
}
```
对外提供 http://localhost:8080/hello 服务，通过`GET、POST`等请求时返回结果为`success`
[github.com/micro-plat/hydra](https://github.com/micro-plat/hydra)
### 二、构建mqc server
监听消息队列，有新的消息时执行对应的服务
```go
package main
import (
"github.com/micro-plat/hydra"
"github.com/micro-plat/hydra/hydra/servers/mqc"
"github.com/micro-plat/hydra/conf/vars/queue/lmq"
)
func main() {
app := hydra.NewApp(
hydra.WithServerTypes(mqc.MQC),
)
//注册服务
app.MQC("/hello",hello,"queue-name")
//设置消息队列服务器(本地内存MQ，支持redis,mqtt等)
hydra.Conf.MQC(lmq.MQ)
app.Start()
}
func hello(ctx hydra.IContext) interface{} {
return "success"
}
```
监听消息队列`queue-name`，有新消息到达时执行服务`/hello`
本示例以本地内存作为消息队列服务器(单机应用)
[github.com/micro-plat/hydra](https://github.com/micro-plat/hydra)
### 三、构建cron server
提供定时任务服务器，按周期定时执行任务
```go
package main
import (
"github.com/micro-plat/hydra"
"github.com/micro-plat/hydra/hydra/servers/cron"
)
func main() {
app := hydra.NewApp(
hydra.WithServerTypes(cron.CRON),
)
//注册服务
app.CRON("/hello",hello,"@every 5s")
app.Start()
}
func hello(ctx hydra.IContext) interface{} {
return "success"
}
```
每隔5秒执行一次"/hello"服务
### 四、构建rpc server
提供基于json的rpc协议服务器
```go
package main
import (
"github.com/micro-plat/hydra"
"github.com/micro-plat/hydra/hydra/servers/rpc"
)
func main() {
app := hydra.NewApp(
hydra.WithServerTypes(rpc.RPC),
)
//注册服务
app.RPC("/hello",hello)
app.Start()
}
func hello(ctx hydra.IContext) interface{} {
return "success"
}
```
对外提供基于RPC协议的服务，可通过hydra.C.RPC().Request组件进行调用
### 五、构建ws server
提供web socket 服务器
```go
package main
import (
"github.com/micro-plat/hydra"
"github.com/micro-plat/hydra/hydra/servers/http"
)
func main() {
app := hydra.NewApp(
hydra.WithServerTypes(http.WS),
)
//注册服务
app.WS("/hello",hello)
app.Start()
}
func hello(ctx hydra.IContext) interface{} {
return "success"
}
```
对外提供`/ws`服务，外部可通过json方式请求服务`/hello`
[github.com/micro-plat/hydra](https://github.com/micro-plat/hydra)
### 六、构建web server
提供静态文件服务
```go
package main
import (
"github.com/micro-plat/hydra"
"github.com/micro-plat/hydra/hydra/servers/http"
)
func main() {
app := hydra.NewApp(
hydra.WithServerTypes(http.WEB),
)
//配置静态文件
hydra.Conf.WEB.Static(static.WithArchive("./static.zip")) //系统自动解压static.zip自动路由到包中对应的文件
//注册服务
app.WEB("/hello",hello)
app.Start()
}
func hello(ctx hydra.IContext) interface{} {
return "success"
}
```
外部可访问`static.zip`中包含的所有静态文件和`/hello`服务
以上6种类型服务器都以服务注册的方式将服务实现对象注册到服务器，并以相同的方式启动即可使用。
### 七、混合服务器
同一个程序中包含多个服务器
```go
package main
import (
"github.com/micro-plat/hydra"
"github.com/micro-plat/hydra/hydra/servers/http"
"github.com/micro-plat/hydra/hydra/servers/cron"
)
func main() {
app := hydra.NewApp(
hydra.WithServerTypes(http.API,cron.CRON),
)
app.API("/hello",hello)
app.CRON("/hello",hello,"@every 5s")
app.Start()
}
func hello(ctx hydra.IContext) interface{} {
return "success"
}
```
以编译后的二进制文件`flowserver`为例：
```sh
$ ./flowserver run --plat test
```
[github.com/micro-plat/hydra](https://github.com/micro-plat/hydra)
日志如下：
```sh
[2020/07/08 09:36:31.140432][i][29f63e41d]初始化: /test/flowserver/api-cron/1.0.0/conf
[2020/07/08 09:36:31.143027][i][29f63e41d]启动[api]服务...
[2020/07/08 09:36:31.643524][i][b65655312]启动成功(api,http://192.168.4.121:8080,1)
[2020/07/08 09:36:31.643885][i][29f63e41d]启动[cron]服务...
[2020/07/08 09:36:31.844844][i][3908a5ccc]启动成功(cron,cron://192.168.4.121,1)
[2020/07/08 09:36:32.346047][d][3908a5ccc]this cron server is started as master
[2020/07/08 09:36:36.648149][i][01751ece6]cron.request: GET /hello from 192.168.4.121
[2020/07/08 09:36:36.648244][i][01751ece6]cron.response: GET /hello 200 193.356µs
[2020/07/08 09:36:41.651858][i][00f45e17b]cron.request: GET /hello from 192.168.4.121
[2020/07/08 09:36:41.651911][i][00f45e17b]cron.response: GET /hello 200 159.694µs
```
服务已经启动，cron server也开始按周期(每隔5秒执行一次服务`/hello`)执行任务
[github.com/micro-plat/hydra](https://github.com/micro-plat/hydra)
有疑问加站长微信联系（非本文作者）
