专注于 JetBrains IDEA 全家桶，永久激活，教程
持续更新 PyCharm，IDEA，WebStorm，PhpStorm，DataGrip，RubyMine，CLion，AppCode 永久激活教程
当前位置：搜云库技术团队 Java汇总 正文

Go 实战丨微信公众号接入及用户消息处理

2020-08-12 分类：Java汇总 阅读(635)

使用 Go 语言的 Web 框架 Gin 进行微信公众号接入，并实现对微信消息的接收以及回复处理。

同时借助 nginx 代理服务器对代理的端口号以及 URI 进行优化处理。

在文章末尾给出该 Demo 的项目地址。

目录

  • 公众号接入
  • 消息接收
  • 消息回复
  • 使用 ngxin 代理服务器
  • 小结

公众号接入

这里使用微信公众平台提供的接口测试号用于开发使用，接口测试号申请。

公众号的接入主要有两个步骤，微信公众平台接入指南：

1、 填写服务器配置
2、 验证服务器地址的有效性

第一步需要配置服务器的 URL 地址，并且必须以 http:// 或 https:// 开头，分别支持 80 端口和 443 端口；还需配置一个 3 ~ 32 位字符的 Token，用于消息验证。

第二步用于验证消息来源的正确性，当第一步配置完成并点提交后，微信服务器将发送 GET 请求到填写的服务器地址上，GET 请求携带的参数及描述如下表所示：

参数 描述
signature 微信加密签名，signature结合了开发者填写的token参数和请求中的timestamp参数、nonce参数。
timestamp 时间戳
nonce 随机数
echostr 随机字符串

服务器需要做的验证操作流程大致为：

1、 对 token、timestamp、nonce 三个参数进行字典序排序；
2、 将排序后的 token、timestamp、nonce 三个参数按顺序拼接成一个字符串，并对该字符串进行 sha1 加密；
3、 使用加密后的字符串与 signature 参数进行比较，如果字符串值相同，则表示校验通过，将 echostr 参数原样返回即可。

使用 Go 实现的微信公众号接入代码如下：

package main

import (
    "github.com/gin-gonic/gin"
    "log"
    "weixin-demo/util"
)

// 与填写的服务器配置中的Token一致
const Token = "coleliedev"

func main() {
    router := gin.Default()

    router.GET("/wx", WXCheckSignature)

    log.Fatalln(router.Run(":80"))
}

// WXCheckSignature 微信接入校验
func WXCheckSignature(c *gin.Context) {
    signature := c.Query("signature")
    timestamp := c.Query("timestamp")
    nonce := c.Query("nonce")
    echostr := c.Query("echostr")

    ok := util.CheckSignature(signature, timestamp, nonce, Token)
    if !ok {
        log.Println("微信公众号接入校验失败!")
        return
    }

    log.Println("微信公众号接入校验成功!")
    _, _ = c.Writer.WriteString(echostr)
}


package util

import (
    "crypto/sha1"
    "encoding/hex"
    "sort"
    "strings"
)

// CheckSignature 微信公众号签名检查
func CheckSignature(signature, timestamp, nonce, token string) bool {
    arr := []string{timestamp, nonce, token}
    // 字典序排序
    sort.Strings(arr)

    n := len(timestamp) + len(nonce) + len(token)
    var b strings.Builder
    b.Grow(n)
    for i := 0; i < len(arr); i++ {
        b.WriteString(arr[i])
    }

    return Sha1(b.String()) == signature
}

// 进行Sha1编码
func Sha1(str string) string {
    h := sha1.New()
    h.Write([]byte(str))
    return hex.EncodeToString(h.Sum(nil))
}

最后，将项目部署至服务器，并在接口配置信息中点击提交按钮，完成微信公众号的接入。

108_1.png

108_2.png

需注意，由于该 Web 程序需监听 80 端口，所以服务器不能有其他监听 80 端口的程序，如 nginx。

消息接收

完成微信公众号的接入后，接下来以普通消息接收和被动回复用户消息这两个 API 为例，来完成 Go 对微信消息的接收和回复处理的具体实现。

首先是消息接收，参考微信官方文档，接收普通消息。

当普通微信用户向公众账号发消息时，微信服务器将POST消息的XML数据包到开发者填写的URL上。

以文本消息为例，其 XML 数据包结构以及参数描述分别如下：

