激情久久久_欧美视频区_成人av免费_不卡视频一二三区_欧美精品在欧美一区二区少妇_欧美一区二区三区的

服務器之家：專注于服務器技術及軟件下載分享
分類導航

PHP教程|ASP.NET教程|JAVA教程|ASP教程|

服務器之家 - 編程語言 - JAVA教程 - java實現京東秒殺功能分享 京東秒殺軟件

java實現京東秒殺功能分享 京東秒殺軟件

2019-11-04 14:14java技術網 JAVA教程

這篇文章主要介紹了秒殺京東手機的程序,實現了下面三個功能，大家參考使用吧

簡單介紹下功能

1.每隔一段時間（比如1分鐘）在京東手機每日一秒殺頁面提取產品（手機）鏈接。 
http://sale.360buy.com/act/8VTHFGr10CjMDyZ.html#01 
2.根據提取到得產品鏈接給后臺發送數據，以便獲取產品價格，描述，折扣，庫存（是否有貨）等信息。 
3.根據得到的信息，進行判斷。 

若符合條件自動調用瀏覽器（前提是chrome加入環境變量,或者改代碼將瀏覽器.exe路徑加入代碼，修改程序）打開產品訂購頁面。 
4.其實也就解決了一個問題：不用自己頻繁的刷新網頁了，不用自己查看； 
登陸，提交訂單還得瀏覽器解決（貌似這幾個功能點比較復雜，沒做處理）

程序做的不太完善： 
運行前需要修改幾個地方： 
1.環境變量：chrome 加入瀏覽器變量，以便調用。。或者自己修改源代碼用其它方式打開。 
2.活動中每個產品的價格信息需要設置。這個比較不好，必須修改源代碼。 
修改的地方在filter()這個函數里。 
3.另外一個需要修改的地方是 
hasStore(String skuidkey)

address="http://price.360buy.com/stocksoa/StockHandler.ashx?callback=getProvinceStockCallback&type=pcastock&skuid="+skuidkey+"&provinceid=1&cityid=2800&areaid=2850";
這個地方的cityid=2800&areaid=...地里位置信息。這個沒做處理。需要從手機產品頁自己搞出來。
其實也比較簡單。chrome+F12 ，修改“城市”，區域等信息后，會看到一個get請求發送到后臺，這個鏈接里面包含了需要的信息。（http://price.360buy.com/stocksoa/StockHandler.ashx?callback=getProvinceStockCallback&type=pcastock&skuid=64EBD0F20F593D95C72C6EED59B64658&provinceid=1&cityid=2805&areaid=2854）適當修改。

Util.java

 

復制代碼代碼如下:


package view.Util;

 

import java.util.ArrayList;

public class Util {
 public static void print(Object o){
  System.out.print(o);
 }
 public static void println(Object o){
  if(null==o)
   System.out.println();
  else
  System.out.println(o);
 }
 public static ArrayList<Integer> toArrayList(int[] ints){
  if(ints.length==0)
  return null;
  ArrayList<Integer> al=new ArrayList<Integer>();
  for(int i=0;i<ints.length;i++){
   al.add(ints[i]);
  }
  return al;
 }
}

 

Miaosha360buy.java

 

復制代碼代碼如下:


package jingdong;

 

public class Miaosha360buy {
 java.util.concurrent.CountDownLatch t= new java.util.concurrent.CountDownLatch(1);

 /**
  * @param args
  */
 public static void main(String[] args) {
  // TODO Auto-generated method stub
  System.out.println(Thread.currentThread().getName() + "開始");
  Miaosha360buy ms360=new Miaosha360buy();
  new ThreadOne360buy(ms360.t).start();
  while(true){
   try {
    ms360.t.await();
   } catch (InterruptedException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   }
   try {
    Thread.sleep(1000*60);//間隔1分鐘調用一次？
   } catch (InterruptedException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   }
   ms360.t=new java.util.concurrent.CountDownLatch(1);
   new ThreadOne360buy(ms360.t).start();
   System.out.println("New Tread in while..");
  }
 }

}

 

Miaosha360buy.java

 

復制代碼代碼如下:


package jingdong;

 

public class Miaosha360buy {
 java.util.concurrent.CountDownLatch t= new java.util.concurrent.CountDownLatch(1);

