Java实现淘宝秒杀聚划算抢购自动提醒源码

说明

本实例能够监控聚划算的抢购按钮，在聚划算整点聚的时间到达时自动弹开页面（URL自己定义）。

可以自定义监控持续分钟数，同时还可以通过多线程加快刷新速度。

源码

package com.itechzero.pricemonitor;



import java.io.BufferedInputStream;

import java.io.BufferedReader;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.net.URI;

import java.net.URL;

import java.net.URLConnection;

import java.text.SimpleDateFormat;

import java.util.Date;



/**

* PriceMonitor.java

*

* @author Techzero

* @Email techzero@163.com

* @Time 2014-5-21 下午1:24:30

*/

class MyThread extends Thread {

public void run() {

  try {

   // 此处参数为监控持续分钟数

   PriceMonitor.monitorButton(10);

  } catch (Exception e) {

   e.printStackTrace();

  }

}

};



public class PriceMonitor {

// 监控的商品URL

private static String URL = "http://detail.ju.taobao.com/home.htm?spm=608.2214381.3.1.AdPEjn&item_id=38260927591&id=10000002781939";



// 监视按钮

public static void monitorButton(int lastMinute) {

  int nowMinute = Integer.parseInt(new SimpleDateFormat("mm").format(new Date()));

  int endMinute = Integer.parseInt(new SimpleDateFormat("mm").format(new Date())) + lastMinute;

  while (nowMinute < endMinute) {

   nowMinute = Integer.parseInt(new SimpleDateFormat("mm").format(new Date()));

   String result[] = getCurrentButtonAndForm(URL, "gb2312").split(",");

   // 当前按钮状态

   String currentButton = result[0];

   // 马上抢表单

   //String form = result[1];

   String nowTime = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());

   System.out.println(nowTime + " - 现在按钮是 " + currentButton);



   if (currentButton == "马上抢" || currentButton.equals("马上抢") || currentButton == "还有机会" || currentButton.equals("还有机会")) {

    System.out.println("赶紧下单！");

    try {

     java.awt.Desktop.getDesktop().browse(new URI(URL));

    } catch (Exception e) {

     e.printStackTrace();

    }

    //doPost(form);

    break;

   } else if (currentButton == "卖光了" || currentButton.equals("卖光了") || currentButton.equals("已结束") || currentButton.equals("已结束")) {

    System.out.println("下次再试吧！");

    break;

   } else {

    System.out.println("还没开始呢，再等等吧！");

   }

  }

}



// 获取当前按钮状态

public static String getCurrentButtonAndForm(String url, String encoding) {

  if (url == null || "".equals(url.trim()))

   return null;

  String buttonState = "";

  StringBuffer content = new StringBuffer();

  boolean formFlag = false;

  try {

   // 新建URL对象

   URL u = new URL(url);

   InputStream is = new BufferedInputStream(u.openStream());

   InputStreamReader theHTML = new InputStreamReader(is, encoding != null ? encoding : "gb2312");

   BufferedReader br = new BufferedReader(theHTML);

   String s = "";

   while ((s = br.readLine()) != null) {

    if (s.indexOf("<input type="submit" class="buyaction J_BuySubmit" title="马上抢" value="马上抢"/>") != -1) {

     buttonState = "马上抢";

    } else if (s.indexOf("<a href="#" class="extra notice J_BuyButtonSub">开团提醒</a>") != -1) {

     buttonState = "开团提醒";

    } else if (s.indexOf("<div class="main-box chance ">") != -1) {

     buttonState = "还有机会";

    } else if (s.indexOf("<span class="out floatright">卖光了...</span>") != -1) {

     buttonState = "卖光了";

    } else if (s.indexOf("<span class="out floatright">已结束...</span>") != -1) {

     buttonState = "已结束";

    }

    if (s.indexOf("<form class="J_BuySubForm" data-ccb="0" data-ques="0" action") != -1) {

     content.append(s + " ");

     formFlag = true;

    }

    if (formFlag == true) {

     if (s.indexOf("<input name='_tb_token_' type='hidden' value") != -1) {

      content.append(s + " ");

     }

     if (s.indexOf("<input type="hidden" name="_input_charset" value") != -1) {

      content.append(s + " ");

     }

     if (s.indexOf("<input type="hidden" name="itemId" value") != -1) {

      content.append(s + " ");

     }

     if (s.indexOf("<input type="hidden" name="id" value") != -1) {

      content.append(s + " ");

     }

     if (s.indexOf("<input type="hidden" name="tgType" value") != -1) {

      content.append(s + " ");

     }

     if (s.indexOf("<input type="submit" class="buyaction J_BuySubmit"") != -1) {

      content.append(s + " ");

     }

     if (s.indexOf("</form>") != -1) {

      content.append(s + " ");

     }

    }

    if (s.indexOf("<div class="time-banner">") != -1) {

     break;

    }

   }

   br.close();

  } catch (Exception e) {

   System.err.println(e);

   return "Open URL Error";

  }

  return buttonState + "," + content;

}



// 提交表单

public static String doPost(String form) {

  StringBuffer content = new StringBuffer();

  try {

   URLConnection connection = new URL(URL).openConnection();

   connection.setDoOutput(true);

   OutputStreamWriter os = new OutputStreamWriter(connection.getOutputStream(), "UTF-8");

   os.write(form);

   os.flush();

   os.close();

   InputStream is = connection.getInputStream();

   InputStreamReader theHTML = new InputStreamReader(is);

   BufferedReader br = new BufferedReader(theHTML);

   String s = "";

   while ((s = br.readLine()) != null) {

    content.append(s + " ");

   }

  } catch (Exception e) {

   e.printStackTrace();

  }

  // 返回提交表单后返回的页面内容

  return content.toString();

}



// 登录

public static void doLogin(String username, String password) {

  String form = "<form id="J_StaticForm" action="https://login.taobao.com/member/login.jhtml" method="post" autocomplete="on"><input type="text" name="TPL_username" id="TPL_username_1" value="" + username + ""><input type="password" name="TPL_password" id="TPL_password_1" value="" + password + ""><input type="hidden" id="J_TPL_redirect_url" name="TPL_redirect_url" value="http://www.taobao.com/?spm=a2107.1.1000340.1.AL2Mpn"><button type="submit" id="J_SubmitStatic">登　录</button></form>";

  doPost(form);

}



public static void main(String[] args) {

  //doLogin();

  // new MyThread().start();

  // new MyThread().start();

  // new MyThread().start();

  // new MyThread().start();

  // new MyThread().start();

  // new MyThread().start();

  // new MyThread().start();

  new MyThread().start();

}

}