<xml>
  <ToUserName><![CDATA[toUser]]></ToUserName>
  <FromUserName><![CDATA[fromUser]]></FromUserName>
  <CreateTime>1348831860</CreateTime>
  <MsgType><![CDATA[text]]></MsgType>
  <Content><![CDATA[this is a test]]></Content>
  <MsgId>1234567890123456</MsgId>
</xml>
参数 描述
ToUserName 开发者微信号
FromUserName 发送方帐号（一个OpenID）
CreateTime 消息创建时间 （整型）
MsgType 消息类型，文本为text
Content 文本消息内容
MsgId 消息id，64位整型

明白了微信服务器向开发服务器传递微信用户消息的方式以及传递的数据包结构后，可知进行消息接收开发，大致需要进行两个步骤：

1、 创建处理微信服务器发送到开发服务器的 POST 类型请求的处理函数；
2、 对请求中的 XML 数据包进行解析。

对于第二步，我们可以借助 Gin 框架的 ShouldBindXML 或 BindXML 方法来对 XML 数据包进行解析。

使用 Go 实现的消息接收代码如下：

package main

import (
    "github.com/gin-gonic/gin"
    "log"
    "weixin-demo/util"
)

const Token = "coleliedev"

func main() {
    router := gin.Default()

    router.GET("/wx", WXCheckSignature)
    router.POST("/wx", WXMsgReceive)

    log.Fatalln(router.Run(":80"))
}

// WXTextMsg 微信文本消息结构体
type WXTextMsg struct {
    ToUserName   string
    FromUserName string
    CreateTime   int64
    MsgType      string
    Content      string
    MsgId        int64
}

// WXMsgReceive 微信消息接收
func WXMsgReceive(c *gin.Context) {
    var textMsg WXTextMsg
    err := c.ShouldBindXML(&textMsg)
    if err != nil {
        log.Printf("[消息接收] - XML数据包解析失败: %v\n", err)
        return
    }

    log.Printf("[消息接收] - 收到消息, 消息类型为: %s, 消息内容为: %s\n", textMsg.MsgType, textMsg.Content)
}

将添加消息接收的代码更新至服务器后，对该接口测试号发送消息，可在服务器查看到如下记录：

108_3.png

108_4.png

消息回复

接下来以被动回复用户消息这个 API 为例，实现对微信用户发送的消息的回复，参考微信官方文档，被动消息回复。

消息回复与消息接收类似，都需要使用 XML 格式的数据包，回复文本消息需要的 XML 数据包结构以及参数如下：

<xml>
  <ToUserName><![CDATA[toUser]]></ToUserName>
  <FromUserName><![CDATA[fromUser]]></FromUserName>
  <CreateTime>12345678</CreateTime>
  <MsgType><![CDATA[text]]></MsgType>
  <Content><![CDATA[你好]]></Content>
</xml>
参数 是否必须 描述
ToUserName 是 接收方帐号（收到的OpenID）
FromUserName 是 开发者微信号
CreateTime 是 消息创建时间 （整型）
MsgType 是 消息类型，文本为text
Content 是 回复的消息内容（换行：在content中能够换行，微信客户端就支持换行显示）

使用 Go 实现的消息回复代码如下：

package main

import (
    "encoding/xml"
    "fmt"
    "github.com/gin-gonic/gin"
    "log"
    "time"
    "weixin-demo/util"
)

const Token = "coleliedev"

func main() {
    router := gin.Default()

    router.GET("/wx", WXCheckSignature)
    router.POST("/wx", WXMsgReceive)

    log.Fatalln(router.Run(":80"))
}

// WXMsgReceive 微信消息接收
func WXMsgReceive(c *gin.Context) {
    var textMsg WXTextMsg
    err := c.ShouldBindXML(&textMsg)
    if err != nil {
        log.Printf("[消息接收] - XML数据包解析失败: %v\n", err)
        return
    }

    log.Printf("[消息接收] - 收到消息, 消息类型为: %s, 消息内容为: %s\n", textMsg.MsgType, textMsg.Content)

    // 对接收的消息进行被动回复
    WXMsgReply(c, textMsg.ToUserName, textMsg.FromUserName)
}

