C# 文件上传到FastDFS C#如何与FastDFS分布式文件系统交互

2次阅读

最稳定、仍在维护的c# fastdfs客户端是fastdfscore,基于.net standard 2.0,支持.net core 3.1+及.net 5/6/7/8;需正确配置tracker地址(ip+端口)、使用可重读流(如memorystream)、注意http访问路径与storage配置一致性。

C# 文件上传到FastDFS C#如何与FastDFS分布式文件系统交互

FastDFS 客户端库选哪个:不要用 FastDFS.Client(已弃用)

目前最稳定、仍在维护的 C# FastDFS 客户端是 FastDFSCore,基于 .NET Standard 2.0,支持 .NET Core 3.1+ 和 .NET 5/6/7/8。旧版 FastDFS.Client 不仅 NuGet 包已下架,且不兼容异步 I/O,上传大文件时容易卡死或超时。

安装命令:

dotnet add package FastDFSCore

  • 务必检查项目目标框架是否 ≥ netcoreapp3.1,否则运行时报 System.IO.FileNotFoundException
  • 如果项目还在用 .NET Framework 4.7.2,得降级用 FastDFSCore 1.3.0(最后支持 .NET Framework 的版本)
  • 别在 Startup.ConfigureServices 里直接 new TrackerClient —— 它不是线程安全的,应注册为 Scoped 或手动池化复用

上传文件前必须配置 Tracker 地址:IP + 端口缺一不可

TrackerClient 初始化时只认 tracker_servers 列表,格式是 "192.168.1.100:22122" 这种字符串,不接受域名、不自动补端口、也不读 fdfs_client.conf

典型错误现象:System.Net.Sockets.SocketException: No such host is known 或连接后立即断开 —— 很大概率是配置了 tracker.yourdomain.com 却没配 DNS,或漏写了 :22122

  • Tracker 地址必须写成 IP + 端口,例如:"10.0.1.5:22122",不能只写 "10.0.1.5"
  • 多个 Tracker 要用数组传入,不是逗号分隔的字符串:new[] { "10.0.1.5:22122", "10.0.1.6:22122" }
  • 如果 FastDFS 集群启用了自定义 tracker_port,请确认端口一致;默认是 22122,但有些运维会改成 22121 或其他

上传流必须是可重读的:MemoryStream 是安全选择

StorageClient.UploadFileAsync 内部会多次读取流(先算 MD5,再发数据),如果传入的是不可重读的 Request.Body 或网络流,第二次读就返回空,最终上传成功但文件大小为 0。

常见错误现象:返回的 fileId 看起来正常(如 "group1/M00/00/00/wKgBZl-xxx.jpg"),但下载下来是空文件或损坏。

  • 上传前务必把原始流复制进 MemoryStream
    using var ms = new MemoryStream();<br>await inputStream.CopyToAsync(ms);<br>ms.Position = 0;
  • 别用 inputStream.Seek(0, SeekOrigin.Begin) —— ASP.NET Core 的 HttpRequest.Body 默认不支持 seek
  • 大文件(>100MB)慎用 MemoryStream,此时应改用临时文件 + FileStream,并确保上传失败后清理临时文件

上传后别直接拼接 HTTP URL:group 名和 storage 端口要对得上

FastDFS 返回的 fileId 是逻辑路径,比如 "group1/M00/00/00/wKgBZl-xxx.jpg",但实际 HTTP 访问地址不是简单拼 http://ip:port/group1/M00/... —— storage 节点的 http.server_portnginx 监听端口必须匹配,且 group 名要和 storage 配置的 group_name 一致。

典型错误:返回 fileId 正确,但浏览器访问 404 —— 多半是 storage 机器上 Nginx 没配 location /group1/,或 FastDFS 的 storage.confgroup_name=group1 和你上传时指定的 group 不一致。

  • HTTP 访问地址格式应为:http://<storage-ip>:<http-port>/<fileid></fileid></http-port></storage-ip>,其中 <http-port></http-port> 是 storage 上 Nginx 的监听端口(常为 8888),不是 tracker 端口
  • 如果用了反向代理(如统一入口域名),需确保 proxy_pass 转发到对应 group 的 storage 节点,且 header 中带 Hostgroup_name 字段供 Nginx 路由
  • 测试阶段建议直接 curl storage 机器的 Nginx:curl http://10.0.1.5:8888/group1/M00/00/00/wKgBZl-xxx.jpg,绕过所有代理

真正麻烦的从来不是调通第一次上传,而是上传后文件在某些 storage 节点上能访问、某些节点 404,这时候得查 storage 日志里的 Error 行,而不是只盯着 C# 代码看。

text=ZqhQzanResources