麻豆小视频在线观看_中文黄色一级片_久久久成人精品_成片免费观看视频大全_午夜精品久久久久久久99热浪潮_成人一区二区三区四区

首頁 > 編程 > Ruby > 正文

Ruby中使用多線程隊列下載保存到本地文件的實例演示

2020-02-24 15:38:18
字體:
來源:轉載
供稿:網友

Ruby中的變量有幾種形式,其實對于初學者來說,他們經常會感覺到困惑,特別是對于初學的Java同學來說,他們仍然很難理解,武林技術頻道小編為大家分享Ruby中使用多線程隊列下載保存到本地文件的實例演示。

Ruby:多線程下載博客文章到本地的完整代碼

?

復制代碼 代碼如下:

#encoding:utf-8
require 'net/http'
require 'thread'
require 'open-uri'
require 'nokogiri'
require 'date'

?

$queue = Queue.new
#文章列表頁數
page_nums = 8
page_nums.times do |num|
? $queue.push("http://www.cnblogs.com/hongfei/default.html?page="+num.to_s)
end

threads = []
#獲取網頁源碼
def get_html(url)
? html = ""
? open(url) do |f|
??? html = f.read
? end
? return html
end

def fetch_links(html)
? doc = Nokogiri::HTML(html)
? #提取文章鏈接
? doc.xpath('//div[@class="postTitle"]/a').each do |link|
??? href = link['href'].to_s
??? if href.include?"html"
????? #add work to the? queue
????? $queue.push(link['href'])
??? end
? end
end

def save_to(save_to,content)
? f = File.new("./"+save_to+".html","w+")
? f.write(content)
? f.close()
end

#程序開始的時間
$total_time_begin = Time.now.to_i

#開辟的線程數
threadNums = 10
threadNums.times do
? threads<<Thread.new do
??? until $queue.empty?
????? url = $queue.pop(true) rescue nil
????? html = get_html(url)
????? fetch_links(html)
????? if !url.include?"?page"
??????? title = Nokogiri::HTML(html).css('title').text
??????? puts "["+ Time.now.strftime("%H:%M:%S") + "]「" + title + "」" + url
??????? save_to("pages/" + title.gsub(////,""),html) if url.include?".html"
????? end
??? end
? end
end
threads.each{|t| t.join}

#程序結束的時間
$total_time_end = Time.now.to_i
puts "線程數:" + threadNums.to_s
puts "執行時間:" + ($total_time_end - $total_time_begin).to_s + "秒"

?

多線程部分講解

?

復制代碼 代碼如下:

$queue = Queue.new
#文章列表頁數
page_nums = 8
page_nums.times do |num|
? $queue.push("http://www.cnblogs.com/hongfei/default.html?page="+num.to_s)
end

?

首先聲明一個Queue隊列,然后往隊列中添加文章列表頁,以便后面可以從這些列表頁中提取文章鏈接,另外queue聲明成全局變量($),以便在函數中也可以訪問到。

我的曾是土木人博客文章列表總共有8頁,所以需要實現給page_nums賦值為8

復制代碼 代碼如下:

#開辟的線程數
threadNums = 10
threadNums.times do
? threads<<Thread.new do
??? until $queue.empty?
????? url = $queue.pop(true) rescue nil
????? html = get_html(url)
????? fetch_links(html)
????? if !url.include?"?page"
??????? title = Nokogiri::HTML(html).css('title').text
??????? puts "["+ Time.now.strftime("%H:%M:%S") + "]「" + title + "」" + url
??????? save_to("pages/" + title.gsub(////,""),html) if url.include?".html"
????? end
??? end
? end
end
threads.each{|t| t.join}

?

通過Thread.new來創建線程

創建線程后,會進入until $queue.empty?循環,直到任務隊列為空(即:沒有要采集的網址了)
開辟的線程,每次都會從任務隊列(queue)取到一個url,并通過get_html函數獲取網頁源碼
由于任務隊列中的url有分頁url和文章url兩種,所以要進行區分。
如果是分頁url(url中含有“?page”),就直接提取文章鏈接。
如果是文章url,就保存到本地(save_to(),文件名為文章title)
在循環體外,創建線程完畢后,需要將創建的線程執行Thread#join方法,以便讓主線程等待,
直到所有的線程執行完畢才結束主線程

代碼執行時間統計

?

復制代碼 代碼如下:

#程序開始的時間
$total_time_begin = Time.now.to_i
#執行過程

?

#程序結束的時間
$total_time_end = Time.now.to_i
puts "執行時間:" + ($total_time_end - $total_time_begin).to_s + "秒"

?

TIme模塊的#now方法可以獲取當前時間,然后使用to_i,可以將當前時間轉換成從1970年1月1日00:00:00 UTC開始所經過的秒數。

獲取網頁源碼

?

復制代碼 代碼如下:

#獲取網頁源碼
def get_html(url)
? html = ""
? open(url) do |f|
??? html = f.read
? end
? return html
end

?

ruby中,獲取網頁的方法用Net::HTTP模塊和OpenURI模塊。OpenURI模塊最簡單,可以直徑將指定網頁當成普通文件一樣進行操作。

執行結果:使用多線程采集130多篇文章,耗時15秒(單線程:47s左右)

以上這些是武林技術頻道小編給大家介紹的Ruby中使用多線程隊列下載保存到本地文件的實例演示,閱讀了這篇文章,大家是否有所了解了?

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表

圖片精選

主站蜘蛛池模板: 亚洲五码在线观看视频 | 久久久久亚洲精品国产 | 亚洲生活片 | 国产精品久久久久久久久久iiiii | 亚洲综合视频网站 | 国av在线 | 日韩中字在线 | 欧美乱淫 | 九九视频在线观看黄 | 日韩伦理电影免费观看 | 国产成人aⅴ | 麻豆19禁国产青草精品 | 国产在线观看免费视频软件 | 一级黄色片武则天 | 欧美日韩一区三区 | 亚洲成人福利电影 | 久草在线观看首页 | a黄在线观看 | 羞羞羞网站 | 成年人激情在线 | 九色 在线 | 黄视频免费在线观看 | 久草热久 | 免费嗨片首页中文字幕 | 国产99久久久国产精品 | 一级空姐毛片 | 97风流梦电影 | 国产成人高潮免费观看精品 | 日本a在线观看 | 久久一区三区 | 人人做人人看 | 亚洲精品tv久久久久久久久久 | japanese massage tube | 国产亚洲精品久久久久久久 | 精品国产九九九 | 99亚洲伊人久久精品影院红桃 | 黄视频免费在线观看 | 国产一区视频免费观看 | 黄色网址在线免费播放 | 91九色福利 | 在线看一区二区三区 |