本文干货充足篇幅较长，建议收藏后阅读避免迷路。文末可获取【自动聊天机器人源码和Demo】。

本教程教大家使用即构 ZIM SDK 创建一个能与微信端互动消息的自动聊天机器人应用。ZIM
SDK可广泛应用于娱乐社交、电商购物、在线教育、互动直播等多种场景下即时通讯功能实现 。
原文作者：RTC_程序猿_Wang
原文链接：https://mp.weixin.qq.com/s/-zXbp4MyQ8ZsFj0qBAEPnA?source=CSDN&article54

前言

使用即构 SDK 和 微信PC端创建自动聊天IM应用非常简单，支持单聊消息、群组消息、房间消息等的收发，以及查询历史消息、删除消息等IM基础功能，除此之外，即构还提供许多拓展功能，可以提高企业客户即时通讯的安全性和便利性。
● 呼叫邀请
● 安全审核
● 离线推送
● 离线消息
● 消息云存储

即时通讯IM概述

如果能开发一款即时聊天App，能和微信消息互通，并且只需少许代码量，应该是件非常兴奋的事情吧。首先，希望快速开发安全稳定的即时聊天App，最好借助（白嫖充足的免费额度）第三方提供的即时聊天SDK。其次，跟微信消息打通，只需借助本文提供的SDK。今天我们学习如何快速实现一款与微信消息互通的聊天App。

最终效果如下（可在文末获取源码）：

1-【自动聊天】

2-【聊天】

3-【自动回复】

1 技术实现原理

整个技术实现原理如下图所示

2 微信消息劫持

2.1 第三方已有的微信消息劫持工具

本文不会教你从零开发微信消息劫持，而是借助第三方已有的工具：pc-wechat-hook-http-api。相关文档在这里https://www.apifox.cn/apidoc/project-1222856/doc-1012539。

需要注意的是，此工具基于3.6.0.18版本微信。下载此版本微信后直接覆盖安装，这样可以保留之前的微信聊天记录。

2.2 如何使用微信消息劫持工具？

首先前往官网下载好压缩包，如果不知道怎么官网怎么下载，可以直接拉到本文文末获取。

将HPSocket4C.dll文件复制到微信目录下（例如E:\Tencent\WeChat\[3.6.0.18]）

2.2.1 注入dll

点击Daen注入器.exe文件：

其中：

1. 文件目录是指微信安装路径，参考上图。
2. DLL路径指的是DaenWxHook.dll文件的完整路径。
3. 进程参数直接使用默认即可。其中图中8089指本地用于接收微信实时消息的http server端口。8055指的是dll开启的http server端口，发送消息时只需往这个端口post数据即可。

点击注入并启动，登录微信即可。这里已完成微信消息的劫持，下一步我们尝试发送微信消息验证。

2.2.2 发送微信消息

发送消息方式为往指定端口post http请求即可，具体端口值为上面注入dll工具中指定的8055，如果用nodejs实现，post请求体如下所示：

function post(data, callback) {var options = {hostname: '127.0.0.1',port: 8055,path: '/DaenWxHook/client/',method: 'POST',headers: {'User-Agent': 'apifox/1.0.0 (https://www.apifox.cn)','Content-Type': 'application/json'}};var req = http.request(options, function (res) {var body = "";res.setEncoding('utf8');res.on('data', function (chunk) {body += chunk;});res.on('end', function () {var json = JSON.parse(body);callback(json);});});req.on('error', function (e) {console.log('problem with request: ' + e.message);});req.write(JSON.stringify(data));req.end();
}

其中data是JSON类型，其数据结构具体形式可以参考官方文档或者直接看本文提供的代码。

2.2.3 接收微信消息

接收微信消息也非常方便，只需开启一个http server，并将端口与dll注入时一致，例如2.2.1中指定了8089，nodejs示例代码如下：

