题目
设计思路
使用方法
Tips:
目前登录以及help部分仍有两个小bug，系由端口的命令断开以及连接部分引起，交由读者自己研究，若不想管可以不使用这两个功能
服务端——>Server
#include "Winsock2.h" #include "windows.h" #include
severAddr
.sin_port
=
htons
(RECV_PORT
)
;
if
(
bind
(sockClient
,
(
struct sockaddr FAR
*
)
&severAddr
,
sizeof
(severAddr
)
)
== SOCKET_ERROR
||
bind
(dataClient
,
(
struct sockaddr FAR
*
)
&dataAddr
,
sizeof
(dataAddr
)
)
== SOCKET_ERROR
)
{
//bind函数用于将socket和地址结构绑定== cout
<<
"绑定失败"
<< endl
;
return
-
1
;
}
return
1
;
} DWORD
mkdir
(
char fileName
[
]
)
{
char path
[
1000
]
;
GetCurrentDirectory
(
sizeof
(path
)
, path
)
;
//找到当前进程的当前目录
strcat
(path
,
"\\"
)
;
strcat
(path
,fileName
)
; cout
<<path
<<endl
; bool flag
=
CreateDirectory
(path
,
NULL
)
;
if
(flag
) cout
<<
"创建文件："
<<fileName
<<
"成功"
<<endl
;
else cout
<<
"创建文件："
<<fileName
<<
"失败"
<<endl
;
} DWORD
delFile
(
char fileName
[
]
)
{
char path
[
1000
]
;
GetCurrentDirectory
(
sizeof
(path
)
, path
)
;
//找到当前进程的当前目录
strcat
(path
,
"\\"
)
;
strcat
(path
,fileName
)
;
// cout<
bool flag
=
RemoveDirectory
(path
)
;
if
(flag
) cout
<<
"删除文件："
<<fileName
<<
"成功"
<<endl
;
else cout
<<
"删除文件："
<<fileName
<<
"失败"
<<endl
;
} DWORD
connectProcess
(
)
{
addrLen
=
sizeof
(ClientAddr
)
;
//addrLen是对象地址的长度
if
(
listen
(sockClient
,
10
)
<
0
||
listen
(dataClient
,
10
)
<
0
)
{
//让套接字进入被动监听状态，参数2为请求队列的最大长度 cout
<<
"监听失败"
<< endl
;
return
-
1
;
} cout
<<
"服务器正在监听中…"
<< endl
;
while
(
1
)
{
//accept取出队列头部的连接请求
//sockclient是处于监听的套接字
//ClientAddr 是监听的对象地址 sockServer
=
accept
(sockClient
,
(
struct sockaddr FAR
*
)
&ClientAddr
,
&addrLen
)
;
while
(
1
)
{
memset
(rbuff
,
0
,
sizeof
(rbuff
)
)
;
memset
(sbuff
,
0
,
sizeof
(sbuff
)
)
;
if
(
recv
(sockServer
, rbuff
,
sizeof
(rbuff
)
,
0
)
<=
0
)
{
continue
;
} cout
<< endl
<<
"获取并执行的命令："
<< rbuff
<< endl
;
if
(
strncmp
(rbuff
,
"get"
,
3
)
==
0
)
{
//将文件发给客户端
strcpy
(fileName
, rbuff
+
4
)
; FILE
* file
;
//定义一个文件访问指针
//处理下载文件请求 file
=
fopen
(fileName
,
"rb"
)
;
//二进制打开文件，只允许读
if
(file
)
{
sprintf
(sbuff
,
"get %s"
, fileName
)
;
if
(
!
send
(sockServer
, sbuff
,
sizeof
(sbuff
)
,
0
)
)
{
cout
<<
"发送失败"
<<endl
;
fclose
(file
)
;
return
0
;
}
else
{
//创建额外数据连接传送数据
if
(
!
sendFile
(dataClient
, file
)
)
{
return
0
;
}
fclose
(file
)
;
}
}
else
{
strcpy
(sbuff
,
"无法打开文件\n"
)
; cout
<<
"无法打开文件"
<<endl
;
if
(
!
send
(sockServer
, sbuff
,
sizeof
(sbuff
)
,
0
)
)
{
return
0
;
}
}
}
//get
else
if
(
strncmp
(rbuff
,
"put"
,
3
)
==
0
)
{
//从客户端上传上来文件 cout
<<
"debug1"
<<endl
; FILE
* fd
;
int cnt
;
strcpy
(fileName
, rbuff
+
4
)
; fd
=
fopen
(fileName
,
"wb"
)
;
if
(fd
==
NULL
)
{
cout
<<
"无法打开文件"
<< fileName
<< endl
;
return
0
;
}
sprintf
(sbuff
,
"put %s"
, fileName
)
;
if
(
!
send
(sockServer
, sbuff
,
sizeof
(sbuff
)
,
0
)
)
{
fclose
(fd
)
;
return
0
;
}
memset
(sbuff
,
'\0'
,
sizeof
(rbuff
)
)
;
int dataAddLen
=
sizeof
(dataClientAddr
)
; dataServer
=
accept
(dataClient
,
(
struct sockaddr FAR
*
)
&dataClientAddr
,
&dataAddLen
)
;
while
(
(cnt
=
recv
(dataServer
, rbuff
,
sizeof
(rbuff
)
,
0
)
)
>
0
)
{
fwrite
(rbuff
,
sizeof
(
char
)
, cnt
, fd
)
;
//把cnt个数据长度为char的数据从rbuff输入到fd指向的文件
} cout
<<
"成功获得文件"
<< fileName
<< endl
;
closesocket
(dataServer
)
;
fclose
(fd
)
;
}
//put
else
if
(
strncmp
(rbuff
,
"pwd"
,
3
)
==
0
)
{
char path
[
1000
]
;
GetCurrentDirectory
(
sizeof
(path
)
, path
)
;
//找到当前进程的当前目录
strcpy
(sbuff
, path
)
;
send
(sockServer
, sbuff
,
sizeof
(sbuff
)
,
0
)
;
}
//pwd
else
if
(
strncmp
(rbuff
,
"ls"
,
2
)
==
0
)
{
strcpy
(sbuff
, rbuff
)
;
send
(sockServer
, sbuff
,
sizeof
(sbuff
)
,
0
)
;
sendFileList
(dataClient
)
;
}
//dir
else
if
(
strncmp
(rbuff
,
"mkdir"
,
5
)
==
0
)
{
strcpy
(fileName
, rbuff
+
6
)
;
strcpy
(sbuff
,rbuff
)
;
send
(sockServer
, sbuff
,
sizeof
(sbuff
)
,
0
)
;
//发送回信息
mkdir
(fileName
)
;
}
//mkdir
else
if
(
strncmp
(rbuff
,
"del"
,
3
)
==
0
)
{
strcpy
(fileName
, rbuff
+
4
)
;
//获得要删的文件名
strcpy
(sbuff
,rbuff
)
;
send
(sockServer
, sbuff
,
sizeof
(sbuff
)
,
0
)
;
//发送回信息
delFile
(fileName
)
;
}
//del
else
if
(
strncmp
(rbuff
,
"cd"
,
2
)
==
0
)
{
strcpy
(fileName
, rbuff
+
3
)
;
strcpy
(sbuff
, rbuff
)
;
send
(sockServer
, sbuff
,
sizeof
(sbuff
)
,
0
)
;
char path
[
1000
]
;
GetCurrentDirectory
(
sizeof
(path
)
, path
)
;
//找到当前进程的当前目录
strcat
(path
,
"\\"
)
;
strcat
(path
,fileName
)
;
SetCurrentDirectory
(path
)
;
//设置当前目录
}
//cd
else
if
(
strncmp
(rbuff
,
"user"
,
4
)
==
0
)
{
char tbuff
[
1024
]
;
strcpy
(tbuff
, rbuff
+
5
)
;
strcat
(tbuff
,
" "
)
;
memset
(rbuff
,
'\0'
,
sizeof
(rbuff
)
)
;
strcpy
(sbuff
,
"成功获取用户名\0"
)
;
send
(sockServer
, sbuff
,
sizeof
(sbuff
)
,
0
)
;
recv
(sockServer
, rbuff
,
sizeof
(rbuff
)
,
0
)
; cout
<< endl
<<
"获取并执行的命令："
<< rbuff
<< endl
;
strcat
(tbuff
, rbuff
+
5
)
;
if
(
strcmp
(tbuff
, namePassword
)
==
0
)
{
//验证是否正确并返回数据给客户端
send
(sockServer
,
"right\0"
,
sizeof
(sbuff
)
,
0
)
;
}
else
{
send
(sockServer
,
"wrong\0"
,
sizeof
(sbuff
)
,
0
)
;
}
}
//user pass
}
closesocket
(sockServer
)
;
}
}
int
sendFile
(SOCKET datatcps
, FILE
* file
)
{
int dataAddLen
=
sizeof
(dataClientAddr
)
; dataServer
=
accept
(datatcps
,
(
struct sockaddr FAR
*
)
&dataClientAddr
,
&dataAddLen
)
; cout
<<
"正在发送文件…"
<< endl
;
memset
(sbuff
,
'\0'
,
sizeof
(sbuff
)
)
;
while
(
1
)
{
//从文件中循环读取数据并发送至客户端
int len
=
fread
(sbuff
,
1
,
sizeof
(sbuff
)
, file
)
;
//把file指针指向的文件中的内容读取到sbuff中
//cout<<"sbuff内容："<
if
(
send
(dataServer
, sbuff
, len
,
0
)
== SOCKET_ERROR
)
{
cout
<<
"连接失败"
<< endl
;
closesocket
(dataServer
)
;
return
0
;
}
if
(len
<
sizeof
(sbuff
)
)
{
//文件传送结束
break
;
}
}
closesocket
(dataServer
)
; cout
<<
"发送成功"
<< endl
;
return
1
;
}
int
sendFileList
(SOCKET datatcps
)
{
int dataAddLen
=
sizeof
(dataClientAddr
)
; dataServer
=
accept
(datatcps
,
(
struct sockaddr FAR
*
)
&dataClientAddr
,
&dataAddLen
)
; HANDLE hff
;
//建立一个线程 WIN32_FIND_DATA fd
;
//搜索文件 hff
=
FindFirstFile
(
"*"
,
&fd
)
;
//查找文件来把待操作文件的相关属性读取到WIN32_FIND_DATA结构中去
if
(hff
== INVALID_HANDLE_VALUE
)
{
//发生错误
const
char
*errStr
=
"列出文件列表时发生错误\n"
; cout
<<
*errStr
<< endl
;
if
(
send
(dataServer
, errStr
,
strlen
(errStr
)
,
0
)
== SOCKET_ERROR
)
{
cout
<<
"发送失败"
<< endl
;
}
closesocket
(dataServer
)
;
return
0
;
} BOOL flag
= TRUE
;
while
(flag
)
{
//发送文件信息
if
(
!
sendFileRecord
(dataServer
,
&fd
)
)
{
closesocket
(dataServer
)
;
return
0
;
} flag
=
FindNextFile
(hff
,
&fd
)
;
//查找下一个文件
}
closesocket
(dataServer
)
;
return
1
;
}
int
sendFileRecord
(SOCKET datatcps
, WIN32_FIND_DATA
*pfd
)
{
//发送当前的文件记录
char fileRecord
[MAX_PATH
+
32
]
; FILETIME ft
;
//文件的建立时间
FileTimeToLocalFileTime
(
&pfd
-> ftLastWriteTime
,
&ft
)
;
//Converts a file time to a local file time. SYSTEMTIME lastWriteTime
;
FileTimeToSystemTime
(
&ft
,
&lastWriteTime
)
;
const
char
*dir
= pfd
-> dwFileAttributes
& FILE_ATTRIBUTE_DIRECTORY
?
"
"
:
" "
;
sprintf
(fileRecord
,
"%04d-%02d-%02d %02d:%02d %5s %10d %-20s\n"
, lastWriteTime
.wYear
, lastWriteTime
.wMonth
, lastWriteTime
.wDay
, lastWriteTime
.wHour
, lastWriteTime
.wMinute
, dir
, pfd
-> nFileSizeLow
, pfd
-> cFileName
)
;
if
(
send
(datatcps
, fileRecord
,
strlen
(fileRecord
)
,
0
)
== SOCKET_ERROR
)
{
//通过datatcps接口发送fileRecord数据，成功返回发送的字节数 cout
<<
"发送失败"
<< endl
;
return
0
;
}
return
1
;
}
int
main
(
)
{
if
(
startSock
(
)
==
-
1
||
createSocket
(
)
==
-
1
||
connectProcess
(
)
==
-
1
)
{
return
-
1
;
}
return
1
;
}
客户端——>Client
#include
if
(
strncmp
(operation
,
"get"
,
3
)
==
0
||
strncmp
(operation
,
"put"
,
3
)
==
0
||
strncmp
(operation
,
"cd"
,
2
)
==
0
||
strncmp
(operation
,
"mkdir"
,
5
)
==
0
||
strncmp
(operation
,
"del"
,
3
)
==
0
)
{
///需要输入文件名的功能 cin
>> name
;
}
else
if
(
strncmp
(operation
,
"quit"
,
4
)
==
0
)
{
///退出功能 cout
<<
"感谢您的使用"
<< endl
;
return
1
;
}
else
if
(
strncmp
(operation
,
"?"
,
1
)
==
0
||
strncmp
(operation
,
"help"
,
4
)
==
0
)
{
///帮助菜单功能
help
(
)
;
}
else
if
(
strncmp
(operation
,
"ls"
,
2
)
==
0
||
strncmp
(operation
,
"pwd"
,
3
)
==
0
)
{
}
else
{
cout
<<
"非法输入"
<<endl
;
return
0
;
}
//将指令整合进order，并存放进buff
strcat
(order
, operation
)
,
strcat
(order
,
" "
)
,
strcat
(order
, name
)
;
sprintf
(buff
, order
)
;
sendTCP
(buff
)
;
//发送指令
recv
(sockClient
, rbuff
,
sizeof
(rbuff
)
,
0
)
;
//接收信息 cout
<< rbuff
<< endl
;
//pwd功能在这里已经实现
if
(
strncmp
(rbuff
,
"get"
,
3
)
==
0
)
{
///下载功能
callServer
(dataClient
,dataAddr
)
; fd1
=
fopen
(name
,
"wb"
)
;
//用二进制的方式打开文件，wb表示打开或新建一个二进制文件（只允许写数据）
if
(fd1
==
NULL
)
{
cout
<<
"打开或者新建 "
<< name
<<
"文件失败"
<< endl
;
return
1
;
}
memset
(rbuff
,
'\0'
,
sizeof
(rbuff
)
)
;
while
(
(cnt
=
recv
(dataClient
, rbuff
,
sizeof
(rbuff
)
,
0
)
)
>
0
)
{
// cout<<"缓冲区"<
fwrite
(rbuff
,
sizeof
(rbuff
)
,
1
, fd1
)
;
//C 库函数 size_t fwrite(const void *ptr, size_t size, size_t nmemb, FILE *stream) 把 ptr 所指向的数组中的数据写入到给定流 stream 中。
}
closesocket
(dataClient
)
;
fclose
(fd1
)
;
//关闭文件
}
//get
else
if
(
strncmp
(rbuff
,
"put"
,
3
)
==
0
)
{
///上传功能
// cout<<"执行"<
strcpy
(fileName
, rbuff
+
4
)
; fd2
=
fopen
(fileName
,
"rb"
)
;
//打开一个二进制文件，文件必须存在，只允许读
if
(fd2
)
{
//成功打开
// cout<<"debug0"<
if
(
!
sendFile
(dataClient
, fd2
)
)
{
cout
<<
"发送失败"
<< endl
;
return
1
;
}
fclose
(fd2
)
;
}
else
{
strcpy
(sbuff
,
"无法打开文件\n"
)
;
if
(
!
send
(sockClient
, sbuff
,
sizeof
(sbuff
)
,
0
)
)
{
return
1
;
}
}
}
//put
else
if
(
strncmp
(rbuff
,
"ls"
,
2
)
==
0
)
{
///ls功能
list
(dataClient
)
;
}
//dir
return
0
;
}
int
main
(
)
{
while
(
1
)
{
startSock
(
)
;
//启动winsock并初始化
if
(
callServer
(sockClient
,serverAddr
)
==
-
1
)
{
//发送连接请求失败
continue
;
} cout
<<
"发送连接请求成功"
<< endl
;
// if (checkFlag == false) {//登陆
// if (user() && pass()) {
// checkFlag = true;
// }
// continue;
// } checkFlag
= true
;
if
(checkFlag
)
{
help
(
)
;
}
while
(checkFlag
)
{
if
(
command
(
)
)
{
break
;
}
} cout
<<
"命令输入结束"
<<endl
;
closesocket
(sockClient
)
;
//关闭连接
WSACleanup
(
)
;
//释放Winsock
return
0
;
}
}
/
*
192.168
.0
.100 user gyc pass
pwd cd Debug get
110.txt
*
/
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请联系我们举报，一经查实，本站将立刻删除。
发布者：全栈程序员-站长，转载请注明出处：https://javaforall.net/178033.html原文链接：https://javaforall.net
