webQQ协议java的实现方法-程序员宅基地

转载自：http://www.javadt.com/article-131-1.html

webQQ协议java的实现方法

2012-4-12 10:42| 发布者: 低调| 查看: 4| 评论: 9|原作者: dt|编辑 |删除

摘要: 迷你版QQ实现，采用WEBQQ协议，具备登陆，获取qq好友列表，收发消息功能。只做学习之用，无任何价值，有兴趣的童鞋拿出修改完善。对于qq号和密码填写正确，但出现这种情况的原因可能是你的qq需要验证码登陆。 ...

迷你版QQ实现，采用WEBQQ协议，具备登陆，获取qq好友列表，收发消息功能。
只做学习之用，无任何价值，有兴趣的童鞋拿出修改完善。

对于qq号和密码填写正确，但出现这种情况的原因可能是你的qq需要验证码登陆。
获取验证码的方法很简单
直接去
http://captcha.qq.com/getimage?aid=1003903&uin="+qq号码+"&vc_type="+checkType; //代码登陆的时候有这个checkType
发送http请求，将结果写出图片文件，打开图片就可以看到验证码。
代码中加入手动加入验证码即可正常登陆。（代码中131行验证码）

Java代码
InputStreamReader ins = new InputStreamReader(System.in);
BufferedReader br = new BufferedReader(ins);
check = br.readLine();

Java代码
package com.mrlans.qq;

import java.io.BufferedReader;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.Serializable;
import java.io.UnsupportedEncodingException;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLEncoder;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.ListIterator;
import java.util.Map;
import java.util.Random;
import java.util.Set;
import java.util.Map.Entry;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import java.util.zip.GZIPInputStream;

import javax.script.ScriptEngine;
import javax.script.ScriptEngineManager;

import atg.taglib.json.JsonEntity;
import atg.taglib.json.util.JSONArray;
import atg.taglib.json.util.JSONException;
import atg.taglib.json.util.JSONObject;
import atg.taglib.json.util.JSONStringer;