app.post('/wechat/', function (req, res) {var data = req.body;var type = data['type'];if (type == 'D0003') {data = data['data']var msg = data['msg']var fromType = data['fromType']  // 1私聊， 2群聊， 3公众号var from_wxid = data['fromWxid']var isRcv = data['msgSource']==0 //0别人发，1自己发if (fromType == 2) {onRcvWXRoomMsg && onRcvWXRoomMsg(msg, from_wxid, isRcv)} else if (fromType == 3) {onGHZMsg && onGHZMsg(msg, from_wxid, isRcv);} else if (fromType == 1) {onRcvWXP2PMsg && onRcvWXP2PMsg(msg, from_wxid, isRcv);}}res.send('');});
app.listen(8089, function () {console.log('正在监听微信消息');
});

3 第三方IM SDK接入

到此，我们实现了收发微信消息，接下来我们需要将这些消息实时转发到自己的app上。如果自己去从0开发一个即时通讯App系统工作量巨大。

我们依然可以借助第三方平台，网上第三方IM平台很多，大家可以随便选一个自己熟悉的平台。这里我选择我比较熟悉的即构IM平台。

即构 IM SDK支持所有主流平台，包括flutter和uniapp两大跨平台框架，加速产品上线。在消息安全审核方面，他们采用主流第三方安全厂商的服务，需要的审核功能基本都能够支持。
不仅支持基础的单聊/群聊功能，还支持消息高并发量的房间聊天，官网数据显示：单房间人数支持到百万以上，适合对房间人数要求高的场景使用。另外还有很新颖的呼叫邀请功能，满足即时通讯的需求。

当然了，对于个人开发者而言，有充足的白嫖额度才是最重要的。一方面，即构IM提供的免费额度足够个人开发者用了。另一方面，未来如果有创业计划，快速接入即构IM上线产品也是非常方便

可以先从即构控制台注册添加应用, 获取AppId和ServerSecret, 如下所示。

更多关于即构即时通讯IM SDK的使用介绍文档，可以参考这里

3.1 中转微信收发消息

由于我们针对的是windows版的微信收发消息做劫持，因此必须在windows端也接入即构IM，通过即构IM将数据转发到App上。 而目前即构IM在windows上只有C++版本SDK，开发效率较低。为了更快速构建我们的服务，笔者将即构IM的web版SDK做了Nodejs运行环境兼容，读者可以直接通过文末获取。

关于即构SDK的使用我这边不做过多介绍，读者只需关注一点：这是个第三方IM平台，我们利用它做微信消息中转，使得我们在开发App的时候可以实时获取微信消息。 这里贴一下关键代码：

function initZego(onError, onRcvMsg, clientUId = 'C123456', serverUId = 'S123456') {___clientUID = clientUId;var token = newToken(serverUId);var startTimestamp = new Date().getTime();function _onError(zim, err) {onError(err);}function onRcvP2PMsg(zim, msgObj) {var msgList = msgObj.messageList;var fromConversationID = msgObj.fromConversationID; msgList.forEach(function (msg) {if (msg.timestamp - startTimestamp >= 0) { //过滤掉离线消息console.log(msg)onRcvMsg(msg, fromConversationID);}  })}function onTokenWillExpire(zim, second) {token = newToken(userId);zim.renewToken(token);}var zim = createZIM(_onError, onRcvP2PMsg, onTokenWillExpire);login(zim, serverUId, token, function (succ, data) {if (succ) {console.log("登录成功！")} else {console.log("登录失败！", data)}})return zim;
}

需要注意的是，创建ZIM(即构IM)引擎时，需要提供AppId，必须去从即构控制台添加应用后自动获取。

4 APP开发

App主要包含3个模块：聊天、联系人、个人设置（包括聊天机器人、自动回复等内容）。App需要集成好即构IM的SDK，这里不展开细聊，相信官网比我讲的更好。

4.1 聊天

聊天包括收发微信消息，但所有的消息都封装成即构IM的消息。我们对每个消息定义一个消息类型，用于识别。即构IM中接收到来自windows端发来的消息如下：

  private void onRcvMsg(ArrayList messageList, String fromUserID) {if (lsArr == null) return;for (ZIMMessage zimMessage : messageList) {if (zimMessage instanceof ZIMTextMessage) {ZIMTextMessage zimTextMessage = (ZIMTextMessage) zimMessage;if (zimMessage.getTimestamp() < this.startTime)continue;String uid = zimTextMessage.getSenderUserID();if (!toUserId.equals(uid)) continue;String json = zimTextMessage.message;Msg msg = Msg.parseMsg(json);for (MsgCenterListener l : lsArr) l.onRcvMsg(msg);}}} 

定义微信消息数据如下：

public class P2PMsg extends Msg { @SerializedName("w")public String wxid; @SerializedName("tm")public long time; @SerializedName("m")public String msg; @SerializedName("r")public boolean isRcv; @Expose(serialize = false, deserialize = false)public String remark; public P2PMsg(String wxid, long time, String msg) {this.type = Msg.TYPE_P2P_MSG;this.wxid = wxid;this.time = time;this.msg = msg;}
}

在App端和windows端都使用P2PMsg定义的json格式数据，通过isRcv自动用于判断此消息是接收到的消息还是发送出去的消息。

对于windows端，收到了P2PMsg消息后，就根据里面指定的微信ID号做消息转发。对于App端，根据微信ID和isRecv字段判断当前消息时跟谁聊以及是接收到的还是发送出去的。

4.2 联系人

联系人获取方式相对比较简单，在windows端获取到联系人列表后，直接发给App端。但是需要注意的是，由于联系人量级可能非常大，如果一次性传输可能因为消息体过大导致消息中转失败。因此我们分批发送联系人信息：

function sendFriendListZego(msg) {var pno = msg.pno;var psize = 10var max_pno = Math.ceil(WXFriendsList.length * 1.0 / psize);var friendsList = [];var json = "";if (pno < 0) {json = {t: TYPE_FRIEND_LIST,fl: [],tt: WXFriendsList.length,p: pno};sendSettings();} else {if (pno < max_pno - 1)friendsList = WXFriendsList.slice(pno * psize, (pno + 1) * psize);elsefriendsList = WXFriendsList.slice(pno * psize, WXFriendsList.length);json = {t: TYPE_FRIEND_LIST,fl: friendsList,tt: max_pno,p: pno};}sendZegoMsg(JSON.stringify(json))
}

4.3 聊天机器人与自动回复

聊天机器人

聊天机器人我们同样站在巨人肩膀上，使用青云客提供的api，实现自动对话。为了代码简洁性，我们用python示例，读者也可以翻到文末获取nodejs版本源码：

def talk_with_robot(msg, robot_name=None):url = 'http://api.qingyunke.com/api.php?key=free&appid=0&msg={}'.format(urllib.parse.quote(msg))html = requests.get(url)rt = html.json()["content"]rt = rt.replace("{br}","\n")if robot_name is not None:rt = rt.replace("菲菲", robot_name)return rt

自动回复与定时发送

自动回复和定时发送属于规则性的定义了，只需将app端的配置发送给windows端，由windows端根据具体的配置执行相关操作。如自动回复，每次收到消息就回复固定内容。定时发送通过设置定时器执行发送任务。

5 获取源码及相关资源

1. 【2209自动聊天机器人版微信安装包】关注：ZEGO即构开发者社区，回复2209
2. 【Daen注入器相关dll文件】 关注：ZEGO即构开发者社区，回复：daen
3. 【android客户端源码】 关注：ZEGO即构开发者社区，回复：WXIM
4. 【windows端消息中转源码】 关注：ZEGO即构开发者社区，回复：WINZEGO