.net core 读取本地指定目录下的文件的实例代码

 更新时间:2018年09月16日 09:43:38   作者:蜗牛丨  
这篇文章主要介绍了.net core 读取本地指定目录下的文件的实例代码,非常不错,具有一定的参考借鉴价值 ,需要的朋友可以参考下

项目需求

asp.net core 读取log目录下的.log文件,.log文件的内容如下:

xxx.log

------------------------------------------begin---------------------------------
写入时间:2018-09-11 17:01:48
 userid=1000
 golds=10
 -------------------------------------------end---------------------------------

一个 begin end 为一组,同一个.log文件里 userid 相同的,取写入时间最大一组值,所需结果如下:

UserID   Golds   RecordDate
 1001     20     2018/9/11 17:10:48 
 1000     20     2018/9/11 17:11:48 
 1003     30     2018/9/11 17:12:48 
 1002     10     2018/9/11 18:01:48
 1001     20     2018/9/12 17:10:48 
 1000     30     2018/9/12 17:12:48 
 1002     10     2018/9/12 18:01:48

项目结构

Snai.File.FileOperation  Asp.net core 2.0 网站

项目实现

新建Snai.File解决方案,在解决方案下新建一个名Snai.File.FileOperation Asp.net core 2.0 空网站

把log日志文件拷备到项目下

修改Startup类的ConfigureServices()方法,注册访问本地文件所需的服务,到时在中间件中通过构造函数注入添加到中间件,这样就可以在一个地方控制文件的访问路径(也就是应用程序启动的时候)

public void ConfigureServices(IServiceCollection services)
{
  services.AddSingleton<IFileProvider>(new PhysicalFileProvider(Directory.GetCurrentDirectory()));
}

新建 Middleware 文件夹,在 Middleware下新建 Entity 文件夹,新建 UserGolds.cs 类,用来保存读取的日志内容,代码如下

namespace Snai.File.FileOperation.Middleware.Entity
{
 public class UserGolds
 {
  public UserGolds()
  {
   RecordDate = new DateTime(1970, 01, 01);
   UserID = 0;
   Golds = 0;
  }
  public DateTime RecordDate { get; set; }
  public int UserID { get; set; }
  public int Golds { get; set; }
 }
}

 在 Middleware 下新建 FileProviderMiddleware.cs 中间件类,用于读取 log 下所有日志文件内容,并整理成所需的内容格式,代码如下

namespace Snai.File.FileOperation.Middleware
{
 public class FileProviderMiddleware
 {
  private readonly RequestDelegate _next;
  private readonly IFileProvider _fileProvider;
  public FileProviderMiddleware(RequestDelegate next, IFileProvider fileProvider)
  {
   _next = next;
   _fileProvider = fileProvider;
  }
  public async Task Invoke(HttpContext context)
  {
   var output = new StringBuilder("");
   //ResolveDirectory(output, "", "");
   ResolveFileInfo(output, "log", ".log");
   await context.Response.WriteAsync(output.ToString());
  }
  //读取目录下所有文件内容
  private void ResolveFileInfo(StringBuilder output, string path, string suffix)
  {
   output.AppendLine("UserID Golds RecordDate");
   IDirectoryContents dir = _fileProvider.GetDirectoryContents(path);
   foreach (IFileInfo item in dir)
   {
    if (item.IsDirectory)
    {
     ResolveFileInfo(output,
      item.PhysicalPath.Substring(Directory.GetCurrentDirectory().Length),
      suffix);
    }
    else
    {
     if (item.Name.Contains(suffix))
     {
      var userList = new List<UserGolds>();
      var user = new UserGolds();
      IFileInfo file = _fileProvider.GetFileInfo(path + "\\" + item.Name);
      using (var stream = file.CreateReadStream())
      {
       using (var reader = new StreamReader(stream))
       {
        string content = reader.ReadLine();
        while (content != null)
        {
         if (content.Contains("begin"))
         {
          user = new UserGolds();
         }
         if (content.Contains("写入时间"))
         {
          DateTime recordDate;
          string strRecordDate = content.Substring(content.IndexOf(":") + 1).Trim();
          if (DateTime.TryParse(strRecordDate, out recordDate))
          {
           user.RecordDate = recordDate;
          }
         }
         if (content.Contains("userid"))
         {
          int userID;
          string strUserID = content.Substring(content.LastIndexOf("=") + 1).Trim();
          if (int.TryParse(strUserID, out userID))
          {
           user.UserID = userID;
          }
         }
         if (content.Contains("golds"))
         {
          int golds;
          string strGolds = content.Substring(content.LastIndexOf("=") + 1).Trim();
          if (int.TryParse(strGolds, out golds))
          {
           user.Golds = golds;
          }
         }
         if (content.Contains("end"))
         {
          var userMax = userList.FirstOrDefault(u => u.UserID == user.UserID);
          if (userMax == null || userMax.UserID <= 0)
          {
           userList.Add(user);
          }
          else if (userMax.RecordDate < user.RecordDate)
          {
           userList.Remove(userMax);
           userList.Add(user);
          }
         }
         content = reader.ReadLine();
        }
       }
      }
      if (userList != null && userList.Count > 0)
      {
       foreach (var golds in userList.OrderBy(u => u.RecordDate))
       {
        output.AppendLine(golds.UserID.ToString() + " " + golds.Golds + " " + golds.RecordDate);
       }
       output.AppendLine("");
      }
     }
    }
   }
  }
  //读取目录下所有文件名
  private void ResolveDirectory(StringBuilder output, string path, string prefix)
  {
   IDirectoryContents dir = _fileProvider.GetDirectoryContents(path);
   foreach (IFileInfo item in dir)
   {
    if (item.IsDirectory)
    {
     output.AppendLine(prefix + "[" + item.Name + "]");
     ResolveDirectory(output,
      item.PhysicalPath.Substring(Directory.GetCurrentDirectory().Length),
      prefix + " ");
    }
    else
    {
     output.AppendLine(path + prefix + item.Name);
    }
   }
  }
 }
 public static class UseFileProviderExtensions
 {
  public static IApplicationBuilder UseFileProvider(this IApplicationBuilder app)
  {
   return app.UseMiddleware<FileProviderMiddleware>();
  }
 }
}

