技术标签: java 操作系统 json javadt.com
转载自:http://www.javadt.com/article-131-1.html
迷你版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; } } |
文章浏览阅读3.4k次,点赞8次,收藏42次。一、什么是内部类?or 内部类的概念内部类是定义在另一个类中的类;下面类TestB是类TestA的内部类。即内部类对象引用了实例化该内部对象的外围类对象。public class TestA{ class TestB {}}二、 为什么需要内部类?or 内部类有什么作用?1、 内部类方法可以访问该类定义所在的作用域中的数据,包括私有数据。2、内部类可以对同一个包中的其他类隐藏起来。3、 当想要定义一个回调函数且不想编写大量代码时,使用匿名内部类比较便捷。三、 内部类的分类成员内部_成员内部类和局部内部类的区别
文章浏览阅读118次。分布式系统要求拆分分布式思想的实质搭配要求分布式系统要求按照某些特定的规则将项目进行拆分。如果将一个项目的所有模板功能都写到一起,当某个模块出现问题时将直接导致整个服务器出现问题。拆分按照业务拆分为不同的服务器,有效的降低系统架构的耦合性在业务拆分的基础上可按照代码层级进行拆分(view、controller、service、pojo)分布式思想的实质分布式思想的实质是为了系统的..._分布式系统运维工具
文章浏览阅读174次。1.数据源准备2.数据处理step1:数据表处理应用函数:①VLOOKUP函数; ② CONCATENATE函数终表:step2:数据透视表统计分析(1) 透视表汇总不同渠道用户数, 金额(2)透视表汇总不同日期购买用户数,金额(3)透视表汇总不同用户购买订单数,金额step3:讲第二步结果可视化, 比如, 柱形图(1)不同渠道用户数, 金额(2)不同日期..._exce l趋势分析数据量
文章浏览阅读3.3k次。堡垒机可以为企业实现服务器、网络设备、数据库、安全设备等的集中管控和安全可靠运行,帮助IT运维人员提高工作效率。通俗来说,就是用来控制哪些人可以登录哪些资产(事先防范和事中控制),以及录像记录登录资产后做了什么事情(事后溯源)。由于堡垒机内部保存着企业所有的设备资产和权限关系,是企业内部信息安全的重要一环。但目前出现的以下问题产生了很大安全隐患:密码设置过于简单,容易被暴力破解;为方便记忆,设置统一的密码,一旦单点被破,极易引发全面危机。在单一的静态密码验证机制下,登录密码是堡垒机安全的唯一_horizon宁盾双因素配置
文章浏览阅读7.7k次,点赞4次,收藏16次。Chrome作为一款挺不错的浏览器,其有着诸多的优良特性,并且支持跨平台。其支持(Windows、Linux、Mac OS X、BSD、Android),在绝大多数情况下,其的安装都很简单,但有时会由于网络原因,无法安装,所以在这里总结下Chrome的安装。Windows下的安装:在线安装:离线安装:Linux下的安装:在线安装:离线安装:..._chrome linux debian离线安装依赖
文章浏览阅读153次。中国发达城市榜单每天都在刷新,但无非是北上广轮流坐庄。北京拥有最顶尖的文化资源,上海是“摩登”的国际化大都市,广州是活力四射的千年商都。GDP和发展潜力是衡量城市的数字指...
文章浏览阅读3.3k次。前言spark在java使用比较少,多是scala的用法,我这里介绍一下我在项目中使用的代码配置详细算法的使用请点击我主页列表查看版本jar版本说明spark3.0.1scala2.12这个版本注意和spark版本对应,只是为了引jar包springboot版本2.3.2.RELEASEmaven<!-- spark --> <dependency> <gro_使用java调用spark注册进去的程序
文章浏览阅读4.8k次。汽车零部件开发工具巨头V公司全套bootloader中UDS协议栈源代码,自己完成底层外设驱动开发后,集成即可使用,代码精简高效,大厂出品有量产保证。:139800617636213023darcy169_uds协议栈 源代码
文章浏览阅读4.6k次,点赞20次,收藏148次。AUTOSAR基础篇之OS(下)前言首先,请问大家几个小小的问题,你清楚:你知道多核OS在什么场景下使用吗?多核系统OS又是如何协同启动或者关闭的呢?AUTOSAR OS存在哪些功能安全等方面的要求呢?多核OS之间的启动关闭与单核相比又存在哪些异同呢?。。。。。。今天,我们来一起探索并回答这些问题。为了便于大家理解,以下是本文的主题大纲:[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-JCXrdI0k-1636287756923)(https://gite_autosar 定义了 5 种多核支持类型
文章浏览阅读2.2k次,点赞6次,收藏14次。原因:自己写的头文件没有被加入到方案的包含目录中去,无法被检索到,也就无法打开。将自己写的头文件都放入header files。然后在VS界面上,右键方案名,点击属性。将自己头文件夹的目录添加进去。_vs2013打不开自己定义的头文件
文章浏览阅读3.3w次,点赞80次,收藏342次。此时,可以将系统中所有用户的 Session 数据全部保存到 Redis 中,用户在提交新的请求后,系统先从Redis 中查找相应的Session 数据,如果存在,则再进行相关操作,否则跳转到登录页面。此时,可以将系统中所有用户的 Session 数据全部保存到 Redis 中,用户在提交新的请求后,系统先从Redis 中查找相应的Session 数据,如果存在,则再进行相关操作,否则跳转到登录页面。当数据量很大时,count 的数量的指定可能会不起作用,Redis 会自动调整每次的遍历数目。_redis命令
文章浏览阅读449次,点赞3次,收藏3次。URP的设计目标是在保持高性能的同时,提供更多的渲染功能和自定义选项。与普通项目相比,会多出Presets文件夹,里面包含着一些设置,包括本色,声音,法线,贴图等设置。全局只有主光源和附加光源,主光源只支持平行光,附加光源数量有限制,主光源和附加光源在一次Pass中可以一起着色。URP:全局只有主光源和附加光源,主光源只支持平行光,附加光源数量有限制,一次Pass可以计算多个光源。可编程渲染管线:渲染策略是可以供程序员定制的,可以定制的有:光照计算和光源,深度测试,摄像机光照烘焙,后期处理策略等等。_urp渲染管线