 /**
  * @param args
  */
 public static void main(String[] args) {
  // TODO Auto-generated method stub
  System.out.println(Thread.currentThread().getName() + "開始");
  Miaosha360buy ms360=new Miaosha360buy();
  new ThreadOne360buy(ms360.t).start();
  while(true){
   try {
    ms360.t.await();
   } catch (InterruptedException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   }
   try {
    Thread.sleep(1000*60);//間隔1分鐘調用一次？
   } catch (InterruptedException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   }
   ms360.t=new java.util.concurrent.CountDownLatch(1);
   new ThreadOne360buy(ms360.t).start();
   System.out.println("New Tread in while..");
  }
 }

}

 

ThreadOne360buy.java

 

復制代碼代碼如下:


package jingdong;

 

import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.util.EntityUtils;
import org.jsoup.Jsoup;
import org.jsoup.nodes.Document;
import org.jsoup.nodes.Element;
import org.jsoup.select.Elements;

import view.Util.Util;

public class ThreadOne360buy extends Thread{
 java.util.concurrent.CountDownLatch c;
 ArrayList al;//記錄秒殺產品頁面
 float price=0.0f;//商品價格
 float discount=0.0f;//商品折扣

 //用于保存線程信息，在這個項目里用處不大
 private static List<Thread> runningThreads = new ArrayList<Thread>();

 //這個是一個計數器（不太會用，線程這方面一直感覺是比較復雜的）
 public ThreadOne360buy(java.util.concurrent.CountDownLatch c) {
  this.c=c;
 }

 @Override
 public void run() {
  regist(this);// 線程開始時注冊
  // 打印開始標記
  System.out.println(Thread.currentThread().getName() + "開始...");
  try {
   //抓取京東手機秒殺頁面
   this.getMessage("http://sale.360buy.com/act/8VTHFGr10CjMDyZ.html#01");

  } catch (ClientProtocolException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
   c.countDown();
  } catch (IOException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
   c.countDown();
  }
  c.countDown();
  unRegist(this);// 線程結束時取消注冊
  // 打印結束標記
  System.out.println(Thread.currentThread().getName() + "結束.");
 }

 public void regist(Thread t) {
  synchronized (runningThreads) {
   runningThreads.add(t);
  }
 }

 public void unRegist(Thread t) {
  synchronized (runningThreads) {
   runningThreads.remove(t);
  }
 }

