GetMsgServer

examples/beego/beego.go

@@ -20,14 +20,13 @@ func hello(ctx *context.Context) {
 	}
 	wc := gowechat.NewWechat(config)
 
-	// 传入request和responseWriter
-	var mp *gowechat.MpMgr
-	var err error
-	mp, err = wc.Mp()
+	mp, err := wc.Mp()
 	if err != nil {
 		return
 	}
-	server := mp.GetServer(ctx.Request, ctx.ResponseWriter)
+
+	// 传入request和responseWriter
+	server := mp.GetMsgServer(ctx.Request, ctx.ResponseWriter)
 	//设置接收消息的处理方法
 	server.SetMessageHandler(func(msg message.MixMessage) *message.Reply {
 

examples/gin/gin.go

@@ -5,6 +5,7 @@ import (
 
 	"github.com/gin-gonic/gin"
 	"github.com/yaotian/gowechat"
+	gcontext "github.com/yaotian/gowechat/context"
 	"github.com/yaotian/gowechat/mp/message"
 )
 
@@ -18,7 +19,7 @@ func main() {
 func hello(c *gin.Context) {
 
 	//配置微信参数
-	config := &gowechat.Config{
+	config := gcontext.Config{
 		AppID:          "your app id",
 		AppSecret:      "your app secret",
 		Token:          "your token",
@@ -26,8 +27,13 @@ func hello(c *gin.Context) {
 	}
 	wc := gowechat.NewWechat(config)
 
+	mp, err := wc.Mp()
+	if err != nil {
+		return
+	}
+
 	// 传入request和responseWriter
-	server := wc.GetServer(c.Request, c.Writer)
+	server := mp.GetMsgServer(c.Request, c.Writer)
 	//设置接收消息的处理方法
 	server.SetMessageHandler(func(msg message.MixMessage) *message.Reply {
 
@@ -37,7 +43,7 @@ func hello(c *gin.Context) {
 	})
 
 	//处理消息接收以及回复
-	err := server.Serve()
+	err = server.Serve()
 	if err != nil {
 		fmt.Println(err)
 		return

examples/http/http.go

@@ -5,13 +5,14 @@ import (
 	"net/http"
 
 	"github.com/yaotian/gowechat"
+	gcontext "github.com/yaotian/gowechat/context"
 	"github.com/yaotian/gowechat/mp/message"
 )
 
 func hello(rw http.ResponseWriter, req *http.Request) {
 
 	//配置微信参数
-	config := &gowechat.Config{
+	config := gcontext.Config{
 		AppID:          "your app id",
 		AppSecret:      "your app secret",
 		Token:          "your token",
@@ -19,8 +20,13 @@ func hello(rw http.ResponseWriter, req *http.Request) {
 	}
 	wc := gowechat.NewWechat(config)
 
+	mp, err := wc.Mp()
+	if err != nil {
+		return
+	}
+
 	// 传入request和responseWriter
-	server := wc.GetServer(req, rw)
+	server := mp.GetMsgServer(req, rw)
 	//设置接收消息的处理方法
 	server.SetMessageHandler(func(msg message.MixMessage) *message.Reply {
 
@@ -30,7 +36,7 @@ func hello(rw http.ResponseWriter, req *http.Request) {
 	})
 
 	//处理消息接收以及回复
-	err := server.Serve()
+	err = server.Serve()
 	if err != nil {
 		fmt.Println(err)
 		return

mp.go

@@ -54,8 +54,8 @@ func (c *MpMgr) GetTemplate() *template.Template {
 	return template.NewTemplate(c.Context)
 }
 
-// GetServer 消息管理
-func (c *MpMgr) GetServer(req *http.Request, writer http.ResponseWriter) *server.Server {
+// GetMsgServer 消息管理
+func (c *MpMgr) GetMsgServer(req *http.Request, writer http.ResponseWriter) *server.Server {
 	c.Context.Request = req
 	c.Context.Writer = writer
 	return server.NewServer(c.Context)