当前位置: 首页 > news >正文

TCP/IP编程实现远程文件传输

 在TCP/IP网络结构中,为了保证网络安全,网络人员往往需要在路由器上添加防火墙,禁止非法用户用ftp等安全危害较大的TCP/IP协议访问主机。而有时系统维护人员需要用ftp将一些文件从中心机房主机传到前端网点主机上,比如应用程序的替换升级。如果每次传输文件时都要打开防火墙,未免显得有些繁琐,要是在自己的应用程序中增加一个专门的文件传输模块,那将是十分愉快的事情。 
  
  UNIX网络程序设计一般都采用套接字(socket)系统调用。针对目前十分流行的客户/服务器模式,其程序编写步骤如下: 
  1.Socket系统调用 
  为了进行网络I/O,服务器和客户机两端的UNIX进程要做的第一件事是调用socket()系统调用,建立软插座,指明合适的通讯协议。格式为: 
  #include<sys/types.h> 
  #include<sys/socket.h> 
  int socket(int family,int type,int protocol) 
  其中:(1)family指明套节字族,其值包括: 
  AF_UNIX   (UNIX内部协议族) 
  AF_INET   (Iternet协议) 
  AF_NS (XeroxNs协议,TCP/IP编程取该值) 
  AF_IMPLINK  (IMP链接层) 
  (2)type 指明套接字类型,取值有: 
  SOCK_STREAM     (流套接字) 
  SOCK_DGRAM     (数据报套接字) 
  SOCK_RAW      (原始套接字) 
  SOCK_SEQPACKET   (定序分组套接字) 
  一般情况下,前两个参数的组合就可以决定所使用的协议,这时第三个参数被置为0,如果第一个参数为AF_INET,第二个参数选SOCK_STREAM,则使用的协议为TCP;第二个参数选SOCK_DGRAM,则使用的协议为UDP;当第二个参数选SOCK_RAW时,使用的协议为IP。值得指出的是并不是所有的族和类型的组合都是合法的,具体请查阅相关资料。该系统调用若成功则返回一个类似文件描述符,成为套节字描述字,可以像文件描述符那样用read和write对其进行I/O操作。当一个进程使用完该软插座时,需用close(<描述符> icon_wink.gif 关闭(具体见后面内容)。 
  2.服务器端Bind系统调用 
  软插座创建时并没有与任何地址相关联,必须用bind()系统调用为其建立地址联系。其格式为: 
  #include<sys/types.h> 
  #include<sys/socket.h> 
  int bind(int socketfd,struct sockaddr_in *localaddr,sizeof(localaddr)); 
  其中:(1)第一个参数socketfd是前步socket()系统调用返回的套节字描述符。 
  (2)第二个参数被捆向本地地址的一种结构,该结构在sys/netinet/in.h中定义: 
  struct sockaddr_in{ 
   short sin_family;/*socket()系统调用的协议族如AF_INET*/ 
   u_short sin_port;/*网络字节次序形式的端口号码*/ 
   struct in_addr sin_addr;/*网络字节次序形式的网络地址*/ 
   char sin_zero[8]; 
  } 
  一台机器上的每个网络程序使用一个各自独立的端口号码,例如:telnet程序使用端口号23,而ftp文件传输程序使用端口号21。我们在设计应用程序时,端口号码可以由getservbyname()函数从/etc/services库文件中获取,也可以由htons (int portnum)函数将任意正整数转换为网络字节次序形式来得到,有些版本的UNIX操作系统则规定1024以下的端口号码只可被超级用户使用,普通用户程序使用的端口号码只限于1025到32767之间。网络地址可以由gethostbyname(char*hostname)函数得到(该函数和getservbyname()一样都以网络字节次序形式返回所有在他们结构中的数据),参数hostname为/etc/hosts文件中某一网络地址所对应的机器名。该函数返回一个类型为hostent的结构指针,hostent结构在netdb.h中定义: 
  struct hostent{ 
   char *h_name; 
   char **h_aliases; 
   int h_addrtype; 
   int h_length;  /*地址长度*/ 
   char **h_addr_list; 
   #define h_addr h_addr_list[0];/*地址*/ 
  } 
  (3)第三个参数为第二个结构参数的长度,如果调用成功,bind返回0,否则将返回-1并设置errno。 
  3.服务器端系统调用listen,使服务器愿意接受连接 
  格式:int listen(int socketfd,int backlong) 
  它通常在socket和bind调用后在accept调用前执行。第二个参数指明在等待服务器执行accept调用时系统可以排队多少个连接要求。此参数常指定为5,也是目前允许的最大值。 
  4.服务器调用accept,以等待客户机调用connect进行连接。格式如下: 
  int newsocket=(int socketfd,struct sockaddr_in *peer,int*addrlen); 
  该调用取得队列上的第一个连接请求并建立一个具有与sockfd相同特性的套节字。如果没有等待的连接请求,此调用阻塞调用者直到一连接请求到达。连接成功后,该调用将用对端的地址结构和地址长度填充参数peer和addlen,如果对客户端的地址信息不感兴趣,这两个参数用0代替。 
  5.客户端调用connect()与服务器建立连接。格式为: 
  connect(int socketfd,struct sockaddr_in *servsddr,int addrlen) 
  客户端取得套接字描述符后,用该调用建立与服务器的连接,参数socketfd为socket()系统调用返回的套节字描述符,第二和第三个参数是指向目的地址的结构及以字节计量的目的地址的长度(这里目的地址应为服务器地址)。调用成功返回0,否则将返回-1并设置errno。 
  6.通过软插座发送数据 
  一旦建立连接,就可以用系统调用read和write像普通文件那样向网络上发送和接受数据。Read接受三个参数:一个是套节字描述符;一个为数据将被填入的缓冲区,还有一个整数指明要读的字节数,它返回实际读入的字节数,出错时返回-1,遇到文件尾则返回0。Write也接受三个参数:一个是套节字描述符;一个为指向需要发送数据的缓冲区,还有一个整数指明要写入文件的字节个数,它返回实际写入的字节数,出错时返回-1。当然,也可以调用send和recv来对套节字进行读写,其调用与基本的read和write系统调用相似,只是多了一个发送方式参数。 
  7.退出程序时,应按正常方式关闭套节字。格式如下: 
  int close(socketfd) 
  前面介绍了UNIX客户/服务器模式网络编程的基本思路和步骤。值得指出的是socket编程所涉及的系统调用不属于基本系统调用范围,其函数原形在libsocket.a文件中,因此,在用cc命令对原程序进行编译时需要带-lsocket选项。 
  现在,我们可以针对文章开头提出的问题着手进行编程了。在图示的网络结构中,为使中心机房的服务器能和网点上的客户机进行通信,需在服务器端添加通过路由器1112到客户机的路由,两台客户机也必须添加通过路由器2221到服务器的路由。在服务器的/etc/hosts文件中应该包含下面内容: 
  1.1.1.1  server 
  2.2.2.2  cli1 
  2.2.2.3  cli2 
  客户机的/etc/hosts文件中应该有本机地址信息和服务器的地址信息,如cli1客户机的/etc/hosts文件: 
  2.2.2.2  cli1 
  1.1.1.1  server 
  网络环境搭建好后,我们可以在服务器端编写fwq.c程序,负责接受客户机的连接请求,并将从源文件中读取的数据发送到客户机。客户机程序khj.c向服务器发送连接请求,接收从服务器端发来的数据,并将接收到的数据写入目标文件。源程序如下: 
None.gif/*服务器源程序fwq.c*/ 
None.gif#include<stdio.h> 
None.gif#include<sys/types.h> 
None.gif#include<sys/fcntl.h> 
None.gif#include<sys/socket.h> 
None.gif#include<sys/netinet/ in.h> 
None.gif#include<netdb.h> 
None.gif#include<errno.h> 
None.gifmain() 
ExpandedBlockStart.gif
InBlock.gif  char c,buf[1024],file[30]; 
InBlock.gif  int fromlen,source; 
InBlock.gif  register int k,s,ns; 
InBlock.gif  struct sockaddr_in sin; 
InBlock.gif  struct hostent *hp; 
InBlock.gif  system(″clear″); 
InBlock.gif  printf(″\n″); 
InBlock.gif    
InBlock.gif  printf(″\n\n\t\t输入要传输的文件名:″); 
InBlock.gif  scanf(″%s″,file); 
ExpandedSubBlockStart.gif  if ((source=open(file,O_RDONLY))<0){ 
InBlock.gif   perror(″源文件打开出错″); 
InBlock.gif   exit(1); 
ExpandedSubBlockEnd.gif  } 
InBlock.gif  printf(″\n\t\t在传送文件,稍候…″); 
InBlock.gif  hp=gethostbyname(″server″); 
ExpandedSubBlockStart.gif  if (hp==NULL){ 
InBlock.gif   perror(″返回主机地址信息错!!!″); 
InBlock.gif   exit(2); 
ExpandedSubBlockEnd.gif  } 
InBlock.gif  s=socket(AF_INET,SOCK_STREAM,0); 
ExpandedSubBlockStart.gif  if(s<0){ 
InBlock.gif   perror(″获取SOCKET号失败!!!″); 
InBlock.gif   exit(3); 
ExpandedSubBlockEnd.gif  } 
InBlock.gif  sin.sin_family=AF_INET; 
InBlock.gif  sin.sin_port=htons(1500);/*使用端口1500*/ 
InBlock.gif  bcopy(hp->h_addr,&sin.sin_addr,hp->h_length); 
ExpandedSubBlockStart.gif  if(bind(s,&sin,sizeof(sin))<0){ 
InBlock.gif   perror(″不能将服务器地址捆绑到SOCKET号上!!!″); 
InBlock.gif   colse(s); 
InBlock.gif   exit(4); 
ExpandedSubBlockEnd.gif  } 
ExpandedSubBlockStart.gif  if(listen(s,5)<0{ 
InBlock.gif   perror(″sever:listen″); 
InBlock.gif   exit(5); 
ExpandedSubBlockEnd.gif  } 
ExpandedSubBlockStart.gifwhile(1){ 
ExpandedSubBlockStart.gif  if((ns=accept(s,&sin,&fromlen))<0){ 
InBlock.gif   perror(″sever:accept″); 
InBlock.gif   exit(6); 
ExpandedSubBlockEnd.gif  } 
InBlock.gif  lseek(source,OL,0);/*每次接受客户机连接,应将用于读的源文件指针移到文件头*/ 
InBlock.gif  write(ns,file,sizeof(file)); /*发送文件名*/ 
InBlock.gif  while((k=read(source,buf,sizeof(buf)))>0) 
InBlock.gif   write(ns,buf,k); 
InBlock.gif  printf(″\n\n\t\t传输完毕!!!\n″); 
InBlock.gif  close(ns); 
ExpandedSubBlockEnd.gif
InBlock.gif  close(source); 
InBlock.gif  exit(0); 
InBlock.gif  /*客户机源程序khj.c*/ 
InBlock.gif  #include<stdio.h> 
InBlock.gif  #include<sys/types.h> 
InBlock.gif  #include<sys/fcntl.h> 
InBlock.gif  #include<sys/socket.h> 
InBlock.gif  #include<sys/netinet/in.h> 
InBlock.gif  #include<netdb.h> 
InBlock.gif  #include<errno.h> 
InBlock.gif  #include <string.h> 
InBlock.gif  main() 
ExpandedSubBlockStart.gif  { 
InBlock.gif   char buf[1024],file[30]; 
InBlock.gif   char *strs=″\n\n\t\t正在接收文件″; 
InBlock.gif   int target; 
InBlock.gif   register int k,s; 
InBlock.gif   struct sockaddr_in sin; 
InBlock.gif   struct hostent *hp; 
InBlock.gif   system(″clear″); 
InBlock.gif   printf(″\n″); 
InBlock.gif     
InBlock.gif   hp=gethostbyname(″server″); 
ExpandedSubBlockStart.gif   if(hp==NULL){ 
InBlock.gif          perror(″返回服务器地址信息错!!!″); 
InBlock.gif    exit(1); 
ExpandedSubBlockEnd.gif   } 
InBlock.gif   s=socket(AF_INET,SOCK_STREAM,0); 
ExpandedSubBlockStart.gif   if(s<0){ 
InBlock.gif    perror(″获取SOCKET号失败!!!″); 
InBlock.gif    exit(2); 
ExpandedSubBlockEnd.gif   } 
InBlock.gif   sin.sin_family=AF_INET; 
InBlock.gif   sin.sin_port=htons(1500);/*端口号需与服务器程序使用的一致*/ 
InBlock.gif   bcopy(hp->h_addr,&sin.sin_addr,hp->h_length); 
InBlock.gif   printf(″\n\n\t\t正在与服务器连接…″); 
ExpandedSubBlockStart.gif   if(connect(s,&sin,sizeof(sin),0)<0){ 
InBlock.gif    perror(″不能与服务器连接!!!″); 
InBlock.gif    exit(3); 
ExpandedSubBlockEnd.gif   } 
InBlock.gif   while((k=read(s,file,sizeof(file)))<=0/*接收文件名*/ 
ExpandedSubBlockStart.gif   if((target=open(file,o_WRONLY|O_CREAT|O_TRUNC,0644))<0){ 
InBlock.gif    perror(″不能打开目标文件!!″); 
InBlock.gif    exit(4); 
ExpandedSubBlockEnd.gif  } 
InBlock.gif  strcat(strs,file); 
InBlock.gif  strcat(strs,″,稍候…″); 
InBlock.gif  write(1,strs,strlen(strs)); 
InBlock.gif  while((k=read(s,buf,sizeof(buf)))>0) 
InBlock.gif   write(tatget,buf,k); 
InBlock.gif  printf(″\n\n\t\t接收文件成功!!!\n″); 
InBlock.gif  close(s); 
InBlock.gif  close(target); 
ExpandedSubBlockEnd.gif  } 

  上述程序在Sco Unix System v3.2及Sco TCP/IP Rumtime环境下调试通过。

相关文章:

  • xshell中复制快捷键的设置
  • MySQL之内联接、左联接、右联接、交叉联接
  • Android自定义Toast
  • [C#]获取指定文件夹下的所有文件名(递归)
  • .Net下的签名与混淆
  • PHP $_SERVER详解
  • 人工智能+医疗 未来医生真的会失业吗
  • 企业如何实施物联网解决方案
  • Learning JQuery(一)
  • [转载]项目风险管理七种武器之结语
  • 构建Xamarin.Forms NuGet
  • 基于Android客户端的人人网开放平台开发系列教程 (有源码哦)
  • UGUI精灵图片实现图片裁剪
  • 26、C#里面标签的属性和事件
  • 广义线性模型
  • ES6核心特性
  • gitlab-ci配置详解(一)
  • IndexedDB
  • js面向对象
  • leetcode98. Validate Binary Search Tree
  • linux安装openssl、swoole等扩展的具体步骤
  • miaov-React 最佳入门
  • nodejs实现webservice问题总结
  • pdf文件如何在线转换为jpg图片
  • Spark学习笔记之相关记录
  • SpiderData 2019年2月23日 DApp数据排行榜
  • TypeScript实现数据结构(一)栈,队列,链表
  • Vue实战(四)登录/注册页的实现
  • 分享一份非常强势的Android面试题
  • 构建二叉树进行数值数组的去重及优化
  • 前嗅ForeSpider中数据浏览界面介绍
  • 数组大概知多少
  • 用Node EJS写一个爬虫脚本每天定时给心爱的她发一封暖心邮件
  • 原创:新手布局福音!微信小程序使用flex的一些基础样式属性(一)
  • ​【原创】基于SSM的酒店预约管理系统(酒店管理系统毕业设计)
  • #我与Java虚拟机的故事#连载02:“小蓝”陪伴的日日夜夜
  • $.each()与$(selector).each()
  • %check_box% in rails :coditions={:has_many , :through}
  • (52)只出现一次的数字III
  • (ISPRS,2023)深度语义-视觉对齐用于zero-shot遥感图像场景分类
  • (SpringBoot)第七章:SpringBoot日志文件
  • (独孤九剑)--文件系统
  • (附源码)python旅游推荐系统 毕业设计 250623
  • (一)Linux+Windows下安装ffmpeg
  • (幽默漫画)有个程序员老公,是怎样的体验?
  • ***监测系统的构建(chkrootkit )
  • 、写入Shellcode到注册表上线
  • .htaccess配置常用技巧
  • .NET : 在VS2008中计算代码度量值
  • .NET 的静态构造函数是否线程安全?答案是肯定的!
  • .NET 设计模式—适配器模式(Adapter Pattern)
  • .Net6支持的操作系统版本(.net8已来,你还在用.netframework4.5吗)
  • .Net7 环境安装配置
  • .NET上SQLite的连接
  • @ 代码随想录算法训练营第8周(C语言)|Day53(动态规划)