nodejs微信开发之自动回复的实现_node.js_脚本之家

作者:编程    发布时间:2020-01-27 15:17     浏览次数 :

[返回]

点击访问原文您还可以加入全栈技术交流群(QQ群号:254842154)

一、简介

这部分是实现简单的自动回复,当然也是很大一部分功能的实现基础,这里使用了图灵机器人的接口。

今天我们来看看有哪些比较好玩的聊天机器人,并且通过微信公众号搭建一个自己的聊天机器人。

上一篇文章介绍了微信公众平台翻译功能的开发,实现了中、英、日语言互译,在实际生活中也能使用到。在接下来的这一篇文章中,我们将完成一个比较有趣的功能,那就是聊天机器人,可以在你无聊的时候陪你聊天逗你开心。

当然,这个机器人的效果如何不是我能管得了的事情了,类似图灵机器人,我们还可以实现段子推送,快递查询等一系列功能,这里不一一实现了。

QQ机器人

二、思路分析

微信的消息处理

腾讯有一个可以聊天的QQ机器人,当时觉得特别好玩,它会不厌其烦地陪你聊天,不吃不喝。它的QQ号是:615050000。

在这个实验中,我们将调取小黄鸡官方()提供的API,结合抓取小九机器人()的网页,互相补充。Simsimi 是收费的,但你可以尝试7天测试,每天可以免费使用100条回复;小九机器人可以无限制使用,但前提是官方不屏蔽。

对于公众平台,每一次发消息相当于发出一个post请求,但是需要注意的是不管是发出的请求还是收到的回复,他的数据格式都是xml,但是nodejs本身无法处理xml,所以需要对xml数据进行处理。仍然使用的是body-parser这个库,但是需要引入body-parser-xml:

小黄鸡

三、小黄鸡API 分析

//解析xmlapp.use(bodyParser.xml({ limit: '1MB', // Reject payload bigger than 1 MB xmlParseOptions: { normalize: true, // Trim whitespace inside text nodes normalizeTags: true, // Transform tags to lowercase explicitArray: false // Only put nodes in array if >1 }}));

曾经非常火的人人网小黄鸡聊天机器人,陪着大学生度过了多少个空虚寂寞冷的日日夜夜。在这里可以找到开发文档: 。它提供了一个快速接入微信后台的功能:

3.1 API & URL

这样req.body.xml就是处理好的数据了。

图片 18.pic.jpg

官方API 地址: 

一般文本消息的格式如下所示:

假如你的微信公众号没有自己开发的功能,那么只要按照下面的“微信接口”说明,在微信公众号后台设置参数即可。

Request URL:

   1348831860   1234567890123456 

假如你的微信公众号已经有自己的功能,现在又想加入小黄鸡的功能,那么就要自己开发了。这里特别注意,msg参数需要GBK编码。

这里使用免费版测试,付费版的类似,只是URL地址不同。

其中ToUserName是接受者的openid,FromUserName是发送者的openid,CreateTime就是一个整型的时间戳。MsgType就是消息类型,一般有文本,语音,小视频,地理位置。下面就以文本消息为例进行编码。

下面给出关键性代码:

3.2 请求示例与参数说明

