生活随笔
收集整理的這篇文章主要介紹了
webqq2协议分析和qq聊天机器人简单实现(转)
小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.
webqq2協(xié)議分析和qq聊天機(jī)器人簡單實(shí)現(xiàn) 轉(zhuǎn)之http://hfutxf.javaeye.com/blog/800866
Java代碼
ScriptEngineManager?m?=?new?ScriptEngineManager();?? ScriptEngine?se?=?m.getEngineByName("javascript");?? se.eval(new?FileReader(new?File("1.js")));?? Object?t?=?se.eval("md5(md5_3(\""+p+"\")+\""+code.toUpperCase()+"\");");?? return?t.toString();?? ScriptEngineManager m = new ScriptEngineManager(); ScriptEngine se = m.getEngineByName("javascript"); se.eval(new FileReader(new File("1.js"))); Object t = se.eval("md5(md5_3(\""+p+"\")+\""+code.toUpperCase()+"\");"); return t.toString(); ?
現(xiàn)在調(diào)用登陸接口，以獲得相關(guān)的cookie。注意Referer。這個(gè)一定得加上，否則不成功：Referer : http://web2-b.qq.com/proxy.html
?
完整代碼：
Java代碼
import?java.awt.image.BufferedImage;?? import?java.io.BufferedReader;?? import?java.io.File;?? import?java.io.FileReader;?? import?java.io.InputStream;?? import?java.io.InputStreamReader;?? import?java.net.HttpURLConnection;?? import?java.net.URL;?? import?java.net.URLEncoder;?? import?java.util.Date;?? import?java.util.Random;?? import?java.util.regex.Matcher;?? import?java.util.regex.Pattern;?? ?? import?javax.imageio.ImageIO;?? import?javax.script.ScriptEngine;?? import?javax.script.ScriptEngineManager;?? ?? import?atg.taglib.json.util.JSONArray;?? import?atg.taglib.json.util.JSONException;?? import?atg.taglib.json.util.JSONObject;?? ?? ?? public?class?QQClient?{?? ?? ????private?int?qq?=?-1;?? ????private?String?pwd?=?null;?? ?????? ????private?int?clientid?=?66933334;//這個(gè)可以隨便寫?? ????private?String?psessionid?=?"";?? ?????? ????private?String?ptwebqq;?? ????private?String?vfwebqq;?? ?????? ????private?String?skey;?? ?????? ????private?String?refer?=?"http://web2-b.qq.com/proxy.html";?? ?????? ????private?String?cookie?=?"";?? ????//讀取消息線程?? ????private?boolean?isrun?=?false;?? ????private?Thread?poolThread?=new?PollThread();?? ????public?Thread?getPoolThread()?{?? ????????return?poolThread;?? ????}?? ????/**? ?????*?記錄日志? ?????*/?? ????private?void?log(String?msg){?? ????????System.out.println(new?Date().toLocaleString()+":"+msg);?? ????}?? ?????? ?????? ????public?QQClient(int?qq,?String?pwd)?{??? ????????this.qq?=?qq;?? ????????this.pwd?=?pwd;?? ????????try?{?? ????????????boolean?rs?=?checkAndLogin();?? ????????????if(rs){??? ????????????????isrun?=?true;?? ????????????????poolThread.start();//開始循環(huán)接收?? ????????????????log("啟動(dòng)成功");?? ????????????}?? ????????}?catch?(Exception?e)?{??? ????????????e.printStackTrace();?? ????????}?? ????}?? ????/*****************華麗的分界線*****************/?? ????//測(cè)試?? ????public?static?void?main(String[]?args)?throws?Exception{?? ????????QQClient?q?=?new?QQClient(qq號(hào)碼,?"123");??? ????????q.getPoolThread().join();?? ????}?? ?????? ????/*****************華麗的分界線*****************/?? ????/**? ?????*?給toQQ發(fā)送一個(gè)msg消息，前提是toQQ是你的好友，要不然他收不到? ?????*/?? ????public?boolean?sendMsg(int?toQQ,?String?message){?? ????????try?{?? ????????????JSONObject?json?=?new?JSONObject();?? ????????????json.put("to",?toQQ);//要發(fā)送的人?? ????????????json.put("face",?0);?? ?????????????? ????????????JSONArray?msg?=?new?JSONArray();?? ????????????msg.add(message);?? ????????????JSONArray?font?=?new?JSONArray();?? ????????????font.add("font");?? ?????????????? ????????????JSONObject?font1?=?new?JSONObject().put("name",?"宋體").put("size",?"10");?? ?????????????? ????????????JSONArray?style?=?new?JSONArray();?? ????????????style.add(0);?? ????????????style.add(0);?? ????????????style.add(0);????????? ????????????font1.put("style",?style);?? ????????????font1.put("color",?"000000");?? ?????????????? ????????????font.add(font1);??????? ????????????msg.add(font);?? ?????????????? ????????????json.put("content",?msg.toString());?? ????????????json.put("msg_id",?new?Random().nextInt(10000000));?? ????????????json.put("clientid",?clientid);?? ????????????json.put("psessionid",?psessionid);//需要這個(gè)才能發(fā)送?? ????????????String?sendMsgUrl?=?"http://web2-b.qq.com/channel/send_msg";?? ????????????String?content?=?json.toString();?? ??????????????? ????????????content?=?URLEncoder.encode(content);//他要需要編碼?? ????????????content?="r="+content;?? ????????????//發(fā)送?? ????????????String?res?=?postUrl(sendMsgUrl,?content);?? ????????????//不出意外，這是返回結(jié)果：{"retcode":0,"result":"ok"}?? ????????????JSONObject?rh?=?new?JSONObject(res);?? ????????????if("ok".equals(rh.getString("result"))){?? ????????????????return?true;?? ????????????}??? ????????}?catch?(JSONException?e)?{??? ????????????e.printStackTrace();?? ????????}?? ?????????? ????????return?false;?? ????}?? ?????? ????/**? ?????*?檢查并且登陸? ?????*/?? ????private?boolean?checkAndLogin()?throws?Exception{?? ????????if(qq?==?-1?||?pwd?==?null)?? ????????????throw?new?IllegalArgumentException("qq和密碼不能為空");?? ????????String?checkIdUrl?=?"http://ptlogin2.qq.com/check?appid=1003903&uin="+qq;?? ????????String?res?=?getUrl(checkIdUrl);?? ????????//ptui_checkVC('0','!ZLE');返回這個(gè)就不需要獲取驗(yàn)證碼了。驗(yàn)證碼就是!ZLE??? ????????//ptui_checkVC('1','95ab7db15e5ab17f50f25d33598259e83ccc098c4af2f8a4');這個(gè)長字符串就需要使用了?? ????????Pattern?p?=?Pattern.?compile("\\,\\'([!\\w]+)\\'");?? ????????Matcher?m?=?p.?matcher(res);?? ????????String?checkType?=?"";?? ????????if(m.find()){?? ????????????checkType?=?m.group(1);??? ????????}?? ????????String?check?=?"";??? ????????if(!checkType.startsWith("!")){?? ????????????//需要輸入驗(yàn)證碼?? ????????????String?getCheckImageUrl?=?"http://captcha.qq.com/getimage?aid=1003903&uin="+qq+"&vc_type="+checkType;?? ????????????String?file?=?readCheckImage(getCheckImageUrl);?? ????????????log("請(qǐng)打開"+file+"，并且在這里輸入其中的字符串，然后回車：");?? ????????????InputStreamReader?ins?=?new?InputStreamReader(System.in);?? ????????????BufferedReader?br?=?new?BufferedReader(ins);?? ????????????check?=?br.readLine();???? ????????}else{?? ????????????//不需要輸入驗(yàn)證碼?? ????????????check?=?checkType;?? ????????}?? ?????????? ????????//開始登陸?? ????????String?loginUrl?=?"http://ptlogin2.qq.com/login?u="+qq+"&"?+?? ????????????????"p="?+mdP(pwd,?check)+?? ????????????????"&verifycode="+check+"&remember_uin=1&aid=1003903"?+?? ????????????????"&u1=http%3A%2F%2Fweb2.qq.com%2Floginproxy.html%3Fstrong%3Dtrue"?+?? ????????????????"&h=1&ptredirect=0&ptlang=2052&from_ui=1&pttype=1&dumy=&fp=loginerroralert";?? ????????res?=?getUrl(loginUrl);?? //??????ptuiCB('0','0','http://web2.qq.com/loginproxy.html?strong=true','0','登錄成功！');?? //??????ptuiCB('4','0','','0','您輸入的驗(yàn)證碼有誤，請(qǐng)重試。');?? ??????? ????????p?=?Pattern.compile("登錄成功！");//提取最后一個(gè)字符串，看看是不是?登錄成功！?? ????????m?=?p.?matcher(res);?? ????????if(m.find()){?? ????????????log("登陸成功");??? ????????}else{?? ????????????//登陸失敗?? ????????????log(checkType);?? ????????????return?false;?? ????????}?? ????????//從cookie中提取ptwebqq,skey?? ????????p?=?Pattern.compile("ptwebqq=(\\w+);");?? ????????m?=?p.matcher(cookie);?? ????????if(m.find()){?? ????????????ptwebqq?=?m.group(1);?? ????????}?? ????????p?=?Pattern.compile("skey=(@\\w+);");?? ????????m?=?p.matcher(cookie);?? ????????if(m.find()){?? ????????????skey?=?m.group(1);?? ????????}?? ????????log("ptwebqq="+ptwebqq+",skey="+skey);?? ?????????? ????????//再次登陸，只有這次登陸，才算真正登陸qq，這個(gè)時(shí)候，如果你qq已經(jīng)登陸，會(huì)把你的qq踢下線，而且此次登陸才算上線。?? ????????String?channelLoginUrl?=?"http://web2-b.qq.com/channel/login";?? ????????String?content?=?"{\"status\":\"\",\"ptwebqq\":\""+ptwebqq+"\",\"passwd_sig\":\"\",\"clientid\":\""+clientid+"\"}";?? ????????content?=?URLEncoder.encode(content);//urlencode??? ????????content?=?"r="+content;//post的數(shù)據(jù)?? ????????res?=?postUrl(channelLoginUrl,?content);//post?? ????????//這次登陸基本上不會(huì)發(fā)生什么問題?? ????????//下面提取很重要的2個(gè)數(shù)據(jù)psessionid?,vwebqq，通用采用正則表達(dá)式,雖然結(jié)果是個(gè)json?? ????????p?=?Pattern.compile("\"vfwebqq\":\"(\\w+)\"");?? ????????m?=?p.matcher(res);?? ????????if(m.find()){?? ????????????vfwebqq?=?m.group(1);?? ????????}?? ????????p?=?Pattern.compile("\"psessionid\":\"(\\w+)\"");?? ????????m?=?p.matcher(res);?? ????????if(m.find()){?? ????????????psessionid?=?m.group(1);?? ????????}?? ????????log("vwebqq="+vfwebqq+","+"psessionid="+psessionid);?? ????????//到此，登陸就算完成了，后面可以調(diào)用發(fā)送qq信息等接口了????????? ?????????return?true;?? ????}?? ?????? ?? ?????? ?????? ????/**? ?????*?調(diào)用tx的js來生成密鑰? ?????*/?? ????public??String?mdP(String?p,?String?code){?? ????????try?{?? ????????????ScriptEngineManager?m?=?new?ScriptEngineManager();?? ????????????ScriptEngine?se?=?m.getEngineByName("javascript");?? ????????????se.eval(new?FileReader(new?File("1.js")));?? ????????????Object?t?=?se.eval("md5(md5_3(\""+p+"\")+\""+code.toUpperCase()+"\");");?? ????????????return?t.toString();?? ????????}catch?(Exception?e)?{?? ????????????e.printStackTrace();?? ????????}??? ????????return?null;?? ????}?? ????/**? ?????*?POST一個(gè)url,contents是輸入的內(nèi)容? ?????*/?? ????private??String?postUrl(String?url,?String?contents){?? ????????try{??? ????????????System.out.println("post>>>"+url);?? ??????????????? ????????????URL?serverUrl?=?new?URL(url);?? ????????????HttpURLConnection?conn?=?(HttpURLConnection)?serverUrl.openConnection();??? ????????????conn.setRequestMethod("POST");//"POST"?,"GET"??? ????????????? ????????????if(refer?!=?null){?? ????????????????conn.addRequestProperty("Referer",?refer);?? ????????????}?? ????????????conn.addRequestProperty("Cookie",?cookie);?? ????????????conn.addRequestProperty("Accept-Charset",?"UTF-8;");//GB2312,?? ????????????conn.addRequestProperty("User-Agent",?"Mozilla/5.0?(Windows;?U;?Windows?NT?5.1;?zh-CN;?rv:1.9.2.8)?Firefox/3.6.8");?? ????????????conn.setDoOutput(true);??? ????????????conn.connect();?? ?????????????? ????????????conn.getOutputStream().write(contents.getBytes());?? ?????????????? ????????????if(conn.getHeaderFields().get("Set-Cookie")?!=?null){?? ????????????????for(String?s:conn.getHeaderFields().get("Set-Cookie")){?? ????????????????????cookie?+=?s;?? ????????????????}?? ????????????}?? ?????????????? ????????????InputStream?ins?=??conn.getInputStream();?? ?????????????? ????????????String?charset?=?"UTF-8";??? ????????????InputStreamReader?inr?=?new?InputStreamReader(ins,?charset);?? ????????????BufferedReader?bfr?=?new?BufferedReader(inr);?? ????????????? ????????????String?line?=?"";?? ????????????StringBuffer?res?=?new?StringBuffer();??? ????????????do{?? ????????????????res.append(line);?? ????????????????line?=?bfr.readLine();?? ???????????????//System.out.println(line);?? ????????????}while(line?!=?null);?? ???????????? ????????????System.out.println(">>>==="+res);?? ?????????????? ????????????return?res.toString();?? ????????}catch(Exception?e){?? ????????????e.printStackTrace();?? ????????????return?null;?? ????????}?? ????}?? ?????? ?????? ????/**? ?????*?GET?一個(gè)url? ?????*/?? ????private??String?getUrl(String?url){?? ????????try{??? ????????????System.out.println("get>>>"+url);?? ??????????????? ????????????URL?serverUrl?=?new?URL(url);?? ????????????HttpURLConnection?conn?=?(HttpURLConnection)?serverUrl.openConnection();??? ????????????conn.setRequestMethod("GET");//"POST"?,"GET"?? ???????????//?conn.setDoOutput(true);??? ????????????if(refer?!=?null){?? ????????????????conn.addRequestProperty("Referer",?refer);?? ????????????}?? ????????????conn.addRequestProperty("Cookie",?cookie);?? ????????????conn.addRequestProperty("Accept-Charset",?"UTF-8;");//GB2312,?? ????????????conn.addRequestProperty("User-Agent",?"Mozilla/5.0?(Windows;?U;?Windows?NT?5.1;?zh-CN;?rv:1.9.2.8)?Firefox/3.6.8");?? ????????????conn.connect();?? ????????????? ????????????if(conn.getHeaderFields().get("Set-Cookie")?!=?null){?? ????????????????for(String?s:conn.getHeaderFields().get("Set-Cookie")){?? ????????????????????cookie?+=?s;?? ????????????????}?? ????????????}?? ????????????InputStream?ins?=??conn.getInputStream();?? ?????????????? ????????????String?charset?=?"UTF-8";??? ????????????InputStreamReader?inr?=?new?InputStreamReader(ins,?charset);?? ????????????BufferedReader?bfr?=?new?BufferedReader(inr);?? ????????????? ????????????String?line?=?"";?? ????????????StringBuffer?res?=?new?StringBuffer();??? ????????????do{?? ????????????????res.append(line);?? ????????????????line?=?bfr.readLine();?? ???????????????//System.out.println(line);?? ????????????}while(line?!=?null);?? ???????????? ????????????System.out.println(">>>==="+res);?? ?????????????? ????????????return?res.toString();?? ????????}catch(Exception?e){?? ????????????e.printStackTrace();?? ????????????return?null;?? ????????}?? ????}?? ?????? ????/**? ?????*?讀取驗(yàn)證碼。返回驗(yàn)證碼文件保存的路徑? ?????*/?? ????private?String?readCheckImage(String?url){?? ????????try{??? ????????????System.out.println("get>>>"+url);?? ??????????? ????????????URL?serverUrl?=?new?URL(url);?? ????????????HttpURLConnection?conn?=?(HttpURLConnection)?serverUrl.openConnection();??? ????????????conn.setRequestMethod("GET");//"POST"?,"GET"??? ?????????????? ????????????conn.addRequestProperty("Accept-Charset",?"UTF-8;");//GB2312,?? ????????????conn.addRequestProperty("User-Agent",?"Mozilla/5.0?(Windows;?U;?Windows?NT?5.1;?zh-CN;?rv:1.9.2.8)?Firefox/3.6.8");?? ????????????conn.connect();?? ????????????//返回的cookie?? ????????????if(conn.getHeaderFields().get("Set-Cookie")?!=?null)?? ????????????????for(String?s:conn.getHeaderFields().get("Set-Cookie")){?? ????????????????????cookie?+=?s;?? ????????????????}?? ?????????????? ????????????InputStream?ins?=??conn.getInputStream();?? ?????????????? ????????????BufferedImage?bi?=?ImageIO.read(ins);?? ????????????File?f?=new?File("qqimg.jpg");?? ????????????ImageIO.write(bi,?"jpg",?f);?? ?????????????? ????????????return?f.getAbsolutePath();?? ????????}catch(Exception?e){?? ????????????e.printStackTrace();??? ????????}??? ????????return?null;?? ????}?? ?????? ????/**? ?????*?當(dāng)有qq消息是回調(diào)此函數(shù)? ?????*/?? ????public?void?receiveMsg(String?message,?int?fromQQ){?? ????????log("qq:"+fromQQ+"說:"+message);?? ????????//test?? ????????sendMsg(fromQQ,?"然后呢？");?? ????}?? ?????? ????/**? ?????*?通過poll一直等待服務(wù)器回應(yīng)。比如收到消息啊，好友上線啊，申請(qǐng)好友啊之類的各類消息都會(huì)通過此接口返回，在獲得數(shù)據(jù)后，應(yīng)該繼續(xù)poll獲取下個(gè)數(shù)據(jù)? ?????*?http://web2-b.qq.com/channel/poll? ?????*/?? ????class?PollThread?extends?Thread{?? ?????????? ????????private?String?pollUrl?=?"http://web2-b.qq.com/channel/poll";?? ????????@Override?? ????????public?void?run()?{??? ????????????String?url?=?pollUrl+?"?clientid="+clientid+"&psessionid="+psessionid;??? ?????????????? ????????????try?{?? ????????????????while(isrun){?? ????????????????????//線程一直等待知道服務(wù)器有返回?cái)?shù)據(jù)?? ????????????????????String?res?=?getUrl(url);?? ?????????????????????? ????????????????????JSONObject?retJ?=?new?JSONObject(res);?? ????????????????????if(retJ.getInt("retcode")?==?0){?? ????????????????????????JSONArray?result?=?retJ.getJSONArray("result");?? ????????????????????????String?poll_type?=?result.getJSONObject(0).getString("poll_type");?? ????????????????????????if("message".equals(poll_type)){?? ????????????????????????????//說明有人發(fā)qq消息給我，???????????????????????????? ????????????????????????????String?raw_content?=?result.getJSONObject(0).getJSONObject("value").get("raw_content").toString();??? ????????????????????????????int?from_uin?=?result.getJSONObject(0).getJSONObject("value").getInt("from_uin");?? ????????????????????????????log("收到來自："+from_uin+":"+raw_content);?? ????????????????????????????//通知客戶端收到了?? ????????????????????????????receiveMsg(raw_content,?from_uin);?? ????????????????????????}?? ????????????????????????//system_message?是系統(tǒng)消息?? ????????????????????}?? ????????????????}?? ????????????}?catch?(JSONException?e)?{??? ????????????????e.printStackTrace();?? ????????????}?? ????????}?? ?????????? ????}?? ?? ?????? }?
總結(jié)
以上是生活随笔 為你收集整理的webqq2协议分析和qq聊天机器人简单实现(转) 的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
如果覺得生活随笔 網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔 推薦給好友。
