socket实现文件上传下载-嵌入式期末报告.doc

第一部分：移植类1一、实验目的；1二、实验内容1三、实验环境1四、实验步骤2五、实验结果与讨论3第二部分：代码类3一、实验目的3二、实验内容与要求4三、主要仪器设备4四、实验内容44.1、实验基本功能44.2主要代码编写：44.2.1、实现服务器功能的主要代码编写54.2.2、实现客户端功能的主要代码编写14五、实验内容运行结果：215.1客户端和服务端均在虚拟机linux下运行215.2 虚拟机linux运行服务端，开发板运行客户端22六、实验结果与讨论24第一部分：移植类一、实验目的；利用虚拟机，在redhat linux下编译一个能在开发板上成功运行的应用软件二、实验内容在嵌入式Linux中移植一个能播放U盘上的mp3音频文件的应用程序MadPlay。三、实验环境Win7、虚拟机中的redhat linux四、实验步骤首先通过ftp把四个所需安装包拷贝到虚拟机的linux中，然后依次进行如下操作：1、创建工作目录：2、创建如下子目录以存放不同的源文件目录说明： tarball 目录用来存放所有的源代码包 src-x86 目录用来存放X86 版本的所有源代码文件 src-arm 目录用来存放ARM 版本的所有源代码文件 target-x86 目录是X86 版本的安装目录 target-arm 目录是ARM 版本的安装目录设置环境变量：将相关安装包拷贝到工作目录中：3、编译安装zlib-1.2.3.tar.zip 配置4、然后make-make install即可5、编译安装libid3tag-0.15.1b（注：截图中的第一行代码后面部分为：-I$TARGET_DIR/include）6、然后make-make install即可7、编译安装libmad-0.15.1b 配置8、然后make-make install即可9、编译安装madplay-0.15.2b 配置10、然后make-make install即可Make install 完成后，会在target-arm/bin目录生成在arm开发板上可以运行的二进制文件madplay，拷贝到user-ftp目录下；打开超级终端，连接到开发板上，在超级终端上通过ftp连接到虚拟机，然后使用get命令获取madplay和mp3文件，退出ftp，运行“./madplay music.mp3”即可播放视频。五、实验结果与讨论成功播发音频文件music.mp3，并演示给老师看，但在实验结束后忘记截取了相关图像，因此结果的图像未展现。第二部分：代码类一、实验目的按照教学计划，本课程要求初步掌握嵌入式基本知识，懂得在开发板使用wince和linux基本操作，本实验是利用socket是的开发板与主机通信。二、实验内容与要求Wince/Linux平台与windows主机间使用以太网实现通信，要求在linux/wince/windows上编写一个TCP socket数据包收发程序，实现数据的通信，如实现文件发送。（也可以是2个开发板间的网络通信）三、主要仪器设备1、已连接网络的计算机。2、安装red hat9的虚拟机。3、装有linux的开发板四、实验内容4.1、实验基本功能在linux下用C语言编写，实现如下功能：服务器端客户端数据的上传、下载 4.2主要代码编写：Linux系统下，用文本编辑器编写ftp客户端与服务器端的C语言代码，另外几个包含的头文件。下面是在ftp客户端和服务器功能实现中比较重要的代码。4.2.1、实现服务器功能的主要代码编写 Main主函数定义一些相关的变量等代码：int main(int argc,char* argv) int sockfd; int clientfd; uint16_t port; int ret; pid_t pid; struct sockaddr_in server_addr; if ( 2 != argc ) printf(usage: command listen_portn); return -1; port = atoi(argv1); server_addr.sin_family = AF_INET; server_addr.sin_addr.s_addr = INADDR_ANY; server_addr.sin_port = htons(port); sockfd = socket(PF_INET,SOCK_STREAM,0); if (sockfd 0) perror(open data stream socket failed!n); return -1; ret = bind(sockfd,(struct sockaddr *)&server_addr,sizeof(server_addr); if(ret 0) perror(bind data socket failed!n); return -1; ret = listen(sockfd, SOMAXCONN ); if( ret 0) perror(listening data stream failed!n); return -1; printf(正在等待客户端到链接.n); while(1) clientfd = accept(sockfd, NULL, NULL); if( clientfd 0) perror(accept data connection error!n); return -1; pid = fork(); if ( pid 0 ) perror(fork error!n); if ( 0 = pid ) /chid process printf(one client come .n); serv_client(clientfd); return 0; close(clientfd); 处理服务器的请求int handle_request( msg_head_ctrl_t * msg, int sockfd);void serv_client(int sockfd) msg_head_ctrl_t *msg; ssize_t size; uint32_t body_len; uint32_t total_len; int ret; fd_set fs_client; struct timeval timeout;等待服务器请求 while(1) FD_ZERO(&fs_client); FD_SET( sockfd, &fs_client); timeout.tv_sec = DEFAULT_TIME_OUT; timeout.tv_usec = 0; ret = select(sockfd+1, &fs_client, NULL, NULL, &timeout); if ( 0 = ret ) /time out printf(time out.n); return ; if ( -1 = ret ) continue; 接收服务器的请求信息 size = recv( sockfd, &body_len, sizeof(uint32_t), MSG_PEEK); if ( sizebody_len = ntohl(msg-body_len); msg-command = ntohl(msg-command);/ printf(len = %d, msg = %sn, msg-body_len, msg-msg_body);如果服务器出现quit 的时候就推出 if ( COMMAND_QUIT = msg-command ) printf(client closed connection!n); close(sockfd); return ; 处理下载请求 ret = handle_request(msg, sockfd); if ( SOCK_ERROR = ret ) return; free(msg); 处理客户端的下载int handle_get(msg_head_ctrl_t * msg, int sockfd) int fd; int ret; bool exist; uint32_t body_len; msg_head_ctrl_t *ack_msg; ssize_t read_bytes; ssize_t sent_bytes;检查所需下载的文件所否存在 exist = file_exist( msg-msg_body ); printf(%s , %d, msg-msg_body, exist); if ( false = exist ) printf(File %s doesnt exist!n,msg-msg_body); body_len = msg-body_len; msg-body_len = htonl(msg-body_len); msg-command = htonl(COMMAND_NO_FILE); ret = send(sockfd, msg, sizeof(msg_head_ctrl_t) + body_len, 0); if ( ( sizeof(msg_head_ctrl_t) + body_len ) != ret) printf(send error,%s:%d,_FUNCTION_, _LINE_); return SOCK_ERROR; return FAILED; 传送下载数据 while(true) read_bytes = read(fd, ack_msg-msg_body, MAX_READ_BYTES); if ( read_bytes 0 ) /printf(len %d, %dn, read_bytes, ack_msg-body_len); ack_msg-body_len = htonl(read_bytes); ack_msg-command = htonl(msg-command); ret = SUCCESSFUL; else if ( -1 = read_bytes ) read_bytes = 0; ack_msg-body_len = 0; ack_msg-command = htonl(COMMAND_ERROR_FILE); ret = FAILED; else if ( 0 = read_bytes ) /传送完退出 ack_msg-body_len = 0; ack_msg-command = htonl(COMMAND_END_FILE); ret = SUCCESSFUL; sent_bytes = send( sockfd, ack_msg, read_bytes + sizeof(msg_head_ctrl_t), 0); if ( sent_bytes != (read_bytes + sizeof(msg_head_ctrl_t) ret = SOCK_ERROR; printf(send data error!%s:%d,_FUNCTION_, _LINE_); break; if ( 0 = ack_msg-body_len ) break; close(fd); return ret;处理显示服务端目录内容和打印服务端路径int handle_ls_pwd(msg_head_ctrl_t * msg, int sockfd) FILE *file; msg_head_ctrl_t *ack_msg; size_t read_bytes; size_t ret; printf(%sn, msg-msg_body); file = popen( msg-msg_body, r); if ( NULL = file ) printf(execute command failed! %sn, msg-msg_body); return FAILED; ack_msg = malloc(sizeof(msg_head_ctrl_t) + MAX_READ_BYTES); if ( NULL = ack_msg ) printf(out of memory!n); return FAILED; ack_msg-command = htonl( msg-command ); while(true) read_bytes = fread(ack_msg-msg_body,1, MAX_READ_BYTES, file); if ( ferror(file) break; ack_msg-body_len = htonl(read_bytes); ret = send(sockfd, ack_msg, read_bytes+sizeof(msg_head_ctrl_t), 0); if ( (read_bytes+sizeof(msg_head_ctrl_t) != ret ) printf(sock error!n); return SOCK_ERROR; if ( feof(file ) ) printf(send over!n); break; pclose(file);处理服务器的请求int handle_request( msg_head_ctrl_t * msg, int sockfd) char *cmd; int ret; switch(msg-command) case COMMAND_CD: /处理cd命令 cmd = trim_all_space( msg-msg_body+2);/skip cd charatcer ret = chdir(cmd); if ( -1 = ret ) printf(%s, |%s|n, strerror(errno), cmd); break; case COMMAND_LS: case COMMAND_PWD: ret = handle_ls_pwd(msg, sockfd); break; case COMMAND_GET: ret = handle_get(msg, sockfd); break; case COMMAND_PUT: break; default: ret = FAILED; break; return ret;4.2.2、实现客户端功能的主要代码编写建立套接字 sockfd = socket(PF_INET, SOCK_STREAM , 0); if(sockfd 0) perror(data stream socket create failed!n); return -1; server.sin_family = AF_INET; port = atoi(argv2); server.sin_port = htons(port); ret = inet_pton(AF_INET, argv1, &server.sin_addr.s_addr); if ( ret =0 ) printf(your ip address is unvalide!n); usage(); return -1; 链接到服务端 ret = connect(sockfd,(struct sockaddr*) &server,sizeof(struct sockaddr_in); if(ret 0) perror(data connection is failed!n); return -1; printf(connect to server successfully!n); clinet_process( sockfd ); /客户端进程函数调用处理服务端信息int handle_server_ack(sockfd) int ret; uint32_t body_len; uint32_t total_len; msg_head_ctrl_t *msg;接受服务器端的请求 ret = recv( sockfd, &body_len , sizeof(body_len), MSG_PEEK); if ( ret=0 ) printf(connectionn lost . n); exit(-1); body_len = ntohl(body_len); total_len = body_len + sizeof(msg_head_ctrl_t); msg = malloc( total_len + 1 ); if ( NULL = msg ) perror(out of memeoryn); return ; memset( msg, 0, total_len + 1); ret = recv( sockfd, msg , total_len, MSG_WAITALL); if ( retbody_len = ntohl(msg-body_len); msg-command = ntohl(msg-command); if ( (COMMAND_LS=msg-command) | (COMMAND_PWD=msg-command) ) printf(n%sn,msg-msg_body); else if ( COMMAND_GET = msg-command ) save_file_to_disk(msg-msg_body); free(msg);把命令传送到服务端int send_command_to_server( int sockfd, char *user_input, command_type_t type) ssize_t ret; msg_head_ctrl_t *msg; int body_len; int total_len; body_len = strlen(user_input); total_len = body_len + sizeof(msg_head_ctrl_t); msg = malloc(total_len); if ( NULL = msg ) printf(out of memeory!n); return FAILED; msg-command = htonl(type); msg-body_len = htonl(body_len); memcpy(msg-msg_body, user_input, body_len); ret = send(sockfd, msg, total_len, 0); if ( ret body_len), MSG_PEEK); if (ret body_len = ntohl(msg-body_len); msg-command = ntohl(msg-command); if ( COMMAND_NO_FILE = msg-command ) printf(File %s doesnt exist on servern, user_input); ret = FAILED; goto Exit; if ( -1 = fd) fd = open(user_input, O_WRONLY|O_CREAT|O_EXCL, 0660); if ( -1 = fd) printf(create file %s failed! %sn, user_input, strerror(errno); ret = FAILED; goto Exit; /save to file ret = write(fd, msg-msg_body, msg-body_len); if ( msg-body_len != ret ) printf(Write file failed!n); ret = FAILED; goto Exit; if ( COMMAND_END_FILE = msg-command ) ret = SUCCESSFUL; goto Exit; Exit: free(msg); if (SUCCESSFUL != ret ) unlink(user_input); close(fd); return ret;客户端进程函数void clinet_process(int sockfd ) fd_set fs_read; int max_sock; char buf255; int ret; max_sock = sockfd STDIN_FILENO ? sockfd : STDIN_FILENO; print_client_prompt(); while(1) FD_ZERO( &fs_read); FD_SET( STDIN_FILENO, &fs_read); FD_SET( sockfd, &fs_read); if ( select ( max_sock+1, &fs_read, NULL, NULL, NULL) 符号void print_client_prompt() printf(PROMPT_STR); fflush(stdout);4.2.3 由于篇幅有限，这里只是列举一些重要的源代码，其他的代码在源