GO 管理微信公众号后台（wechat）

package main

import (
	"fmt"
	"log"
	"net/http"

	wechat "github.com/silenceper/wechat/v2"
	"github.com/silenceper/wechat/v2/cache"
	offConfig "github.com/silenceper/wechat/v2/officialaccount/config"
	"github.com/silenceper/wechat/v2/officialaccount/message"
)

// 一个分词函数，输入字符串，输出

func serveWechat(rw http.ResponseWriter, req *http.Request) {
	wc := wechat.NewWechat()
	//这里本地内存保存access_token，也可选择redis，memcache或者自定cache
	memory := cache.NewMemory()
	cfg := &offConfig.Config{
		AppID:          "XXXXXXX",
		AppSecret:      "XXXXXXXXX",
		Token:          "tokenhere",
		EncodingAESKey: "QfG7Xd2utub6P1aIc276jFXiYvCPuTcrn6vv0bshe0T",
		Cache:          memory,
	}
	// 微信公众号后台接口校验
	officialAccount := wc.GetOfficialAccount(cfg)

	// 传入request和responseWriter
	server := officialAccount.GetServer(req, rw)
	//设置接收消息的处理方法
	server.SetMessageHandler(func(msg *message.MixMessage) *message.Reply {
		var info string
		log.Print(msg.MsgType)
		if msg.MsgType == "text" {
			//回复消息：演示回复用户发送的消息
			log.Print("获得用户消息:", msg.Content)
			fmt.Printf("%T\n", msg.Content)
			info = "收到你的消息: " + msg.Content
		} else {
			log.Print("仅支持文本消息哦~")
			info = "仅支持文本消息哦~"
		}
		text := message.NewText(info)
		return &message.Reply{MsgType: message.MsgTypeText, MsgData: text}
	})

	//处理消息接收以及回复
	err := server.Serve()
	if err != nil {
		log.Print(err)
		return
	}
	//发送回复的消息
	server.Send()
}

func main() {
	http.HandleFunc("/", serveWechat)
	log.Print("wechat server listener at", ":8001")
	err := http.ListenAndServe(":8001", nil)
	if err != nil {
		log.Print("start server error , err=%v", err)
	}
}