// WXRepTextMsg 微信回复文本消息结构体
type WXRepTextMsg struct {
    ToUserName   string
    FromUserName string
    CreateTime   int64
    MsgType      string
    Content      string
    // 若不标记XMLName, 则解析后的xml名为该结构体的名称
    XMLName      xml.Name `xml:"xml"`
}

// WXMsgReply 微信消息回复
func WXMsgReply(c *gin.Context, fromUser, toUser string) {
    repTextMsg := WXRepTextMsg{
        ToUserName:   toUser,
        FromUserName: fromUser,
        CreateTime:   time.Now().Unix(),
        MsgType:      "text",
        Content:      fmt.Sprintf("[消息回复] - %s", time.Now().Format("2006-01-02 15:04:05")),
    }

    msg, err := xml.Marshal(&repTextMsg)
    if err != nil {
        log.Printf("[消息回复] - 将对象进行XML编码出错: %v\n", err)
        return
    }
    _, _ = c.Writer.Write(msg)
}

需要注意的是 WXRepTextMsg 结构体中必须添加 XMLName 属性，并且对该属性进行 xml 标记，用于将该 xml 名标记为 xml，即使用 xml.Marshal 方法对该结构体对象进行编码后，得到的 xml 数据的最外层标签为 <xml></xml>，如若不添加该 XMLName 属性，则编码后得到的 xml 数据的最外层标签为 <WXRepTextMsg></WXRepTextMsg>，不符合微信官方要求的 xml 数据包格式，因此所有 xml 名称即编码后的 xml 数据的最外层标签不为 <xml></xml> 的数据包都无法成功回复。

将添加消息回复的代码更新至服务器后，向服务器发送消息将收到如下回复：

108_5.png

108_6.png

使用 nginx 代理服务器

通常服务器都不会把 80 端口或 443 端口交给 Web 程序，这时可使用 nginx 作为代理服务器，将 Web 程序跑在其它端口上，如 8002，让 nginx 监听 80 端口或 443 端口，并对指定的 URI 进行反向代理操作，如以下配置，将把 80 端口 URI 为 /weixin 的请求代理到服务器本地的 8002 端口的 /wx 上：

server {
    listen 80;

    location /weixin {
        proxy_pass http://127.0.0.1:8002/wx;
        proxy_redirect default;
    }
}

修改程序监听的端口号为 8002：

func main() {
    router := gin.Default()

    router.GET("/wx", WXCheckSignature)
    router.POST("/wx", WXMsgReceive)

    log.Fatalln(router.Run(":8002"))
}

修改微信公众号接入接口配置：

108_7.png

108_8.png

最后测试结果如下：

108_9.png

108_10.png

108_11.png

从 nginx 的日志文件中可以看到其确实收到了 URI 为 /weixin 的请求，并且在该 Web 程序的日志文件中，也可以看到其收到的 URI 为 /wx 的请求，通过观察两份日志记录的请求参数，可以发现，nginx 做的代理是成功的。

小结

最后做一个对该文章的小结，这篇文章主要使用了 Go 语言的 Gin 框架以及借助微信接口测试号，完成了对微信公众号接入的开发，以及实现接收微信用户消息和回复微信用户消息的两个功能。

以及，感谢大家的耐心阅读！！！

演示 Demo github 地址：github.com/hkail/weixi…

演示 Demo gitee 地址：gitee.com/hkail/weixi…

文章永久链接：https://tech.souyunku.com/41950

AD：【JetBrains 全家桶，激活、破解、教程】获取 IDEA 激活码、PyCharm 激活码、WebStorm 激活码和 DataGrip 激活码，提供详细破解教程与永久激活方法。支持 IDEA 永久激活与破解，免费获取注册码与激活码，解决 2024/2025 版本激活问题，轻松实现所有 JetBrains 工具的激活。
未经允许不得转载：搜云库技术团队 » Go 实战丨微信公众号接入及用户消息处理

相关推荐

热门专题

JetBrains 全家桶，激活、破解、教程

提供 JetBrains 全家桶激活码、注册码、破解补丁下载及详细激活教程，支持 IntelliJ IDEA、PyCharm、WebStorm 等工具的永久激活。无论是破解教程，还是最新激活码，均可免费获得，帮助开发者解决常见激活问题，确保轻松破解并快速使用 JetBrains 软件。获取免费的破解补丁和激活码，快速解决激活难题，全面覆盖 2024/2025 版本！

联系我们联系我们