使用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