乐趣区

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

本文干货短缺篇幅较长,倡议珍藏后浏览防止迷路。文末可获取【主动聊天机器人源码和 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();}

其中 dataJSON类型,其数据结构具体模式能够参考官网文档或者间接看本文提供的代码。

2.2.3 接管微信音讯

接管微信音讯也十分不便,只需开启一个 http server,并将端口与dll 注入时统一,例如 2.2.1 中指定了 8089nodejs 示例代码如下:

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 上。而目前 即构 IMwindows 上只有 C++ 版本 SDK,开发效率较低。为了更疾速构建咱们的服务,笔者将 即构 IMwebSDK做了 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须要集成好 即构 IMSDK,这里不开展细聊,置信官网比我讲的更好。

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 端,依据 微信 IDisRecv 字段判断以后音讯时跟谁聊以及是接管到的还是发送进来的。

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
退出移动版