/**
* QQ MINI 客户端
* @author mrlans E-mail:[email protected]
* @version create Time：Dec 11, 2010 8:54:38 PM
*
*/
@SuppressWarnings({"unused","deprecation"})
public class MiniQQClient
{

private int qq = 4008403;
private String password = null;

private int clientid = 73937875;
private String psessionid = "";
private String ptwebqq;
private String vfwebqq;
private String skey;

private final String host = "http://d.web2.qq.com";

private String refer = this.host+"/proxy.html?v=20101025002";

private String cookie = "";

private Map<Long, User> firends = new HashMap<Long, User>();
private Map<Long, User> firends2 = new HashMap<Long, User>();

public enum METHOD {GET, POST}

private boolean run = false;
private PollMessageThread poll = new PollMessageThread();
public Thread getPoolThread()
{
      return poll;
}

public MiniQQClient(int qq, String password)
{
      this.qq = qq;
      this.password = password;

      try
      {
         boolean login = login();
         if(login)
         {
            //fetchAllOnlineFriends();
            fetchAllFriends();
            run = true;
            getPoolThread().start();
            log("QQ START SUCESS.......");

            sendMsgToQQ(4008403, "哥上线了！");
         }
      }
      catch (Exception e)
      {
         log("QQ发生异常退出\t"+e.getMessage());
         Thread.currentThread().stop();
      }
}

public static void main(String[] args)
{
      MiniQQClient clinet = new MiniQQClient(4008403, "密码填写处");
      try
      {
         clinet.getPoolThread().join();
      }
      catch (Exception e)
      {
         System.out.println("QQ异常退出\t"+e.getMessage());
      }
}

private boolean login()
{
      //login 1
      String checkQQUrl = "http://ptlogin2.qq.com/check?appid=1003903&uin="+qq;
      String result = sendHttpMessage(checkQQUrl, METHOD.GET.name(), null);
      Pattern p = Pattern. compile("\\,\\'([!\\w]+)\\'");
      Matcher m = p. matcher(result);
      String checkType = "";
      if(m.find())
      {
         checkType = m.group(1);
      }
      String check = "";
      if(!checkType.startsWith("!"))
      {
         //生成图片验证码
      }
      else
      {
         check = checkType;
      }

      //login 2
      String loginUrl = "http://ptlogin2.qq.com/login?u="+qq+"&" +
            "p=" +encodePass(this.password, 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";

      result = sendHttpMessage(loginUrl, METHOD.GET.name(), null);

      p = Pattern.compile("登录成功！");
      m = p. matcher(result);
      if(m.find())
      {
         log("Welcome QQ : "+this.qq+" Login Success！");
      }
      else
      {
         log(checkType);
         return false;
      }

      //从cookie中提取ptwebqq,skey
      p = Pattern.compile("ptwebqq=(\\w+);");
      m = p.matcher(cookie);
      if(m.find())
      {
         this.ptwebqq = m.group(1);
      }
      p = Pattern.compile("skey=(@\\w+);");
      m = p.matcher(cookie);
      if(m.find())
      {
         this.skey = m.group(1);
      }
      //log("ptwebqq="+ptwebqq+",skey="+skey);

      //login 3
      String channelLoginUrl = this.host+"/channel/login2";
      String content = "{\"status\":\"\",\"ptwebqq\":\""+ptwebqq+"\",\"passwd_sig\":\"\",\"clientid\":\""+clientid+"\"}";
      try
      {
         content = URLEncoder.encode(content,"UTF-8");
      }
      catch (UnsupportedEncodingException e)
      {
      }
      content = "r="+content;//post的数据
      result = sendHttpMessage(channelLoginUrl, METHOD.POST.name(), content);

      p = Pattern.compile("\"vfwebqq\":\"(\\w+)\"");
      m = p.matcher(result);
      if(m.find())
         this.vfwebqq = m.group(1);
      p = Pattern.compile("\"psessionid\":\"(\\w+)\"");
      m = p.matcher(result);
      if(m.find())
         psessionid = m.group(1);
      //log("vwebqq="+vfwebqq);
      //log("psessionid="+psessionid);

      return true;
}

//登陆成功取QQ好友
public void fetchAllFriends()
{
      String getFriendsurl = "http://web2-b.qq.com/api/get_user_friends2";
      String getFriendsurl2 = "http://web2-b.qq.com/api/get_user_friends";
      String result = fetchAllFriends(getFriendsurl);
      String result2 = fetchAllFriends(getFriendsurl2);
      //firends
      Map<String, User> user = getFriendInfo(result);  //
      Map<String, User> user2 = getFriendInfo(result2); //真正的QQ号码

      if(user!=null && user2!=null && user.size() == user2.size())
      {
         Set<Map.Entry<String, User>> set = user.entrySet();
         for(Iterator<Entry<String, User>> it = set.iterator(); it.hasNext();)
         {
            Entry<String, User> e = it.next();
            User u = e.getValue();
            u.setQq(user2.get(e.getKey()).getUin());
            log(u.getQq()+"\t"+u.getNick()+"\t"+u.getUin());
            firends.put(u.getQq(), u);
            firends2.put(u.getUin(), u);
         }
      }
}

//在线用户
public void fetchAllOnlineFriends()
{
      String onlineUserURL = host+"/channel/get_online_buddies2";
      onlineUserURL = onlineUserURL+ "?clientid="+clientid+"&psessionid="+psessionid;
      String  result = sendHttpMessage(onlineUserURL, METHOD.GET.name(), null);
      System.out.println(result);
}

@SuppressWarnings("unchecked")
public  Map<String, User>  getFriendInfo(String result)
{
      Map<String, User> users = new HashMap<String, User>(500);
      try
      {
         JSONObject retJson = new JSONObject(result);
         if( retJson.getInt("retcode") == 0)
         {
            JSONArray  infos = retJson.getJSONObject("result").getJSONArray("info");
            for(ListIterator<JSONObject> it = infos.listIterator(); it.hasNext();)
            {
                  JSONObject obj = it.next();
                  User user = new User(obj.getLong("uin"), obj.getString("nick"), obj.getInt("face"), obj.getLong("flag"));
                  users.put(user.getNick()+user.getFlag(), user);
            }
         }
      }
      catch (Exception e)
      {
         log("getFriendInfo failure  "+e.getMessage());
      }
      return users;
}

public String fetchAllFriends(String getFriendsurl)
{
      //{"h":"hello","vfwebqq":"7fe84931db23dc5a0351d759905642bcf5d09632e001bbfc8822809067538431d4da9dd1e8e653a0"}
      String content = "{\"h\":\"hello\",\"vfwebqq\":\""+vfwebqq+"\"}";
      try
      {
         content = URLEncoder.encode(content, "UTF-8");
         content = "r="+content;
         String  result = sendHttpMessage(getFriendsurl, METHOD.POST.name(), content);
         //log("AllFriends= "+result);
         return result;
      }
      catch (Exception e)
      {
         log("fetchAllFriends failure.............\t"+e.getMessage());
         return null;
      }
}

public User getFriend(long qq)
{
      return this.firends.get(qq);
}


public boolean sendMsg(long toQQ, String message)
{
      try
      {
         JSONObject json = new JSONObject();
         json.put("to", toQQ);//要发送的人
         json.put("face", 330);

         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", this.clientid);
         json.put("psessionid", this.psessionid);//需要这个才能发送
         String sendMsgUrl = this.host+"/channel/send_msg2";
         String content = json.toString();

         try
         {
            content = URLEncoder.encode(content,"UTF-8");
         }
         catch (UnsupportedEncodingException e)
         {
         }//他要需要编码
         content ="r="+content;
         //发送
         String res = sendHttpMessage(sendMsgUrl, METHOD.POST.name(), content);
         //不出意外，这是返回结果：{"retcode":0,"result":"ok"}
         if(null == res || !res.contains("result"))  return false;
         JSONObject rh = new JSONObject(res);
         if("ok".equals(rh.getString("result")))
         {
            return true;
         }
      }
      catch (Exception e)
      {
         log("send message to "+toQQ+" failure......\n"+e.getMessage());
      }
      return false;
}

public boolean sendMsgToQQ(long qq, String message)
{
      return sendMsg(getFriend(qq).getUin(), message);
}

//HTTP 消息发送
public String sendHttpMessage(String url, String method, String contents)
{
      try
      {
         log("request="+url);
         URL serverUrl = new URL(url);
         HttpURLConnection conn = (HttpURLConnection) serverUrl.openConnection();
         conn.setConnectTimeout(20000);
         conn.setRequestMethod(method);//"POST" ,"GET"
         if(null != refer)
            conn.addRequestProperty("Referer", refer);

         conn.addRequestProperty("Cookie", cookie);
         conn.addRequestProperty("Connection", "Keep-Alive");
         conn.addRequestProperty("Accept-Language", "zh-cn");
         conn.addRequestProperty("Accept-Encoding", "gzip, deflate");
         conn.addRequestProperty("Cache-Control", "no-cache");
         conn.addRequestProperty("Accept-Charset", "UTF-8;");
         conn.addRequestProperty("User-Agent", "Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 5.1; Trident/4.0; .NET CLR 2.0.50727)");
         if(method.equalsIgnoreCase(METHOD.GET.name()))
         {
            conn.connect();
         }
         else if(method.equalsIgnoreCase(METHOD.POST.name()))
         {

            conn.setDoOutput(true);
            conn.connect();
            conn.getOutputStream().write(contents.getBytes());
         }
         else
            throw new RuntimeException("your method is not implement");


         if(conn.getHeaderFields().get("Set-Cookie") != null)
         {
            for(String s:conn.getHeaderFields().get("Set-Cookie"))
            {
                  cookie += s;
            }
         }

         InputStream ins =  conn.getInputStream();

         //处理GZIP压缩的
         if(null != conn.getHeaderField("Content-Encoding") && conn.getHeaderField("Content-Encoding").equals("gzip"))
         {
            byte[] b = null;
            GZIPInputStream gzip = new GZIPInputStream(ins);
            byte[] buf = new byte[1024*8];
            int num = -1;
            ByteArrayOutputStream baos = new ByteArrayOutputStream();
            while ((num = gzip.read(buf, 0, buf.length)) != -1)
            {
                  baos.write(buf, 0, num);
            }
            b = baos.toByteArray();
            baos.flush();
            baos.close();
            gzip.close();
            ins.close();
            return new String(b).trim();
         }

         String charset = "UTF-8";
         InputStreamReader inr = new InputStreamReader(ins, charset);
         BufferedReader br = new BufferedReader(inr);

         String line = "";
         StringBuffer sb = new StringBuffer();
         do
         {
            sb.append(line);
            line = br.readLine();
         }while(line != null);
         log("response="+sb);
         return sb.toString();
      }
      catch (MalformedURLException e)
      {
         // TODO Auto-generated catch block
         e.printStackTrace();
         return null;
      }
      catch (IOException e)
      {
         // TODO Auto-generated catch block
         e.printStackTrace();
         return null;
      }

}

//加密密码
public  String encodePass(String pass, String code)
{
      try
      {
         ScriptEngineManager m = new ScriptEngineManager();
         ScriptEngine se = m.getEngineByName("javascript");
         se.eval(new FileReader(new File(this.getClass().getClassLoader().getResource("com/mrlans/qq/1.js").getPath())));
         Object t = se.eval("md5(md5_3(\""+pass+"\")+\""+code.toUpperCase()+"\");");
         return t.toString();
      }catch (Exception e)
      {
         e.printStackTrace();
      }
      return null;
}


// 记录日志
private void log(String msg)
{
      System.out.println(new SimpleDateFormat("yyyy-MM-dd hh:mm:ss").format(new Date())+" : "+ msg);
}

public String numToIp(Long num)
{
      String aaa = Long.toHexString(num);
      String n1 = Integer.parseInt(aaa.substring(0,2),16)+"";
      String n2 = Integer.parseInt(aaa.substring(2,4),16)+"";
      String n3 = Integer.parseInt(aaa.substring(4,6),16)+"";
      String n4 = Integer.parseInt(aaa.substring(6),16)+"";

      return n1+"."+n2+"."+n3+"."+n4;
}

public void receiveMsg(JSONObject value) throws Exception
{
      String content = value.getJSONArray("content").getString(1);
      long from_uin = value.getLong("from_uin");
      long reply_ip = value.getLong("reply_ip");

      sendMsg(from_uin, "此乃QQ聊天机器人程序测试中，消息会转发到QQ：4008403上");
      Thread.sleep(2000);
      User u = firends2.get(from_uin);
      if(null == u)
         sendMsgToQQ(4008403, "[qq = "+from_uin+"] send message  :\r\n"+content);
      else
      {
         log("receive [qq = "+u.getQq()+" and name ="+u.getNick()+"] message {"+content+"}  ~~~");
         sendMsgToQQ(4008403, "[qq = "+u.getQq()+" and name ="+u.getNick()+"] send message  :\r\n"+content);
      }
}

public void changeStatus(JSONObject value) throws Exception
{
      long from_uin = value.getLong("uin");
      String status = value.getString("status");
      User u = firends2.get(from_uin);
      log("用户："+u.getNick()+"\t"+status);
}

class PollMessageThread extends Thread
{
      @Override
      public void run()
      {
            String pollUrl = host+ "/channel/poll2?clientid="+clientid+"&psessionid="+psessionid;
            while(run)
            {
                  try
                  {
                     String ret= sendHttpMessage(pollUrl, METHOD.GET.name(), null);
                     JSONObject retJ = new JSONObject(ret);
                     int retcode = retJ.getInt("retcode");
                     if(retcode == 0)
                     {
                        JSONArray result = retJ.getJSONArray("result");
                        String poll_type = result.getJSONObject(0).getString("poll_type");
                        JSONObject value = result.getJSONObject(0).getJSONObject("value");
                        if("message".equals(poll_type))
                        {//好友消息
                              try
                              {
                                 receiveMsg(value);
                              }
                              catch (Exception e)
                              {
                              }
                        }
                        else if("buddies_status_change".equals(poll_type))
                        {//好友上下线
                              changeStatus(value);
                        }
                        else if("group_message".equals(poll_type))
                        {//群消息

                        }
                        //system_message 是系统消息
                     }
                     else if(retcode == 121)
                     {
                        run = false;
                        log("QQ已经在别处登录！");
                     }
                  }
                  catch (Exception e)
                  {
                     // TODO: handle exception
                     log("Response PollMessage failure = "+e.getMessage());
                  }
            }
      }
}
}

@SuppressWarnings("serial")
class User implements Serializable
{
private long uin;

private long qq;

private String nick;

private int face;

private long flag;

public User()
{
      super();
}

public User(long uin, String nick, int face, long flag)
{
      super();
      this.uin = uin;
      this.nick = nick;
      this.face = face;
      this.flag = flag;
}

public long getUin()
{
      return uin;
}

public void setUin(long uin)
{
      this.uin = uin;
}

public long getQq()
{
      return qq;
}

public void setQq(long qq)
{
      this.qq = qq;
}

public String getNick()
{
      return nick;
}

public void setNick(String nick)
{
      this.nick = nick;
}

public int getFace()
{
      return face;
}

public void setFace(int face)
{
      this.face = face;
}

public long getFlag()
{
      return flag;
}

public void setFlag(long flag)
{
      this.flag = flag;
}

@Override
public String toString()
{
      String user = this.uin+"\t\t"+this.qq+"\t\t"+this.nick+"\t\t"+this.flag;
      return user;
}
}

本文链接：https://blog.csdn.net/a13476386553/article/details/84185466

原作者删帖不实内容删帖广告或垃圾文章投诉

智能推荐

oracle 12c 集群安装后的检查_12c查看crs状态-程序员宅基地

文章浏览阅读1.6k次。安装配置gi、安装数据库软件、dbca建库见下：http://blog.csdn.net/kadwf123/article/details/784299611、检查集群节点及状态：[root@rac2 ~]# olsnodes -srac1 Activerac2 Activerac3 Activerac4 Active[root@rac2 ~]_12c查看crs状态

解决jupyter notebook无法找到虚拟环境的问题_jupyter没有pytorch环境-程序员宅基地

文章浏览阅读1.3w次，点赞45次，收藏99次。我个人用的是anaconda3的一个python集成环境，自带jupyter notebook，但在我打开jupyter notebook界面后，却找不到对应的虚拟环境，原来是jupyter notebook只是通用于下载anaconda时自带的环境，其他环境要想使用必须手动下载一些库：1.首先进入到自己创建的虚拟环境(pytorch是虚拟环境的名字)activate pytorch2.在该环境下下载这个库conda install ipykernelconda install nb__jupyter没有pytorch环境

国内安装scoop的保姆教程_scoop-cn-程序员宅基地

文章浏览阅读5.2k次，点赞19次，收藏28次。选择scoop纯属意外，也是无奈，因为电脑用户被锁了管理员权限，所有exe安装程序都无法安装，只可以用绿色软件，最后被我发现scoop，省去了到处下载XXX绿色版的烦恼，当然scoop里需要管理员权限的软件也跟我无缘了（譬如everything）。推荐添加dorado这个bucket镜像，里面很多中文软件，但是部分国外的软件下载地址在github，可能无法下载。以上两个是官方bucket的国内镜像，所有软件建议优先从这里下载。上面可以看到很多bucket以及软件数。如果官网登陆不了可以试一下以下方式。_scoop-cn

Element ui colorpicker在Vue中的使用_vue el-color-picker-程序员宅基地

文章浏览阅读4.5k次，点赞2次，收藏3次。首先要有一个color-picker组件 <el-color-picker v-model="headcolor"></el-color-picker>在data里面data() { return {headcolor: ’ #278add ’ //这里可以选择一个默认的颜色} }然后在你想要改变颜色的地方用v-bind绑定就好了，例如：这里的:sty..._vue el-color-picker

迅为iTOP-4412精英版之烧写内核移植后的镜像_exynos 4412 刷机-程序员宅基地

文章浏览阅读640次。基于芯片日益增长的问题，所以内核开发者们引入了新的方法，就是在内核中只保留函数，而数据则不包含，由用户（应用程序员）自己把数据按照规定的格式编写，并放在约定的地方，为了不占用过多的内存，还要求数据以根精简的方式编写。boot启动时，传参给内核，告诉内核设备树文件和kernel的位置，内核启动时根据地址去找到设备树文件，再利用专用的编译器去反编译dtb文件，将dtb还原成数据结构，以供驱动的函数去调用。firmware是三星的一个固件的设备信息，因为找不到固件，所以内核启动不成功。_exynos 4412 刷机

Linux系统配置jdk_linux配置jdk-程序员宅基地

文章浏览阅读2w次，点赞24次，收藏42次。Linux系统配置jdkLinux学习教程，Linux入门教程（超详细）_linux配置jdk

随便推点

matlab(4)：特殊符号的输入_matlab微米怎么输入-程序员宅基地

文章浏览阅读3.3k次，点赞5次，收藏19次。xlabel('\delta');ylabel('AUC');具体符号的对照表参照下图：_matlab微米怎么输入

C语言程序设计-文件(打开与关闭、顺序、二进制读写)-程序员宅基地

文章浏览阅读119次。顺序读写指的是按照文件中数据的顺序进行读取或写入。对于文本文件，可以使用fgets、fputs、fscanf、fprintf等函数进行顺序读写。在C语言中，对文件的操作通常涉及文件的打开、读写以及关闭。文件的打开使用fopen函数，而关闭则使用fclose函数。在C语言中，可以使用fread和fwrite函数进行二进制读写。‍ Biaoge 于2024-03-09 23:51发布阅读量：7 ️文章类型：【 C语言程序设计】在C语言中，用于打开文件的函数是____，用于关闭文件的函数是____。

Touchdesigner自学笔记之三_touchdesigner怎么让一个模型跟着鼠标移动-程序员宅基地

文章浏览阅读3.4k次，点赞2次，收藏13次。跟随鼠标移动的粒子以grid（SOP）为partical（SOP）的资源模板，调整后连接【Geo组合+point spirit（MAT)】，在连接【feedback组合】适当调整。影响粒子动态的节点【metaball(SOP)+force(SOP)】添加mouse in（CHOP)鼠标位置到metaball的坐标，实现鼠标影响。..._touchdesigner怎么让一个模型跟着鼠标移动

【附源码】基于java的校园停车场管理系统的设计与实现61m0e9计算机毕设SSM_基于java技术的停车场管理系统实现与设计-程序员宅基地

文章浏览阅读178次。项目运行环境配置：Jdk1.8 + Tomcat7.0 + Mysql + HBuilderX（Webstorm也行）+ Eclispe（IntelliJ IDEA,Eclispe,MyEclispe,Sts都支持）。项目技术：Springboot + mybatis + Maven +mysql5.7或8.0+html+css+js等等组成，B/S模式 + Maven管理等等。环境需要1.运行环境：最好是java jdk 1.8，我们在这个平台上运行的。其他版本理论上也可以。_基于java技术的停车场管理系统实现与设计

Android系统播放器MediaPlayer源码分析_android多媒体播放源码分析时序图-程序员宅基地

文章浏览阅读3.5k次。前言对于MediaPlayer播放器的源码分析内容相对来说比较多，会从Java-&amp;gt;Jni-&amp;gt;C/C++慢慢分析，后面会慢慢更新。另外，博客只作为自己学习记录的一种方式，对于其他的不过多的评论。MediaPlayerDemopublic class MainActivity extends AppCompatActivity implements SurfaceHolder.Cal..._android多媒体播放源码分析时序图

java 数据结构与算法 ——快速排序法-程序员宅基地

文章浏览阅读2.4k次，点赞41次，收藏13次。java 数据结构与算法 ——快速排序法_快速排序法