0
点赞
收藏
分享

微信扫一扫

品味FastDFS~第二回 FastDFS客户端的使用

FastDFS客户端可以帮助我们很方便的连接DFS服务器,将封装好的SOCKET命令发送到服务器端,DFS只提供linux环境下的服务器端,暂不支持WINDOWS系统,我们做.net开始,可以选择C#版的FastDFS客户端,自己可以根据自己的需要再去完善它。

我的改造:

为了调用方便,我把与tracker连接的工作放到了DFS客户端上,并且为它分配默认的组

public class FastDFSClient
{
#region Constructors
static List<IPEndPoint> trackerIPs = new List<IPEndPoint>();
static IPEndPoint endPoint;
public static StorageNode DefaultGroup;
/// <summary>
/// 当前默认的组,节,卷名称
/// 开发人员可以通过FastDFSClient.GetStorageNode("groupname")去指定自己的组
/// </summary>
static FastDFSClient()
{
trackerIPs = new List<IPEndPoint>();
endPoint = new IPEndPoint(
IPAddress.Parse(FastDFSManager.Instance.Host), FastDFSManager.Instance.Port);
trackerIPs.Add(endPoint);
ConnectionManager.Initialize(trackerIPs);
DefaultGroup = FastDFSClient.GetStorageNode(FastDFSManager.Instance.GroupName);
}
#endregion

对于开始人员来说,在调用时,可以这样完成上传,下载等操作,看代码:

/* FastDFS Test */
//===========================UploadFile=====================================
byte[] content = null;

FileStream streamUpload = new FileStream(@"c:\resource\video.mp4", FileMode.Open);
using (BinaryReader reader = new BinaryReader(streamUpload))
{
content = reader.ReadBytes((int)streamUpload.Length);
}

string fileName = FastDFSClient.UploadFile(FastDFSClient.DefaultGroup, content, "doc");
Console.ReadKey();

下面我把FastDFSClient类的源代码公开一下,大家看了后有问题,再提出来,大家再一起解决。

namespace FastDFS.Client
{
/// <summary>
/// FastDFS客户端
/// </summary>
public class FastDFSClient
{
#region Constructors
static List<IPEndPoint> trackerIPs = new List<IPEndPoint>();
static IPEndPoint endPoint;
public static StorageNode DefaultGroup;
/// <summary>
/// 当前默认的组,节,卷名称
/// 开发人员可以通过FastDFSClient.GetStorageNode("groupname")去指定自己的组
/// </summary>
static FastDFSClient()
{
trackerIPs = new List<IPEndPoint>();
endPoint = new IPEndPoint(
IPAddress.Parse(FastDFSManager.Instance.Host), FastDFSManager.Instance.Port);
trackerIPs.Add(endPoint);
ConnectionManager.Initialize(trackerIPs);
DefaultGroup = FastDFSClient.GetStorageNode(FastDFSManager.Instance.GroupName);
}
#endregion

/// <summary>
/// 获取存储节点
/// </summary>
/// <param name="groupName">组名</param>
/// <returns>存储节点实体类</returns>
public static StorageNode GetStorageNode(string groupName)
{
FDFSRequest trackerRequest = QUERY_STORE_WITH_GROUP_ONE.Instance.GetRequest(groupName);
QUERY_STORE_WITH_GROUP_ONE.Response trackerResponse = new QUERY_STORE_WITH_GROUP_ONE.Response(trackerRequest.GetResponse());
IPEndPoint storeEndPoint = new IPEndPoint(IPAddress.Parse(trackerResponse.IPStr), trackerResponse.Port);
StorageNode result = new StorageNode();
result.GroupName = trackerResponse.GroupName;
result.EndPoint = storeEndPoint;
result.StorePathIndex = trackerResponse.StorePathIndex;
return result;
}
/// <summary>
/// 上传文件
/// </summary>
/// <param name="storageNode">GetStorageNode方法返回的存储节点</param>
/// <param name="contentByte">文件内容</param>
/// <param name="fileExt">文件扩展名(注意:不包含".")</param>
/// <returns>文件名</returns>
public static string UploadFile(StorageNode storageNode, byte[] contentByte, string fileExt)
{
FDFSRequest storageReqeust = UPLOAD_FILE.Instance.GetRequest(storageNode.EndPoint, storageNode.StorePathIndex, contentByte.Length, fileExt, contentByte);
UPLOAD_FILE.Response storageResponse = new UPLOAD_FILE.Response(storageReqeust.GetResponse());
return storageResponse.FileName;
}

/// <summary>
/// 上传从文件
/// </summary>
/// <param name="storageNode">GetStorageNode方法返回的存储节点</param>
/// <param name="contentByte">文件内容</param>
/// <param name="master_filename">主文件名</param>
/// <param name="prefix_name">从文件后缀</param>
/// <param name="fileExt">文件扩展名(注意:不包含".")</param>
/// <returns>文件名</returns>
public static string UploadSlaveFile(string groupName, byte[] contentByte, string master_filename, string prefix_name, string fileExt)
{
FDFSRequest trackerRequest = QUERY_UPDATE.Instance.GetRequest(groupName, master_filename);
QUERY_UPDATE.Response trackerResponse = new QUERY_UPDATE.Response(trackerRequest.GetResponse());
IPEndPoint storeEndPoint = new IPEndPoint(IPAddress.Parse(trackerResponse.IPStr), trackerResponse.Port);

FDFSRequest storageReqeust = UPLOAD_SLAVE_FILE.Instance.GetRequest(storeEndPoint, contentByte.Length, master_filename, prefix_name, fileExt, contentByte);
UPLOAD_FILE.Response storageResponse = new UPLOAD_FILE.Response(storageReqeust.GetResponse());
return storageResponse.FileName;
}


/// <summary>
/// 上传可以Append的文件
/// </summary>
/// <param name="storageNode">GetStorageNode方法返回的存储节点</param>
/// <param name="contentByte">文件内容</param>
/// <param name="fileExt">文件扩展名(注意:不包含".")</param>
/// <returns>文件名</returns>
public static string UploadAppenderFile(StorageNode storageNode, byte[] contentByte, string fileExt)
{
FDFSRequest storageReqeust = UPLOAD_APPEND_FILE.Instance.GetRequest(storageNode.EndPoint, storageNode.StorePathIndex, contentByte.Length, fileExt, contentByte);
UPLOAD_APPEND_FILE.Response storageResponse = new UPLOAD_APPEND_FILE.Response(storageReqeust.GetResponse());
return storageResponse.FileName;
}
/// <summary>
/// 附加文件
/// </summary>
/// <param name="groupName">组名</param>
/// <param name="fileName">文件名</param>
/// <param name="contentByte">文件内容</param>
public static void AppendFile(string groupName, string fileName, byte[] contentByte)
{
FDFSRequest trackerRequest = QUERY_UPDATE.Instance.GetRequest(groupName, fileName);
QUERY_UPDATE.Response trackerResponse = new QUERY_UPDATE.Response(trackerRequest.GetResponse());
IPEndPoint storeEndPoint = new IPEndPoint(IPAddress.Parse(trackerResponse.IPStr), trackerResponse.Port);

FDFSRequest storageReqeust = APPEND_FILE.Instance.GetRequest(storeEndPoint, fileName, contentByte);
storageReqeust.GetResponse();
}
/// <summary>
/// 删除文件
/// </summary>
/// <param name="groupName">组名</param>
/// <param name="fileName">文件名</param>
public static void RemoveFile(string groupName, string fileName)
{
FDFSRequest trackerRequest = QUERY_UPDATE.Instance.GetRequest(groupName, fileName);
QUERY_UPDATE.Response trackerResponse = new QUERY_UPDATE.Response(trackerRequest.GetResponse());
IPEndPoint storeEndPoint = new IPEndPoint(IPAddress.Parse(trackerResponse.IPStr), trackerResponse.Port);
FDFSRequest storageReqeust = DELETE_FILE.Instance.GetRequest(storeEndPoint, groupName, fileName);
storageReqeust.GetResponse();
}
/// <summary>
/// 下载文件
/// </summary>
/// <param name="storageNode">GetStorageNode方法返回的存储节点</param>
/// <param name="fileName">文件名</param>
/// <returns>文件内容</returns>
public static byte[] DownloadFile(StorageNode storageNode, string fileName)
{
FDFSRequest storageReqeust = DOWNLOAD_FILE.Instance.GetRequest(storageNode.EndPoint, 0L, 0L, storageNode.GroupName, fileName);
DOWNLOAD_FILE.Response storageResponse = new DOWNLOAD_FILE.Response(storageReqeust.GetResponse());
return storageResponse.Content;
}
/// <summary>
/// 增量下载文件
/// </summary>
/// <param name="storageNode">GetStorageNode方法返回的存储节点</param>
/// <param name="fileName">文件名</param>
/// <param name="offset">从文件起始点的偏移量</param>
/// <param name="length">要读取的字节数</param>
/// <returns>文件内容</returns>
public static byte[] DownloadFile(StorageNode storageNode, string fileName, long offset, long length)
{
FDFSRequest storageReqeust = DOWNLOAD_FILE.Instance.GetRequest(storageNode.EndPoint, offset, length, storageNode.GroupName, fileName);
DOWNLOAD_FILE.Response storageResponse = new DOWNLOAD_FILE.Response(storageReqeust.GetResponse());
return storageResponse.Content;
}
/// <summary>
/// 获取文件信息
/// </summary>
/// <param name="storageNode">GetStorageNode方法返回的存储节点</param>
/// <param name="fileName">文件名</param>
/// <returns></returns>
public static FDFSFileInfo GetFileInfo(StorageNode storageNode, string fileName)
{
FDFSRequest storageReqeust = QUERY_FILE_INFO.Instance.GetRequest(storageNode.EndPoint, storageNode.GroupName, fileName);
FDFSFileInfo result = new FDFSFileInfo(storageReqeust.GetResponse());
return result;
}
}
}

作者:仓储大叔,张占岭,
荣誉:微软MVP

举报

相关推荐

0 条评论