go 语言实现一个微信机器人

第一步: 我们用 docker 启动一个 web 协议的服务

可以把这个 docker 服务想像成一个无 UI 的网页版的微信，通过 grpc 暴露出一些自动化 API

在终端执行以下命令:

export WECHATY_LOG="verbose" export WECHATY_PUPPET="wechaty-puppet-wechat" export WECHATY_PUPPET_SERVER_PORT="30001" # 设置启动 web 协议后暴露出来的端口 export WECHATY_TOKEN="3d415ebb-7a6f-4cba-b602-1f4ae400f891" # 自己生成一串 uuid docker run -ti \ --name wechaty_puppet_service_token_gateway \ --rm \ -e WECHATY_LOG \ -e WECHATY_PUPPET \ -e WECHATY_PUPPET_SERVER_PORT \ -e WECHATY_TOKEN \ -p "$WECHATY_PUPPET_SERVER_PORT:$WECHATY_PUPPET_SERVER_PORT" \ wechaty/wechaty:latest 

等待启动成功，会输出一堆日志, 当看到有输出 Online QR Code Image: https://wechaty.js.org/qrcode/xxxx 就说明启动成功了

07:47:33 VERB PuppetWeChat start() throttleQueue.subscribe() new item: [object Object] 07:47:33 INFO IoClient [2] https://login.weixin.qq.com/l/xxxxxxx Online QR Code Image: https://wechaty.js.org/qrcode/https%3A%2F%2Flogin.weixin.qq.com%2Fl%2F4Yxxxx 07:47:33 VERB StorageFile save() to /wechaty/3d415ebb-7a6f-4cba-b602-1f4ae400f011.memory-card.json 

第二步: 启动 go 写的机器人

主要使用这个开源包 https://github.com/wechaty/go-wechaty 作为 sdk

一个简单的机器人已经提前写好了，我们 clone 下来就可以直接跑起来，这个机器人功能很简单，只要接到 ding 的消息就会回复一个 dong

执行如下命令:

git clone https://github.com/wechaty/go-wechaty-getting-started.git cd go-wechaty-getting-started WECHATY_PUPPET_SERVICE_ENDPOINT=127.0.0.1:30001 make bot 

程序跑起来之后，会返回一个微信登录二维码的链接，浏览器打开链接，然后用微信扫码，这样一个机器人就启动起来了

$ WECHATY_PUPPET_SERVICE_ENDPOINT=127.0.0.1:30001 make bot go run examples/ding-dong-bot.go 2021/04/17 16:05:52 PuppetService Start() 2021/04/17 16:05:52 PuppetService onGrpcStreamEvent({type:EVENT_TYPE_SCAN payload:{"qrcode":"https://login.weixin.qq.com/l/xxxx","status":2}}) Scan QR Code to login: ScanStatusWaiting https://wechaty.js.org/qrcode/https://login.weixin.qq.com/l/xxxx 2021/04/17 16:08:45 PuppetService onGrpcStreamEvent({type:EVENT_TYPE_SCAN payload:{"qrcode":"https://login.weixin.qq.com/l/xxxx","status":4}}) Scan QR Code to login: ScanStatusConfirmed User nickname logined 

我们用另一个微信向这个微信发送 ding 试下，可以看到机器人很快就回复了 dong

ding-dong 机器人的核心代码

package main import ( "fmt" "log" "os" "os/signal" "time" "github.com/wechaty/go-wechaty/wechaty" "github.com/wechaty/go-wechaty/wechaty-puppet/schemas" "github.com/wechaty/go-wechaty/wechaty/user" ) func main() { var bot = wechaty.NewWechaty() bot.OnScan(func(ctx *wechaty.Context, qrCode string, status schemas.ScanStatus, data string) { fmt.Printf("Scan QR Code to login: %v\nhttps://wechaty.js.org/qrcode/%s\n", status, qrCode) }).OnLogin(func(ctx *wechaty.Context, user *user.ContactSelf) { fmt.Printf("User %s logined\n", user.Name()) }).OnMessage(onMessage).OnLogout(func(ctx *wechaty.Context, user *user.ContactSelf, reason string) { fmt.Printf("User %s logouted: %s\n", user, reason) }) var err = bot.Start() if err != nil { panic(err) } var quitSig = make(chan os.Signal) signal.Notify(quitSig, os.Interrupt, os.Kill) select { case <-quitSig: log.Fatal("exit.by.signal") } } func onMessage(ctx *wechaty.Context, message *user.Message) { log.Println(message) if message.Self() { log.Println("Message discarded because its outgoing") } if message.Age() > 2*60*time.Second { log.Println("Message discarded because its TOO OLD(than 2 minutes)") } if message.Type() != schemas.MessageTypeText || message.Text() != "ding" { log.Println("Message discarded because it does not match 'ding'") return } // 1. reply 'dong' _, err := message.Say("dong") if err != nil { log.Println(err) return } log.Println("REPLY: dong") } 

一些 link

• go-wechaty: go 语言写的开发微信机器人的 sdk，理论可以支持任意 im 软件
• go-wechaty-getting-started: ding dong 机器人源码
• @dchaofei: 我的 github 主页，目前做的开源项目就是 go-wechaty