计算机网络课程设计报告文件传输协议的简单实现
- 格式:doc
- 大小:362.00 KB
- 文档页数:23
《计算机网络系统实践》报告设计题目:网络文件传输学生姓名:专业班级:计算机科学与技术2016 年 1 月一、设计要求1. 实现单线程文件传输功能;2. 在以上基础上,掌握多线程技术,在文件网络传输时,可选择单线程或多线程;3. 加入异常控制依据,增强程序的鲁棒性(Robust);4. 了解如何提高套接字传输的速率,以及如何加强传输的稳定性。
二、开发环境与工具Eclips+java三、设计原理1.文件共享传输方式原理:主要采用TCPIP协议访问资源,一般是利用名字解析NETBIOS,dns,wins获得对方的IP地址,获取对方共享资源列表,当点击共享资源时候,客户机对服务器端点发出建立会话请求,这发生在传输层。
为了在服务端和客户端之间传送TCP数据,必须先建立一个虚拟电路,也就是TCP连接,建立TCP连接的标准过程是这样的:第一步,请求端(客户端)发送一个包含SYN标志的TCP报文,SYN即同步(Synchronize),同步报文会指明客户端使用的端口以及TCP连接的初始序号;第二步,服务器在收到客户端的SYN报文后,将返回一个SYN+ACK的报文,表示客户端的请求被接受,同时TCP序号被加一,ACK即确认(Acknowledgement)。
第三步,客户端也返回一个确认报文ACK给服务器端,同样TCP序列号被加一,到此一个TCP连接完成。
以上的连接过程在TCP协议中被称为三次握手(Three-way Handshake)。
会话连接建立后,对方检查共享资源的设置,通过注册表中的共享级别。
2.客户端:通过ss.socket()这个方法获取服务器的socket对象,并同过BufferReader来获取通道中的字节流中的内容3.服务器:将要发送的文件事先封装到通道内,并通过BufferWriter写入通道中四、系统功能描述及软件模块划分网络文件传输所实现的主要功能:网络文件传输主要由两个方面组成:1.客户端 2.服务器1.客户端:接受服务器发来的文件2.服务器:发送要发送的文件五、设计步骤1.服务器端的设计:①创建服务器对象ServerSocket ss = new ServerSocket (11111);②循环等待客户端的连接,若有客户端访问,就单独为它创建一个线程While(true){Socket s = ss.accept();New thread(new UserThread(s).start());}③封装字节流BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));④给出反馈bwServer.write(“文件上传成功”);⑤释放资源bw.close();2.客户端的设计①创建客户端对象Sockert s = new Socket();②封装文件BufferedWriter bw = new BUfferWriter(newOutputStreamWriter(s.getOutputStream()));③从通道中接受并反馈String client = brClient.readLine();System.out.println(client);④释放资源s.colse();六、关键问题及其解决方法1.怎样实现多线程的问题:While(true){Socket s = ss.accept();New thread(new UserThread(s).start());}2.怎样让// 封装通道内的流BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));// 封装文本文件// BufferedWriter bw = new BufferedWriter(new// FileWriter("Copy.java"));// 为了防止名称冲突String newName = System.currentTimeMillis() + ".txt";BufferedWriter bw = new BufferedWriter(new FileWriter(newName));String line = null;while ((line = br.readLine()) != null) { // 阻塞bw.write(line);bw.newLine();bw.flush();}客户端与服务器端运用TCP协议进行连接七、设计结果1.功能:实现客户端与服务器之间进行文件的传输2.课后思考题①套接字有基于阻塞和非阻塞的工作方式,试问你编写的程序是基于阻塞还是非阻塞的?各有什么优缺点?我编写的程序是基于阻塞的。
目录摘要 (3)第一章课程设计要求 (4)一、设计任务 (3)1.1.1 课程设计内容 (3)1.1.2、课程设计的基本要求 (3)二、设计基本思路及相关理论 (3)1.2.1、TCP/IP协议 (3)1.2.2、客户机/服务器模型 (4)1.2.3、设计基本思路 (4)第二章设计概要 (5)2.1 功能设计 (5)2.2 程序系统功能模块 (6)2.3 功能分析 (7)2.3.1 功能流程图: (7)2.3.2 程序主要功能说明 (7)第三章调试分析与测试结果 (23)3.1服务器端与客户端 (23)3.2文件管理的过程 (26)第四章设计总结 (28)参考文献 (28)课程设计评分表 (30)摘要网络的Socket数据传输是一种特殊的I/O,Socket也是一种文件描述符。
Socket也具有一个类似于打开文件的函数调用Socket(),该函数返回一个整型的Socket描述符,随后的连接建立、数据传输等操作都是通过该Socket实现的。
Socket接口是TCP/IP网络的API,Socket接口定义了许多函数或例程,程序员可以用它们来开发TCP/IP网络上的应用程序。
要学Internet上的TCP/IP网络编程,必须理解Socket接口。
Socket接口设计者最先是将接口放在Unix操作系统里面的。
如果了解Unix系统的输入和输出的话,就很容易了解Socket了。
常用的Socket类型有两种:流式Socket (SOCK_STREAM)和数据报式Socket(SOCK_DGRAM)。
流式是一种面向连接的Socket,针对于面向连接的TCP服务应用;数据报式Socket是一种无连接的Socket,对应于无连接的UDP服务应用。
Socket接口是TCP/IP网络的API,Socket接口定义了许多函数或例程,程序员可以用它们来开发TCP/IP网络上的应用程序。
要学Internet上的TCP/IP网络编程,必须理解Socket接口。
网络编程文件传输实验报告CKBOOD was revised in the early morning of December 17, 2020.基于TCP一、1、2、sockets 二、本程序是基于TCP/IP协议栈的网络编程,使用C语言,利用操作系统提供的套接字网络编程接口进行编写TCP协议是其中重要的传输协议,为应用层提供可靠的端到端的流传输服务.其中套接字取值sock_stream即为TCP的流传输服务Windows socket包含了人们所熟悉的Berkeley Socket风格的函数库,也包含了一组针对windows的扩展库函数,以使程序员能充分的利用windows驱动消息机制进行编程。
Windows Sockets的规范本意在于提供给应用开发者一套简单的API,并让个网络应用软件开发商遵守该协议。
此外在一个特定的版本windows基础上,Windows socket也定义了一个二进制借口(ABI),从此来保证Windowssocket API应用程序能够在任何符合Windows socket协议的实现上工作。
三、设计概述1、创建套接字服务进程和客户进程在实现通信前必须创建各自的套接字,然后才能用相应的套接字进行发送接收操作,服务进程总是先于客户端进程启动,服务器端进程和客户端进程创建套接字。
Socket()函数实现代码如下:SOCKET serSocket=socket(AF_INET,SOCK_STREAM,0);....\n");....\n");//得到主机开始传送消息recv(clientSocket,receiveBuf,101,0);printf("%s\n",receiveBuf);if(strcmp(receiveBuf,"开始传送")==0){//传送文件长度char sendBuf[20];ltoa(length,sendBuf,10);send(clientSocket,sendBuf,21,0);fseek(fp,0L,SEEK_SET);//传送文件long int y=0;double cent;char trans[SIZE];while(!feof(fp)){fread(trans,1,SIZE,fp);y=y+SIZE;if(y<length){cent=(double)y*(double)length;printf("已发送:%%\n",cent); send(clientSocket,trans,SIZE+1,0); } else{ send(clientSocket,trans,length+SIZE-y+1,0);closesocket(clientSocket); WSACleanup(); } }fclose(fp);}printf("文件发送完毕\n");system("pause");}四、实验结果及分析:客户端运行结果服务器端运行结果五、心得体会:网络编程的实验课虽然只有八次,但是我们充分了解了各种网络编程和winsock控件的知识,了解了TCP/IP协议的相关知识以及其中两个重要协议TCP UDP的特点与差异,进一步学习了文件传输等知识,创建套接字监听传输关闭等过程,直到最后写出C/S模式的文件传输程序感觉我们巩固了教材的内容实践的能力也得到了提高不足之处就是自己粗心大意,在写代码时候参数注解等经常注明的不够好,希望以后能养成良好的编程习惯。
课程设计课程名称计算机网络课程设计题目名称文件传输协议的简单设计与实现学生学院专业班级___ _学号学生姓名______ _________指导教师______ _____2010 年 1 月 5 日设计摘要关键词:SOCKET编程,FTPclient/server程序摘要:本课程设计包含了文件传输协议的简单设计与实现。
文件传送是各种计算机网络实现的基本功能,文件传送协议是一种最基本的应用层协议按照客户/服务器的模式进行工作,提供交互式的访问,是INTERNET使用最广泛的协议之一。
文件传输协议的简单设计与实现建立在计算机网络实验环境TCP/IP 网络体系结构之上,使用socket 编程接口编写两个程序,分别为客户程序(client.c)和服务器程序(server.c),实现下述命令功能:get , put, pwd, dir, cd, ?, quit 等,利用了已有网络环境设计并实现简单应用层协议。
本设计包括了具体设计任务,基本思路及所涉及的相关理论,设计流程图,调试过程中出现的问题及相应解决办法,实验运行结果,核心程序,个人体会及建议等。
目录1、文件传输协议的简单设计与实现------------------------------181. 1 具体设计任务----------------------------------------------18 1.2 基本思路及所涉及的相关理论--------------------------------181.2.1基本思路-------------------------------------------------182.2.2 相关理论--------------------------------------------18 1.3设计流程图------------------------------------------------191.4实验运行情况----------------------------------------------191.5 核心程序--------------------------------------------------222.5.1 服务器(sever)程序---------------------------------222.5.2 客户(client)程序----------------------------------291.6心得体会-----------------------------------------------------------------------------37参考文献--------------------------------------------------------382、文件传输协议的简单设计与实现2. 1 具体设计任务计算机网络实验环境建立在TCP/IP 网络体系结构之上。
计算机网络技术第四版课程设计一、设计题目本次计算机网络技术课程设计的题目是“基于TCP协议的文件传输程序实现”。
二、设计目的计算机网络技术是网络工程专业的核心基础课程之一,课程涉及到计算机网络领域的各个方向,例如网络协议、网络体系结构、路由协议、网络安全等。
通过本次课程设计,旨在让学生深入了解TCP协议的应用,掌握TCP协议的实现过程和技术要点,提高学生对计算机网络技术的理解和应用能力。
三、设计要求实现一个基于TCP协议的文件传输程序,要求如下:1.接收方和发送方分别处于不同的机器上。
2.文件传输过程通过TCP协议完成。
3.实现断点续传功能。
4.通过命令行界面输入传输文件的路径和传输模式(上传/下载)等必要信息。
四、设计流程1. 建立网络连接建立TCP连接是实现文件传输的第一步,需要使用Python的socket库实现。
按照TCP三次握手的规则,建立与对方的链接。
2. 传输文件使用Python的文件读取方式,将要传输的文件读取至内存中。
使用TCP协议,将文件分成多个数据块,依次传输至对方机器。
3. 断点续传在传输文件的过程中,可能会出现意外断开连接的情况。
为了实现断点续传功能,传输过程中需要保存已经传输的文件块,当重新建立连接后继续传输。
4. 命令行控制实现一个命令行界面,通过命令行输入文件传输的相关信息,例如待传输文件的路径、传输模式(上传/下载)等信息。
通过分析用户的操作,执行相应的文件传输操作,并在命令行上显示传输过程的相关信息。
五、技术要点1.Python Socket编程2.TCP协议3.文件读取和写入4.断点续传5.命令行控制六、设计结论通过本次基于TCP协议的文件传输程序实现的计算机网络技术课程设计,我们深入了解了TCP协议的应用过程,掌握了TCP协议的实现技术要点,并实现了文件传输过程中常见的断点续传功能和命令行控制。
这些技术点均是计算机网络技术课程中的重点内容,对我们深入学习和理解计算机网络技术的概念和应用具有重要的帮助和启示。
一、实验目的1. 理解文件传送协议的基本原理和流程。
2. 掌握常用的文件传送协议,如FTP、TFTP等。
3. 学习使用文件传送协议进行文件的上传和下载。
4. 了解文件传送协议在实际应用中的优势和局限性。
二、实验环境1. 操作系统:Windows 102. 软件环境:Cygwin、FTP Server、FTP Client3. 网络环境:局域网三、实验内容1. FTP协议实验2. TFTP协议实验四、实验步骤1. FTP协议实验(1)搭建FTP服务器1)在Cygwin中安装FTP服务器。
2)配置FTP服务器,设置用户名和密码。
3)启动FTP服务器。
(2)使用FTP客户端连接FTP服务器1)在Cygwin中安装FTP客户端。
2)使用FTP客户端连接到FTP服务器。
3)登录FTP服务器。
(3)上传和下载文件1)在FTP客户端选择要上传的文件。
2)使用FTP客户端将文件上传到FTP服务器。
3)在FTP客户端选择要下载的文件。
4)使用FTP客户端将文件从FTP服务器下载到本地。
2. TFTP协议实验(1)搭建TFTP服务器1)在Cygwin中安装TFTP服务器。
2)配置TFTP服务器,设置共享目录。
3)启动TFTP服务器。
(2)使用TFTP客户端连接TFTP服务器1)在Cygwin中安装TFTP客户端。
2)使用TFTP客户端连接到TFTP服务器。
(3)上传和下载文件1)在TFTP客户端选择要上传的文件。
2)使用TFTP客户端将文件上传到TFTP服务器。
3)在TFTP客户端选择要下载的文件。
4)使用TFTP客户端将文件从TFTP服务器下载到本地。
五、实验结果与分析1. FTP协议实验实验结果表明,使用FTP协议可以方便地进行文件的上传和下载。
FTP服务器和客户端的配置较为简单,易于操作。
但在实际应用中,FTP协议存在以下局限性:(1)FTP协议不是加密传输,存在安全隐患。
(2)FTP协议传输速度较慢。
(3)FTP协议不支持断点续传。
计算机网络中的传输协议与实现计算机网络是现代社会中最重要的基础设施之一,其靠的是一系列协议来保证网络的正常运行。
其中最重要的就是传输协议。
本文将探讨计算机网络中的传输协议与实现。
传输协议是计算机网络中的一种协议,它负责在不同计算机之间传输数据。
具体来说,传输协议主要分为两类:面向连接的传输协议和无连接的传输协议。
面向连接的传输协议是指在传输数据之前,发送端和接收端之间要先建立一条连接,然后再传输数据。
这种协议比较安全可靠,但是由于需要建立连接,速度较慢。
常见的面向连接的传输协议有TCP协议。
TCP协议是一种面向连接的传输协议,它是整个互联网传输层协议中最主要的一种。
TCP协议有以下特点:1.可靠性高:TCP协议在传输数据时会检测数据的完整性,如果数据在传输过程中发生了错误,TCP协议会重新发送数据,保证数据的正确性;2.面向连接:TCP协议在传输数据之前需要建立连接,这样可以保证数据传输的可靠性;3.流量控制:TCP协议可以根据网络状况自动控制数据的传输速率,使网络负载保持在合理的范围内。
无连接的传输协议是指在传输数据时,发送端和接收端之间不需要建立连接,直接发射数据包。
这种协议速度较快,但是由于不需要建立连接,数据传输的可靠性不如面向连接的传输协议。
常见的无连接的传输协议有UDP协议。
UDP协议是一种无连接的传输协议,它是整个互联网传输层协议中最基础的一种。
UDP协议有以下特点:1.传输速度快:UDP协议不需要建立连接,直接发送数据包,速度比较快;2.简单易实现:UDP协议的实现比较简单,开发者可以容易地实现它;3.面向无连接:UDP协议不需要建立连接,数据传输的可靠性比较低。
对于大多数应用程序而言,TCP协议能够满足其对传输协议的需求,但是对于实时视频和音频等需要实时传输的应用来说,UDP协议则更加适用。
因为对于实时传输来说,速度比可靠性更加重要,如果在处理实时数据时因为网络传输问题导致数据延迟过高,就会对应用的性能产生很大的影响。
第ChpNum章文件传输协议的C语言实现1设计目的本设计旨在利用Winsock 简单实现FTP(File Transfer Protocol,文件传输协议)的客户端和服务器端程序。
通过完成此设计,了解Winsock API函数调用方法和一般网络应用程序的编程方法,理解FTP协议,掌握C语言设计FTP协议软件的基本技术,为将来开发其他通信协议软件打下坚实基础。
2 设计准备(1)连入同一局域网的PC,每人一台。
(2)PC装有Windows操作系统、Visual C++ 编译器及开发手册MSDN 。
3关键技术文件传输协议介绍FTP 是File Transfer Protocol(文件传输协议)的英文简称,用于Internet上的控制文件的双向传输。
在实现的层面上,FTP又可理解为一个可用于文件传输的客户机/服务器系统,该系统包括客户机端程序和服务器端程序,客户端和服务器端通信规则为FTP协议。
用户通过客户机程序向服务器程序发出命令请求,服务器程序执行用户所发出的命令,并将执行的结果返回到客户机。
比如说,用户发出一条命令,要求服务器向用户传送某一个文件的一份拷贝,服务器会响应这条命令,将指定文件送至用户的机器上。
客户机程序接收到这个文件,将其存放在用户目录中。
在通信协议的分层模型中,文件传输协议是在TCP(Transmission control Protocol,传输控制协议)之上的一个应用层协议,应用程序之间的通信需要用到传输层提供的字节流透明无误传输服务。
Windows操作系统具有TCP/IP协议栈,应用程序可通过Winsock API函数的调用实现端到端透明数据链接的建立。
Winsock API介绍因特网(Internet)最初是基于Unix的,而Sockets(套接字)是Unix第一个支持TCP/IP 协议栈的网络API,最早于1982年8月随BSD版Unix推出,常被称为Berkeley sockets (伯克利套接字)。
课程设计课程名称_计算机网络题目名称_文件传输协议的简单设计与实现学生学院_自动化学院专业班级_13级物联网工程1班学号_**********学生姓名梁建斌指导教师刘洪涛2015年12月25日摘要文件传送是各种计算机网络都实现的基本功能,文件传送协议是一种最基本的应用层协议按照客户/服务器的模式进行工作,提供交互式的访问。
本设计是基于Eclipse平台下使用Java实现的FTP文件传输。
实现基本的文件传输操作。
建立客户端和服务器、客户端基于TCP Socket进行数据传输,采用多线程进行数据传输,套接字来实现。
在实现过程中采用类与对象的思想进行规划,体验了一个软件开发过程的具体实现步骤。
关键字:Java网络编程FTP文件传输文件上传下载文件操作1目录一、实验目的 (3)二、实验内容和要求 (3)1、实验内容 (3)2、具体要求 (3)三、实验主要仪器设备和材料 (3)四、基本原理 (3)1.FTP系统模型 (3)2. 系统功能设计 (4)2.1总体设计 (4)基本功能 (4)2.2系统实现 (4)五、实现结构流程图 (5)六、整体实现的逻辑、数据结构 (5)1.客户端的抽象数据类型 (5)1.1FTPClient用户界面 (5)1.2FTPClient控制连接线程 (7)1.3FTPClient数据连接线程 (7)2. 服务器的抽象数据类型 (8)2.1 FTPServer的控制连接线程 (8)2.2FTPServer的数据连接线程 (9)七、具体的一些方法实现 (9)1. FTPClient用户界面 (10)2. FTPClient控制连接 (10)3. FTPClient数据传输 (12)4. FTPServer控制连接 (14)5. FTPServer数据传输 (14)八、测试结果客户端结果 (16)服务端结果 (16)九、课程设计心得 (17)十、参考文献 (18)2一、实验目的文件传送是各种计算机网络都实现的基本功能,文件传送协议是一种最基本的应用层协议按照客户/服务器的模式进行工作,提供交互式的访问,是INTERNET使用最广泛的协议之一。
要求:用socket 编程接口编写两个程序,分别为客户程序(client.c)和服务器程序(server.c),该程序应能实现下述命令功能:get:取远方的一个文件put:传给远方一个文件pwd:显示远主当前目录dir:列出远方当前目录cd :改变远方当前目录?:显示你提供的命令quit :退出返回注意事项:这此命令的具体工作方式(指给出结果的形式)可以参照FTP 的相应命令,有余力的同学可以多实现几个命令。
使用Socket进行Client/Server程序设计的一般连接过程是这样的:Server端Listen(监听)某个端口是否有连接请求,Client端向Server端发出Connect(连接)请求,Server端向Client 端发回Accept(接受)消息。
一个连接就建立起来了。
Server端和Client端都可以通过Send,Write等方法与对方通信。
对于一个功能齐全的Socket,都要包含以下基本结构,其工作过程包含以下四个基本的步骤:(1)创建Socket;(2)打开连接到Socket的输入/出流;(3)按照一定的协议对Socket进行读/写操作;(4)关闭Socket.下面是源代码:/****************client.c****************/#include <winsock2.h>#include <stdio.h>#include <stdlib.h>#pragma comment(lib,"ws2_32.lib")#define DEFAULT_PORT 2302#define DEFAULT_BUFFER 2048#define DEFAULT_MESSAGE "This is a test of the emergency \ broadcasting system"char szServerip[128], // Server to connect toszMessage[1024]; // Message to send to severint iPort = DEFAULT_PORT; // Port on server to connect to//DWORD dwCount = DEFAULT_COUNT; // Number of times to send messageBOOL bSendOnly = FALSE; // Send data only; don't receiveint dirfun();int getfun();int putfun();int pwdfun();int cdfun();int mdfun();int delfun();int usafun();void usage(){printf("usage: client [-p:x] [-s:IP] [-n:x] [-o]\n\n");printf(" -p:x Remote port to send to\n");printf(" -s:IP Server's IP address or hostname\n");printf(" -n:x Number of times to send message\n");printf(" -o Send messages only; don't receive\n");ExitProcess(1);}void ValidateArgs(int argc, char **argv){int i;for(i = 1; i < argc; i++){if ((argv[i][0] == '-') || (argv[i][0] == '/')){switch (tolower(argv[i][1])){case 'p': // Remote portif (strlen(argv[i]) > 3)iPort = atoi(&argv[i][3]);break;case 's': // Serverif (strlen(argv[i]) > 3)strcpy(szServerip, &argv[i][3]);break;case 'n': // Number of times to send messageif (strlen(argv[i]) > 3)//dwCount = atol(&argv[i][3]);break;case 'o': // Only send message; don't receivebSendOnly = TRUE;break;default:usage();break;}}}}int main(int argc, char **argv){WSADATA wsd;SOCKET sClient;char szBuffer[DEFAULT_BUFFER];int ret;//unsigned int i;//int j;struct sockaddr_in server;struct hostent *host = NULL;char choice[5],choice2[40];// Parse the command line and load Winsock//argv[1]="-s:127.0.0.1";strcpy(szServerip, &argv[1][3]);//ValidateArgs(argc, argv);if (WSAStartup(MAKEWORD(2,2), &wsd) != 0){printf("Failed to load Winsock library!\n");return 1;}//strcpy(szMessage, DEFAULT_MESSAGE);//// Create the socket, and attempt to connect to the server//sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);if (sClient == INV ALID_SOCKET){printf("socket() failed: %d\n", WSAGetLastError());return 1;}server.sin_family = AF_INET;server.sin_port = htons(iPort);printf("server.sin_port=%u\n",server.sin_port);server.sin_addr.s_addr = inet_addr(szServerip);//// If the supplied server address wasn't in the form// "c.ddd" it's a hostname, so try to resolve it//if (server.sin_addr.s_addr == INADDR_NONE){host = gethostbyname(szServerip);if (host == NULL){printf("Unable to resolve server: %s\n", szServerip);return 1;}CopyMemory(&server.sin_addr, host->h_addr_list[0],host->h_length);}if (connect(sClient, (struct sockaddr *)&server,sizeof(server)) == SOCKET_ERROR){printf("connect() failed: %d\n", WSAGetLastError());return 1;}//显示接通信息//////for(j=0;j<2;j++)//{ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);if (ret == 0) // Graceful closereturn 0;else if (ret == SOCKET_ERROR){printf("recv() failed: %d\n", WSAGetLastError());return 0;}szBuffer[ret] = '\0';printf("%s\n",szBuffer);if(ret<15){ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);if (ret == 0) // Graceful closereturn 0;else if (ret == SOCKET_ERROR){//printf("recv() failed: %d\n", WSAGetLastError());return 0;}szBuffer[ret] = '\0';printf("%s\n",szBuffer);}//printf("DEFAULT_BUFFER=%d\n",DEFAULT_BUFFER);}while(1){puts("------------------------------------------");printf("ftp> ");scanf("%s", choice);if(strncmp(choice,"dir",3)==0||strncmp(choice,"DIR",2)==0){dirfun(sClient);continue;}else if(strncmp(choice,"pwd",3)==0||strncmp(choice,"PWD",3)==0) {pwdfun(sClient);continue;}else if(strncmp(choice,"?",1)==0){usafun(sClient);continue;}else if(strncmp(choice,"quit",4)==0||strncmp(choice,"QUIT",2)==0) {break;}scanf("%s", choice2);if(strncmp(choice,"get",3)==0||strncmp(choice,"GET",3)==0){getfun(sClient,choice2);continue;}else if(strncmp(choice,"put",3)==0||strncmp(choice,"PUT",3)==0) {putfun(sClient,choice2);continue;}else if(strncmp(choice,"cd",2)==0||strncmp(choice,"CD",2)==0) {cdfun(sClient,choice2);continue;}else if(strncmp(choice,"md",2)==0||strncmp(choice,"MD",2)==0) {mdfun(sClient,choice2);}else if(strncmp(choice,"del",3)==0||strncmp(choice,"DEL",3)==0){delfun(sClient,choice2);continue;}//elseputs("输入错误,请重新输入");fflush(stdin);fflush(stdin);printf("\n");printf("\n");}closesocket(sClient);WSACleanup();return 0;}int dirfun(SOCKET sClient){int ret;char *MSG="dir$";char szBuffer[80];strcpy(szMessage, MSG);ret = send(sClient, szMessage, strlen(szMessage), 0);if (ret == 0)return 1;else if (ret == SOCKET_ERROR){printf("send() failed: %d\n", WSAGetLastError());return 1;}//printf("Send %d bytes\n", ret);//printf("bSendOnly=%d\n",bSendOnly);while(!bSendOnly){//读取流并显示//ret = recv(sClient, szBuffer, 80, 0);//printf("%s",szBuffer);ret = recv(sClient, szBuffer, 80, 0);if (ret == 0) // Graceful closeelse if (ret == SOCKET_ERROR){printf("recv() failed: %d\n", WSAGetLastError());return 1;}szBuffer[ret] = '\0';if(strncmp(szBuffer,"226 Close",strlen("226 Close"))==0){break;}printf("%s",szBuffer);if(strncmp(szBuffer,"500 Syntax error",strlen("500 Syntax error"))==0){break;}}return 0;}int getfun(SOCKET sClient,char filename[40]){int ret;FILE *fpre;char szBuffer[80];szMessage[0]='\0';strcat(szMessage, "get$");//strcat(szMessage, "\\");strcat(szMessage,filename);//printf("MSG[4]=%c\n",szMessage[4]);//szMessage[0]='g';szMessage[1]='e';szMessage[2]='t';////szMessage[4]='m';szMessage[5]='e';szMessage[6]='.';szMessage[7]='t';////szMessage[8]='x';szMessage[9]='t';szMessage[10]='\0';ret = send(sClient, szMessage, strlen(szMessage)+1, 0);if (ret == 0)return 1;else if (ret == SOCKET_ERROR){printf("send() failed: %d\n", WSAGetLastError());}printf("Send %d bytes\n", ret);ret = recv(sClient, szBuffer, 80, 0);/*if (ret == 0) // Graceful closebreak;else if (ret == SOCKET_ERROR){printf("recv() failed: %d\n", WSAGetLastError());break;}*/szBuffer[ret] = '\0';printf("%s\n",szBuffer);if(strncmp( szBuffer,"125 Transfering...",strlen("125 Transfering...") )==0) {if( (fpre=fopen(filename,"w")) == NULL ){printf("open errer");return 1;}printf("bSendOnly=%d\n",bSendOnly);while(!bSendOnly){//读取流并显示ret = recv(sClient, szBuffer, 80, 0);if (ret == 0) // Graceful closereturn 1;else if (ret == SOCKET_ERROR){printf("recv() failed: %d\n", WSAGetLastError());return 1;}szBuffer[ret] = '\0';//printf("%s",szBuffer);if(strncmp(szBuffer,"226 Transfer",strlen("226 Transfer"))==0){break;}if(strncmp(szBuffer,"500 Syntax error",strlen("500 Syntax error"))==0){break;}fprintf(fpre,"%s",szBuffer);}printf("%s\n",szBuffer);fclose(fpre);}return 0;}int putfun(SOCKET sClient,char filename[40]){int ret;//int i;FILE *fpse;//char *filename;//char *MSG="get\0me.txt";char szBuffer[80],temp_buffer[80];//sprintf(szMessage, "get\0","te.txt\0");szMessage[0]='\0';strcat(szMessage, "put$");strcat(szMessage,filename);ret = send(sClient, szMessage, strlen(szMessage)+1, 0);if (ret == 0)return 0;else if (ret == SOCKET_ERROR){printf("send() failed: %d\n", WSAGetLastError());return 1;}//printf("Send %d bytes\n", ret);//filename="me.txt";printf("filename=%s\n",filename);if( (fpse=fopen(filename,"r")) == NULL ){printf("open errer");return 1;}else{printf("The file %s found,ready to transfer.\n",filename);//i=0;while (fgets(temp_buffer,80,fpse)!=NULL){sprintf(szBuffer,"%s",temp_buffer);send(sClient, szBuffer, 80, 0);}}sprintf(szBuffer, "226 Transfer completed... \r\n");ret = send(sClient, szBuffer, strlen(szBuffer), 0);fclose(fpse);return 0;}int pwdfun(SOCKET sClient){int ret;char *MSG="pwd$";char szBuffer[160];strcpy(szMessage, MSG);ret = send(sClient, szMessage, strlen(szMessage), 0);if (ret == 0)return 1;else if (ret == SOCKET_ERROR){printf("send() failed: %d\n", WSAGetLastError());return 1;}printf("Send %d bytes\n", ret);printf("bSendOnly=%d\n",bSendOnly);while(!bSendOnly){//读取流并显示ret = recv(sClient, szBuffer, 160, 0);if (ret == 0) // Graceful closereturn 1;else if (ret == SOCKET_ERROR){printf("recv() failed: %d\n", WSAGetLastError());return 1;}szBuffer[ret] = '\0';printf("%s\n",szBuffer);if(strncmp(szBuffer,"226 Close",strlen("226 Close"))==0){break;}if(strncmp(szBuffer,"500 Syntax error",strlen("500 Syntax error"))==0) {break;}}return 0;}int cdfun(SOCKET sClient,char pathname[40]){int ret;szMessage[0]='\0';strcat(szMessage, "cd$");strcat(szMessage,pathname);ret = send(sClient, szMessage, strlen(szMessage)+1, 0);if (ret == 0)return 1;else if (ret == SOCKET_ERROR){printf("send() failed: %d\n", WSAGetLastError());return 1;}printf("Send %d bytes\n", ret);return 0;}int mdfun(SOCKET sClient,char pathname[20]){int ret;char szBuffer[160];//char *MSG="md$";szMessage[0]='\0';strcat(szMessage, "md$");//strcat(szMessage, "\\");strcat(szMessage,pathname);//strcpy(szMessage, MSG);ret = send(sClient, szMessage, strlen(szMessage)+1, 0);if (ret == 0)return 1;else if (ret == SOCKET_ERROR){printf("send() failed: %d\n", WSAGetLastError());return 1;}printf("Send %d bytes\n", ret);while(!bSendOnly){//读取流并显示ret = recv(sClient, szBuffer, 80, 0);if (ret == 0) // Graceful closereturn 1;else if (ret == SOCKET_ERROR){printf("recv() failed: %d\n", WSAGetLastError());return 1;}szBuffer[ret] = '\0';printf("%s",szBuffer);if(strncmp(szBuffer,"226 Close",strlen("226 Close"))==0){break;}if(strncmp(szBuffer,"500 Syntax error",strlen("500 Syntax error"))==0){break;}}return 0;}int delfun(SOCKET sClient,char name[20]){int ret;char szBuffer[80];szMessage[0]='\0';strcat(szMessage, "del$");strcat(szMessage,name);ret = send(sClient, szMessage, strlen(szMessage)+1, 0);if (ret == 0)return 1;else if (ret == SOCKET_ERROR){printf("send() failed: %d\n", WSAGetLastError());return 1;}printf("Send %d bytes\n", ret);while(!bSendOnly){ret = recv(sClient, szBuffer, 80, 0);if (ret == 0) // Graceful closereturn 1;else if (ret == SOCKET_ERROR){printf("recv() failed: %d\n", WSAGetLastError());return 1;}szBuffer[ret] = '\0';if(strncmp(szBuffer,"del ok",strlen("del ok"))==0){printf("del %s ok\n",name);break;}printf("%s",szBuffer);if(strncmp(szBuffer,"500 Syntax error",strlen("500 Syntax error"))==0) {break;}}return 0;}int usafun(){puts("------------------------------------------");puts("get:取远方的一个文件");puts("put:传给远方一个文件");puts("pwd:显示远主当前目录");puts("dir:列出远方当前目录");puts("md :在远方新建文件夹");puts("cd :改变远方当前目录");puts("?:显示你提供的命令");puts("quit :退出返回");return 0;}//int quit()/****************server.c****************/#include <stdio.h>#include <winsock.h>#include <stdlib.h>#pragma comment(lib,"ws2_32.lib")WSADATA wsd;char sbuffer[80],rbuffer[80];//send and receive buffersint n,bytes;//countersSOCKET newsocket,ns_data;struct sockaddr_in remoteaddr; //remoteaddr_data;int port_connect=0;//port connect flagchar path[80]="";char order[100]="";//SOCKET s_data_port;int sy_error=1; // use for indicate Syntax error//server functionsint sdirfun(SOCKET newsocket);int sgetfun(SOCKET newsocket);int sputfun(SOCKET newsocket);int spwdfun(SOCKET newsocket);int scdfun(SOCKET newsocket);int smdfun(SOCKET newsocket);int sdelfun(SOCKET newsocket);void HandleError(char *func);//server functions end//MAINint main(int argc, char *argv[]){struct sockaddr_in localaddr;//local address structureSOCKET s;//s_data;//welcome socket and welcome socket for data connection,and port connection for connect to clientint addr_inlen;//address lenght variableif (WSAStartup(MAKEWORD(2,2), &wsd) != 0){WSACleanup();printf("WSAStartup failed\n");}memset(&localaddr,0,sizeof(localaddr));//clear localaddrs = socket(PF_INET, SOCK_STREAM, 0);if (s <0){printf("socket failed\n");}localaddr.sin_family = AF_INET;if(argc == 2)localaddr.sin_port = htons((u_short)atoi(argv[1]));elselocaladdr.sin_port = htons(2302);localaddr.sin_addr.s_addr = INADDR_ANY;if (bind(s,(struct sockaddr *)(&localaddr),sizeof(localaddr)) < 0){printf("Bind failed!\n");}//INFINITE LOOPwhile (1){ // while loop 1//LISTENlisten(s,3);addr_inlen = sizeof(remoteaddr);//ACCEPT main connection (control connection)newsocket = accept(s,(struct sockaddr *)(&remoteaddr),&addr_inlen);if (newsocket == INV ALID_SOCKET) break;printf("connected to %s at port %d \n",inet_ntoa(remoteaddr.sin_addr),ntohs(localaddr.sin_port));//Respond with welcome message, FTP client requires thosesprintf(sbuffer,"200 Welcome \r\n");bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);sprintf(sbuffer,"530 Log in \r\n");bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);//INFINITE LOOPwhile (1) // while loop 2{n = 0;sy_error=1;while (1) // while loop 3{//RECEIVEbytes = recv(newsocket, &rbuffer[n], 1, 0);printf("rbuffer[%d]=%c\n",n,rbuffer[n]);if ((bytes < 0) || (bytes == 0))break;if (rbuffer[n] == '$'){rbuffer[n] = '\0';break;}if (rbuffer[n] != '\r')n++;} // end of while loop 3if ((bytes < 0) || (bytes == 0))break;printf("#The Server receives:# '%s' from client \n", rbuffer); //THE FTP COMMANDS HERE//LISTif(strncmp(rbuffer,"dir",3)==0){sdirfun(newsocket);}//当前目录if(strncmp(rbuffer,"pwd",3)==0){spwdfun(newsocket);}//改变目录if (strncmp(rbuffer,"cd",2)==0){scdfun(newsocket);}//GETif (strncmp(rbuffer,"get",3)==0){sgetfun(newsocket);}//PUTif (strncmp(rbuffer,"put",3)==0){sputfun(newsocket);}//MDif (strncmp(rbuffer,"md",2)==0){smdfun(newsocket);}if (strncmp(rbuffer,"del",3)==0){sdelfun(newsocket);}//QUITif (strncmp(rbuffer,"quit",4)==0){printf("quit \n");sprintf(sbuffer, "221 Bye bye ... \r\n");bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);sy_error=0;break;}//Syntax errorif (sy_error==1){printf("command unrecognized, non-implemented!\n");sprintf(sbuffer, "500 Syntax error. \n");bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);}} // end of while loop 2//CLOSE CONTROL SOCKETclosesocket(newsocket);printf("disconnected from %s at port %d, close control socket.\n",inet_ntoa(remoteaddr.sin_addr),ntohs(localaddr.sin_port));} // end of while loop 1//CLOSE WELCOME SOCKETclosesocket(s);printf("Welcome sockets close");return 0;}int sdirfun(SOCKET newsocket){char temp_buffer[80];printf("Equivalent to dir \n");order[0]='\0';strcat(order,"dir ");strcat(order,path);strcat(order," >tmp.txt");system(order);FILE *fin;fin=fopen("tmp.txt","r");sprintf(sbuffer, "125 Transfering... \r\n");bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);while (fgets(temp_buffer,80,fin)!=NULL){sprintf(sbuffer,"%s",temp_buffer); //if (port_connect==0)send(newsocket, sbuffer, strlen(sbuffer), 0);}fclose(fin);sprintf(sbuffer, "226 Transfer completed... \r\n");bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);system("del tmp.txt");//CLOSE the ns_data SOCKET or data port SOCKETif(port_connect==0){closesocket(ns_data);sprintf(sbuffer,"226 Close the data socket... \r\n");bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);ns_data = socket(AF_INET, SOCK_STREAM, 0);}sy_error=0;return 0;}int sgetfun(SOCKET newsocket){printf("RETR mode.\r\n");int i=4,k=0;char filename[20],temp_buffer[80];// identify the filename from rbuffer after the word "RETR "while (1) // while loop 4{//RECEIVEbytes = recv(newsocket, &rbuffer[i], 1, 0);printf("rbuffer[i]=%c\n",rbuffer[i]);if ((bytes < 0) || (bytes == 0))break;filename[k]=rbuffer[i];if (rbuffer[i] == '\0'){ /*end on LF*/filename[k] = '\0';break;}if (rbuffer[i] != '\r'){i++;k++;/*ignore CR's*/}} // end of while loop 4order[0]='\0';strcat(order,path);if(strlen(path)>0)strcat(order,"\\");strcat(order,filename);char *p_filename=order;FILE *fp;if( (fp=fopen(p_filename,"r")) == NULL ){sprintf(sbuffer, "Sorry, cannot open %s. Please try again.\r\n",filename);bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);sprintf(sbuffer, "226 Transfer completed... \r\n");bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);return 1;}else{printf("The file %s found,ready to transfer.\n",filename);sprintf(sbuffer, "125 Transfering... \r\n");bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);while (fgets(temp_buffer,80,fp)!=NULL){sprintf(sbuffer,"%s",temp_buffer); //if (port_connect==0)send(newsocket, sbuffer, strlen(sbuffer), 0);}//end of whilefclose(fp);sprintf(sbuffer, "226 Transfer completed... \r\n");bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);}sy_error=0;return 0;}int sputfun(SOCKET newsocket){printf("Equivalent to put. \n");int i=4,k=0;char filename[20];// identify the filename from rbuffer after the word "RETR "while (1){bytes = recv(newsocket, &rbuffer[i], 1, 0);if ((bytes < 0) || (bytes == 0))break;filename[k]=rbuffer[i];if (rbuffer[i] == '\0'){ /*end on LF*/filename[k] = '\0';break;}if (rbuffer[i] != '\r'){i++;k++;/*ignore CR's*/}} // end of whileorder[0]='\0';strcat(order,path);if(strlen(path)>0)strcat(order,"\\");strcat(order,filename);printf("filename=%s,",order);char *p_filename=order;FILE *fpse;if( (fpse=fopen(order,"w")) == NULL ){printf("open errer");return 1;}else{printf("The file %s found,ready to transfer.\n",filename);while(1){//读取流并显示int ret;ret = recv(newsocket, rbuffer, 80, 0);if (ret == 0) // Graceful closereturn 0;else if (ret == SOCKET_ERROR){printf("recv() failed: %d\n", WSAGetLastError());return 0;}if(strncmp(rbuffer,"226 Transfer",strlen("226 Transfer"))==0){break;}fprintf(fpse,"%s",rbuffer);}printf("RBUFFER=%s",rbuffer);fclose(fpse);}sy_error=0;return 0;}int spwdfun(SOCKET newsocket){printf("Equivalent to pwd \n");//order[0]='\0';//strcat(order,"dir ");//strcat(order,path);//strcat(order,);system("cd >tmp.txt");FILE *fin;fin=fopen("tmp.txt","r+");sprintf(sbuffer, "125 Transfering... \r\n");bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);char temp_buffer[160];while (fgets(temp_buffer,80,fin)!=NULL){temp_buffer[strlen(temp_buffer)-1]='\0';printf("temp_buffer=%s",temp_buffer);///////////////////////////////目录判定if(path[0]!='\0')sprintf(sbuffer,"%s\\%s",temp_buffer,path);elsesprintf(sbuffer,"%s",temp_buffer);///////////////////////////////if (port_connect==0)//send(ns_data, sbuffer, strlen(sbuffer), 0);send(newsocket, sbuffer, strlen(sbuffer), 0);}fclose(fin);sprintf(sbuffer, "226 Transfer completed... \r\n");bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);system("del tmp.txt");//CLOSE the ns_data SOCKET or data port SOCKETif(port_connect==0){closesocket(ns_data);sprintf(sbuffer,"226 Close the data socket... \r\n");bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);ns_data = socket(AF_INET, SOCK_STREAM, 0);}sy_error=0;return 0;}int scdfun(SOCKET newsocket){int i=3,k=0;char name[20],name2[20];int j,count=0;//path overfollowint pathlen;printf("Equivalent to cd \n");while (1){//RECEIVEbytes = recv(newsocket, &rbuffer[i], 1, 0);printf("rbuffer[i]=%c\n",rbuffer[i]);printf("bytes=%d\n",bytes);if ((bytes < 0) || (bytes == 0))break;name[k]=rbuffer[i];name2[k]=rbuffer[i];if (rbuffer[i] == '\0'){name[k] = '\0';name2[k] = '\0';break;}if (rbuffer[i] != '\r'){i++;k++;}}//end whileif(path[0]!='\0')strcat(path,"\\");strcat(path,name);if(strncmp(name2,"..",2)==0){pathlen=strlen(path);for(j=pathlen-1;j>=0;j--){if(path[j]=='\\'){path[j]='\0';count++;}if(count==2){//path[j]='\0';break;}}printf("%d=\n",j);path[j+1]='\0';}printf("path=%s",path);sy_error=0;return 0;}int smdfun(SOCKET newsocket) {char name[20];int i=3,k=0;printf("Equivalent to md \n");while (1) // while loop 3{//RECEIVEbytes = recv(newsocket, &rbuffer[i], 1, 0);printf("rbuffer[i]=%c\n",rbuffer[i]);printf("bytes=%d\n",bytes);if ((bytes < 0) || (bytes == 0))break;name[k]=rbuffer[i];if (rbuffer[i] == '\0'){ /*end on LF*/name[k] = '\0';break;}if (rbuffer[i] != '\r'){i++;k++;/*ignore CR's*/}}order[0]='\0';strcat(order,"md ");strcat(order,path);if(strlen(path)>0)strcat(order,"\\");strcat(order,name);system(order);//CLOSE the ns_data SOCKET or data port SOCKETif(port_connect==0){//closesocket(ns_data);sprintf(sbuffer,"226 Close the data socket... \r\n");bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);//ns_data = socket(AF_INET, SOCK_STREAM, 0);}sy_error=0;return 0;}int sdelfun(SOCKET newsocket){int i=3,k=0;char name[20];printf("Equivalent to del \n");while (1){//RECEIVEbytes = recv(newsocket, &rbuffer[i], 1, 0);printf("rbuffer[i]=%c\n",rbuffer[i]);printf("bytes=%d\n",bytes);if ((bytes < 0) || (bytes == 0))break;name[k]=rbuffer[i];if (rbuffer[i] == '\0'){name[k] = '\0';break;}if (rbuffer[i] != '\r'){i++;k++;}}//end whileorder[0]='\0';strcat(order,"rd ");strcat(order,path);if(path[0]!='\0')strcat(path,"\\");strcat(order,name);system(order);sprintf(sbuffer,"del ok... \r\n");bytes = send(newsocket, sbuffer, strlen(sbuffer), 0);if (bytes == SOCKET_ERROR){HandleError("recv()");sy_error=1;return 1;}sy_error=0;return 0;}void HandleError(char *func){char info[65]= {0};_snprintf(info, 64, "%s: %d\n", func, WSAGetLastError());printf(info);}。
课程设计课程名称计算机网络课程设计题目名称文件传输协议的简单设计与实现学生学院专业班级___ _学号学生姓名______ _________指导教师______ _____2010 年 1 月 5 日设计摘要关键词:SOCKET编程,FTPclient/server程序摘要:本课程设计包含了文件传输协议的简单设计与实现。
文件传送是各种计算机网络实现的基本功能,文件传送协议是一种最基本的应用层协议按照客户/服务器的模式进行工作,提供交互式的访问,是INTERNET使用最广泛的协议之一。
文件传输协议的简单设计与实现建立在计算机网络实验环境TCP/IP 网络体系结构之上,使用socket 编程接口编写两个程序,分别为客户程序(client.c)和服务器程序(server.c),实现下述命令功能:get , put, pwd, dir, cd, ?, quit 等,利用了已有网络环境设计并实现简单应用层协议。
本设计包括了具体设计任务,基本思路及所涉及的相关理论,设计流程图,调试过程中出现的问题及相应解决办法,实验运行结果,核心程序,个人体会及建议等。
目录1、文件传输协议的简单设计与实现------------------------------181. 1 具体设计任务----------------------------------------------18 1.2 基本思路及所涉及的相关理论--------------------------------181.2.1基本思路-------------------------------------------------182.2.2 相关理论--------------------------------------------18 1.3设计流程图------------------------------------------------191.4实验运行情况----------------------------------------------191.5 核心程序--------------------------------------------------222.5.1 服务器(sever)程序---------------------------------222.5.2 客户(client)程序----------------------------------291.6心得体会-----------------------------------------------------------------------------37参考文献--------------------------------------------------------382、文件传输协议的简单设计与实现2. 1 具体设计任务计算机网络实验环境建立在TCP/IP 网络体系结构之上。
各计算机除了安装TCP/IP 软件外,还安装了TCP/IP 开发系统。
实验室各计算机具备Windows环境中套接字socket 的编程接口功能,可为用户提供全网范围的进程通信功能。
本实验要求利用这些功能,设计和实现一个简单的文件传送协议。
用socket 编程接口编写两个程序,分别为客户程序(client.c)和服务器程序(server.c),该程序应能实现下述命令功能:get:取远方的一个文件put:传给远方一个文件pwd:显示远主当前目录dir:列出远方当前目录cd :改变远方当前目录?:显示你提供的命令quit :退出返回2.2基本思路及所涉及的相关理论2.2.1基本思路设计程序使客户端连接的时候,服务器将会向客户端发回一条消息告知它的IP地址,然后关闭连接并继续接收端口的连接。
建立各个命令功能对应的函数,发送请求,等待服务器端的服务。
服务器端初始化WinSock,创建SOCKET,获取主机信息,并对客户端进行会话,发送回复讯息给客户端,响应完毕后关闭连接,释放WinSock。
2.2.2 相关理论文件传送是各种计算机网络都实现的基本功能,文件传送协议是一种最基本的应用层协议按照客户/服务器的模式进行工作,提供交互式的访问,是INTERNET使用最广泛的协议之一。
计算机网络实验环境建立在TCP/IP 网络体系结构之上。
各计算机除了安装TCP/IP 软件外,还安装了TCP/IP 开发系统。
实验室各计算机具备Windows 环境中套接字socket 的编程接口功能,可为用户提供全网范围的进程通信功能。
本设计利用这些功能,设计和实现一个简单的文件传送协议。
用socket 编程接口编写两个程序,分别为客户程序(client.c)和服务器程序(server.c)。
2.3 设计流程图2.4实验运行情况服务器端运行,默认自动启动监听,情况如下图:服务如果关闭监听,效果如下图:客服端运行,如下图:输入服务器端的IP和端口号进行连接,效果如图:下面设置文件保存位置,如图:下面演示上传一个视频文件,然后再下载下来,其中上传过程的进度信息:上传完成后的效果图:下载文件的进度提示信息:下载完成后,指定目录下就有了该文件了:2.5 核心程序2.5.1 服务器(server)程序如下using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading;using ;using .Sockets;using System.IO;using System.Windows.Forms;namespace TCP文件传输_服务器{class WorkThread{byte[] buffer;int bufferSize= 4096;Thread mythread;Socket handler;public WorkThread(Socket workSocket){handler = workSocket;buffer = new byte[bufferSize];mythread = new Thread(BeginCommunication);}public void Start(){mythread.Start();}public void Abort(){mythread.Abort();}private void BeginCommunication(){while (true)//从客户端接收数据,直到连接断开{try{int reCount = handler.Receive(buffer);string insStr =Encoding.BigEndianUnicode.GetString(buffer, 0, reCount);if (insStr.Substring(0, 4) == "name")//收到下文件请求{string fileName = insStr.Substring(5, insStr.Length - 5);SendFile(fileName, handler);}else if (insStr.Substring(0, 4) == "boot")//收到获取根目录请求 {string listStr = GetFileNames("F:", false);SendString(handler, listStr);}else if (insStr.Substring(0, 4) == "path")//收到获取指定目录内容请求{string path = insStr.Substring(5, insStr.Length - 5);string listStr = GetFileNames(path, false);SendString(handler, listStr);}else if (insStr.Substring(0, 4) == "Queu")//获取下载文件夹请求,回复完整文件名列表{string path = insStr.Substring(5, insStr.Length - 5);string listStr = GetFileNames(path, true);SendString(handler, listStr);}else if (insStr.Substring(0, 4) == "upld")//收到上传文件请求{string reFileName = insStr.Substring(5, insStr.Length - 5);LoadFile(reFileName, handler);}else if (insStr.Substring(0, 4) == "quit")//收到断开连接命令{HostQuit();break;}}catch { HostQuit();break; }}}private void LoadFile(string reFileName, Socket handler){try{FileStream fs = new FileStream(reFileName, FileMode.Create, FileAccess.Write);handler.Receive(buffer, 8, SocketFlags.None);//接收文件大小long filesize = BitConverter.ToInt64(buffer, 0);long receiveCount = 0;while (receiveCount < filesize)//接收文件{int readcount = handler.Receive(buffer, bufferSize, SocketFlags.None);fs.Write(buffer, 0, readcount);receiveCount += readcount;}fs.Close();}catch{HostQuit();}}private void SendFile(string fileNmae, Socket handler){try{FileStream fs = new FileStream(fileNmae, FileMode.Open, FileAccess.Read);long size = fs.Length;byte[] bysize = BitConverter.GetBytes(size);handler.Send(bysize, 8, SocketFlags.None);//发送文件大小BinaryReader br = new BinaryReader(fs);int sendcount = 0;while (sendcount < size)//发送文件{int readcount = br.Read(buffer, 0, bufferSize);sendcount += readcount;handler.Send(buffer, readcount, SocketFlags.None); }}catch{HostQuit();}}private void HostQuit(){GlobalValues.canControl.WaitOne();GlobalValues.canControl.Release();if (handler.Connected == true){handler.Shutdown(SocketShutdown.Both);handler.Close();}}private void SendString(Socket handler,string listStr){byte[] list = Encoding.BigEndianUnicode.GetBytes(listStr);byte[] listcountbuffer =BitConverter.GetBytes(Convert.ToInt64(list.Length));try{handler.Send(listcountbuffer, 8, SocketFlags.None);//发送列表大小int sendcount = 0;while (sendcount < list.Length)//发送列表{if (sendcount + bufferSize < list.Length)//不是最后一次{int i = handler.Send(list, sendcount, bufferSize, SocketFlags.None);sendcount += i;}else{int i= handler.Send(list, sendcount, list.Length- sendcount, SocketFlags.None);//发送最后一次sendcount += i;}}}catch (Exception e){MessageBox.Show("连接断开.");}}//fileOnly=true则获取指定目录及子目录内所有文件信息,fileOnly=false则获取指定目录文件信息及文件夹信息private string GetFileNames(string path, bool fileOnly){string listStr = string.Empty;DirectoryInfo drct = new DirectoryInfo(path);foreach (FileSystemInfo fsi in drct.GetFileSystemInfos()){if (fsi is FileInfo){//文件FileInfo fi = (FileInfo)fsi;listStr += fi.FullName;listStr += "\n";if (fi.Length < 1024){string sizeStr = fi.Length.ToString() + "字节";listStr += sizeStr;}else if (fi.Length < 1024 * 1024){double temp = Convert.ToDouble(fi.Length) / 1024;string sizeStr = string.Format("{0:F1}", temp) + "KB";listStr += sizeStr;}else if (fi.Length < 1024 * 1024 * 1024){double temp = Convert.ToDouble(fi.Length) / 1024 / 1024;string sizeStr = string.Format("{0:F1}", temp) + "MB";listStr += sizeStr;}else{double temp= Convert.ToDouble(fi.Length) / 1024 / 1024 / 1024;string sizeStr = string.Format("{0:F1}", temp) + "GB";listStr += sizeStr;}listStr += "\n";listStr += stWriteTime.ToString("yyyy-MM-dd hh:mm:ss");listStr += "\n";}else if (fsi is DirectoryInfo){if (fileOnly){listStr += GetFileNames(fsi.FullName, true);}else{//文件夹DirectoryInfo di = (DirectoryInfo)fsi;listStr += di.FullName;listStr += "\n";listStr += "dir";listStr += "\n";listStr+= stWriteTime.ToString("yyyy-MM-dd hh:mm:ss");listStr += "\n";}}}return listStr;}}}public服务器(){InitializeComponent();Control.CheckForIllegalCrossThreadCalls = false;string HostName = Dns.GetHostName(); //得到主机名IPHostEntry IpEntry = Dns.GetHostEntry(HostName); //得到主机IPstring strIPAddr = IpEntry.AddressList[0].ToString();tsTxb_IPAdd.Text = strIPAddr;hostIPAddress = IPAddress.Parse(strIPAddr);Server = new IPEndPoint(hostIPAddress,Convert.ToInt32(tsTxb_Port.Text));sock = new Socket(AddressFamily.InterNetwork,SocketType.Stream, ProtocolType.Tcp);sock.Bind(Server);sock.Listen(10);string str = "正在监听端口 " + tsTxb_Port.Text + "...";tsLbl_Status.Text = "状态:" + str;AcceptTh = new Thread(ThAccept);AcceptTh.Start();//开始监听端口}//下面是监听和停止监听的按钮事件private void btn_Start_Click(object sender, EventArgs e){tsBtn_Start.Enabled = false;tsBtn_Stop.Enabled = true;Server= new IPEndPoint(hostIPAddress, Convert.ToInt32(tsTxb_Port.Text));sock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);sock.Bind(Server);sock.Listen(10);string str = "正在监听端口 " + tsTxb_Port.Text + "...";tsLbl_Status.Text = "状态:" + str;AcceptTh = new Thread(ThAccept);AcceptTh.Start();}private void btn_stop_Click(object sender, EventArgs e){tsBtn_Start.Enabled = true;tsBtn_Stop.Enabled = false;try{sock.Shutdown(SocketShutdown.Both);}catch { }sock.Close();tsLbl_Status.Text = "状态:已停止监听";}2.5.2 客户(client)程序//MyThread.cs中的实现using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.IO;using .Sockets;using System.Threading;using System.Windows.Forms;namespace客户端_TCP文件传输{public class myThread{Thread downloadTh;Thread uploadTh;Socket wordSocket;string fileName;string savePath;byte[] buffer;const int bufferSize = 4096;ToolStripProgressBar tspBar;ToolStripStatusLabel speed;int startTime=0;long receivecount = 0;long sendCount = 0;int upOrDown = 1;//指示上传或下载System.Windows.Forms.Timer timer1 = new System.Windows.Forms.Timer();public myThread(Socket workSock, string FileName,string SavePath, ref ToolStripProgressBar TspBar, ref ToolStripStatusLabel Speed){wordSocket = workSock;fileName = FileName;savePath = SavePath;buffer = new byte[bufferSize];downloadTh = new Thread(new ThreadStart(Download));uploadTh = new Thread(new ThreadStart(Upload));tspBar = TspBar;speed = Speed;}public myThread(Socket workSock, string FileName,ref ToolStripProgressBar TspBar, ref ToolStripStatusLabel Speed){wordSocket = workSock;fileName = FileName;buffer = new byte[bufferSize];downloadTh = new Thread(new ThreadStart(Download));uploadTh = new Thread(new ThreadStart(Upload));tspBar = TspBar;speed = Speed;}public void StartDownload(){upOrDown = 1;downloadTh.Start();timer1.Enabled = true;timer1.Interval = 100;timer1.Tick += new EventHandler(timer1_Tick);startTime = System.Environment.TickCount;timer1.Start();}public void StartUpload(){upOrDown = 0;uploadTh.Start();timer1.Enabled = true;timer1.Interval = 50;timer1.Tick += new EventHandler(timer1_Tick);startTime = System.Environment.TickCount;timer1.Start();}void timer1_Tick(object sender, EventArgs e){int spentTime = System.Environment.TickCount - startTime;if (spentTime != 0){if (upOrDown == 1){double sp = Convert.ToDouble(receivecount) /Convert.ToDouble(spentTime) * 1000 / 1024;if (sp < 1024)speed.Text = tspBar.Value.ToString() + "% 下载速度:" + string.Format("{0:F1}", sp) + "KB";else speed.Text = tspBar.Value.ToString() + "% 下载速度:" + string.Format("{0:F1}", sp / 1024) + "MB/S";}else{double sp = Convert.ToDouble(sendCount) /Convert.ToDouble(spentTime) * 1000 / 1024;if (sp < 1024)speed.Text = tspBar.Value.ToString() + "% 上传速度:" + string.Format("{0:F1}", sp) + "KB";else speed.Text = tspBar.Value.ToString() + "% 上传速度:" + string.Format("{0:F1}", sp / 1024) + "MB/S";}}}private void Download(){try{string ins = "name=" + fileName;byte[] data = Encoding.BigEndianUnicode.GetBytes(ins);wordSocket.Send(data, data.Length, SocketFlags.None);//发送下载请求string reFileName = savePath + "\\" + GetFileName(fileName);Directory.CreateDirectory(savePath);FileStream fs = new FileStream(reFileName, FileMode.Create, FileAccess.Write);wordSocket.Receive(buffer, 8, SocketFlags.None);//接收文件大小long filesize = BitConverter.ToInt64(buffer, 0);while (receivecount < filesize)//接收文件{int readcount = wordSocket.Receive(buffer, bufferSize, SocketFlags.None);fs.Write(buffer, 0, readcount);receivecount += readcount;tspBar.Value = Convert.ToInt32(Convert.ToDouble(receivecount) / Convert.ToDouble(filesize) * 100);}tspBar.Value = 100;timer1_Tick(new object(), new EventArgs());fs.Close();timer1.Stop();StaticValue.isBusy = false;}catch{MessageBox.Show("连接断开.");timer1.Stop();if (wordSocket.Connected == true){wordSocket.Shutdown(SocketShutdown.Both);wordSocket.Close();timer1.Stop();StaticValue.isBusy = false;}}}private void Upload(){try{string shortFileName= fileName.Substring(stIndexOf('\\') + 1, fileName.Length - stIndexOf('\\') - 1);string serverFileName = StaticValue.curServerPath + "\\" + shortFileName;//指定上传到服务器的哪个路径string ins = "upld=" + serverFileName;byte[] byins = Encoding.BigEndianUnicode.GetBytes(ins);wordSocket.Send(byins, byins.Length, SocketFlags.None);//发送上传请求及完整文件名FileStream fs = new FileStream(fileName, FileMode.Open, FileAccess.Read);long size = fs.Length;byte[] bysize = BitConverter.GetBytes(size);wordSocket.Send(bysize, 8, SocketFlags.None);//发送上传文件大小BinaryReader br = new BinaryReader(fs);while (sendCount < size)//发送文件{int readcount = br.Read(buffer, 0, bufferSize);sendCount += readcount;wordSocket.Send(buffer, readcount, SocketFlags.None);tspBar.Value = Convert.ToInt32(Convert.ToDouble(sendCount) / Convert.ToDouble(size) * 100);}tspBar.Value = 100;timer1_Tick(new object(), new EventArgs());fs.Close();timer1.Stop();StaticValue.isBusy = false;}catch (Exception e){MessageBox.Show("连接断开.");wordSocket.Shutdown(SocketShutdown.Both);wordSocket.Close();timer1.Stop();StaticValue.isBusy = false;}}public string GetFileName(string fileName){return fileName.Substring(stIndexOf('\\')+1, fileName.Length - stIndexOf('\\')-1);}public string GetFileType(string fileName){return fileName.Substring(stIndexOf('.'), fileName.Length - stIndexOf('.'));}}}//下面给出各按钮点击事件///<summary>///连接服务器按钮点击事件///</summary>///<param name="sender"></param>///<param name="e"></param>private void btn_Connect_Click(object sender, EventArgs e){hostIPAddress = IPAddress.Parse(ttxb_IPAdd.Text);int port =Convert.ToInt32( ttxb_port.Text);Server = new IPEndPoint(hostIPAddress, port);sock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);try{sock.Connect(Server);//连接服务器toolStripStatusLabel1.Text = "与远程主机" + ttxb_IPAdd.Text + " " + ttxb_port.ToString() + "连接成功";RefreshListView(GetDtListArray("boot", false));//获取服务器根目录connectDone = true;tsBtn_Connect.Enabled = false;tsBtn_DisConnect.Enabled = true;}catch{MessageBox.Show("连接失败.");if (sock.Connected == true){sock.Shutdown(SocketShutdown.Both);sock.Close();}}}///<summary>///下载文件点击事件///</summary>///<param name="sender"></param>///<param name="e"></param>private void btn_GetFile_Click(object sender, EventArgs e){DownLoad(listView1);//调用自定义方法下载文件}private void DownLoad(ListView listView1){if(listView1.SelectedIndices.Count> 0 && listView1.SelectedIndices[0] !=0)//有选定项且选定的不是"返回上层"{string size=listView1.SelectedItems[0].SubItems[1].Text;if ( size!= "")//如果选定的是文件{listView2.Items.Add(listView1.SelectedItems[0].SubItems[0].Text);listView2.Items[listView2.Items.Count-1].SubItems.Add(size);//将文件大小加入listViewlistView2.Items[listView2.Items.Count-1].ImageIndex =ICOSearcher.GetIcoIndex(listView1.SelectedItems[0].SubItems[0].Text);//获取该文件的图标int index = listView1.SelectedIndices[0] - 1;string FileName = fullNameList[index];downloadItem newfile = new downloadItem(FileName,StaticValue.curSavePath);downQueue.Enqueue(newfile);}else//如果是文件夹{string downPath=StaticValue.curServerPath +"\\"+listView1.SelectedItems[0].SubItems[0].Text;string[] listArray = GetDtListArray(downPath, true);Queue<downloadItem> tempQueue = GetDownFileQueue(listArray);while(tempQueue.Count>0){downQueue.Enqueue(tempQueue.Dequeue());}}}}///<summary>///设置保存位置的按钮点击事件///</summary>///<param name="sender"></param>///<param name="e"></param>private void tsBtn_savePath_Click(object sender, EventArgs e) { if (folderBrowserDialog1.ShowDialog() == DialogResult.OK){StaticValue.curSavePath = folderBrowserDialog1.SelectedPath;}}///<summary>///点击断开连接的按钮事件,断开连接,并清空listView等///</summary>///<param name="sender"></param>///<param name="e"></param>private void tsBtn_DisConnect_Click(object sender, EventArgs e)//{try{string ins = "quit";byte[] byins = Encoding.BigEndianUnicode.GetBytes(ins);sock.Send(byins, byins.Length, SocketFlags.None);sock.Shutdown(SocketShutdown.Both);sock.Close();tsBtn_Connect.Enabled = true;tsBtn_DisConnect.Enabled = false;DirLayer = 0;}catch { }toolStripStatusLabel1.Text = "连接已断开";connectDone = false;listView1.Items.Clear();fullNameList.Clear();}///<summary>///双击列表项的事件,返回上一级或者进入到下一级目录///</summary>///<param name="sender"></param>///<param name="e"></param>private void listView1_MouseDoubleClick(object sender, MouseEventArgs e) {if (connectDone&&!StaticValue.isBusy)//如果已连接服务器{if (listView1.SelectedIndices[0] == 0){if (DirLayer > 0){StaticValue.curServerPath = StaticValue.curServerPath.Substring(0,StaticValue.stIndexOf("\\"));//获取父目录DirLayer--;RefreshListView(GetDtListArray(StaticValue.curServerPath, false));}}else{string s =listView1.SelectedItems[0].SubItems[1].Text;if (s == ""){StaticValue.curServerPath =StaticValue.curServerPath + "\\" + listView1.SelectedItems[0].SubItems[0].Text;//获取子目录DirLayer++;RefreshListView(GetDtListArray(StaticValue.curServerPath, false));}else DownLoad(listView1);}}}///<summary>///上传文件的点击事件///</summary>///<param name="sender"></param>///<param name="e"></param>private void tsBtn_Upload_Click(object sender, EventArgs e){openFileDialog1.ShowDialog();string fileName = openFileDialog1.FileName;myThread workThread = new myThread(sock, fileName, ref toolStripProgressBar1, ref toolStripStatusLabel2);workThread.StartUpload();}2.6心得体会通过本次实验,我对网络命令有了一定的概念性认识,并熟悉了基本网络命令的使用,通过miniFTP Client/Server实验的实践,了解了SOCKET编程相关的一些知识以及用法,了解了客户端和服务器端进行通信的相关算法机制,在建立通信的基础上,实现了一些简单的功能。