說明
本實例能夠監控聚劃算的搶購按鈕,在聚劃算整點聚的時間到達時自動彈開頁面(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 [email protected]
- * @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();
- }
- }
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持服務器之家。
原文鏈接:http://blog.csdn.net/Techzero/article/details/26686283