Golang 入门系列（十三）用Beego开发web应用

接着之前的内容，前面已经讲过很多Golang的基础语法，mysql的使用，redis的使用，也讲了orm框架，如何创建一个webapi 服务等等，感兴趣的可以看看以前的文章，https://www.cnblogs.com/zhangweizhong/category/1275863.html，

今天要来说一说，如何用beego开发web应用。

介绍

beego 是一个快速开发 Go 应用的 HTTP 框架，他可以用来快速开发 API、Web 及后端服务等各种应用，是一个 RESTful 的框架，同时也是一个关注度和使用量都比价高的开源项目。我认为它是go初学者比较容易上手的一门MVC Web框架。

它是由国内团队开发的开源框架，文档基本都是中文，简单易懂。

安装

　　需要安装 Beego 和 Bee 的开发工具:

$ go get github.com/astaxie/beego
$ go get github.com/beego/bee

　　注意：

beege和bee是两个概念。beego是框架，bee是工具，是命令。
在安装Beego前，先确认是否将$GOPATH/bin写入GO环境中。

创建应用

　　创建一个名为webDemo的应用

$ bee new webDemo     //创建一个web应用
$ bee api webDemo     //创建一个api应用

编译运行

　　进入webDemo目录中，执行bee run，就会完成编译、运行：

$ bee run

　　成功后，打开浏览器访问：http://localhost:8080,可以看到如图：

开发

　　以上就beego 的安装和运行简单的介绍完了，下面我们就通过订单查询和新增的例子来学习学习如何用beego开发web应用。

　　一般的 beego 项目的目录如下所示：

├── conf           //配置文件
│   └── app.conf
├── controllers    //控制器
│   └── default.go
├── main.go
├── models         //模型
│   └── models.go
├── routers       //路由
│   └──router.go
├── static         //静态文件
│   ├── css
│   ├── ico
│   ├── img
│   └── js
└── views          //界面└── index.tpl

conf

　　在app.conf 中增加数据库连接配置

appname = webDemo
httpport = 8080
runmode = devDBConn="root:root@tcp(localhost:3306)/zwz_test?charset=utf8"

controller

　　在controller目录下，增加pay.go

package controllersimport ("webDemo/models"
)func (c *MainController) PayQuery() {AccountID, _ := c.GetInt64("AccountID1")payment, _ := models.GetPaymenRec(AccountID)c.Data["AccountID"] = payment.AccountIDc.Data["PartnerID"] = payment.PartnerIDc.Data["UserID"] = payment.UserIDc.Data["CreateTime"] = payment.CreateTimec.Data["Amount"] = payment.Amountc.Data["OuterTradeNo"] = payment.OuterTradeNoc.Data["Remark"] = payment.Remarkc.Data["Status"] = payment.Statusc.Data["Msg"] = payment.Msgc.TplName = "query.html"
}
func (c *MainController) PayAdd() {var payment models.PaymentRecordStrc.ParseForm(&payment)pay, _ := models.AddPaymenRec(payment)c.Data["AccountID"] = pay.AccountIDc.Data["PartnerID"] = pay.PartnerIDc.Data["UserID"] = pay.UserIDc.Data["CreateTime"] = pay.CreateTimec.Data["Amount"] = pay.Amountc.Data["OuterTradeNo"] = pay.OuterTradeNoc.Data["Remark"] = pay.Remarkc.TplName = "query.html"
}

models

　　1. 在models目录下，增加pay.go

