Hadoop-2.6.0上调用C的API实现类似云盘的功能（上传，下载，删除，重命名）

测试系统：CentOS6.6， hadoop-2.6.0

本次测试是调用hadoop下的C的API来访问HDFS实现类似云盘的上传，下载，删除，重命名的功能，其它功能还请有意者自行添加，，废话少说，开始进入正题。

首先我们要能在hadoop-2.6.0上的C的API访问HDFS

详情可以访问：

下面开始我们的云盘功能：

首先我们在主函数中连接到我们的hadoop服务器，并创建一个用户自己的文件夹

int main(int argc, char **argv) 
{
char CreatDirName[30];/*创建文件夹和路径*/
char DirNamePath[50];
int Create;

hdfsFS fs = hdfsConnect("10.25.100.130", 9000);     //连接到hadoop服务器

printf("请输入你想创建的文件夹和路径:\n");
scanf("%s", CreatDirName);


Create = hdfsCreateDirectory(fs, CreatDirName);

printf("Create = %d\n", Create);
if(Create == -1)
{
printf("创建失败!\n");
exit(1);
}

while(1)
{
int num;

HdfsChoseMenu_Function();
scanf("%d", &num);
switch(num)
{
case 1:HdfsSendFile_Function(fs, CreatDirName);     //Hdfs上传文件Function
break;
case 2:HdfsDownFile_Function(fs, CreatDirName);      //下载文件Function
break;
case 3:HdfsDelete_Function(fs);//HdfsDelete_Function
break;
case 4:HdfsRename_Function(fs);//HdfsRename_Function
break;
case 0:HdfsQuit_Function(fs);
break;
default:printf("PLease input Error!!!\n");
}
}
}

上传文件到服务器：

void HdfsSendFile_Function(hdfsFS fs, char CreatDirName[])     //Hdfs上传文件Function
{
char SendFileName[30];//FileName
char SendFilePath[50];//FilePath
char buffer[LENGTH];//BufferFile

printf("请输入要上传的文件名: ");
scanf("%s", SendFileName);
sprintf(SendFilePath, "%s/%s", CreatDirName, SendFileName);
hdfsFile OpenFileName = hdfsOpenFile(fs, SendFilePath, O_WRONLY|O_CREAT, 0, 0, 0);


FILE *fp = fopen(SendFileName, "r");   


if(NULL == fp)      
{        
printf("File:%s Not Found\n", SendFileName);      
}    
else
{
bzero(buffer, LENGTH);
tSize length = 0;
while((length = fread(buffer, sizeof(char), LENGTH, fp)) > 0)        
{ 
printf("length = %d\n", length);
tSize num_written_bytes = hdfsWrite(fs, OpenFileName, buffer, length);
printf("num_written_bytes = %d\n", num_written_bytes);
if (hdfsFlush(fs, OpenFileName)) 
{
fprintf(stderr, "Failed to ‘flush‘ %s\n", SendFilePath);
exit(-1);
}
bzero(buffer, LENGTH);
}
fclose(fp);  
hdfsCloseFile(fs, OpenFileName);
printf("\n>>>上传文件成功!!!\n\n");
}
}

下载文件：

void HdfsDownFile_Function(hdfsFS fs, char CreatDirName[])      //下载文件Function
{
char DownFileName[30];//DownFileName
char DownFilePath[50];//DownFilePath
char buffer[LENGTH];//BufferFile

printf("请输入要下载的文件名: ");
scanf("%s", DownFileName);

sprintf(DownFilePath, "%s/%s", CreatDirName, DownFileName);
hdfsFile DownOpenFile = hdfsOpenFile(fs, DownFilePath, O_RDONLY, 0, 0, 0);
if(NULL == DownOpenFile)
{
printf("打开文件失败!\n");
exit(1);
}
else
{
FILE *fp = fopen(DownFileName, "w");    
if(NULL == fp)    
{      
printf("File:\t%s Can Not Open To Write\n", DownFileName);      
exit(1);    
}  
else
{
tSize D_length = 0;
while((D_length = hdfsRead(fs, DownOpenFile, buffer, LENGTH)) > 0)
{
printf("D_length = %d\n", D_length);


if(fwrite(buffer, sizeof(char), D_length, fp) < D_length)      
{        
printf("File:\t%s Write Failed\n", DownFileName);        
break;      
}   
bzero(buffer, LENGTH);
}//sleep(1);
fclose(fp);  
hdfsCloseFile(fs, DownOpenFile);
printf("\n>>>下载文件成功!!!\n\n");
}
}
}

删除文件：

void HdfsDelete_Function(hdfsFS fs)       //HdfsDelete_Function
{
int num_Delete;
char delete_HdfsFilePath[50];

printf("请输入你要删除的文件的名字和路径: ");
scanf("%s", delete_HdfsFilePath);
num_Delete = hdfsDelete(fs, delete_HdfsFilePath, 0);
printf("num_Delete = %d\n", num_Delete);

}

文件重命名：