router.post('/', function  { res.writeHead(200, {'Content-Type': 'application/xml'}); var data = req.body.xml; var resMsg = '' + '' + '' + '' + parseInt / 1000) + '' + '' + '' + ''; res.end;
 public function response{ $r["r"] = false; $response = getWebCont(SK_ROBOT_API . iconv("UTF-8","GB2312//IGNORE", $postObj['content'])); //返回的格式是否正确,假如正确,是以[msg]开头的 if(preg_match(SK_REG_ROBOT_RESPONSE_MSG_BEGIN, $response , $match)){ $response = str_replace("[msg]" , "" , $response); $response = str_replace("[/msg]" , "" , $response); $r["r"] = true; $r["res"] = $response; } return $r;}

请求示例:

只需要将header的content-type设置为xml,返回一个xml的响应,那么公众号就会相应的回复一个消息,这里回复的消息是文本格式。

宏定义:

http://sandbox.api.simsimi.com/request.p?key=your_trial_key&lc=en&ft=1.0&text=hi

如上图,发送消息则会回复一个内容一样的消息,一个简单的自动回复就实现了。

define ("SK_ROBOT_API","http://dev.skjqr.com/api/weixin.php?email=your_email&appkey=your_appkey&msg=");// 返回的消息以 [msg] 开头define("SK_REG_ROBOT_RESPONSE_MSG_BEGIN","/[msg]/"); 

参数说明:

图灵机器人

getWebCont是php中通过curl方式发送请求的自定义方法:

key: 申请的API Key

这个接口的使用十分简单,get请求链接,记得带上apikey的头,然后就会返回响应的内容。我这里请求使用的是nodejs request库。

function getWebCont($url, $data = '', $sslVerify = false) {$ch = curl_init();if ($sslVerify) { curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE); curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, FALSE);}curl_setopt($ch, CURLOPT_URL, $url);curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);if  { curl_setopt($ch, CURLOPT_POST, 1); curl_setopt($ch, CURLOPT_POSTFIELDS, $data);}$body = curl_exec;$head = curl_getinfo;$error = curl_error;curl_close;if ($head['http_code'] == '200') { return $body;} else { //log here return false;}}

lc: Language code,支持的语言,简体中文用ch,繁体中文用zh,英文用en,详细请参考:

const request = require;const config = require;function getTuringResponse { if(typeof info !== 'string') { info = info.toString(); } var options = { method:'GET', url: 'http://apis.baidu.com/turing/turing/turing?key=879a6cb3afb84dbf4fc84a1df2ab7319&info='+info, headers: { 'apikey': config.turingKey } }; return new Promise => { request(options, function  { if ; } else { reject}module.exports = getTuringResponse;

可以看到,使用还是比较简单的。

ft: 是否设置过滤器,

使用promise处理异步返回的结果,避免多次回调,记得把apikey设置为header内容。

图灵机器人

  0.0:未过滤(包含诅咒,性内容);

公众号机器人

个人比较喜欢图灵机器人,官方网址: 它返回的聊天数据中,类型比较全面,而且是友好的json格式。而小黄鸡返回的就是一个字符串。

  1.0:过滤不文明字句(暂时只支持韩文)

好了,上面是二者分开的讲的,如果看到这应该知道一个聊天机器人的实现是非常简单的了。就是将接口响应的内容返回给用户(?如果不是非要自己实现聊天机器人的话。。。),后台这里也就相当于一个跳板。

图片 29.pic.jpg

text: 请求的文本

turingRobot.js

针对它返回的数据,我们可以重新对数据进行整合。这是我写的一个方法:

3.3 返回值分析

const request = require;const config = require;function getTuringResponse { if(typeof info !== 'string') { info = info.toString(); } var options = { method:'GET', url: 'http://apis.baidu.com/turing/turing/turing?key=879a6cb3afb84dbf4fc84a1df2ab7319&info='+info, headers: { 'apikey': config.turingKey } }; return new Promise => { request(options, function  { if ; } else { reject}module.exports = getTuringResponse;
/* * 注意:info字段需要urlencode编码 * $postObj是微信返回的数据,我对它进行了二次封装 */public function response{ $r["r"] = true; $response = getWebCont(TL_ROBOT_API . "user我无法理解你的问题。抱歉。"; return $r; } $json = json_decode($response); if(!is_object || !property_exists($json, "code")){ $r['res'] = "我无法理解你的问题。抱歉。"; return $r; } //$r["r"] = true; switch($json->code){ //文本类数据 case 100000: $tmp = $json->text; break; //网址类数据 打开百度 case 200000: $tmp = $json->text . "n" . $json->url; break; //菜谱 红烧肉怎么做? case 308000: $tmp = $json->text . "nn"; foreach($json->list as $kv){ $t = WXResponseHelper::buildHref($kv->name,$kv->detailurl,false); $t .= "(" . $kv->info . ")"; $t .= "nn"; if(!WXResponseHelper::maxLen){ $tmp .= $t; }else{ break; } } break; //列车信息 深圳到成都的火车 case 305000: $tmp = $json->text . "nn"; foreach($json->list as $kv){ $t = $kv->trainnum . "n"; $t .= $kv->start . "(" . $kv->starttime . ")" . " → " . $kv->terminal . "(" . $kv->endtime . ")"; $t .= "nn"; if(!WXResponseHelper::maxLen){ $tmp .= $t; }else{ break; } } break; //航班 明天成都飞深圳的飞机 case 306000: $tmp = $json->text . "nn"; foreach($json->list as $kv){ $t = $kv->starttime . " - " . $kv->endtime . " " . $kv->flight . "nn"; if(!WXResponseHelper::maxLen){ $tmp .= $t; }else{ break; } } break; //酒店 深圳南山区附近的酒店 case 309000: $tmp = $json->text . "nn"; foreach($json->list as $kv){ $t = $kv->price . " " . $kv->satisfaction . " " . WXResponseHelper::buildHref($kv->name,$kv->icon) . "n"; if(!WXResponseHelper::maxLen){ $tmp .= $t; }else{ break; } } break; //商品价格 惠人榨汁机多少钱 case 311000: $tmp = $json->text . "nn"; foreach($json->list as $kv){ $t = $kv->price . " " . WXResponseHelper::buildHref($kv->name,$kv->detailurl) . "nn"; if(!WXResponseHelper::maxLen){ $tmp .= $t; }else{ break; } } break; //新闻 最新新闻 case 302000: $tmp = $json->text . "nn"; foreach($json->list as $kv){ $t = WXResponseHelper::buildHref($kv->article,$kv->icon) . "(" . $kv->source . ")" . "nn"; if(!WXResponseHelper::maxLen){ $tmp .= $t; }else{ break; } } break; case 40001: $tmp = "key的长度错误"; break; case 40002: $tmp = "请求内容为空"; break; case 40003: $tmp = "key错误或帐号未激活"; break; case 40004: $tmp = "当天请求次数已用完"; break; case 40005: $tmp = "暂不支持该功能"; break; case 40006: $tmp = "服务器升级中"; break; case 40007: $tmp = "服务器数据格式异常"; break; case 50000: $tmp = "机器人设定的“学用户说话”或者“默认回答”"; break; default: $tmp = "我无法理解你的问题。抱歉。"; break; } $r['res'] = $tmp; return $r;}

result:执行结果返回码

这部分代码很简单了,就是将图灵机器人的接口响应消息返回出来。下面要做的就是将消息返回给用户,这里有一点需要注意的是对于发出的响应,该接口不能直接响应中文字符串,需要进行urlencode。

宏定义:

    • 100-OK.
    • 400-Bad Request.
    • 401-Unauthorized.
    • 404-Not found.
    • 500-Server Error.
//autoReply.jsconst request = require;function autoReply { switch  { case 'text': var resMsg = '' + '' + '' + '' + parseInt / 1000) + '' + '' + '' + ''; break; } return resMsg;}module.exports = autoReply;
下一篇:没有了