请求地址:https://www.cnblogs.com/aggsite/topdiggs
public class RecommendedRankingModel { /// <summary> /// 文章标题 /// </summary> public string ArticleTitle { get; set; } /// <summary> /// 文章简介 /// </summary> public string ArticleSummary { get; set; } /// <summary> /// 文章地址 /// </summary> public string ArticleUrl { get; set; } }RecommendedRankingSpider
public class RecommendedRankingSpider : Spider { public RecommendedRankingSpider(IOptions<SpiderOptions> options, DependenceServices services, ILogger<Spider> logger) : base(options, services, logger) { // 堆代码 duidaima.com } public static async Task RunAsync() { var builder = Builder.CreateDefaultBuilder<RecommendedRankingSpider>(); builder.UseSerilog(); builder.UseDownloader<HttpClientDownloader>(); builder.UseQueueDistinctBfsScheduler<HashSetDuplicateRemover>(); await builder.Build().RunAsync(); } protected override async Task InitializeAsync(CancellationToken stoppingToken = default) { // 添加自定义解析 AddDataFlow(new Parser()); // 使用控制台存储器 AddDataFlow(new ConsoleStorage()); // 添加采集请求 await AddRequestsAsync(new Request("https://www.cnblogs.com/aggsite/topdiggs") { // 请求超时10秒 Timeout = 10000 }); } class Parser : DataParser { public override Task InitializeAsync() { return Task.CompletedTask; } protected override Task ParseAsync(DataFlowContext context) { var recommendedRankingList = new List<RecommendedRankingModel>(); // 网页数据解析 var recommendedList = context.Selectable.SelectList(Selectors.XPath(".//article[@class='post-item']")); foreach (var news in recommendedList) { var articleTitle = news.Select(Selectors.XPath(".//a[@class='post-item-title']"))?.Value; var articleSummary = news.Select(Selectors.XPath(".//p[@class='post-item-summary']"))?.Value?.Replace("\n", "").Replace(" ", ""); var articleUrl = news.Select(Selectors.XPath(".//a[@class='post-item-title']/@href"))?.Value; recommendedRankingList.Add(new RecommendedRankingModel { ArticleTitle = articleTitle, ArticleSummary = articleSummary, ArticleUrl = articleUrl }); } using (StreamWriter sw = new StreamWriter("recommendedRanking.txt")) { foreach (RecommendedRankingModel model in recommendedRankingList) { string line = $"文章标题:{model.ArticleTitle}\r\n文章简介:{model.ArticleSummary}\r\n文章地址:{model.ArticleUrl}"; sw.WriteLine(line+ "\r\n =========================================================================================="); } } return Task.CompletedTask; } } }Program调用
internal class Program { static async Task Main(string[] args) { Console.WriteLine("Hello, World!"); await RecommendedRankingSpider.RunAsync(); Console.WriteLine("数据抓取完成"); } }抓取数据和页面数据对比