上面有两个方法 ResolveFileInfo()和ResolveDirectory()

ResolveFileInfo()  读取目录下所有文件内容,也就是需求所用的方法

ResolveDirectory() 读取目录下所有文件名,是输出目录下所有目录和文件名,不是需求所需但也可以用

修改Startup类的Configure()方法,在app管道中使用文件中间件服务

public void Configure(IApplicationBuilder app, IHostingEnvironment env)
{
  if (env.IsDevelopment())
  {
    app.UseDeveloperExceptionPage();
  }

  app.UseFileProvider();
  
  app.Run(async (context) =>
  {
    await context.Response.WriteAsync("Hello World!");
  });
}

到此所有代码都已编写完成

启动运行项目,得到所需结果,页面结果如下

源码访问地址:https://github.com/Liu-Alan/Snai.File

总结

以上所述是小编给大家介绍的.net core 读取本地指定目录下的文件的相关知识,希望对大家有所帮助,如果大家有任何疑问欢迎给我留言,小编会及时回复大家的!

相关文章

  • .Net Core路由处理的知识点与方法总结

    .Net Core路由处理的知识点与方法总结

    这篇文章主要给大家介绍了关于.Net Core路由处理的知识点与方法的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2021-04-04
  • ASP.NET实现多域名多网站共享Session值的方法

    ASP.NET实现多域名多网站共享Session值的方法

    实现功能:可设置哪些站点可以共享Session值,这样就防止别人利用这个去访问,要想实现这个功能就必须得把Session值 放入数据库中, 所有我们先在VS命令工具下注册一个
    2011-11-11
  • 一个Asp.Net的显示分页方法 附加实体转换和存储过程 带源码下载

    一个Asp.Net的显示分页方法 附加实体转换和存储过程 带源码下载

    现在自己写的webform都不用服务器控件了,所以自己仿照aspnetpager写了一个精简实用的返回分页显示的html方法,其他话不说了,直接上代码
    2012-10-10
  • CommunityServer又称CS论坛的相关学习资料

    CommunityServer又称CS论坛的相关学习资料

    以前项目需要整合这个论坛,同事找了一些资料,现在放上来,并说下自己对这个论坛的看法。
    2009-05-05
  • ASP.NET中验证控件的使用方法

    ASP.NET中验证控件的使用方法

    这篇文章主要内容是ASP.NET中验证控件的使用方法,RequiredFieldValidation控件的介绍,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2015-08-08
  • ASP.net的验证控件浅析

    ASP.net的验证控件浅析

    前些天在做注册页面的验证的时候,用了下ASP.net的验证控件,有一些体会,特写下这篇博客,如果有朋友有不同ideas,欢迎大家留言
    2011-11-11
  • asp.net Core3.0区域与路由配置的方法

    asp.net Core3.0区域与路由配置的方法

    这篇文章主要给大家介绍了关于asp.net Core3.0区域与路由配置的方法,文中通过示例代码介绍的非常详细,对大家学习或者使用asp.net Core3.0具有一定的参考学习价值,需要的朋友们下面来一起学习学习吧
    2019-05-05
  • ASP.NET Core Api网关Ocelot的使用初探

    ASP.NET Core Api网关Ocelot的使用初探

    这篇文章主要介绍了ASP.NET Core Api网关Ocelot的使用初探,帮助大家更好的理解和学习使用.NET技术,感兴趣的朋友可以了解下
    2021-03-03
  • Asp.net mvc实时生成缩率图到硬盘

    Asp.net mvc实时生成缩率图到硬盘

    这篇文章主要介绍了Asp.net mvc实时生成缩率图到硬盘的相关资料,需要的朋友可以参考下
    2016-05-05
  • .NET关于API 句柄泄漏分析

    .NET关于API 句柄泄漏分析

    本文主要介绍了.NET关于API 句柄泄漏分析,文中结合代码与图片讲解的非常详细,感兴趣的小伙伴可以自行参考一下
    2021-08-08

最新评论