Golang實現(xiàn)微信公眾號后臺接入的示例代碼
最近在學習Golang,寫了個微信公眾號項目練練手。
一、開發(fā)前準備
1、注冊微信公眾號
百度搜索微信公眾號進入官網(wǎng),注冊一個訂閱號,其他信息按要求填寫即可。
注冊完成后進入個人公眾號主頁,下拉至設置與開發(fā)
點擊基本配置,查看AppID和AppSecret(之后進行代碼開發(fā)會用到)。
2、服務器配置
然后進行服務器配置,由于是本地開發(fā),為了方便調(diào)試,可以暫時使用內(nèi)網(wǎng)穿透工具ngork映射公網(wǎng)地址,具體的使用方法網(wǎng)上都有,在此就不多贅述。
下載完成后是一個可執(zhí)行文件
在當前目錄打開命令行窗口輸入命令啟動ngork
ngork.exe http 80
將本地80端口映射到公網(wǎng)地址
將映射的公網(wǎng)地址填入服務器URL,令牌Token填寫一個自定義的字符串(之后進行代碼編寫時會用到),然后使用明文模式。
至此基本配置完成,接下來就是代碼開發(fā)。
二、代碼編寫
使用Golang的http包創(chuàng)建一個web服務器
package main import ( "fmt" "net/http" "wechat-oa/route" ) func main() { fmt.Println("====== 微信公眾號服務器程序 ======") http.HandleFunc("/", route.WechatServer) // 處理微信服務器請求 err := http.ListenAndServe(":80", nil) if err != nil { fmt.Println("wechat server start error", err) } }
微信服務器發(fā)送請求都會帶上4個參數(shù),以此判斷請求是否來自微信服務器。
開發(fā)者通過檢驗 signature 對請求進行校驗(下面有校驗方式)。若確認此次 GET 請求來自微信服務器,請原樣返回 echostr 參數(shù)內(nèi)容,則接入生效,成為開發(fā)者成功,否則接入失敗。加密/校驗流程如下:
1)將token、timestamp、nonce三個參數(shù)進行字典序排序
2)將三個參數(shù)字符串拼接成一個字符串進行sha1加密
3)開發(fā)者獲得加密后的字符串可與 signature 對比,標識該請求來源于微信
公眾號配置
// 微信公眾號平臺配置 const ( appId = "xxxxxxxxxx" // 公眾號開發(fā)識別碼 appSecret = "xxxxxxxxxx" // 公眾號開發(fā)者密碼 encodingAESKey = "xxxxxxxxxx" // 消息加密秘鑰 token = "xxxxxxxxxx" // 跟微信公眾平臺的token一樣即可 )
服務處理代碼
當在服務器配置頁面點擊啟用時微信服務器會向配置服務器發(fā)送GET請求已驗證服務器是否可用
func WechatServer(w http.ResponseWriter, req *http.Request) { defer req.Body.Close() fmt.Println("服務器請求: ", req) //打印http的請求url // 1、驗證消息是否來自微信服務器 hashcode,signature,echostr := handleValid(req) if hashcode != signature { // 校驗 return } // 2、請求處理 if req.Method == "GET" { _, _ = w.Write([]byte(echostr)) // 驗證成功返回echostr } else if req.Method == "POST" { handleMsg(w,req) }else { _, _ = w.Write([]byte("error")) } }
驗證代碼
以下代碼通過加密規(guī)則對請求參數(shù)進行加密,最后返回加密后的hashcode
func handleValid(r *http.Request) (hashcode string,signature string,echostr string){ //1.嘗試獲取4個字段 nonce := r.URL.Query().Get("nonce") timestamp := r.URL.Query().Get("timestamp") signature = r.URL.Query().Get("signature") echostr = r.URL.Query().Get("echostr") //2. 賦值一個token //3.token,timestamp,nonce按字典排序的字符串list strs := sort.StringSlice{token, timestamp, nonce} // 使用本地的token生成校驗 sort.Strings(strs) str := "" for _, s := range strs { str += s } // 4. 哈希算法加密list得到hashcode h := sha1.New() h.Write([]byte(str)) hashcode = fmt.Sprintf("%x", h.Sum(nil)) // h.Sum(nil) 做hash return }
消息處理
// 處理POST請求 // 微信服務器會將用戶發(fā)送的數(shù)據(jù)以POST請求的方式轉(zhuǎn)發(fā)給開發(fā)者服務器 func handleMsg(rw http.ResponseWriter, req *http.Request) { wc := wechat.NewWechat() //這里本地內(nèi)存保存access_token,也可選擇redis,memcache或者自定義cache memory := cache.NewMemory() cfg := &offConfig.Config{ AppID: appId, AppSecret: appSecret, Token: token, EncodingAESKey: encodingAESKey, Cache: memory, } // 底層根據(jù)AppID和AppSecret獲取access_token并保存到cache中 // access_token每兩個小時刷新一次 officialAccount := wc.GetOfficialAccount(cfg) // 傳入request和responseWriter server := officialAccount.GetServer(req, rw) // 設置接收消息的處理方法 server.SetMessageHandler(controller.HandleMsg) //處理消息接收以及回復 err := server.Serve() if err != nil { fmt.Println(err) return } //發(fā)送回復的消息 _ = server.Send() }
controller.HandleMsg
這里的基本邏輯是根據(jù)用戶發(fā)送消息的類型作不同的處理,目前只處理了文本消息和事件推送消息。
當用戶發(fā)送文本消息時回復用戶自己發(fā)送的消息
// 處理用戶發(fā)送的消息 func HandleMsg(msg *message.MixMessage) *message.Reply{ fmt.Println("接收用戶消息:",msg.Content) switch msg.MsgType { case message.MsgTypeText: // 文本消息 return &message.Reply{ MsgType: message.MsgTypeText, MsgData: message.NewText(msg.Content), } case message.MsgTypeEvent: // 事件推送 return service.HandleEventMsg(msg) default: return &message.Reply{ MsgType: message.MsgTypeText, MsgData: message.NewText("感謝關注沐風丶,更多功能正在開發(fā)中..."), } } }
service.HandleEventMsg
// 處理事件推送 func HandleEventMsg(msg *message.MixMessage) *message.Reply{ switch msg.Event { case message.EventSubscribe: // 用戶訂閱 fmt.Printf("%s 訂閱了你 \n",msg.FromUserName) return &message.Reply{ MsgType: message.MsgTypeText, MsgData: message.NewText("感謝關注沐風丶,(* ̄︶ ̄)?你真好看"), } case message.EventUnsubscribe: // 用戶取消訂閱 fmt.Printf("%s 取消了訂閱 \n",msg.FromUserName) return &message.Reply{ MsgType: message.MsgTypeText, MsgData: message.NewText(""), } default: return &message.Reply{ MsgType: message.MsgTypeText, MsgData: message.NewText("default"), } } }
三、測試
1、啟動項目
2、啟動服務器配置
啟動成功后服務器響應
3、用戶關注公眾號
服務器響應
4、用戶發(fā)送消息
服務器響應
5、用戶取消訂閱
服務器響應
四、總結
更多文檔:開發(fā)文檔
個人訂閱號無法進行微信認證,許多接口都沒有權限,推薦使用個人頁UI管理公眾號
到此這篇關于Golang實現(xiàn)微信公眾號后臺接入的示例代碼的文章就介紹到這了,更多相關Golang微信公眾號后臺內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
golang使用 gomodule 在公共測試環(huán)境管理go的依賴的實例詳解
這篇文章主要介紹了golang使用 gomodule 在公共測試環(huán)境管理go的依賴,本文給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2020-11-11如何使用Golang創(chuàng)建與讀取Excel文件
我最近工作忙于作圖,圖表,需要自己準備數(shù)據(jù)源,所以經(jīng)常和Excel打交道,下面這篇文章主要給大家介紹了關于如何使用Golang創(chuàng)建與讀取Excel文件的相關資料,需要的朋友可以參考下2022-07-07