关于即时通讯:微信｜零到一打造一款与微信互通的自动聊天机器人应用

34次阅读

共计 6164 个字符，预计需要花费 16 分钟才能阅读完成。

本文干货短缺篇幅较长，倡议珍藏后浏览防止迷路。文末可获取【主动聊天机器人源码和 Demo】。

本教程教大家应用即构 ZIM SDK 创立一个能与微信端互动音讯的主动聊天机器人利用。ZIM SDK 可广泛应用于娱乐社交、电商购物、在线教育、互动直播等多种场景下即时通讯性能实现
原文作者：RTC_程序猿_Wang
原文链接：https://mp.weixin.qq.com/s/-z…

前言

应用即构 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<ZIMMessage> 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 = 10
    var 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);
        else
            friendsList = 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

正文完
即时通讯
发表至： 即时通讯
2022-11-03
 0
关于即时通讯:开源即时通讯IM框架MobileIMSDK的微信小程序端开发快速入门
关于即时通讯:im即时通讯开发万人群聊消息
关于即时通讯:直播系统聊天技术六百万人在线的直播间实时聊天消息分发技术实践
关于即时通讯:长连接网关技术专题四爱奇艺WebSocket实时推送网关技术实践