使用Golang+Mongodb构建简单的Blog API
(原文作者:Kyaw Myint Thein)
本文是关于使用Golang和mongodb构建简单的Blog API。它将包括使用Golang(Beego)和Mongodb构建数据库的Restful API。它是Restful API的基本框架。因此,您也可以创建您的项目。
在本文中,我主要讨论Mongodb与Golang的配合使用,Beestful API的Beego框架,错误处理等。
首先,我想分享一些关于beego框架的信息。
Beego FO是一个web框架[R Golang。在beego中,您可以构建Web应用程序和Restful API。这次,我想谈论Beego API。如果您想详细了解beego,请查看此链接http://beego.me/。
Beego包含称为“ bee”的命令行工具,用于生成和设置文件和项目框架。您也可以使用“ bee”命令来运行beego项目。
这次,我不想在本文中解释如何安装golang。因此,让我们从安装Beego框架开始。
首先,使用以下命令在计算机中安装beego和bee工具。
go get -u github.com/beego/bee
go get -u github.com/astaxie/beego
然后,转到$ GOPATH / src并使用“ bee tools”来构建beego api骨架。使用以下命令来搭建“ blog_api”。
bee api blog_api
现在,您可以在$ GOPATH / src下找到blog_api项目。使用以下命令运行项目。
cd blog_api && bee run -downdoc=true -gendoc=true
Beego使用“ Swagger”获取api文档。“ -downdoc = true”命令将自动下载项目中的swagger文件夹,“-gendoc = true”用于生成api文档。现在,您可以打开以下链接以查看您的项目正在运行。
http://127.0.0.1:8080/swagger/swagger-1/
现在,默认情况下,您的项目在端口8080上运行。
Beego也是MVC框架。下图是beego api项目文件夹结构。conf文件夹包含用于配置的app.conf文件。您也可以在controllers文件夹和模型中创建controller。路由器包括router.rb,用于为您的控制器指定路由。docs用于api文档。它还包括用于测试用例的测试文件夹。
对于本文,我想通过将Mongodb用于数据库来构建简单的Blog API。因此,我们需要连接Beego和mongodb数据库。
对于mongodb,我将使用https://labix.org/mgo golang库。使用该库之前,需要在计算机中安装golang软件包。您可以按照以下说明使用“ go get”命令进行安装。
go get gopkg.in/mgo.v2
然后,我们可以使用该库来连接本地计算机中的mongodb数据库。在开始构建Blog API之前,我们需要为mongodb数据库连接创建一些基本的实现。
之后,在您的models文件夹中创建db文件夹,如下所示。
首先,我们将在db文件夹下创建service.go。
package db
import “gopkg.in/mgo.v2”
type Service struct {
baseSession *mgo.Session
queue chan int
URL string
Open int
}var service Service
func (s *Service) New() error {
var err error
s.queue = make(chan int, maxPool)
for i := 0; i < maxPool; i = i + 1 {
s.queue <- 1
}
s.Open = 0
s.baseSession, err = mgo.Dial(s.URL)
return err
}func (s *Service) Session() *mgo.Session {
<-s.queue
s.Open++
return s.baseSession.Copy()
}func (s *Service) Close(c *Collection) {
c.db.s.Close()
s.queue <- 1
s.Open —
}
在service.go中,有3个功能,例如创建新的mongo会话,get会话和关闭会话。
然后,我们将创建database.go。
package db
import “gopkg.in/mgo.v2”
type Database struct {
s *mgo.Session
name string
session *mgo.Database
}func (db *Database) Connect() {
db.s = service.Session()
session := *db.s.DB(db.name)
db.session = &session
}func newDBSession(name string) *Database {
var db = Database{
name: name,
}
db.Connect()
return &db
}
在database.go中,有2个主要功能通过使用service.go中的mongo会话来连接mongodb数据库。
之后,我们还需要创建driver.go
package db
import “github.com/astaxie/beego”
var maxPool int
func init() {
var err error
maxPool, err = beego.AppConfig.Int(“DBMaxPool”)
if err != nil {
// todo: panic!!!
// panic(err)
println(err)
}
// init method to start db
checkAndInitServiceConnection()
}func checkAndInitServiceConnection() {
if service.baseSession == nil {
service.URL = beego.AppConfig.String(“DBPath”)
err := service.New()
if err != nil {
// todo: panic!!!
// panic(err)
println(err)
}
}
}
在driver.go中,有一个功能负责使用service.go检查mongo会话并创建新会话。在此文件中,我们从app.conf中读取了一些配置。(例如beego.AppConfig.String(“ DBPath”))。因此,您需要按照以下步骤在app.conf文件中创建DBPath。
appname = blog_api
httpport = 8080
runmode = dev
autorender = false
copyrequestbody = true
EnableDocs = true
EnableDocs = true
DBPath = “localhost”
DBMaxPool = 30
DBName = “blog_api”
然后,我们还需要创建collection.go文件
package db
import (
“github.com/astaxie/beego”
“gopkg.in/mgo.v2”
)type Collection struct {
db *Database
name string
Session *mgo.Collection
}func (c *Collection) Connect() {
session := *c.db.session.C(c.name)
c.Session = &session
}func NewCollectionSession(name string) *Collection {
var c = Collection{
db: newDBSession(beego.AppConfig.String(“DBName”)),
name: name,
}
c.Connect()
return &c
}func (c *Collection) Close() {
service.Close(c)
}
collection.go用于连接以获得mongodb集合的新会话。
现在可以在模型中将mongodb用作数据库了。我将继续作为第2部分,在builidng博客API中使用该功能。
原文地址:
https://medium.com/@kyawmyintthein/building-simple-blog-api-with-golang-mongodb-part-1-d9de449c1fd6