在.NetCore里操作物理文件，其实是比较常见的动作。

我们今天来梳理下几个操作，包括（1）依赖注入文件系统，（2）读取文件内容，（3）文件改变时触发事件；

一、依赖注入

在ConfigureServices里我们将操作物理文件的方法进行依赖注入；

  IFileProvider physicalProvider = new PhysicalFileProvider(@"D:\Test\WebAPITest");
   services.AddSingleton<IFileProvider>(physicalProvider);

注意，这里必须使用Signleton单例模式的依赖注入。New一个物理文件提供方法PhysicalFileProvider，并且指定根目录地址。

思考：若是有多个根目录，依赖注入其实并非完美的解决方案，因为这里只能指定一个目录，解决办法有两种，第一种使用AutoFac指定key或者Name；第二种直接放弃依赖注入，采用New全新创建的方法；接下来我们使用第2种方法进行操作。

二、读取文件内容

首先我们要创建一个控制器，写一个读取文件的方法。

 private async Task<string> ReadAsync(string path)       
  {  
   
      PhysicalFileProvider _fileProvider= new PhysicalFileProvider(@"D:\Test\WebAPITest");
                
        await using var stream = _fileProvider.GetFileInfo(path).CreateReadStream();
             
               var buffer = new byte[stream.Length];  
               
                         await stream.ReadAsync(buffer, 0, buffer.Length); 
                         
                                    return Encoding.Default.GetString(buffer); 
                                     
                                          }

递归读取文件目录和文件名的方法如下：

/// <summary>        /// 读取文件目录和文件名        /// </summary>        public void Dir()        {            var indent = -1;
            void Get(string subpath)            {                indent++;                foreach (var fileinfo in _fileProvider.GetDirectoryContents(subpath))                {                    Console.WriteLine(new string('\t', indent) + fileinfo.Name);                    if (fileinfo.IsDirectory)                    {                        Get($@"{subpath}\{fileinfo.Name}");                    }                }
            }
            Get("");
        }

三、文件变化的时候触发事件：

using Microsoft.Extensions.Primitives;

 [HttpGet]        public async Task<string> Get()        {            _fileProvider = new PhysicalFileProvider(@"D:\Test\WebAPITest");
            string path= @"111.txt";
            Console.WriteLine(await ReadAsync(path));
            ChangeToken.OnChange(() => _fileProvider.Watch(path), async () =>            {                // 这里写你的逻辑                 Console.WriteLine("文件变化了");                 Console.WriteLine(await ReadAsync(path));
            });
            return "ok";        }

该类的全部源码如下：

using Microsoft.AspNetCore.Mvc;using Microsoft.Extensions.FileProviders;using Microsoft.Extensions.Primitives;using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading.Tasks;
// For more information on enabling Web API for empty projects, visit https://go.microsoft.com/fwlink/?LinkID=397860
namespace WebAPITest.Controllers{    [Route("api/[controller]")]    [ApiController]    public class FileTestController : ControllerBase    {
        PhysicalFileProvider _fileProvider;        public FileTestController( )        { 
        }        // GET: api/<FileTestController>        [HttpGet]        public async Task<string> Get()        {            _fileProvider = new PhysicalFileProvider(@"D:\Test\WebAPITest");
            string path= @"111.txt";
            Console.WriteLine(await ReadAsync(path));
            ChangeToken.OnChange(() => _fileProvider.Watch(path), async () =>            {                // 这里写你的逻辑                 Console.WriteLine("文件变化了");
                Console.Clear();                Console.WriteLine(await ReadAsync(path));
            });
            return "ok";        }

        /// <summary>        /// 读取文件目录和文件名        /// </summary>        public void Dir()        {            var indent = -1;
            void Get(string subpath)            {                indent++;                foreach (var fileinfo in _fileProvider.GetDirectoryContents(subpath))                {                    Console.WriteLine(new string('\t', indent) + fileinfo.Name);                    if (fileinfo.IsDirectory)                    {                        Get($@"{subpath}\{fileinfo.Name}");                    }                }
            }
            Get("");
        }
        private async Task<string> ReadAsync(string path)        {            await using var stream = _fileProvider.GetFileInfo(path).CreateReadStream();            var buffer = new byte[stream.Length];            await stream.ReadAsync(buffer, 0, buffer.Length);            return Encoding.Default.GetString(buffer);        }    }}