package modelsimport ("database/sql""errors""strconv""time""github.com/astaxie/beego"_ "github.com/go-sql-driver/mysql"
)var Db *sql.DBtype PaymentRecord struct {Id           int64AccountID    int64PartnerID    string UserID string CreateTime string Amount float64 OuterTradeNo string Remark string Status int Msg string } type PaymentRecordStr struct { AccountID string PartnerID string UserID string CreateTime string Amount string OuterTradeNo string Remark string } func init() { dbconn := beego.AppConfig.String("DBConn") db, err := sql.Open("mysql", dbconn) if err != nil { return } db.SetMaxOpenConns(2000) db.SetMaxIdleConns(0) db.Ping() Db = db } func Close() { if Db != nil { Db.Close() } } func AddPaymenRec(rec PaymentRecordStr) (PaymentRecord, error) { var isql = "INSERT pay_demo SET account_id=?,partner_id=?,user_id=?,amount=?,outer_tradeno=?,remark=?" AccountID, _ := strconv.ParseInt(rec.AccountID, 10, 64) Amount, _ := strconv.ParseFloat(rec.Amount, 64) response := PaymentRecord{0, AccountID, rec.PartnerID, rec.UserID, rec.CreateTime, Amount, rec.OuterTradeNo, rec.Remark, 0, ""} if Db == nil { return response, errors.New("AddPaymenRec connect mysql failed") } stmt, _ := Db.Prepare(isql) defer stmt.Close() beego.Informational("AddPaymenRec rec=%#v", rec) res, err := stmt.Exec(AccountID, rec.PartnerID, rec.UserID, Amount, rec.OuterTradeNo, rec.Remark) if err == nil { response.Id, _ = res.LastInsertId() response.Status = 1 response.Msg = "已生效" return response, nil } return response, nil } func GetPaymenRec(AccountID int64) (PaymentRecord, error) { var qsql = "SELECT * FROM pay_demo WHERE account_id=?" var response PaymentRecord response.Msg = "失败" if AccountID != 0 { if Db == nil { return response, errors.New("GetPaymenRec connect mysql failed") } stmt, _ := Db.Prepare(qsql) rows, err := stmt.Query(AccountID) defer rows.Close() if err != nil { return response, err } var timedate string for rows.Next() { err = rows.Scan(&response.Id, &response.AccountID, &response.PartnerID, &response.UserID, &timedate, &response.Amount, &response.OuterTradeNo, &response.Remark) if err != nil { return response, err } DefaultTimeLoc := time.Local loginTime, err := time.ParseInLocation("2006-01-02 15:04:05", timedate, DefaultTimeLoc) if err == nil { unix_time := loginTime.Unix() //time to int64 response.CreateTime = time.Unix(unix_time, 0).Format("2006-01-02 15:04:05") response.Status = 2 response.Msg = "成功" return response, err } else { return response, err } } return response, nil } return response, errors.New("GetPaymenRec Requset is non porinter") }

　　 2. 在数据库中，增加pay_demo表

CREATE TABLE `pay_demo` (`id` int(64) NOT NULL AUTO_INCREMENT,`account_id` int(64) NOT NULL,`partner_id` varchar(50) CHARACTER SET utf8 DEFAULT NULL,`user_id` varchar(50) CHARACTER SET utf8 DEFAULT NULL,`create_time` datetime DEFAULT CURRENT_TIMESTAMP,`amount` double DEFAULT '0',`outer_tradeno` varchar(50) CHARACTER SET utf8 DEFAULT NULL,`remark` varchar(255) CHARACTER SET utf8 DEFAULT NULL,PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=5024 DEFAULT CHARSET=utf8 COLLATE=utf8_bin;

views

　　将原有的index.tpl 删除，增加新的index.html 和query.html

index.html

<!DOCTYPE html><html>
<head><title>webDemo</title><meta http-equiv="Content-Type" content="text/html; charset=utf-8">
</head><body>
<div><form action="/query" method="Post"><div>GetPaymentBy AccountID:<input  type="text" name="AccountID1" /></div><div><input type= "submit" name="n" /></div></form><br/><br/><form action="/add" method="Post"><div>AccountID:<input  type="text" name="AccountID" /></div><div>PartnerID:<input  type="text" name="PartnerID" /></div><div>UserID   :<input  type="text" name="UserID" /></div><div>CreateTime:<input  type="text" name="CreateTime" /></div><div>Amount:<input  type="text" name="Amount" /></div><div>OuterTradeNo:<input  type="text" name="OuterTradeNo" /></div><div>Remark:<input  type="text" name="Remark" /></div><div><input type= "submit" name="add" value="添加"/></div></form></div>
</body>
</html>

query.html

<!DOCTYPE html><html>
<head><title>BeegoDemo</title><meta http-equiv="Content-Type" content="text/html; charset=utf-8">
</head><body><div>        <div>Payment:</div><div>AccountID:{{.AccountID}}</div><div>PartnerID:{{.PartnerID}}</div><div>UserID:{{.UserID}}</div><div>CreateTime:{{.CreateTime}}</div><div>Amount:{{.Amount}}</div><div>        OuterTradeNo:{{.OuterTradeNo}}</div><div>Remark:{{.Remark}}</div></div>
</body>
</html>

routers

　　在router.go 中增加以上新增的2个路由

package routersimport ("webDemo/controllers""github.com/astaxie/beego"
)func init() {beego.Router("/query", &controllers.MainController{}, "Post:PayQuery")        // 新增PayQuery路由beego.Router("/add", &controllers.MainController{}, "Post:PayAdd")　　　　　　　// 新增PayAdd路由beego.Router("/", &controllers.MainController{})
}

重新运行

　　增加完以上代码之后，重新运行webDemo应用，就可以看到我们新增加的订单查询和新增订单的功能。

最后

　　1. 以上就把beego 的安装给介绍完了。同时也通过简单的订单支付的例子，介绍如何使用beego 开发web应用。

·　　2. 这里只是对beego 做一个最基本的介绍，想要详细了解beego 的各种功能，可以去它的官网：https://beego.me

　　 3. 完整例子下载：webDemo

转载于:https://www.cnblogs.com/zhangweizhong/p/10919672.html