大佬教程收集整理的这篇文章主要介绍了Golang 使用 Beego 与 Mgo 开发的示例程序，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。
这个示例的代码可以在 GoingGo 帐户下的 GitHub 仓库中找到：https://github.com/goinggo/beego-mgo。
你可以拉取并运行它。它使用了我在 MongoLab 创建的公开 MongoDB 数据库。你会需要安装 git 和 bazaar 以保证能够使用 go get 来将它安装到你系统中。
go get github.com/goinggo/beego-mgo
使用 zscripts 文件夹里的脚步可以快速运行或测试 Web 应用程序。
app：包含 business、model 和 service 层。
app/models：用于 business 和 service 层的数据结构。
app/business：被 controller 和处理 business 规则的函数所调用。多种服务的组合调用可用于实现更大层面上的功能。
controllers：URL 或 Web API 调用的切入点。控制器会直接调用 business 层的函数来直接处理请求。
routes：用于 URL 和控制器代码的映射。
static：用于存放脚本、CSS 和图片等静态资源。
test：可使用 go test 运行的测试用例。
views：用于存放模板文件。
zscripts：帮助更方便构建、运行和测试 Web 应用程序的脚本。
这些层的代码组成了 Web 应用程序。我的框架背后的理念是尽可能的抽象化代码为样板。这就要求我实现一个 base 控制器包和 base 服务包。
base 控制器包由所有控制器所要求的默认抽象的控制器行为来组成：
type (
BaseController struct {
beego.Controller
services.Service
}
)
func (this *BaseController) Prepare() {
this.UserId = "unkNown"
tracelog.TRACE(this.UserId,"Before","UserId[%s] Path[%s]",this.UserId,this.Ctx.Request.URL.Path)
var err error
this.MongoSession,err = mongo.CopyMonotonicSession(this.UserId)
if err != nil {
tracelog.ERRORf(err,this.Ctx.Request.URL.Path)
this.ServeError(err)
}
}
func (this *BaseController) Finish() {
defer func() {
if this.MongoSession != nil {
mongo.CloseSession(this.UserId,this.MongoSession)
this.MongoSession = nil
}
}()
tracelog.COMPLETEDf(this.UserId,"Finish",this.Ctx.Request.URL.Path)
}
一个名为 BaseController 的新类型直接由类型 beego.Controller 和 services.Service 嵌入而组成。这样做就可以直接获得这两个类型的所有字段和方法给 BaseController，并直接操作这些字段和方法。
服务包用于样板化所有服务所要求的代码：
type (
Service struct {
MongoSession *mgo.Session
UserId string
}
)
func (this *Service) DBAction(databaseName string,collectionName string,mongoCall mongo.MongoCall) (err error) {
return mongo.Execute(this.UserId,this.MongoSession,databaseName,collectionName,mongoCall)
}
在 Service 类型中，包含了 Mongo 会话和用户 ID。函数 DBAction 提供了运行 MongoDB 命令和查询的抽象层。
基于 base 类型和样板函数，我们现在可以实现一个 Web 调用了：
类型 BuoyController 实现了两个结合 BaseController 和 business 层 Web API 调用。我们主要关注名为 Station 的 Web 调用。
type BuoyController struct {
bc.BaseController
}
func (this *BuoyController) Station() {
buoyBusiness.Station(&this.BaseController,this.GetString(":stationId"))
}
BuoyController 直接由单独的 BaseController 组成。通过这种组合方式，BuoyController 自动获得了已经自定义实现的 Prepare和 Finish 方法以及所有 beego.Controller 的字段。
函数 Station 通过下面路由分发。stationId 作为 URL 的最后一项。当这个路由被请求时，一个 BuoyController 对象会被实例化并执行函数 Station。
beego.Router("/station/:stationId",&controllers.BuoyController{},"get:Station")
Station 会在底层调用 business 层的代码来处理请求。
Buoy Business 包实现了 BuoyController 的 business 层。让我看看在 BuoyController 中的函数 Station 所调用的 business 层的代码是怎样的：
func Station(controller *bc.BaseController,stationId string) {
defer bc.CatchPanic(controller,"Station")
tracelog.STARTEDf(controller.UserId,"Station","StationId[%s]",stationId)
buoyStation,err := buoyService.FindStation(&controller.Service,stationId)
if err != nil {
ServeError(err)
return
}
controller.Data["json"] = &buoyStation
controller.ServeJson()
tracelog.COMPLETED(controller.UserId,"Station")
}
你可以看到 business 层的函数 Station 处理了整个请求的逻辑。这个函数还使用了Buoy Service 来处理与 MongoDB 的交互。
Buoy Service 包实现了与 MongoDB 的交互。让我们来看下被 business 层的函数 Station 所调用的函数 FindStation 的代码：
func FindStation(service *services.Service,stationId string) (buoyStation *buoyModels.BuoyStation,err error) {
defer helper.CatchPanic(&err,service.UserId,"FindStation")
tracelog.STARTED(service.UserId,"FindStation")
queryMap := bson.M{"station_id": stationId}
tracelog.TRACE(service.UserId,"FindStation","Query : %s",mongo.ToString(queryMap))
buoyStation = &buoyModels.BuoyStation{}
err = service.DBAction(Config.Database,"buoy_stations",func(collection *mgo.Collection) error {
return collection.Find(queryMap).One(buoyStation)
})
if err != nil {
tracelog.COMPLETED_ERROR(err,"FindStation")
return buoyStation,err
}
tracelog.COMPLETED(service.UserId,"FindStation")
return buoyStation,err
}
FindStation 用于准备通过 DBAction 函数进行与 MongoDB 的查询与执行操作。
我们现在有一个 URL 可以路由到一个控制器以及相应的 business 与 service 层的逻辑，它可以通过以下方式测试：
func TestStation(t *testing.T) {
r,_ := http.NewRequest("GET","/station/42002",nil)
w := httptest.NewRecorder()
beego.BeeApp.Handlers.ServeHTTP(w,r)
err := struct {
Error string
}{}
json.Unmarshal(w.Body.Bytes(),&err)
Convey("Subject: Test Station Endpoint\n",t,func() {
Convey("Status Code Should Be 200",func() {
So(w.Code,ShouldEqual,200)
})
Convey("The Result Should Not Be Empty",func() {
So(w.Body.Len(),ShouldBeGreaterThan,0)
})
Convey("The Should Be No Error In The Result",func() {
So(len(err.Error),0)
})
})
}
测试创建了一个某个路由的虚拟调用。这种做法很赞，因为我们不需要真正地去启动一个 Web 应用来测试代码。使用 goconvey 我们能够创建非常优雅的输出且易于阅读。
以下是一个测试失败的样例：
Subject: Test Station Endpoint
Status Code Should Be 200
The Result Should Not Be Empty
The Should Be No Error In The Result
Failures:
* /Users/bill/Spaces/Go/Projects/src/github.com/goinggo/beego-mgo/test/endpoints/buoyEndpoints_test.go
Line 35:
Expected: '200'
Actual: '400'
(Should be equal)
* /Users/bill/Spaces/Go/Projects/src/github.com/goinggo/beego-mgo/test/endpoints/buoyEndpoints_test.go
Line 37:
Expected: '0'
Actual: '9'
(Should be equal)
3 assertions thus far
--- FAIL: TestStation-8 (0.03 seconds)
以下是一个测试成功的样例：
Subject: Test Station Endpoint
Status Code Should Be 200
The Result Should Not Be Empty
The Should Be No Error In The Result
3 assertions thus far
--- PASS: TestStation-8 (0.05 seconds)
花点时间下载这个项目随便看看。我尽最大努力让你能够清晰地看到我所想要展示给你的重点。beego 框架让你能够非常轻松地实现抽象和样板代码，遵照 go 的风格集成 go 测试、运行及部署。
以上是大佬教程为你收集整理的Golang 使用 Beego 与 Mgo 开发的示例程序全部内容，希望文章能够帮你解决Golang 使用 Beego 与 Mgo 开发的示例程序所遇到的程序开发问题。
如果觉得大佬教程网站内容还不错，欢迎将大佬教程推荐给程序员好友。
本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。