 public static boolean hasThreadRunning() {
  // 通過判斷runningThreads是否為空就能知道是否還有線程未執行完
  return (runningThreads.size() > 0);
 }
 /**
  * 從手機秒殺頁面獲取 prodcut鏈接,product skuid,skuidkey,price,store信息
  * @param url：手機秒殺頁面
  * @throws ClientProtocolException
  * @throws IOException
  */
 public void getMessage(String url) throws ClientProtocolException, IOException{
  al=getMainUrl(down(url));

  Util.println(al);
  if(al.size()==0){
   c.countDown();
   System.exit(0);
   return;
  }

  for(int i=0;i<al.size();i++){
   StringBuffer sb=new StringBuffer();
   StringBuffer openUrl = new StringBuffer();
   openUrl.append("http://www.360buy.com/product/");
   openUrl.append(al.get(i).toString().subSequence(al.get(i).toString().lastIndexOf('/')+1, al.get(i).toString().lastIndexOf('.')));
   openUrl.append(".html");
//   557673
   sb.append("http://d.360buy.com/fittingInfo/get?skuId=");
   sb.append(al.get(i).toString().subSequence(al.get(i).toString().lastIndexOf('/')+1, al.get(i).toString().lastIndexOf('.')));
   sb.append("&callback=Recommend.cbRecoFittings");
   Util.println(sb.toString());
   //map中保存的是產品name,price,折扣信息
   Util.println("Al("+i+") down:"+sb.toString());
   HashMap<String, String> hm=parseProduct(down(sb.toString()));
   //用來匹配價格信息。匹配庫存信息
   filter(hm,openUrl.toString());//過濾價格,如果條件符合就打開瀏覽器
  }
 }
 /**
  * 一個驗證方法
  * @param hm 保存著價格信息
  * @param url 產品頁面
  */
 public void filter(HashMap<String, String> hm,String url){//url既是產品頁面
//  view.Util.oenCMD.openWinExe(null,url);
//  是不是應該先查看庫存？
  String skuidkey=parseSkuidkey(url);
  if(!hasStore(skuidkey)){
   Util.println("-------------------------------------");
   Util.println("沒有庫存了！");
   Util.println("-------------------------------------");
   //減掉計數，以便主線程判斷
   c.countDown();
   //應該結束子線程哦？
   return;
  }

  if(hm.get("skuid").equals("201602")){//判斷//摩托羅拉skuid=201602
   //這里的價格是寫死了，運行前得改過來才行。
   this.setPrice(499.0f);
   //是不是應該打開控制臺？
   if(Float.parseFloat(hm.get("price"))<=this.getPrice()){
    view.Util.oenCMD.openWinExe(null,url);
   }
  }else if(hm.get("skuid").equals("675647")){//天語skuid=675647
//   //這里的價格是寫死了，運行前得改過來才行。
//   this.setPrice(699.0f);
//   //是不是應該打開控制臺？
//   if(Float.parseFloat(hm.get("price"))<=this.getPrice()){
//    view.Util.oenCMD.openWinExe(null,url);
//   }
  }

 }
 /**
  * 解析了產品頁面中name,skuid，price信息
  * @param doc
  * @return
  */
 public static HashMap<String, String> parseProduct(Document doc){
  String text=doc.text();
  String docc=text.substring(text.indexOf("master")+9,text.indexOf("fittings")-3).replaceAll("[\\s]", "");
  String[] ss=docc.split(",");
  HashMap<String, String> hm=new HashMap<String, String>();
  for(String it: ss){
   String string=it.replaceAll("\"", "");
   if(string.contains("\\u"))
   string=unicodeDecode(string);

   String[] str=string.split(":");
   hm.put(str[0], str[1]);
  }
  Util.println(hm);
  return hm;
 }
 /**
  * 處理unicode字符，轉換成顯示字符（漢字），不太通用
  * @param it: \u6a5d
  * @return
  */
 public static String unicodeDecode(String it){//有個缺點，就是前面的字符無法去掉
  Util.println(it);
  String regex="(\\\\u[0-9a-f]{4})";
  Pattern pt= Pattern.compile(regex);
  Matcher mc;
  StringBuffer sb;
  StringBuffer sba=new StringBuffer();
  mc=pt.matcher(it);
  while(mc.find()){
   sb=new StringBuffer();
    mc.appendReplacement(sba,sb.append((char )Integer.parseInt((mc.group(1).substring(2)), 16)).toString());
  }
  return sba.toString();
 }
 /**
  * 返回文檔對象（下載內容）
  * @param url 下載頁面
  * @return
  * @throws ClientProtocolException
  * @throws IOException
  */
 public static Document down(String url) throws ClientProtocolException, IOException{
  Document doc = null;
  DefaultHttpClient httpClient=new DefaultHttpClient();
  Util.println("DownLoad:"+url);
  HttpGet get=new HttpGet(url);
  HttpResponse response;
  response = httpClient.execute(get);
  HttpEntity entity = response.getEntity();
  doc = Jsoup.parse(entity.getContent(), "utf-8","");
  //釋放資源
  EntityUtils.consume(entity);
  //關閉連接
  httpClient.getConnectionManager().shutdown();
  return doc;
 }
 /**
  * 加入了編碼控制信息
  * @param url 待下載頁面
  * @param code 編碼
  * @return
  * @throws ClientProtocolException
  * @throws IOException
  */
 public static Document down(String url,String code) throws ClientProtocolException, IOException{
  Document doc = null;
  DefaultHttpClient httpClient=new DefaultHttpClient();
  Util.println("DownLoad:"+url);
  HttpGet get=new HttpGet(url);
  HttpResponse response;
  response = httpClient.execute(get);
  HttpEntity entity = response.getEntity();
  doc = Jsoup.parse(entity.getContent(), code,"");
  //釋放資源
  EntityUtils.consume(entity);
  //關閉連接
  httpClient.getConnectionManager().shutdown();
  return doc;
 }
 /**
  * 用來解析 秒殺頁面中的產品（收集）鏈接
  * @param doc
  * @return
  */
 public static ArrayList<String> getMainUrl(Document doc){
  if(doc.equals("")||doc==null)
   return null;
  try {
   Thread.sleep(50);
  } catch (InterruptedException e1) {
   // TODO Auto-generated catch block
   e1.printStackTrace();
  }
  ArrayList<String> urls=new ArrayList<String>();
  String rule="map[name=Map] >area[href~=product]";
  /**
   * 開始解析
   */
  Elements elements=doc.select(rule);
  for (Element e : elements) {
//   Util.println(e.absUrl("abs:href"));
   urls.add(e.absUrl("abs:href"));
  }
  return urls;
 }
 /**
  * 獲取skuidkey,用于查詢商品庫存信息
  * @param url
  * @return
  */
 public static String parseSkuidkey(String url){
  Document doc=null;
  try {
   doc=down(url,"gb2312");
  } catch (ClientProtocolException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  } catch (IOException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
//  Util.println(doc.select("script"));
  String text = null;
  for(Element e : doc.select("script")){
   if(e.data().contains("skuidkey:")){
    text=e.data();
    break;
   }
  }
  //skuidkey:'7D45919EA8242511DAA5CC7C6D7B351C'
  text=text.substring(text.indexOf("skuidkey:")+10, text.indexOf("skuidkey:")+42);
  Util.println("---------------------------------");
  Util.println(text);
  return text;
 }
 /**
  * 查看庫存信息
  * @param skuidkey
  * @return
  */
 public static boolean hasStore(String skuidkey){//這個地方沒有處理，直接提取瀏覽器中的信息
  String address = null;
  boolean hasStore=false;
  if(skuidkey!=null && !"".equals(skuidkey))
  address="http://price.360buy.com/stocksoa/StockHandler.ashx?callback=getProvinceStockCallback&type=pcastock&skuid="+skuidkey+"&provinceid=1&cityid=2800&areaid=2850";
  else{
   Util.println("解析skuidkey錯誤");
  }
  try {
   if(parseStore(down(address))){
    hasStore=true;
   }
  } catch (ClientProtocolException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  } catch (IOException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
  return hasStore;
 }
/* if(array[1]=="34"||array[1]=="18"){
 changeCart(false);
djdarea.stockInfoDom.html("<strong class='store-over'>無貨</strong>");
}
else if(array[1]=="0"){
changeCart(false);
djdarea.stockInfoDom.html("<strong class='store-over'>無貨</strong>");
}
else if(array[2]=="0"&&array[4]!="2"){
changeCart(false);
djdarea.stockInfoDom.html("很抱歉，該商品無法送至您選擇的區域");
}
else if(array[1]=="33"||array[1]=="5"){
changeCart(true);
djdarea.stockInfoDom.html("<strong>現貨</strong>"+(array[4]=="1"?"，該區域"+(array[3]=="0"?"不":"")+"支持貨到付款":"")+cashdesc);
}
else if(array[1]=="36"){
changeCart(true);
djdarea.stockInfoDom.html("<strong>預訂</strong>"+(array[4]=="1"?"，該區域"+(array[3]=="0"?"不":"")+"支持貨到付款":"")+cashdesc);
}
else if(array[1]=="39"){
changeCart(true);
djdarea.stockInfoDom.html("<strong>在途</strong>"+(array[4]=="1"?"，該區域"+(array[3]=="0"?"不":"")+"支持貨到付款":"")+cashdesc);
}
else if(array[1]=="40"){
changeCart(true);
djdarea.stockInfoDom.html("<strong>可配貨</strong>"+(array[4]=="1"?"，該區域"+(array[3]=="0"?"不":"")+"支持貨到付款":"")+cashdesc);
}
 */
 /**
  * 解析庫存信息
  * @param doc
  * @return
  */
 public static boolean parseStore(Document doc){
  String text=doc.text();
  String docc=text.substring(text.indexOf("-")-1,text.lastIndexOf(",")-1);
  Util.println(docc);
  String[] store=docc.split("-");
  if(store[1].equals("34") || store[1].equals("18")){
   //無貨
   Util.println("此地無貨");
   return false;
  }else if(store[1].equals("33") || store[1].equals("5")){
   //現貨
   Util.println("此地現貨");
   return true;
  }
  Util.println(store[1]);
  return false;
 }
 //幾個bean方法
 public float getPrice() {
  return price;
 }
 public void setPrice(float price) {
  this.price = price;
 }
 public float getDiscount() {
  return discount;
 }
 public void setDiscount(float discount) {
  this.discount = discount;
 }
 

}

 

oenCMD.java

 

復制代碼代碼如下:


package view.Util;

 

public class oenCMD {
// public static void main(String[] args) {
////    openWinExe(null);
//    openExe(null,"http://www.baidu.com");
//    }
    //用 Java 調用windows系統的exe文件，比如notepad，calc之類
    public static void openWinExe(String command,String url) {
     if(command==null ||command.equals("")){
      command = "chrome "+url;
     }
    Runtime rn = Runtime.getRuntime();
    Process p = null;
    try {

    p = rn.exec(command);
    } catch (Exception e) {
    System.out.println("Error win exec!");
    }
    }
    //調用其他的可執行文件，例如：自己制作的exe，或是 下載 安裝的軟件.
    public static void openExe(String pathAndName,String url) {
     if(pathAndName==null || pathAndName.equals("")){
      pathAndName="C:\\Users\\Administrator\\AppData\\Local\\Google\\Chrome\\Application\\chrome.exe";
     }
     if(url!=null && !url.equals("")){
      pathAndName+=" ";
      pathAndName+=url;
     }
    Runtime rn = Runtime.getRuntime();
    Process p = null;
    try {
    p = rn.exec(pathAndName);
    } catch (Exception e) {
    System.out.println("Error exec!");
    }
    }
}

 

延伸 · 閱讀

精彩推薦
  • JAVA教程Spring cloud Feign 深度學習與應用詳解

    Spring cloud Feign 深度學習與應用詳解

    這篇文章主要介紹了Spring cloud Feign 深度學習與應用詳解，小編覺得挺不錯的，現在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧...

    無涯Ⅱ9302019-07-08
  • JAVA教程史上最全的java隨機數生成算法分享

    史上最全的java隨機數生成算法分享

    這篇文章主要介紹了史上最全的java隨機數生成算法,我分享一個最全的隨機數的生成算法,最代碼的找回密碼的隨機數就是用的這個方法 ...

    java教程網3432019-11-01
  • JAVA教程java的引用類型的詳細介紹

    java的引用類型的詳細介紹

    在java中提供了4個級別的引用：強引用、軟引用、弱引用、虛引用。其中強引用FinalReference是default個飾符來修飾，其它3個級別均為public修飾 ...

    java之家3772019-10-15
  • JAVA教程Java中用戶向系統傳遞參數的三種基本方式實例分享

    Java中用戶向系統傳遞參數的三種基本方式實例分享

    這篇文章主要介紹了Java中用戶向系統傳遞參數的三種基本方式實例，有需要的朋友可以參考一下 ...

    java教程網1322019-11-04
  • JAVA教程Spring Cloud Alibaba Nacos 入門詳解

    Spring Cloud Alibaba Nacos 入門詳解

    這篇文章主要介紹了Spring Cloud Alibaba Nacos入門詳解，小編覺得挺不錯的，現在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧...

    幻楚3892019-06-22
  • JAVA教程map實現按value升序排序

    map實現按value升序排序

    map內部是按照hash算法存儲的，但如果能對map排序在某些時候還是有用的，下面實現對map按照value升序排序，實現對map按照key排序，大家參考使用吧 ...

    java教程網1432019-11-03
  • JAVA教程java多線程編程之join方法的使用示例

    java多線程編程之join方法的使用示例

    join方法的功能就是使異步執行的線程變成同步執行。也就是說，當調用線程實例的start方法后，這個方法會立即返回，如果在調用start方法后后需要使用一...

    java技術網4612019-11-04
  • JAVA教程java 實現約瑟夫環的實例代碼

    java 實現約瑟夫環的實例代碼

    這一次是借鑒模仿別人寫的代碼，以前覺得不好將數據結構的鏈結構什么的遷移到java上來使用，但這一次確實讓我感受到了可以自己構造數據結構，然后使...

    java代碼網3222019-10-15
主站蜘蛛池模板： 中文字幕在线观看视频www | 黄色成人av在线 | 欧美特级黄色 | 手机免费看一级片 | 国产一区二区免费在线观看 | 超碰97青青草 | 久久久www视频 | 日本不卡一二三区 | 日韩黄色免费电影 | 久久精品欧美电影 | 国产精品一品二区三区四区18 | 久久国产精品二国产精品中国洋人 | 日韩黄在线 | 女人叉开腿让男人桶 | 免费观看黄色影片 | 亚洲一区二区三区在线 | 欧美一级黄色片免费观看 | 中国hdxxxx护士爽在线观看 | 一级黄色在线免费观看 | av在线免费看网址 | av电影免费看 | 久久婷婷一区二区三区 | 麻豆自拍偷拍视频 | 色婷婷综合久久久中字幕精品久久 | 久久精品性视频 | 请播放一级毛片 | 精品中文字幕久久久久四十五十骆 | 极品一级片 | 成人免费观看毛片 | 九九热在线视频观看 | 99精品国产小情侣高潮露脸在线 | 国产精品久久久久久久模特 | 亚洲国产视频网 | 欧美亚洲国产一区 | 国产午夜电影在线观看 | 免费的性爱视频 | 国产精品无码久久久久 | 蜜桃成品人免费视频 | 日本精品黄色 | 禁漫天堂久久久久久久久久 | 少妇一级淫片免费放4p |