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

1. packagecom.itechzero.pricemonitor;
3. importjava.io.BufferedInputStream;
4. importjava.io.BufferedReader;
5. importjava.io.InputStream;
6. importjava.io.InputStreamReader;
7. importjava.io.OutputStreamWriter;
8. importjava.net.URI;
9. importjava.net.URL;
10. importjava.net.URLConnection;
11. importjava.text.SimpleDateFormat;
12. importjava.util.Date;
14. /**
15. *PriceMonitor.java
16. *
17. *@authorTechzero
18. *@Emailtechzero@163.com
19. *@Time2014-5-21下午1:24:30
20. */
21. classMyThreadextendsThread{
22. publicvoidrun(){
23. try{
24. //此处参数为监控持续分钟数
25. PriceMonitor.monitorButton(10);
26. }catch(Exceptione){
27. e.printStackTrace();
28. }
29. }
30. };
32. publicclassPriceMonitor{
33. //监控的商品URL
34. privatestaticStringURL="http://detail.ju.taobao.com/home.htm?spm=608.2214381.3.1.AdPEjn&item_id=38260927591&id=10000002781939";
36. //监视按钮
37. publicstaticvoidmonitorButton(intlastMinute){
38. intnowMinute=Integer.parseInt(newSimpleDateFormat("mm").format(newDate()));
39. intendMinute=Integer.parseInt(newSimpleDateFormat("mm").format(newDate()))+lastMinute;
40. while(nowMinute<endMinute){
41. nowMinute=Integer.parseInt(newSimpleDateFormat("mm").format(newDate()));
42. Stringresult[]=getCurrentButtonAndForm(URL,"gb2312").split(",");
43. //当前按钮状态
44. StringcurrentButton=result[0];
45. //马上抢表单
46. //Stringform=result[1];
47. StringnowTime=newSimpleDateFormat("yyyy-MM-ddHH:mm:ss").format(newDate());
48. System.out.println(nowTime+"-现在按钮是"+currentButton);
50. if(currentButton=="马上抢"||currentButton.equals("马上抢")||currentButton=="还有机会"||currentButton.equals("还有机会")){
51. System.out.println("赶紧下单！");
52. try{
53. java.awt.Desktop.getDesktop().browse(newURI(URL));
54. }catch(Exceptione){
55. e.printStackTrace();
56. }
57. //doPost(form);
58. break;
59. }elseif(currentButton=="卖光了"||currentButton.equals("卖光了")||currentButton.equals("已结束")||currentButton.equals("已结束")){
60. System.out.println("下次再试吧！");
61. break;
62. }else{
63. System.out.println("还没开始呢，再等等吧！");
64. }
65. }
66. }
68. //获取当前按钮状态
69. publicstaticStringgetCurrentButtonAndForm(Stringurl,Stringencoding){
70. if(url==null||"".equals(url.trim()))
71. returnnull;
72. StringbuttonState="";
73. StringBuffercontent=newStringBuffer();
74. booleanformFlag=false;
75. try{
76. //新建URL对象
77. URLu=newURL(url);
78. InputStreamis=newBufferedInputStream(u.openStream());
79. InputStreamReadertheHTML=newInputStreamReader(is,encoding!=null?encoding:"gb2312");
80. BufferedReaderbr=newBufferedReader(theHTML);
81. Strings="";
82. while((s=br.readLine())!=null){
83. if(s.indexOf("<inputtype="submit"class="buyactionJ_BuySubmit"title="马上抢"value="马上抢"/>")!=-1){
84. buttonState="马上抢";
85. }elseif(s.indexOf("<ahref="#"class="extranoticeJ_BuyButtonSub">开团提醒</a>")!=-1){
86. buttonState="开团提醒";
87. }elseif(s.indexOf("<divclass="main-boxchance">")!=-1){
88. buttonState="还有机会";
89. }elseif(s.indexOf("<spanclass="outfloatright">卖光了…</span>")!=-1){
90. buttonState="卖光了";
91. }elseif(s.indexOf("<spanclass="outfloatright">已结束…</span>")!=-1){
92. buttonState="已结束";
93. }
94. if(s.indexOf("<formclass="J_BuySubForm"data-ccb="0"data-ques="0"action")!=-1){
95. content.append(s+"");
96. formFlag=true;
97. }
98. if(formFlag==true){
99. if(s.indexOf("<inputname='_tb_token_'type='hidden'value")!=-1){
100. content.append(s+"");
101. }
102. if(s.indexOf("<inputtype="hidden"name="_input_charset"value")!=-1){
103. content.append(s+"");
104. }
105. if(s.indexOf("<inputtype="hidden"name="itemId"value")!=-1){
106. content.append(s+"");
107. }
108. if(s.indexOf("<inputtype="hidden"name="id"value")!=-1){
109. content.append(s+"");
110. }
111. if(s.indexOf("<inputtype="hidden"name="tgType"value")!=-1){
112. content.append(s+"");
113. }
114. if(s.indexOf("<inputtype="submit"class="buyactionJ_BuySubmit"")!=-1){
115. content.append(s+"");
116. }
117. if(s.indexOf("</form>")!=-1){
118. content.append(s+"");
119. }
120. }
121. if(s.indexOf("<divclass="time-banner">")!=-1){
122. break;
123. }
124. }
125. br.close();
126. }catch(Exceptione){
127. System.err.println(e);
128. return"OpenURLError";
129. }
130. returnbuttonState+","+content;
131. }
133. //提交表单
134. publicstaticStringdoPost(Stringform){
135. StringBuffercontent=newStringBuffer();
136. try{
137. URLConnectionconnection=newURL(URL).openConnection();
138. connection.setDoOutput(true);
139. OutputStreamWriteros=newOutputStreamWriter(connection.getOutputStream(),"UTF-8");
140. os.write(form);
141. os.flush();
142. os.close();
143. InputStreamis=connection.getInputStream();
144. InputStreamReadertheHTML=newInputStreamReader(is);
145. BufferedReaderbr=newBufferedReader(theHTML);
146. Strings="";
147. while((s=br.readLine())!=null){
148. content.append(s+"");
149. }
150. }catch(Exceptione){
151. e.printStackTrace();
152. }
153. //返回提交表单后返回的页面内容
154. returncontent.toString();
155. }
157. //登录
158. publicstaticvoiddoLogin(Stringusername,Stringpassword){
159. Stringform="<formid="J_StaticForm"action="https://login.taobao.com/member/login.jhtml"method="post"autocomplete="on"><inputtype="text"name="TPL_username"id="TPL_username_1"value=""+username+""><inputtype="password"name="TPL_password"id="TPL_password_1"value=""+password+""><inputtype="hidden"id="J_TPL_redirect_url"name="TPL_redirect_url"value="http://www.taobao.com/?spm=a2107.1.1000340.1.AL2Mpn"><buttontype="submit"id="J_SubmitStatic">登　录</button></form>";
160. doPost(form);
161. }
163. publicstaticvoidmain(String[]args){
164. //doLogin();
165. //newMyThread().start();
166. //newMyThread().start();
167. //newMyThread().start();
168. //newMyThread().start();
169. //newMyThread().start();
170. //newMyThread().start();
171. //newMyThread().start();
172. newMyThread().start();
173. }
174. }

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持快网idc。

原文链接：http://blog.csdn.net/Techzero/article/details/26686283