http2/

README

freedom

http2和依赖倒置

---

启动

$  go run application/main.go
#  本程序是一个购物的小示例, 浏览器可输入http://127.0.0.1:8000/shop/1, 1-4为商品ID

http2 server

main.go

//创建应用
app := freedom.NewApplication()
//安装第三方日志中间件
installLogrus(app)

//创建 http2.0 H2cRunner
h2caddrRunner := app.CreateH2CRunner(config.Get().App.Other["listen_addr"].(string))
app.Run(h2caddrRunner, *config.Get().App)

func installLogrus(app freedom.Application) {
	logrus.SetLevel(logrus.InfoLevel)
	logrus.SetFormatter(&logrus.JSONFormatter{TimestampFormat: "2006-01-02 15:04:05.000"})
	//安装Logrus后，日志输出全部使用Logrus。
	freedom.Logger().Install(logrus.StandardLogger())
}

// 安装中间件
func installMiddleware(app freedom.Application) {
	/*
		设置框架自带中间件,可重写
		NewTrace默认设置了总线, 下游服务和事件消费者服务都会拿到TRACE-ID
		NewLogger和NewRuntimeLogger 默认读取了总线里的TRACE-ID, 所有上下游服务打印日志全部都携带TRACE-ID
	*/
	app.InstallMiddleware(middleware.NewTrace("TRACE-ID"))
	app.InstallMiddleware(middleware.NewLogger("TRACE-ID", true))
	app.InstallMiddleware(middleware.NewRuntimeLogger("TRACE-ID"))

	app.InstallBusMiddleware(newBus(config.Get().App.Other["service_name"].(string)))
}

// newBus 自定义总线中间件示例.
func newBus(serviceName string) func(freedom.Runtime) {
	//调用下游服务和事件消费者将传递service-name， 下游服务和mq事件消费者，使用 Runtime.Bus() 可获取到service-name。
	return func(run freedom.Runtime) {
		bus := run.Bus()
		bus.Add("service-name", serviceName)
	}
}

依赖倒置

依赖倒置的本质是以 依赖注入 + 接口隔离 的方式隔离 实现和调用依赖，可以灵活的应对多变的业务和多人协作。

/*
	购买的接口定义 
	ShoppingInterface 接口声明在 service包， 由controller使用
	文件 application/interface.go
*/
type ShoppingInterface interface {
	Shopping(goodsID int) string
}

/*
	文件 controllers/shop.go
*/
type ShopController struct {
	Shopping services.ShoppingInterface	//定义接口变量, 框架会自动注入该接口的实现
}

// Get handles the GET: /shop/:id route.
func (s *ShopController) GetBy(id int) string {
	//该接口的使用 s.Shopping
	return s.Shopping.Shopping(id)
}

/*
	商品的接口定义
	Goods 接口声明在 repositorys包， 由service使用
	文件 repositorys/interface.go
*/
type GoodsInterface interface {
	GetGoods(goodsID int) objects.GoodsModel
}

/*
	文件 application/shop.go
*/
type ShopService struct {
	Goods   repositorys.GoodsInterface //定义接口变量, 框架会自动注入该接口的实现
}

// Shopping implment Shopping interface
func (s *ShopService) Shopping(goodsID int) string {
	//该接口的使用 s.Goods
	entity := s.Goods.GetGoods(goodsID)
	return fmt.Sprintf("您花费了%d元, 购买了一件 %s。", entity.Price, entity.Name)
}

http2 client

/*
	Repo 数据源访问
	1.实例必须继承 freedom.Repository
	2.创建http请求 .NewHttpRequest()
	3.创建http2.0请求 .NewH2CRequest()
*/
type GoodsRepository struct {
	freedom.Repository
}

// GetGoods implment Goods interface
func (repo *GoodsRepository) GetGoods(goodsID int) (result objects.GoodsModel) {
	//篇幅所限，示例直接调用自身服务的其他http接口，而不是下游。
	addr := "http://127.0.0.1:8000/goods/" + strconv.Itoa(goodsID)
	repo.NewH2CRequest(addr).Get().ToJSON(&result)

	correctReq := repo.NewH2CRequest(addr)
	go func() {
		//panic 错误方式, repo.NewH2CRequest方法使用了Runtime.Bus(),用来设置传递给下游的总线相关数据，并发中请求运行时结束会导致panic
		var model objects.GoodsModel
		repo.NewH2CRequest(addr).Get().ToJSON(&model)

		//正确方式1, 在请求内创建
		correctReq.Get().ToJSON(&model)

		//正确方式2, 不向下游传递trace相关数据,不会访问请求运行时。通常访问外部服务设置false。
		repo.NewH2CRequest(addr, false).Get().ToJSON(&model)
	}()
	return result
}