package com.xingcai;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.net.URL;

import java.text.SimpleDateFormat;

import java.util.Date;

import java.util.Timer;

import java.util.TimerTask;

 运用定时器，不停的发送请求抓取数据

public class GetYinInfo extends TimerTask {

private void getCOMEXInfo() throws IOException{

String res = "";

SimpleDateFormat dateformat=new SimpleDateFormat("HH:mm:ss");

String df=dateformat.format(new Date());

URL url = new URL("https://www.baidu.com/");

java.net.HttpURLConnection conn = (java.net.HttpURLConnection) url.openConnection();

conn.connect();

BufferedReader bf = new BufferedReader(new InputStreamReader(

conn.getInputStream(), "GBK"));

String line;

while ((line = bf.readLine()) != null) {

res += line;

}

String AGTD[]=res.split(",");

String re[]=AGTD[0].split("");

System.out.println("COMEX "+df+"："+re[1]);

bf.close();

}

private void getTDInfo() throws IOException{

String res = "";

SimpleDateFormat dateformat=new SimpleDateFormat("HH:mm:ss");

String df=dateformat.format(new Date());

URL url = new URL("https://www.baidu.com/");

java.net.HttpURLConnection conn = (java.net.HttpURLConnection) url.openConnection();

conn.connect();

BufferedReader bf = new BufferedReader(new InputStreamReader(

conn.getInputStream(), "GBK"));

String line;

while ((line = bf.readLine()) != null) {

res += line;

}

String AGTD[]=res.split(",");

String re[]=AGTD[0].split("");

System.out.println("AG "+df+"："+re[1]);

bf.close();

}

@Override

public void run() {

try {

getCOMEXInfo();

getTDInfo();

System.out.println("---------------------------------------------");

} catch (IOException e) {

e.printStackTrace();

}

}

/**

* @param args

*/

public static void main(String[] args) {

Timer timer = new Timer();

TimerTask t1 = new GetYinInfo();

// 1000毫秒后,每隔1000毫秒运行一次t1任务

timer.schedule(t1, 1000, 5000);

/*

* try { Thread.sleep(10000); } catch (InterruptedException e) {

* e.printStackTrace(); } timer.cancel();

*/

}

}