Linux下基于socket的文件传输程序设计
- 格式:doc
- 大小:533.85 KB
- 文档页数:29
socket传输文件的原理
文件传输是计算机网络中的一项基本功能,它允许在网络上的不同计算机之间共享和传输文件。
Socket是实现文件传输的一种常用方式,其原理如下:
1. 建立连接:在进行文件传输之前,需要在发送方和接收方之间建立连接。
这通常通过TCP/IP 协议实现,使用Socket进行连接的建立。
一旦连接建立成功,发送方和接收方就可以通过该连接进行数据传输。
2. 文件分割:由于文件通常较大,不适合一次性传输,因此需要将文件分割成较小的数据块。
这些数据块可以按照一定的顺序进行编号,以便于接收方重新组合成完整的文件。
3. 发送数据:发送方通过Socket将分割好的数据块逐个发送给接收方。
在发送数据时,需要按照一定的协议进行数据的封装,例如添加文件名、数据块大小等信息。
4. 接收数据:接收方通过Socket接收到数据后,需要按照发送方的协议对数据进行解析和处理。
接收方会将收到的数据块进行缓存,以便后续重新组合成完整的文件。
5. 确认机制:为了确保文件传输的完整性和正确性,发送方和接收方之间需要建立一种确认机制。
例如,发送方可以发送一个数据包的编号给接收方,接收方在收到数据包后回复一个确认信号给发送方,表示该数据包已经成功接收。
如果发送方在一定时间内没有收到确认信号,则会重新发送数据包,以确保数据的可靠传输。
6. 关闭连接:当文件传输完成后,发送方和接收方之间的连接会被关闭。
这可以通过Socket 的关闭函数实现,释放网络资源。
通过以上步骤,使用Socket可以实现文件的传输。
在实际应用中,不同的文件传输协议可能会有一些差异,但基本原理是相同的。
C语⾔基于socket的⽂件传输(可循环发送多个⽂件)基本简介:本次⽂件传输的实现主要是通过客户端向服务器发送下载请求,然后在服务器中找到对应的⽂件并打开⽂件,再继续向客户端传送⽂件,⽽客户端就在不停的接收。
这是因为⽂件可能⽐较⼤,⼀个缓冲数组只能保存⼀部分⽂件内容,因此服务器得不断从⽂件中读取内容并发给客户端,⽽客户端得不停的循环接收。
但是在事先,得将相应要发送的⽂件(照⽚,⾳频,视频等)保存在服务器相应的⽬录下。
⽽这个是不符合实际要求的,通常来讲,是应该将客户端1的⽂件发送给客户端2,⽽服务器仅仅只是起到⼀个中转站的作⽤,即⽂件应该事先保存在客户端1下。
这⾥我们只是完成⽂件传输的相应功能就⾏了,就不在计较这些啦。
因为只要你理解了这⼀块,可以根据⾃⼰的实际需要,在进⾏修改。
具体编译:gcc server.c -o server -lpthread //这是因为在服务器中加⼊了线程函数,所以编译的时候需要加上 -lpthread 。
gcc client.c -o client记住⼀定要先运⾏服务器,在运⾏客户端。
在客户端运⾏的时候回提醒你输⼊服务器对应的pc ip,如实输⼊就⾏啦。
如果是在本机pc上进⾏测试的话,也可以输⼊0.0.0.0 。
server.c:#include <stdio.h>#include <netdb.h>#include <sys/socket.h>#include <arpa/inet.h>#include <sys/types.h>#include <string.h>#include <stdlib.h>#include <unistd.h>#include <fcntl.h>#include <netinet/in.h>#include <pthread.h>#define portnum 12345#define FILE_SIZE 500#define BUFFER_SIZE 1024void *net_thread(void * fd);int main(){//初始化套接字int server_fd=socket(AF_INET,SOCK_STREAM,0);if(-1==server_fd){perror("socket");exit(1);}//绑定端⼝和ip;struct sockaddr_in server_addr; //struct sockaddr_in为结构体类型,server_addr为定义的结构体server_addr.sin_family=AF_INET; //Internet地址族=AF_INET(IPv4协议)server_addr.sin_port=htons(portnum); //将主机字节序转化为⽹络字节序 ,portnum是端⼝号(server_addr.sin_addr).s_addr=htonl(INADDR_ANY);//IP地址if(-1==bind(server_fd,(struct sockaddr *)&server_addr,sizeof(server_addr))) //套接字与端⼝绑定{perror("bind");exit(6);}//开启监听if(-1==listen(server_fd,5)) //5是最⼤连接数,指服务器最多连接5个⽤户if(-1==listen(server_fd,5)) //5是最⼤连接数,指服务器最多连接5个⽤户{perror("listen");exit(7);}while(1){struct sockaddr_in client_addr;int size=sizeof(client_addr);int new_fd=accept(server_fd,(struct sockaddr *)&client_addr,&size); //server_fd服务器的socket描述字,&client_addr指向struct sockaddr *的指针,&size指向协议地址if(-1==new_fd){perror("accept");continue; //进⾏下⼀次循环}printf("accept client ip:%s:%d\n",inet_ntoa(client_addr.sin_addr),client_addr.sin_port);//inet_ntoa将⼀个⼗进制⽹络字节序转换为点分⼗进制IP格式的字符串。
Linux的SOCKET编程详解1. 网络中进程之间如何通信进程通信的概念最初来源于单机系统。
由于每个进程都在自己的地址范围内运行,为保证两个相互通信的进程之间既互不干扰又协调一致工作,操作系统为进程通信提供了相应设施,如UNIX BSD有:管道(pipe)、命名管道(named pipe)软中断信号(signal)UNIX system V有:消息(message)、共享存储区(shared memory)和信号量(semaphore)等.他们都仅限于用在本机进程之间通信。
网间进程通信要解决的是不同主机进程间的相互通信问题(可把同机进程通信看作是其中的特例)。
为此,首先要解决的是网间进程标识问题。
同一主机上,不同进程可用进程号(process ID)唯一标识。
但在网络环境下,各主机独立分配的进程号不能唯一标识该进程。
例如,主机A赋于某进程号5,在B机中也可以存在5号进程,因此,“5号进程”这句话就没有意义了。
其次,操作系统支持的网络协议众多,不同协议的工作方式不同,地址格式也不同。
因此,网间进程通信还要解决多重协议的识别问题。
其实TCP/IP协议族已经帮我们解决了这个问题,网络层的―ip地址‖可以唯一标识网络中的主机,而传输层的―协议+端口‖可以唯一标识主机中的应用程序(进程)。
这样利用三元组(ip地址,协议,端口)就可以标识网络的进程了,网络中的进程通信就可以利用这个标志与其它进程进行交互。
使用TCP/IP协议的应用程序通常采用应用编程接口:UNIX BSD的套接字(socket)和UNIX System V的TLI(已经被淘汰),来实现网络进程之间的通信。
就目前而言,几乎所有的应用程序都是采用socket,而现在又是网络时代,网络中进程通信是无处不在,这就是我为什么说―一切皆s ocket‖。
TCP/IP(Transmission Control Protocol/Internet Protocol)即传输控制协议/网间协议,是一个工业标准的协议集,它是为广域网(WANs)设计的。
利用socket进行数据通信与传输的步骤Socket是计算机之间进行数据传输和通信的标准接口。
利用Socket可以方便地进行网络编程,实现不同设备之间的数据交换和传输。
下面将介绍Socket进行数据通信和传输的步骤,以及一些注意事项。
1. 创建Socket连接首先,需要在客户端和服务器端分别创建Socket连接。
在客户端,可以使用socket.connect()方法;在服务器端,可以使用socket.bind()方法。
这些方法都需要指定IP地址和端口号,以确保连接成功。
2. 发送数据一旦连接成功,就可以开始发送数据。
在Python中,可以使用socket.send()方法发送数据。
这个方法需要传入一个字符串参数,表示要发送的数据。
如果要发送二进制数据,则需要使用socket.sendall()方法。
这个方法需要传入一个字节串参数。
3. 接收数据一旦数据发送成功,服务器端就可以接收到这些数据。
在Python 中,可以使用socket.recv()方法接收数据。
这个方法需要传入一个整数参数,表示要接收的数据大小。
如果数据不足这个大小,则该方法会阻塞,等待更多数据到达。
4. 处理数据一旦接收到数据,就需要对这些数据进行处理。
这通常包括解析数据、验证数据、存储数据等操作,以确保数据的正确性和完整性。
5. 关闭连接最后,需要在客户端和服务器端分别关闭Socket连接。
在Python 中,可以使用socket.close()方法关闭连接。
这个方法不需要传入任何参数,只需要调用即可。
在进行Socket编程时,还需要注意一些事项。
比如,需要指定协议类型(如TCP或UDP)、设置超时时间、处理异常等。
此外,还需要考虑数据安全性和加密性等问题,以确保数据在传输过程中不会被恶意攻击者窃取或篡改。
总之,Socket编程是实现计算机间数据通信和传输的重要方法,可以应用于各种场景,如互联网、物联网、机器人等领域。
在使用Socket时,需要严格遵循以上步骤和注意事项,以确保数据的正确传输和保密性。
Linux终端命令的进程通信和数据传输Linux终端命令是开发人员和系统管理员在Linux操作系统上进行各种操作的基础工具。
在Linux中,进程通信和数据传输是关键的功能之一,它允许不同的进程之间相互交换信息和共享资源。
本文将介绍Linux终端命令中的进程通信和数据传输的几种方法。
一、管道(pipe)管道是Linux终端命令中最简单和最常用的进程通信方式之一。
它实际上是一个特殊的文件,用于将一个命令的输出连接到另一个命令的输入。
管道使用竖线符号(|)来表示,例如:```command1 | command2```这将把command1的输出作为command2的输入。
通过管道,可以在不创建临时文件的情况下将多个命令串联起来,实现数据的流动和传输。
二、命名管道(named pipes)命名管道是一种特殊的文件类型,用于在不相关的进程之间进行通信。
与简单管道不同,命名管道可以通过文件系统中的路径进行引用,允许任意数量的进程进行读写操作。
命名管道使用mkfifo命令进行创建,例如:```mkfifo mypipe```创建后,可以通过文件读写的方式进行进程间通信,示例:```echo "Message" > mypipecat mypipe```第一条命令将一条消息写入命名管道,第二条命令将读取并显示该消息。
三、信号(signal)信号是一种Linux终端命令中用于进程间通信的异步通知机制。
当一个进程需要通知另一个进程发生了某个事件时,可以发送一个信号。
接收信号的进程可以根据信号的类型和处理方式来做出相应的响应。
常见的信号包括中断信号(SIGINT)和终止信号(SIGTERM)。
通过kill命令可以向指定进程发送信号,例如:```kill -SIGINT PID```这将中断具有PID标识符的进程。
四、共享内存(shared memory)共享内存是一种高效的进程间通信机制,允许不同的进程访问同一块物理内存。
Linux中的Socket是一种用于网络通信的编程接口,它允许进程通过网络进行数据传输。
Socket在Linux内核中的实现涉及到多个组件和原理。
1. 网络协议栈:Linux内核中的网络协议栈负责处理网络通信的各个层次,包括物理层、数据链路层、网络层和传输层。
Socket通过网络协议栈与网络进行交互。
2. 套接字数据结构:在Linux内核中,套接字(Socket)被实现为一种数据结构,用于表示网络连接。
套接字数据结构包含了连接的相关信息,如IP地址、端口号等。
3. 文件描述符:在Linux中,套接字被视为一种文件,因此每个套接字都有一个对应的文件描述符。
通过文件描述符,进程可以对套接字进行读写操作。
4. 网络设备驱动程序:Linux内核中的网络设备驱动程序负责处理网络设备的底层操作,如发送和接收数据包。
套接字通过网络设备驱动程序与网络设备进行通信。
5. 网络协议处理:当进程通过套接字发送或接收数据时,Linux内核会根据套接字的协议类型(如TCP或UDP)进行相应的协议处理。
这包括建立连接、数据分片、错误检测等操作。
6. 系统调用:在用户空间中,进程通过系统调用(如socket、bind、connect等)来创建和操作套接字。
系统调用会触发内核中相应的函数,完成套接字的创建和操作。
总的来说,Linux内核中的Socket实现涉及到网络协议栈、套接字数据结构、文件描述符、网络设备驱动程序、网络协议处理和系统调用等多个组件和原理。
这些组件和原理共同工作,使得进程能够通过套接字进行网络通信。
{"code":0,"msg":"请求出现异常","data":{}}。
福建电脑2012年第12期基于Linux的Socket网络编程及性能优化马丽洁(内蒙古电子信息职业技术学院内蒙古呼和浩特010070)【摘要】:本文主要从Socket的建立、配置、连接、数据传输和结束通信五个方面阐述了基于Linux的Socket网络编程的方法和步骤,最后又从最小化报文传输延迟、最小化系统调用负载、为Bandwidth Delay Product调节tcp窗口、动态优化GNU/linux TCP/IP协议栈四个方面进行性能优化,以使应用程序高效、稳定。
【关键词】:Linux,Socket,网络编程,性能优化Socket的英文原义是“孔”或“插座”,通常也称作"套接字",用于描述IP地址和端口,是一个通信链的句柄。
在Internet上的主机一般运行了多个服务软件,同时提供几种服务。
每种服务都打开一个Socket,并绑定到一个端口上,不同的端口对应于不同的服务。
Socket正如其英文原意那样,象一个多孔插座。
一台主机犹如布满各种插座的房间,每个插座有一个编号,有的插座提供220伏交流电,有的提供110伏交流电,有的则提供有线电视节目。
客户软件将插头插到不同编号的插座,就可以得到不同的服务。
socket也是一种文件描述符。
1.Socket编程1.1Socket的建立为了建立Socket,程式能够调用Socket函数,该函数返回一个类似于文档描述符的句柄。
Socket描述符是个指向内部数据结构的指针,他指向描述符表入口。
调用Socket函数时,socket执行体将建立一个Socket,实际上"建立一个Socket"意味着为一个Socket数据结构分配存储空间。
Socket执行体为您管理描述符表。
两个网络程式之间的一个网络连接包括五种信息:通信协议、本地协议地址、本地主机端口、远端主机地址和远端协议端口。
Socket数据结构中包含这五种信息。
1.2Socket的配置通过socket调用返回一个socket描述符后,在使用socket进行网络传输以前,必须配置该socket。
安全文件传输系统的设计与实现院系:计算机与通信工程学院班级:嵌入式软件10-01姓名:学号:*****指导老师:陈晓雷老师1.安全文件传输系统的软件设计框架安全文件传输系统由硬件和软件两部分组成。
硬件部分可以是普通的安装Linux操作系统的PC机,也可以是嵌入式系统。
本系统的硬件实现平台是S3C2440嵌入式开发板。
现代网络通信中,大部分网络协议的实现都由客户端(Client)和服务器端(Server)来协作完成。
这种模型本质上涉及两个不同的程序,通常这两个程序在不同机器上运行,这些机器之间都有网络连接。
服务器端程序提供服务并对来自客户程序的请求作成响应。
而客户端程序则是在使用者和服务器端程序之间建立某种沟通的渠道,或者是作为使用服务器端提供的某种网络服务的工具。
本文传输过程也是通过客户端和服务器端来实现,软件实现的总体框图如图:系统使用C和C++程序编写,支持将每个文件的元数据进行存储;支持从服务器中获取文件的元数据;服务器是多线程的,能够允许多个客户端同时连接;并且记录文件操作事件日志,能够支持用户名和密码的验证;客户端是QT应用程序,具有上传和下载两种能力,并且为了确保上传和下载是否成功,先检查碰盘空间。
系统的数据流如图:服务器端是数据流向的交汇点,也是系统数据存储的资源池。
各个客户端发起连接请求,服务端利用进程并发技术,相应多个客户端的请求。
因此服务端主要完成两个任务,检查客户端是否成功登录,以及判断客户端发来的信号,对该信号进行相应。
客户端是每个应用终端的实现方式也是外在表现,它主要包括:登录交互平台、检查信息是否完整喝客户端主窗口的配置。
用户根据自己的需要在成功登录系统以后,可以向服务器发出命令。
可以发出的命令包括:服务器List显示、服务器端List刷新、上传文件、下载文件、客户端List显示。
系统的内部设计是通过socket套接字建立连接,socket在所有的网络操作系统和网络应用程序中都是必不可少的,它是网络通信中应用进程和网络协议之间的接口。
LinuxCC++TCPSocket传输⽂件或图⽚实例环境:Linux语⾔:C/C++通信⽅式:TCP 下⾯⽤TCP协议编写⼀个简单的服务器、客户端,其中服务器端⼀直监听本机的6666号端⼝。
如果收到连接请求,将接收请求并接收客户端发来的消息;客户端与服务器端建⽴连接。
连接建⽴成功后,读取⽂件内容(/root/workspace/socket-picture/bizhi.jpg),发送给服务器端,服务器端新建new1.jpg⽂件,将接收到的⽂件内容保存到new1.jpg中,new1.jpg在当前⽬录下;Server.cpp1 #include<stdio.h>2 #include<stdlib.h>3 #include<string.h>4 #include<errno.h>5 #include<sys/types.h>6 #include<sys/socket.h>7 #include<netinet/in.h>8 #include<unistd.h>910#define MAXLINE 40961112int main(int argc, char** argv){13int listenfd, connfd;14struct sockaddr_in servaddr;15char buff[4096];16 FILE *fp;17int n;1819if( (listenfd = socket(AF_INET, SOCK_STREAM, 0)) == -1 ){20 printf("create socket error: %s(errno: %d)\n",strerror(errno),errno);21return0;22 }23 printf("----init socket----\n");2425 memset(&servaddr, 0, sizeof(servaddr));26 servaddr.sin_family = AF_INET;27 servaddr.sin_addr.s_addr = htonl(INADDR_ANY);28 servaddr.sin_port = htons(6666);29//设置端⼝可重⽤30int contain;31 setsockopt(listenfd,SOL_SOCKET, SO_REUSEADDR, &contain, sizeof(int));3233if( bind(listenfd, (struct sockaddr*)&servaddr, sizeof(servaddr)) == -1){34 printf("bind socket error: %s(errno: %d)\n",strerror(errno),errno);35return0;36 }37 printf("----bind sucess----\n");3839if( listen(listenfd, 10) == -1){40 printf("listen socket error: %s(errno: %d)\n",strerror(errno),errno);41return0;42 }43if((fp = fopen("new1.jpg","ab") ) == NULL )44 {45 printf("File.\n");46 close(listenfd);47 exit(1);48 }4950 printf("======waiting for client's request======\n");51while(1){52struct sockaddr_in client_addr;53 socklen_t size=sizeof(client_addr);54if( (connfd = accept(listenfd, (struct sockaddr*)&client_addr, &size)) == -1){55 printf("accept socket error: %s(errno: %d)",strerror(errno),errno);56continue;57 }58while(1){59 n = read(connfd, buff, MAXLINE);60if(n == 0)61break;62 fwrite(buff, 1, n, fp);63 }64 buff[n] = '\0';65 printf("recv msg from client: %s\n", buff);66 close(connfd);67 fclose(fp);68 }69 close(listenfd);70return0;71 }Client.cpp1 #include <stdio.h>2 #include <errno.h>3 #include <string.h>4 #include <netdb.h>5 #include <sys/types.h>6 #include <netinet/in.h>7 #include <sys/socket.h>8 #include <stdlib.h>9 #include <unistd.h>10 #include <arpa/inet.h>11 #include <netdb.h>12#define MAXLINE 40961314int main(int argc, char** argv){15int sockfd, len;16char buffer[MAXLINE];17struct sockaddr_in servaddr;18 FILE *fq;1920if( argc != 2){21 printf("usage: ./client <ipaddress>\n");22return0;23 }2425if( (sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0){26 printf("create socket error: %s(errno: %d)\n", strerror(errno),errno);27return0;28 }2930 memset(&servaddr, 0, sizeof(servaddr));31 servaddr.sin_family = AF_INET;32 servaddr.sin_port = htons(6666);33if( inet_pton(AF_INET, argv[1], &servaddr.sin_addr) <= 0){34 printf("inet_pton error for %s\n",argv[1]);35return0;36 }3738if( connect(sockfd, (struct sockaddr*)&servaddr, sizeof(servaddr)) < 0){ 39 printf("connect error: %s(errno: %d)\n",strerror(errno),errno);40return0;41 }42if( ( fq = fopen("/root/workspace/socket-picture/bizhi.jpg","rb") ) == NULL ){43 printf("File open.\n");44 close(sockfd);45 exit(1);46 }4748 bzero(buffer,sizeof(buffer));49while(!feof(fq)){50 len = fread(buffer, 1, sizeof(buffer), fq);51if(len != write(sockfd, buffer, len)){52 printf("write.\n");53break;54 }55 }56 close(sockfd);57 fclose(fq);5859return0;60 }makefile1 all:server client2 server:server.o3 g++ -g -o server server.o4 client:client.o5 g++ -g -o client client.o6 server.o:server.cpp7 g++ -g -c server.cpp8 client.o:client.cpp9 g++ -g -c client.cpp10 clean:all11 rm all 执⾏make命令后,⽣成server和client两个可执⾏⽂件。
课程设计报告课程设计题目:Linux下基于socket的文件传输程序设计学院:专业班级:年级:姓名:学号:完成时间:年月日成绩:指导教师:课程设计指导教师评定成绩表指导教师评定成绩:指导教师签名:年月日课程设计指导教师评定成绩表指导教师评定成绩:指导教师签名:年月日摘要线程(thread)技术早在60年代就被提出,但真正应用线程到操作系统中去,是在80年代中期。
为什么有了进程的概念后,还要再引入线程呢?使用多线程到底有哪些好处?使用多线程的理由之一是和进程相比,它是一种非常"节俭"的多任务操作方式。
在Linux系统下,启动一个新的进程必须分配独立的地址空间,建立众多的数据表来维护它的代码段、堆栈段和数据段。
而运行于一个进程中的多个线程,它们之间使用相同的地址空间,共享大部分数据,启动一个线程所花费的空间远远小于进程所花费的空间,而且,线程间彼此切换所需的时间也远远小于进程间所需要的时间。
使用多线程的理由之二是线程间方便的通信机制。
对不同进程来说,它们具有独立的数据空间,要进行数据的传递只能通过通信的方式进行,这种方式费时且很不方便。
由于同一进程下的线程之间共享数据空间,所以一个线程的数据可以直接为其它线程所用,这样快且方便。
在计算机中,凡是提供服务的一方我们称为服务端(Server),而接受服务的另一方我们称作客户端(Client)。
不过客户端及伺服端的关系不见得一定建立在两台分开的机器上,提供服务的伺服端及接受服务的客户端也有可能都在同一台机器上,这样在同一台机器上就同时扮演伺服端及客户端。
线程间方便的通信机制可以使得在我们在服务端和客户端方便的进行通信传输与各种操作,可以通过运用多线程机制方便实现上传、下载文件;增加、删除用户;以及在服务端进行文件的管理。
关键字:多线程、socket通信、服务器和客户端·1需求分析这次课程设计的要求是在以Linux为内核的操作系统下,实现多线程文件传输系统功能模块。
系统模块分为服务器和客户端两部分,客户端实现对文件的上传、下载和查看服务器默认路径下的文件列表;服务器可以对文件进行管理操作,包括创建、删除和重命名等。
多线程文件传输是一种一对多或者多对多的关系,一般是一个服务器对应着多个客户端。
客户端通过socket连接服务器,服务器要为客户端创建一个单独进程(线程)监听每个客户端的请求。
创建好连接之后文件就可以通过流的形式传输。
linux内核中为我们提供了两种不同形式的读写流,包括read()、write()和send()、recv()。
客户机对文件的查看指令也是通过流传递给服务器,服务器根据请求类型返回不同相应流。
根据socket原理和特点绘画出链接流程图,将客户机与服务器的相互通信划分为不同的模块,每个模块负责独立的功能项。
服务器输入指令管理目录下的文件,create filename是创建文件命令,rename oldname newname是删除文命令,delete filename 是删除文件命令,同时监听着客户端的请求;客户端向服务器发送上传、下载和查看请求,从而得到不同的相应,包括将文件下载到当前路径下,从当前路径下上传文件给服务器,列出服务器的文件列表。
·2 socket通信原理国际标准化组织(ISO)在1978年提出开放系统互连参考模型(OSI:open system interconnection reference mode),该模型是设计和描述网络通信的基本框架。
OSI采用分层的额结构化技术将通信网络分为7层,从低到高为物理层、数据链路层、网络层、传输层、会话层、表示层、应用层。
TCP/IP参考模型是由美国国防部创建,且发展至今最成功的通信协议模型,与OSI模型对应,它将网络功能分为4层,包括网络接口层、网络层、传输层和应用层,每一层都有对应的协议。
在传输层的主要协议是TCP协议和UDP协议。
socket连接就是基于TCP协议。
TCP是一种可靠地数据传输协议。
socket是一种套接口,它把网络地址和端口号信息放在一个结构体中,也就是套接字地址结构。
结构图如下:通用套接口地址数据结构定义在<sys/socket.h>头文件中,形式如下: struct sockaddr {uint8_t sa_len;sa_family_t sa_family; char sa_data[14]; };IPv4套接口地址数据结构以socketaddr_in 命名,定义在<netinet/in.h>头文件中,形式如下: struct socketaddr_in {unit8_t sin_len;sa_family_t sin_family; in_port_t sin_port;struct in_addr sin_addr; unsigned char sin_zero[8]; }下图是TCP 套接口通信工作流程图:通信工作的大致流程:1) 服务器先用socket()函数来建立一个套接口,用这个套接口完成通信的监听及数据的收发。
2) 服务器用bind()函数来绑定一个端口号和ip 地址,是套接口与指定的端口号和ip 关联。
3) 服务器调用linsten()函数,是服务器的端口和Ip 处于监听状态,等待网络中某一个客户机的连接请求。
4) 客户机用socket()函数建立一个套接口,设定远程ip 和端口 5) 客户机调用connect()函数连接远程计算机指定的端口。
6) 服务器调用accept()函数来接受远程计算机的连接请求,建立起与客户机之间的通信连接。
7) 建立连接之后,客户机用write()函数(或send())想socket 中写入数据。
也可以用read()函数(或recv()函数)赌气服务器发送来的数据。
8) 服务器用read()函数(或recv()函数)来读取客户机发来的数据,也可以用write()函数(或send()函数)来发送数据。
9) 完成通信以后,使用close()函数关闭socket 连接。
·3详细设计过程·3.1服务器端创建监听与文件管理服务器负责的功能模块主要有两部分,一是对连接进来客户端所有线程的管理和服务器目录下的文件管理;二是创建线程来单独监听客户端的动作。
为了便于管理,我们创建两个user.txt和client.txt两个文档来分别负责服务器的连接和客户端的连接。
user.txt中存放了服务器名和密码。
client.txt存放了连接客户端名字和密码。
我们首先对服务器的创建有个监测,即在启动时先核实服务器的所有者username和密码password,将输入的用户、密码与user.txt中的用户密码比较,匹配成功则同意启动,否则return -1表失败。
接着创建一个socket套接口,绑定Ip设置客户端的最大连接数为10,然后创建一个sever线程来实现对服务器本身监听动作。
主体代码见最后接下来创建线程完成对客户端的监听监听等待连接:while(1){sockdata = accept(sockfd,(struct sockaddr*)0,(int*)0);…………….我们定义结构体:struct client_t{pthread_t tid;int conn_fd;int used;char name[20];}p_client[10];来存放每个客户端的socket信息、线程标识、使用号、连接号和客户名。
创建线程实现单独监听:p_client[i].conn_fd = sockdata;p_client[i].used = i;strcpy(p_client[i].name , client_name);pthread_create(&p_client[i].tid,NULL,&client_conn,&p_client[i])接下来是线程client_conn()的功能监听客户端的功能完成。
·3.2客户端连接与文件传输在客户端这边我们同样适用了检测机制,运行客户机时要将用户名、密码以及ip地址和端口号作为参数输进来,先建立与服务器的连接,然后将用户名和密码发送到服务端检测,如果检测失败则接收到一条拒绝信息,连接断开,如果检测成功则接收到一条确认信息,双方通信开始。
主体代码见最后:到此为止我们已经实现了服务器和客户端的主体功能,具体代码查看附录文件夹。
·4结果演示编译完成的serve和client创建文档a将文档a改名为b将文件a由send上传到recieve1将文档a上传由send上传到recieve2客服端响应并连接服务器删除文档b下载文当前下载文档后具体代码如下:服务器:#include<stdio.h>#include<unistd.h>#include<stdlib.h>#include<string.h>#include<sys/socket.h>#include<sys/stat.h>#include<arpa/inet.h>#include <sys/resource.h>#include <sys/types.h>#include <dirent.h>#define MAXBUF 256/*-------start of fileList functions----------*/ int fileSize(char fileName[]);//文件信息typedef struct fileinfo{char name[256];char fullName[1024];int size;time_t mod_time;char type[10];}fileinfo;//文件列表typedef struct filelist{fileinfo file;struct filelist* nextfile;}fileList;//function getfilelist//输入目录名//输出目录下的文件列表头指针fileList * getFileList(char name[1024]){fileList *head=NULL;fileList *cur=NULL;char name_temp[1024];//目录DIR * dir;//目录环境struct dirent *dir_env;//文件描述struct stat stat_file;//初始化headhead =(fileList*)malloc(sizeof(fileList)); head->nextfile = NULL;//打开目录dir=opendir(name);while(dir_env=readdir(dir))//读文件描述表{//排除.和..if(strcmp(dir_env->d_name,".")==0 || strcmp(dir_env->d_name,"..")==0)continue;//把文件全名保存到新变量strcpy(name_temp,name);strcat(name_temp,dir_env->d_name);stat(name_temp,&stat_file);//获取文件描述信息//将文件信息存放到链表中//产生临时节点cur=(fileList*)malloc(sizeof(fileList));//cur赋值//文件名,fullName=cur_dir+"name";strcpy(cur->,dir_env->d_name);strcpy(cur->file.fullName,name_temp);//文件大小//文件类型if( S_ISDIR(stat_file.st_mode)){cur->file.size = 0;strcpy(cur->file.type,"mulu");strcat(cur->file.fullName,"/");}else{cur->file.size = stat_file.st_size;strcpy(cur->file.type,"file");}//修改日期cur->file.mod_time = ctime(&stat_file.st_mtime);//将临时节点插入head中if(head->nextfile ==NULL){head->nextfile = cur;cur->nextfile = NULL;}else{cur->nextfile = head->nextfile;head->nextfile = cur;}}return head;}//showAllNode//输入:目录//输出:次目录下所有的文件,和所有目录之下的文件void showAllNode(fileList *head){fileList * temp;//数组索引int i=0,j=0;//如果head为空,直接返回fileList * headArray[1024];if(head == NULL)return ;//输出当前目录printf("%s ",head->file.fullName);printf("\n");//输出head中的文件temp =head->nextfile;char fileListString[MAXBUF];FILE *file;char _temp[30];strcpy(_temp,"temp.txt");file=fopen(_temp,"w");if(file==NULL){printf("The file is created failed!");exit(1);}while(temp){//判断是否为文件,是文件显示文件//若为目录,将目录名放入队列,求队列目录if (strcmp(temp->file.type,"file")==0){bzero(fileListString,MAXBUF);printf("file:%s ",temp->file.fullName);strcat(fileListString,temp->file.fullName);strcat(fileListString,"\n");while ((strlen(fileListString)) > 0){int write_length = fwrite(fileListString, sizeof(char), strlen(fileListString), file);if (write_length < strlen(fileListString)){printf("File Write into Failed\n");break;}bzero(fileListString, MAXBUF);}}else{if(i>=1024){printf("there are too many direcotry\n");return;}//头节点初始化headArray[i] = getFileList(temp->file.fullName);//头节点名称strcpy(headArray[i]->file.fullName,temp->file.fullName); i++;}temp=temp->nextfile;}fclose(file);//对目录队列中目录使用递归,直到结束for(j=0;j<i;j++)showAllNode(headArray[j]);return ;}//showList//输入:列表头//输出:显示列表,返回voidvoid showList(fileList * head){//判断head 是否为空,若为空直接返回if(head == NULL)return;//若不为空则显示它的内容while(head){printf("%s\n",head->file.fullName);head = head->nextfile;}return ;}/*----------end of fileList functions-----------*/void main(){int opt=1;while(opt!=0){printf("Please choose your choice bellow:\n");printf("1:Manage the files.\n");printf("2:Connect the clients.\n");char window[2];scanf("%s",window);if((strncmp(window,"1",1))==0){printf("Please input your choice bellow:\n");printf("1: Create a new file.\n");printf("2: Delete a file.\n");printf("3: Rename a known file.\n");char choice[2];scanf("%s",choice);if((strncmp(choice,"1",1))==0){printf("Please input the new file name:");char filename[20];scanf("%s",filename);FILE *file;file=fopen(filename,"w");if(file==NULL){printf("The file created failed!\n");}else{printf("The file has created successfully.\n");}continue;}else if((strncmp(choice,"2",1))==0){printf("Please input the file name with the file path you want to delete:\n");char filename[20];scanf("%s",filename);remove(filename);printf("The file has been deleted successfully.\n");continue;}else{printf("Please input the file name you want to rename:\n");char _old[20];scanf("%s",_old);printf("Please input the new file name:\n");char _new[20];scanf("%s",_new);int result = rename( _old, _new );if( result != 0 )printf( "Could not rename '%s'\n", _old );elseprintf( "File '%s' renamed to '%s'\n", _old, _new );continue;}}else{int ssock;int clen;struct sockaddr_in client_addr,server_addr;char buf[MAXBUF];if((ssock=socket(AF_INET,SOCK_DGRAM,IPPROTO_UDP))<0){ perror("socket error:");exit(1);}printf("Run the server successfully.\nAnd now waiting the client comming...\n");memset(&server_addr,0,sizeof(server_addr));server_addr.sin_family=AF_INET;server_addr.sin_addr.s_addr=inet_addr("127.0.0.1");server_addr.sin_port=htons(6669);if(bind(ssock,(struct sockaddr *)&server_addr,sizeof(server_addr))<0){perror("bind error:");exit(1);}int window=1;while(window!=0){clen=sizeof(client_addr);recvfrom(ssock,(void *)buf,MAXBUF,0,(struct sockaddr*)&client_addr,&clen);printf("%s\n",buf);if((strncmp(buf, "0", 1)) == 0){if((strncmp(buf, "0yy", 7)) == 0){strcpy(buf,"yes");printf("It's username and right.\n");}else{strcpy(buf,"no");printf("It's username but wrong.\n");}sendto(ssock,(void *)buf,MAXBUF,0,(struct sockaddr*)&client_addr ,sizeof(client_addr));}else if((strncmp(buf, "1", 1)) == 0){if((strncmp(buf, "1123", 4)) == 0){strcpy(buf,"yes");sendto(ssock,(void *)buf,MAXBUF,0,(struct sockaddr*)&client_addr ,sizeof(client_addr));printf("It's password and right.\n");recvfrom(ssock,(void *)buf,MAXBUF,0,(struct sockaddr*)&client_addr,&clen);if((strncmp(buf, "upload", 5)) == 0){printf("The client is going to upload file...\n");recvfrom(ssock,(void *)buf,MAXBUF,0,(struct sockaddr*)&client_addr,&clen);//get filenameprintf("The filename of the file uploaded by user is:%s\n",buf);FILE *file;char temp[30];strcpy(temp,"recieve/");strcat(temp,buf);file=fopen(temp,"w");if(file==NULL){printf("The file is created failed!");exit(1);}bzero(buf, MAXBUF);recvfrom(ssock,(void *)buf,MAXBUF,0,(structsockaddr*)&client_addr,&clen);while (strlen(buf) > 0){int write_length = fwrite(buf, sizeof(char), strlen(buf), file);if (write_length < strlen(buf)){printf("File Write into Failed\n");break;}bzero(buf, MAXBUF);}fclose(file);printf("Recieve file already success.\n");}else{printf("The client wants to download file.\n");printf("Send the filelist to the client...\n");//filelistfileList *mylist;//显示的目录char name[1024]="recieve/";//取得目录下文件//头指针传递的目录或者文件名mylist =getFileList(name);strcpy(mylist->file.fullName,name);//显示目录下文件//showList(mylist);//显示目录下所有文件showAllNode(mylist);//send fileListFILE *file;char temp[30];strcpy(temp,"temp.txt");file=fopen(temp,"r");if(file==NULL){printf("The file cannot open!");exit(1);}else{printf("\nThe fileListString open successfully!\n");bzero(buf,MAXBUF);int lengsize = 0;while((lengsize = fread(buf,1,MAXBUF,file)) > 0){printf("lengsize = %d\n",lengsize);sendto(ssock,(void*)buf,MAXBUF,0,(struct sockaddr*)&client_addr,sizeof(server_addr));printf("%s\n",buf);bzero(buf, MAXBUF);}printf("The fileListString has been sent to the client already.\n");}fclose(file);bzero(buf, MAXBUF);recvfrom(ssock,(void *)buf,MAXBUF,0,(struct sockaddr*)&client_addr,&clen);printf("The client choosen file: %s\n",buf);strcpy(temp,"recieve/");strcat(temp,buf);file=fopen(temp,"r");if(file==NULL){printf("The file is created failed!");exit(1);}else{printf("The file open successfully!\n");printf("The file is downloading to the client now...\n");bzero(buf,MAXBUF);int lengsize = 0;while((lengsize = fread(buf,1,MAXBUF,file)) > 0){printf("lengsize = %d\n",lengsize);sendto(ssock,(void*)buf,MAXBUF,0,(struct sockaddr*)&client_addr,sizeof(server_addr));bzero(buf, MAXBUF);}printf("The file has been downloaded already.\n");}fclose(file);exit(1);//还可以显示此时的文件目录信息,检查是否完成了上传}close(ssock);window=0;}else{strcpy(buf,"no");sendto(ssock,(void *)buf,MAXBUF,0,(struct sockaddr*)&client_addr ,sizeof(client_addr));printf("It's password but wrong.\n");}}}}}}客服端:#include<stdio.h>#include<stdlib.h>#include<unistd.h>#include<strings.h>#include<string.h>#include<sys/types.h>#include<sys/socket.h>#include<netinet/in.h>#include<netdb.h>#define PORT 6669#define MAXBUF 256int check_passwd(int sockfd);int tra_file(int sockfd);void main ( int argc, char *argv[]){char username[20];char password[20];char temp[21];char window;printf("Please input your selections bellow:\n");printf("1:Login the server with your username and password\n");printf("2:Registe a newly user now.\n");printf("0:Exit the system.\n");window=getchar();while(window>0){if(window=='1'){int key=0;printf("Please input your username:");scanf("%s",username);printf("%s\n",username);int ssock;int clen;struct sockaddr_in client_addr,server_addr;char buf[MAXBUF];if((ssock = socket(AF_INET,SOCK_DGRAM,0))<0){perror("socket error:你暂时不能登录服务器server,请稍后再登录...\n");exit(1);}else{while(key==0){memset(&server_addr,0,sizeof(server_addr));server_addr.sin_family =AF_INET;server_addr.sin_addr.s_addr=inet_addr("127.0.0.1");server_addr.sin_port=htons(PORT);strcpy(temp,"0");strcat(temp,username);strcpy(buf,temp);sendto(ssock,(void *)buf,MAXBUF,0,(struct sockaddr*)&server_addr,sizeof(server_addr));printf("你已经发送username(%s)给server请等待响应...\n",buf);clen=sizeof(client_addr);sockaddr*)&server_addr,&clen);printf("你已经得到了server的响应:%s\n",buf);if((strncmp(buf, "yes", 3)) != 0){printf("The username you inputed is wrong!\n");window='1';close(ssock);printf("Please input your username:");scanf("%s",username);printf("%s\n",username);}else{close(ssock);key=1;}}}printf("Please input your password:");scanf("%s",password);printf("%s\n",password);if((ssock = socket(AF_INET,SOCK_DGRAM,0))<0){perror("socket error:你暂时不能登录服务器server,请稍后再登录...\n");exit(1);}else{key=0;while(key==0){memset(&server_addr,0,sizeof(server_addr));server_addr.sin_family =AF_INET;server_addr.sin_addr.s_addr=inet_addr("127.0.0.1");server_addr.sin_port=htons(PORT);bzero(temp,21);strcpy(temp,"1");printf("%s\n",temp);strcat(temp,password);strcpy(buf,temp);sendto(ssock,(void *)buf,MAXBUF,0,(struct sockaddr*)&server_addr,sizeof(server_addr));printf("你已经发送password(%s)给server请等待响应...\n",buf);clen=sizeof(client_addr);sockaddr*)&server_addr,&clen);printf("你已经得到了server的响应:%s\n",buf);if((strncmp(buf, "yes", 3)) != 0){printf("The password you inputed is wrong!\n");window='1';close(ssock);printf("Please input your password:");scanf("%s",password);printf("%s\n",password);}else{//file list display and file chooseprintf("Please choose eithor upload file or download file bellow:\n");printf("1:upload file.\n");printf("2:download file.\n");char choose[2];scanf("%s",choose);char path[20];char filename[20];if((strncmp(choose,"1",1))==0){printf("please input the path you want to upload end with '/':\n");scanf("%s",path);printf("Please input the file you want to upload:\n");strcpy(buf,"upload");sendto(ssock,(void *)buf,MAXBUF,0,(struct sockaddr*)&server_addr,sizeof(server_addr));scanf("%s",filename);strcat(path,filename);strcpy(buf,filename);sendto(ssock,(void *)buf,MAXBUF,0,(struct sockaddr*)&server_addr,sizeof(server_addr));FILE *file;file=fopen(path,"r");if(file==NULL){perror("The file open failed!");exit(1);}else{printf("The file open successfully!\n");printf("The file is uploading now...\n");bzero(buf,MAXBUF);int lengsize = 0;while((lengsize = fread(buf,1,MAXBUF,file)) > 0){printf("lengsize = %d\n",lengsize);sendto(ssock,(void*)buf,MAXBUF,0,(struct sockaddr*)&server_addr,sizeof(server_addr));bzero(buf, MAXBUF);}printf("The file has been uploaded already.\n");exit(1);//还可以显示此时的文件目录信息,检查是否完成了上传}}else{bzero(buf,MAXBUF);strcpy(buf,"download");sendto(ssock,(void *)buf,MAXBUF,0,(struct sockaddr*)&server_addr,sizeof(server_addr));printf("The filelist supported by server is bellow:\n");bzero(buf,MAXBUF);recvfrom(ssock,(void *)buf,MAXBUF,0,(struct sockaddr*)&server_addr,&clen);printf("%s\n",buf);printf("Please input the file you want to download :\n");scanf("%s",filename);strcpy(buf,filename);sendto(ssock,(void *)buf,MAXBUF,0,(struct sockaddr*)&server_addr,sizeof(server_addr));bzero(buf,MAXBUF);FILE *file;char temp[30];strcpy(temp,"download/");strcat(temp,filename);file=fopen(temp,"w");if(file==NULL){printf("The file is created failed!");exit(1);}bzero(buf, MAXBUF);recvfrom(ssock,(void *)buf,MAXBUF,0,(struct sockaddr*)&server_addr,&clen);while (strlen(buf) > 0){int write_length = fwrite(buf, sizeof(char), strlen(buf), file);printf("The write_length is:%d\n",write_length);if (write_length < strlen(buf)){printf("File Write into Failed\n");break;}bzero(buf, MAXBUF);}fclose(file);printf("Download file already success.\n");}close(ssock);key=1;window=0;}}}}else if(window=='2'){printf("Please input your newly username:");scanf("%s",username);printf("Please input your newly password:");scanf("%s",password);}else {break;}}}·5总结体会为期一周的Linux课程设计结束了,从中获益匪浅。