import java.net.*;
import java.sql.*;
import java.io.*;
import java.util.*;
//import db.*;
public class test extends Thread{
URL weburl;
String urladdr;
public test()
{}
public test(String urladdr,URL weburl)
{
this.urladdr=urladdr;
this.weburl=weburl;
}
public test(String urladdr)
{
try{
this.urladdr=urladdr;
//weburl=new URL(urladdr);
this.start();
}
catch(Exception e){System.out.println(e.toString());}
}
public InputStream getStream(String url)
{
try{
//urladdr=url;
URL tempurl=new URL(url);
return tempurl.openStream();
}catch(Exception e){System.out.println("hello");}
return null;
}
public void run()
{
while(true)
{ try{
getStream(urladdr);
Thread.sleep(200);
}catch(Exception e){}
}
}
public String getStr(InputStream in)
{
try{
StringBuffer temp=null;
BufferedReader buffer=new BufferedReader(new InputStreamReader(in));
String tempstr="";
String strsum="";
while ((tempstr=buffer.readLine())!=null)
{
strsum=strsum+tempstr;
}
buffer.close();
//in.close();
return strsum;}
catch(Exception e){System.out.println("shit");
}
return "";
}
public String getMTVURL(String html)
{ try{
String temp=html.substring(html.lastIndexOf("../")+3);
temp=temp.substring(0,temp.indexOf("""));
temp="http://movies.v111.com/movies/film/play.asp?Id=30959"+temp;
temp=temp.trim();
return temp; }catch(Exception e){System.out.println(e.toString());}
return null;
}
public String getMTVname(String html)
{
try{
String temp=html.substring(html.indexOf("作品名：")+4);
temp=temp.substring(0,temp.indexOf("</td>"));
temp=temp.trim();
return temp;}
catch(Exception e){System.out.println("hello");}
return null;
}
public void insertdb(String MTVURL,String MTVname)
{
// DBoperate writer=new DBoperate();
// String insert="insert into mtvList(mtvname,mtvurl)Values('"+MTVname+"','"+MTVURL+"')";
// writer.exesql(insert);
}
public void getover()
{
InputStream in=getStream(urladdr);
String content=getStr(in);
String url=getMTVURL(content);
String name=getMTVname(content);
insertdb(url,name);
}
public static void main(String[] avg)
{
for(;;)
{
try{
test look=new test("http://www.sje.cn");
look.getStream(look.urladdr).close();
Thread.sleep(500);
}
catch(Exception e){
System.out.println(e.toString());
continue;}}
}
}
在保留原出处的情况下，欢迎转载! Java, java, J2SE, j2se, J2EE, j2ee, J2ME, j2me, ejb, ejb3, JBOSS, jboss, spring, hibernate, jdo, struts, webwork, ajax, AJAX, mysql, MySQL, Oracle, Weblogic, Websphere, scjp, scjd
标签：
