mirror of
https://github.com/silenceper/wechat.git
synced 2026-02-04 12:52:27 +08:00
46 lines
1010 B
Go
46 lines
1010 B
Go
package main
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
"github.com/astaxie/beego"
|
|
"github.com/astaxie/beego/context"
|
|
"github.com/silenceper/wechat"
|
|
"github.com/silenceper/wechat/message"
|
|
)
|
|
|
|
func hello(ctx *context.Context) {
|
|
//配置微信参数
|
|
config := &wechat.Config{
|
|
AppID: "your app id",
|
|
AppSecret: "your app secret",
|
|
Token: "your token",
|
|
EncodingAESKey: "your encoding aes key",
|
|
}
|
|
wc := wechat.NewWechat(config)
|
|
|
|
// 传入request和responseWriter
|
|
server := wc.GetServer(ctx.Request, ctx.ResponseWriter)
|
|
//设置接收消息的处理方法
|
|
server.SetMessageHandler(func(msg message.MixMessage) *message.Reply {
|
|
|
|
//回复消息：演示回复用户发送的消息
|
|
text := message.NewText(msg.Content)
|
|
return &message.Reply{MsgType: message.MsgTypeText, MsgData: text}
|
|
})
|
|
|
|
//处理消息接收以及回复
|
|
err := server.Serve()
|
|
if err != nil {
|
|
fmt.Println(err)
|
|
return
|
|
}
|
|
//发送回复的消息
|
|
server.Send()
|
|
}
|
|
|
|
func main() {
|
|
beego.Any("/", hello)
|
|
beego.Run(":8001")
|
|
}
|