接着之前的内容，前面已经讲过很多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 的开发工具:
1$ go get github.com/astaxie/beego 2$ go get github.com/beego/bee
注意：
- beege和bee是两个概念。beego是框架，bee是工具，是命令。
- 在安装Beego前，先确认是否将$GOPATH/bin写入GO环境中。
创建应用
创建一个名为webDemo的应用
1$ bee new webDemo //创建一个web应用 2$ bee api webDemo //创建一个api应用
编译运行
进入webDemo目录中，执行bee run，就会完成编译、运行：
$ bee run
成功后，打开浏览器访问：http://localhost:8080,可以看到如图：
开发
以上就beego 的安装和运行简单的介绍完了，下面我们就通过订单查询和新增的例子来学习学习如何用beego开发web应用。
一般的 beego 项目的目录如下所示：
1├── conf //配置文件 2│ └── app.conf 3├── controllers //控制器 4│ └── default.go 5├── main.go 6├── models //模型 7│ └── models.go 8├── routers //路由 9│ └──router.go 10├── static //静态文件 11│ ├── css 12│ ├── ico 13│ ├── img 14│ └── js 15└── views //界面 16 └── index.tpl
conf
在app.conf 中增加数据库连接配置
1appname = webDemo 2httpport = 8080 3runmode = dev 4 5DBConn="root:root@tcp(localhost:3306)/zwz_test?charset=utf8"
controller
在controller目录下，增加pay.go
1package controllers 2 3import ( 4 "webDemo/models" 5) 6 7func (c *MainController) PayQuery() { 8 AccountID, _ := c.GetInt64("AccountID1") 9 payment, _ := models.GetPaymenRec(AccountID) 10 c.Data["AccountID"] = payment.AccountID 11 c.Data["PartnerID"] = payment.PartnerID 12 c.Data["UserID"] = payment.UserID 13 c.Data["CreateTime"] = payment.CreateTime 14 c.Data["Amount"] = payment.Amount 15 c.Data["OuterTradeNo"] = payment.OuterTradeNo 16 c.Data["Remark"] = payment.Remark 17 c.Data["Status"] = payment.Status 18 c.Data["Msg"] = payment.Msg 19 c.TplName = "query.html" 20} 21func (c *MainController) PayAdd() { 22 var payment models.PaymentRecordStr 23 c.ParseForm(&payment) 24 pay, _ := models.AddPaymenRec(payment) 25 c.Data["AccountID"] = pay.AccountID 26 c.Data["PartnerID"] = pay.PartnerID 27 c.Data["UserID"] = pay.UserID 28 c.Data["CreateTime"] = pay.CreateTime 29 c.Data["Amount"] = pay.Amount 30 c.Data["OuterTradeNo"] = pay.OuterTradeNo 31 c.Data["Remark"] = pay.Remark 32 c.TplName = "query.html" 33}
models
1. 在models目录下，增加pay.go
1package models 2 3import ( 4 "database/sql" 5 "errors" 6 7 "strconv" 8 "time" 9 10 "github.com/astaxie/beego" 11 _ "github.com/go-sql-driver/mysql" 12) 13 14var Db *sql.DB 15 16type PaymentRecord struct { Id int64 AccountID int64 PartnerID 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表
1CREATE TABLE `pay_demo` ( 2 `id` int(64) NOT NULL AUTO_INCREMENT, 3 `account_id` int(64) NOT NULL, 4 `partner_id` varchar(50) CHARACTER SET utf8 DEFAULT NULL, 5 `user_id` varchar(50) CHARACTER SET utf8 DEFAULT NULL, 6 `create_time` datetime DEFAULT CURRENT_TIMESTAMP, 7 `amount` double DEFAULT '0', 8 `outer_tradeno` varchar(50) CHARACTER SET utf8 DEFAULT NULL, 9 `remark` varchar(255) CHARACTER SET utf8 DEFAULT NULL, 10 PRIMARY KEY (`id`) 11) ENGINE=InnoDB AUTO_INCREMENT=5024 DEFAULT CHARSET=utf8 COLLATE=utf8_bin;
views
将原有的index.tpl 删除，增加新的index.html 和query.html
index.html
1<!DOCTYPE html> 2 3<html> 4<head> 5 <title>webDemo</title> 6 <meta http-equiv="Content-Type" content="text/html; charset=utf-8"> 7</head> 8 9<body> 10<div> 11 <form action="/query" method="Post"> 12 <div> 13 GetPaymentBy AccountID:<input type="text" name="AccountID1" /> 14 </div> 15 16 <div> 17 <input type= "submit" name="n" /> 18 </div> 19 </form> 20 <br/> 21 <br/> 22 <form action="/add" method="Post"> 23 <div> 24 AccountID:<input type="text" name="AccountID" /> 25 </div> 26 <div> 27 PartnerID:<input type="text" name="PartnerID" /> 28 </div> 29 <div> 30 UserID :<input type="text" name="UserID" /> 31 </div> 32 <div> 33 CreateTime:<input type="text" name="CreateTime" /> 34 </div> 35 <div> 36 Amount:<input type="text" name="Amount" /> 37 </div> 38 <div> 39 OuterTradeNo:<input type="text" name="OuterTradeNo" /> 40 </div> 41 <div> 42 Remark:<input type="text" name="Remark" /> 43 </div> 44 45 <div> 46 <input type= "submit" name="add" value="添加"/> 47 </div> 48 </form> 49 50</div> 51</body> 52</html>
query.html
1<!DOCTYPE html> 2 3<html> 4<head> 5 <title>BeegoDemo</title> 6 <meta http-equiv="Content-Type" content="text/html; charset=utf-8"> 7</head> 8 9<body> 10 <div> 11 <div> 12 Payment: 13 </div> 14 <div> 15 AccountID:{{.AccountID}} 16 </div> 17 <div> 18 PartnerID:{{.PartnerID}} 19 </div> 20 <div> 21 UserID:{{.UserID}} 22 </div> 23 <div> 24 CreateTime:{{.CreateTime}} 25 </div> 26 <div> 27 Amount:{{.Amount}} 28 </div> 29 <div> 30 OuterTradeNo:{{.OuterTradeNo}} 31 </div> 32 <div> 33 Remark:{{.Remark}} 34 </div> 35 36 37 </div> 38</body> 39</html>
routers
在router.go 中增加以上新增的2个路由
1package routers 2 3import ( 4 "webDemo/controllers" 5 "github.com/astaxie/beego" 6) 7 8func init() { 9 beego.Router("/query", &controllers.MainController{}, "Post:PayQuery") // 新增PayQuery路由 10 beego.Router("/add", &controllers.MainController{}, "Post:PayAdd") // 新增PayAdd路由 11 beego.Router("/", &controllers.MainController{}) 12}
重新运行
增加完以上代码之后，重新运行webDemo应用，就可以看到我们新增加的订单查询和新增订单的功能。
最后
1. 以上就把beego 的安装给介绍完了。同时也通过简单的订单支付的例子，介绍如何使用beego 开发web应用。
· 2. 这里只是对beego 做一个最基本的介绍，想要详细了解beego 的各种功能，可以去它的官网：https://beego.me
3. 完整例子下载：webDemo