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

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

【腾讯云】轻量 2核2G4M,首年65元

阿里云限时活动-云数据库 RDS MySQL  1核2G配置 1.88/月 速抢

本文由乐趣区整理发布,转载请注明出处,谢谢。

您可能还喜欢...

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注

此站点使用Akismet来减少垃圾评论。了解我们如何处理您的评论数据