- 浏览: 44185 次
- 性别:
- 来自: 杭州
文章分类
最新评论
很早之前写的一个爬虫,抓取数据并存放mysql数据库,支持多线程
用法很简单,只要输入查询关键字就行
#! /usr/local/bin/ruby require 'hpricot' require "open-uri" require 'net/http' require 'CompanyLink' require 'parser/CompanyParser' require 'parser/CompanyParser2' require 'export/CsvExport' require 'export/MysqlExport' class AlibabaWebCatcher def initialize @exporter = nil end def setExporter(export = nil) @exporter = export end #collect by given company site def collectByCompanyLink(companySite) companyLink = CompanyLink.new(companySite) companyHostUri = companyLink.hostUri companyIntroduceUri = companyLink.introduceUri companyContactUri = companyLink.contactUri begin puts 'Collect company : ' + companySite http = Net::HTTP.new(companyHostUri, 80) puts 'Opening Page: http://' + companyHostUri + companyIntroduceUri resp, data = http.get(companyIntroduceUri, nil) #puts data if resp.message == "OK" then puts 'Opened Page: http://' + companyHostUri + companyIntroduceUri companyLink.parser.parseProfile(data) else puts 'Opening Page: http://' + companyHostUri + companyIntroduceUri + ' failed' end puts 'Opening Page: http://' + companyHostUri + companyContactUri resp2, data2 = http.get(companyContactUri, nil) #put data2 if resp2.message == 'OK' then puts 'Opened Page: http://' + companyHostUri + companyContactUri companyLink.parser.parseContact(data2) else puts 'Opening Page: http://' + companyHostUri + companyContactUri + ' failed' end if @exporter.nil? then puts 'Please provider exporter for export function.' else @exporter.doExport(companyLink.parser.getCompany) end rescue Exception => err puts 'Exception happend caused by : ' + err.to_s #raise err ensure puts 'Collect company : ' + companySite + " finished." end end #collect by company list def collectByCompanyList(companyListUrl) companySearchHostUri = getCompanySearchHost companySearchUri = companyListUrl.split(/alibaba.com/)[1] #puts companySearchUri begin http = Net::HTTP.new(companySearchHostUri, 80) puts 'Opening Page: http://' + companySearchHostUri + companySearchUri resp, data = http.get(companySearchUri, nil) #puts data if resp.message == "OK" puts 'Opened Page: http://' + companySearchHostUri + companySearchUri #parse company list companySites = parseCompanySites(data) for companySite in companySites collectByCompanyLink(companySite) end nextPage = getNextSearchPage(data) if !nextPage.nil? then collectByCompanyList(nextPage) end else puts 'Opening Page: http://' + companySearchHostUri + companySearchUri + ' failed' end rescue Exception => err puts 'Exception happend caused by : ' + err.to_s raise err ensure end end #collect by company list url def collectByKeywords(searchKeywords) puts 'Searching ... ' + searchKeywords companySearchHostUri = getCompanySearchHost() companySearchUri = getCompanySearchUri(searchKeywords) collectByCompanyList(companySearchHostUri + companySearchUri) end #collect by company list url use thread def collectByKeywordsByThread(searchKeywords) puts 'Searching ... ' + searchKeywords companySearchHostUri = getCompanySearchHost() companySearchUri = getCompanySearchUri(searchKeywords) http = Net::HTTP.new(companySearchHostUri, 80) puts 'Opening Page: http://' + companySearchHostUri + companySearchUri resp, data = http.get(companySearchUri, nil) #puts data if resp.message == "OK" then puts 'Opened Page: http://' + companySearchHostUri + companySearchUri totalPage = getTotalPage(data) secondPage = getNextSearchPage(data) uri = '/company' + secondPage.split(/\/company/)[1] #puts uri threads = [] for i in 1..totalPage threads << Thread.new(companySearchHostUri) do |page| begin h = Net::HTTP.new(page, 80) uri = uri.gsub(/\d+\.html/, i.to_s + '.html') #puts uri puts "Opening Page: http://#{page}#{uri}" resp_t, data_t = h.get(uri, nil) #puts data #puts resp_t.message if resp_t.message == "OK" then puts "Opened Page: http://#{page}#{uri}" #parse company list companySites = parseCompanySites(data_t) for companySite in companySites collectByCompanyLink(companySite) end else puts "Opening Page: http://#{page}#{uri} failed." end rescue Exception => err puts 'Exception thrown out when got page ' + i.to_s + ' since ' + err.to_s #raise ensure end end end threads.each { |t| t.join } else puts 'Opening Page: http://' + companySearchHostUri + companySearchUri + ' failed' end end protected #parse the company site list def parseCompanySites(companyListHtml) companySites = Array.new doc = Hpricot(companyListHtml) doc.search('//div[@class="content"]/div[@class="info"]/span[@class="m undline"]/a').each do |item| companyHref = item.attributes['href'] puts '公司链接: ' + companyHref companySites << companyHref end return companySites end private #get company search host def getCompanySearchHost return 'search.china.alibaba.com'; end #get company search uri according to keywords def getCompanySearchUri(keywords) return '/search/company_search.htm?filt=y&categoryId=0&maxCatId=&isNoRepost=false&descend_order=&show_fid=&cat_field=' + '&tradeType=&searchType=&pageSize=30&sm=&seType=&townId=0&onlineStatus=all&memberlevel=' + '&province=%BD%AD%CB%D5%2C%D5%E3%BD%AD%2C%C9%CF%BA%A3&city=&biztype=&established_year=' + '&keywords=' + URI.escape(keywords) #return '/company/' + URI.escape(keywords, 'utf-8') + '/1.html?province=%BD%AD%CB%D5%2C%D5%E3%BD%AD%2C%C9%CF%BA%A3' end #get company search next page def getNextSearchPage(data) doc = Hpricot(data) nextPageHref = doc.at('//div[@class="pages"]/div[@class="list_offer_pages"]/h1/b/a[text()="下一页"]') if !nextPageHref.nil? then #puts '下一页: ' + nextPageHref.attributes['href'] return nextPageHref.attributes['href'] end end #get company search total page def getTotalPage(data) totalItems = data.scan(/共找到\s<span class="red sm">(\d+)<\/span>\s条/)[0] if !totalItems.nil? then totalPage = ((totalItems.last.to_i%30 == 0) ? totalItems.last.to_i/30 : (totalItems.last.to_i/30 + 1)) puts '共 ' + totalItems.last + '条 共' + totalPage.to_s + ' 页' return totalPage else return 0 end end end
用法很简单,只要输入查询关键字就行
#! /usr/local/bin/ruby require 'test/unit' require 'AlibabaWebCatcher' require 'export/CsvExport' require 'export/MysqlExport' class AlibabaWebCatcherTest < Test::Unit::TestCase def setup @webCatcher = AlibabaWebCatcher.new #@webCatcher.export = CsvExport.new('test.csv') @webCatcher.exporter = MysqlExport.new end def teardown @webCatcher = nil end def test_download assert_not_nil(@webCatcher) #@webCatcher.collectByCompanyShortName('qianbusha') @webCatcher.collectByKeywords('婴幼儿用品') assert(true, 'Should go here') end end
发表评论
-
Perl常用函数集
2012-04-26 10:05 811#!/usr/bin/perl -w package C ... -
用Perl发送邮件
2012-04-26 10:02 1045#!/usr/bin/perl -w package M ... -
Ruby版给图片加水印
2011-06-17 13:45 989ImageUtils.rb #!/usr/local/bi ... -
NCS(Nightly CoSIM Script)
2011-06-14 15:45 854NCS(Nightly CoSIM Script)包括Perl ... -
Perl与Ruby解析Properties文件之异同
2011-06-14 15:38 1753Perl解释Properties不太方便,需要自己分析 # ...
相关推荐
用Ruby写的一个网络爬虫,用到了正则表达式 和哈希表
在Ruby开发中,Web爬虫是用于自动化网络数据提取的重要工具,特别是在数据挖掘、数据分析以及信息监控等领域。Wombat的出现为Ruby社区提供了一个易于上手且功能强大的解决方案。它不仅适用于初学者,也适合有经验的...
编写网络爬虫可以使用多种编程语言,包括系统编程语言如C和C++以及脚本语言如Perl、Python、Java和Ruby。C和C++语言因其高效性和快速性而被广泛用于大型搜索引擎的全网爬取任务,但它们开发周期长且代码较为复杂。...
编写网络爬虫可以使用多种编程语言,包括C/C++、Perl、Python、Java、Ruby和C#等。C和C++语言因其执行效率高而适合全网爬取任务,但编写和维护难度较大,适于有特定性能需求的专业搜索引擎。脚本语言如Perl、Python...
### 网络爬虫——Python与数据分析 #### 一、网络爬虫概述 网络爬虫,也称为网络蜘蛛或网络机器人,是一种自动化的程序,主要用于在网络上抓取和下载网页内容。这种技术对于搜索引擎至关重要,因为它们依赖于爬虫...
### 网络爬虫爬取Ajax:利用Ruby技术实现 在现代互联网应用中,Ajax(Asynchronous JavaScript and XML)已成为提升用户体验的关键技术之一。它允许网页在不重新加载整个页面的情况下更新部分数据,从而实现了更为...
《网络爬虫——Python和数据分析》是一份关于利用Python进行网络爬虫开发和技术应用的文档。网络爬虫,顾名思义,是一种自动化程序,它能够遍历互联网上的网页,通常用于搜索引擎的数据采集。网络爬虫从一个或一组...
网络爬虫是一种能够自动提取网页内容的程序,它是搜索引擎获取信息的核心技术之一。网络爬虫的工作原理是从一个或多个初始的URL出发,获取这些页面上的所有链接,然后再访问这些链接所指向的页面,循环往复,直到...
RubyRetriever是一款基于Ruby语言实现的异步Web爬虫工具,它被设计为一个既可以作为命令行程序运行,也可以作为框架供开发者自定义爬取逻辑的解决方案。这个项目的核心特性在于其异步处理能力,这使得它在抓取大量...
一个非常基本的网络爬虫 给定一个 url,将对所有链接页面(在同一域和方案上)执行广度优先爬网,并构建每个页面所依赖的静态资产列表。 它需要一个完整的 url,带有方案(http 或 https)。 给定一个子域,它不会...
用Python写网络爬虫-35 Python是一种非常流行的语言,用来写网络爬虫非常合适。本文将详细介绍如何用Python写网络爬虫,以及网络爬虫的应用场景。 首先,什么是网络爬虫?网络爬虫是一个自动提取网页的程序,它为...
在IT领域,网络爬虫是数据获取的重要工具,它能够自动化地从互联网上抓取大量信息。本资源“不同语言实现的爬虫程序和爬虫框架.zip”包含了一个名为"awesome-crawler-master"的开源项目,这个项目汇集了多种编程语言...
#### 一、网络爬虫概述 **定义:** - **网络爬虫**是一种自动从互联网上获取数据的程序,通常用于搜索引擎来下载网页内容。 **功能:** - 作为搜索引擎的基础组件,负责网页的收集工作。 - 可用于构建垂直搜索引擎...