如何使用beego快速开发web系统【Golang 入门系列十三】
接着之前的内容,前面已经讲过很多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/beegogo 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,可以看到如图:
一个完整的web项目
以上就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 = webDemohttpport = 8080runmode = 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 stringUserID stringCreateTime stringAmount float64OuterTradeNo stringRemark stringStatus intMsg string}type PaymentRecordStr struct {AccountID stringPartnerID stringUserID stringCreateTime stringAmount stringOuterTradeNo stringRemark string}func init() {dbconn := beego.AppConfig.String("DBConn")db, err := sql.Open("mysql", dbconn)if err != nil {return}db.SetMaxOpenConns(2000)db.SetMaxIdleConns()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{, AccountID, rec.PartnerID, rec.UserID, rec.CreateTime, Amount, rec.OuterTradeNo, rec.Remark, , ""}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 = 1response.Msg = "已生效"return response, nil}return response, nil}func GetPaymenRec(AccountID int64) (PaymentRecord, error) {var qsql = "SELECT * FROM pay_demo WHERE account_id=?"var response PaymentRecordresponse.Msg = "失败"if AccountID != {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 stringfor 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.LocalloginTime, err := time.ParseInLocation("2006-01-02 15:04:05", timedate, DefaultTimeLoc)if err == nil {unix_time := loginTime.Unix() //time to int64response.CreateTime = time.Unix(unix_time, ).Format("2006-01-02 15:04:05")response.Status = 2response.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
<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
<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
相关文章