蜗牛的JAVA外壳

┎Running Snail┒ ┖ -------------- ┚
  BlogJava :: 首页 :: 联系 :: 聚合  :: 管理
  13 Posts :: 0 Stories :: 10 Comments :: 0 Trackbacks
Java单线程阻塞解决方案

我写了一个Feed提取小程序，但有时由于Feed长时间无响应，所以需要去判断是否超时，以下的程序
主线程：

 1package test.thread;
 2
 3import com.sun.syndication.feed.synd.SyndFeed;
 4
 5public class RssThread extends Thread {
 6    
 7    public void run() {
 8        while(true)
 9        {
10            try
11            {
12                
13                System.out.println("start");
14                
15                String[] str = new String[]{"http://del.icio.us/rss/geneboy",
16                        "http://picasaweb.google.com/data/feed/base/user/icyleaf.cn",
17                        "http://feeds.qzone.qq.com/cgi-bin/cgi_rss_out?uin=414680"};
18                
19                for( int i = 0 ; i < str.length ; i++ )
20                {
21                    System.out.println("url = " + str[i]);
22
23                    RssUtil ru = new RssUtil();
24                    ru.setUrl(str[i]);
25                    ru.start();
26                    
27                    while(true)
28                    {
29                        sleep(2000);
30                        SyndFeed feed = ru.getFeed();
31                        System.out.println("feed = " + (feed != null ? "ok" : "timeOut"));
32                        
33                        if ( feed == null )
34                        {
35                            sleep(10000);
36                            
37                            feed = ru.getFeed();
38                            System.out.println("second feed = " + (feed != null ? "ok" : "timeOut"));
39                        }                            
40                        
41                        if ( feed == null )
42                        {
43                            break;
44                        }
45                        else
46                        {
47                            System.out.println("处理不null");
48                            break;
49                        }
50                    }
51                }
52                
53                System.out.println("end");
54                
55                sleep(2000);
56                
57            }catch(Exception e)
58            {
59                //e.printStackTrace();
60            }
61        }        
62    }
63    
64    public static void main(String[] args)
65    {
66        RssThread rss = new RssThread();
67        rss.start();
68    }
69}
70

RssUtil：负责提取Rss
 1package test.thread;
 2
 3import java.net.URL;
 4
 5import org.apache.commons.logging.Log;
 6import org.apache.commons.logging.LogFactory;
 7
 8import com.sun.syndication.feed.synd.SyndFeed;
 9import com.sun.syndication.io.SyndFeedInput;
10import com.sun.syndication.io.XmlReader;
11
12/**
13 * Rss相关
14 * 
15 * @author Administrator
16 * 
17 */
18public class RssUtil extends Thread {
19    
20    private String url;
21    
22    private SyndFeed feed;
23
24    private static final Log logger = LogFactory.getLog(RssUtil.class);
25    
26    public void run() {
27        
28        feed = getFeed(url);
29    }
30
31    /**
32     * 获得Feed
33     * 
34     * @param url
35     * @return
36     */
37    public SyndFeed getFeed(String url) {
38        try 
39        {
40            URL feedUrl = new URL(url);
41            SyndFeedInput input = new SyndFeedInput();
42
43            SyndFeed feed = input.build(new XmlReader(feedUrl));
44
45            return feed;
46            
47        } catch (Exception ex) {
48            //ex.printStackTrace();
49        }
50
51        return null;
52    }
53
54    public SyndFeed getFeed() {
55        return feed;
56    }
57
58    public void setFeed(SyndFeed feed) {
59        this.feed = feed;
60    }
61
62    public String getUrl() {
63        return url;
64    }
65
66    public void setUrl(String url) {
67        this.url = url;
68    }
69}
70
posted on 2008-01-09 16:31 会跑的蜗牛 阅读(1934) 评论(0)  编辑  收藏 所属分类: Java

只有注册用户登录后才能发表评论。
网站导航: