热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

socket编程---简单的C/S之间的通信

一、socket通信过程简介在WIN32平台上的WINSOCK编程都要经过下列步骤:定义变量->获得WINDOCK版本->加载WINSOCK库->初始化->创

一、socket通信过程简介

在WIN32平台上的WINSOCK编程都要经过下列步骤:

定义变量->获得WINDOCK版本->加载WINSOCK库->初始化->创建套接字->设置套接字选项->关闭套接字->卸载WINSOCK库->释放资源。

在VC中进行WINSOCK编程时,需要引入如下两个库文件:WINSOCK.H(这个是WINSOCK API的头文件,WIN2K以上支持WINSOCK2,所以WINSOCK2.H);Ws2_32.lib(WINSOCK API连接库文件)。
使用方式如下:
           #include
           #pragma comment(lib,"ws2_32.lib")

二、重要函数

1.加载winsock文件

/*加载winsock文件*/
  WSADATA wsaData;                    //WSADATA结构被用来储存调用AfxSocketInit全局函数返回的Windows Sockets初始化信息    定义在Winsock.h
  WORD sockVersion=MAKEWORD(2,0);     //使用WINSOCK2版本
 
  ::WSAStartup(sockVersion,&wsaData);   //第一个参数是WINSOCK 版本号,第二个参数是指向WSADATA的指针.
                                        //该函数返回一个INT型值,通过检查这个值来确定初始化是否成功   

2.创建服务器端的套接字

/*创建服务器端的套接字*/
  SOCKET s=::socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);
                                    //三个参数分别代表 使用TCP/IP;传输过程使用TCP;不适用其他特殊协议

  if(s==INVALID_SOCKET)
  {   
	  printf("Failed socket()\n");
      ::WSACleanup();
      system("pause");
	  return 0;
  }

3.socket中装入地址信息

(服务器端)

/*socket中装入地址信息*/
  sockaddr_in sin;
  sin.sin_family=AF_INET;              //sin_family指代协议族,在socket编程中只能是AF_INET
  sin.sin_port=htons(13);              //表示服务器监听的端口号为13
  sin.sin_addr.S_un.S_addr=INADDR_ANY; //存储IP地址,INADDR_ANY就是指定地址为0.0.0.0的地址,这个地址事实上表示不确定地址,或“所有地址”、“任意地址”

(客户端)

 /*socket中装入地址信息*/
  sockaddr_in servAddr;
  servAddr.sin_family=AF_INET;
  servAddr.sin_port=htons(13); /*接收服务器13端口号*/
  servAddr.sin_addr.S_un.S_addr=inet_addr("127.0.0.1");/*本地IP地址为127.0.0.1*/

4.绑定地址及端口号

/*绑定地址及端口号*/
  if(::bind(s,(LPSOCKADDR)&sin,sizeof(sin))==SOCKET_ERROR)//返回:0---成功,-1---失败
  {   
	  printf("Failed bind()\n");
      ::WSACleanup();
      system("pause");
	  return 0;
  }

在套接口中,一个套接字只是用户程序与内核交互信息的枢纽,它自身没有太多的信息,也没有网络协议地址和端口号等信息,在进行网络通信的时候,必须把一个套接字与一个地址相关联,这个过程就是地址绑定的过程。
许多时候内核会我们自动绑定一个地址,然而有时用户可能需要自己来完成这个绑定的过程,以满足实际应用的需要,最典型的情况是一个服务器进程需要绑定一个众所周知的地址或端口以等待客户来连接。这个事由bind的函数完成。

参数一:指定与那个套接字绑定;

参数二:指定地址;

参数三:确定复制多少数据。

bind函数并不是总是需要调用的,只有用户进程想与一个具体的地址或端口相关联的时候才需要调用这个函数。如果用户进程没有这个需要,那么程序可以依赖内核的自动的选址机制来完成自动地址选择,而不需要调用bind的函数,同时也避免不必要的复杂度。
在一般情况下,对于服务器进程问题需要调用bind函数,对于客户进程则不需要调用bind函数

5.监听客户端的连接请求(服务器端调用)

/*监听客户端的连接请求*/
  if(::listen(s,2)==SOCKET_ERROR)//返回:0---成功,-1---失败
  {   
	  printf("Failed listen()\n");
      ::WSACleanup();
      system("pause");
	  return 0;
  }

listen函数使主动连接套接口变为被连接套接口,使得一个进程可以接受其它进程的请求,从而成为一个服务器进程。在TCP服务器编程中listen函数把进程变为一个服务器,并指定相应的套接字变为被动连接。
listen函数在一般在调用bind之后-调用accept之前调用。

参数一:被listen函数调用的套接字;

参数二:连接数量的上限。

在服务器编程中,用户希望这个套接字可以接受外来的连接请求,也就是被动等待用户来连接。由于系统默认时认为一个套接字是主动连接的,所以需要通过某种方式来告诉系统,用户进程通过系统调用listen来完成这件事。

6.等待并接受连接(服务器端调用)

client=::accept(s,(SOCKADDR*)&remoteAddr,&nAddrLen);//accept默认会阻塞进程,直到有一个客户连接建立后返回,它返回的是一个新可用的套接字,这个套接字是连接套接字。
      if(client==INVALID_SOCKET)
	  {   
		  printf("Failed accept()\n");
	      continue;
	  }

对于服务器编程中最重要的一步等待并接受客户的连接,那么这一步在编程中如何完成,accept函数就是完成这一步的。它从内核中取出已经建立的客户连接,然后把这个已经建立的连接返回给用户程序,此时用户程序就可以与自己的客户进行点到点的通信了。

参数一:监听套接字,这个套接字用来监听一个端口,当有一个客户与服务器连接时,它使用这个一个端口号,而此时这个端口号正与这个套接字关联。当然客户不知道套接字这些细节,它只知道一个地址和一个端口号。

参数二:一个结果参数,它用来接受一个返回值,这返回值指定客户端的地址。

7.连接服务器(客户端调用)

/*连接服务器*/
  if(::connect(s,(sockaddr*)&servAddr,sizeof(servAddr))==-1)//返回:0---成功,-1---失败
  {   
	  printf("Failed connect()\n");
      ::WSACleanup();
	  system("pause");
  }

onnect函数完成主动连接的过程,connect函数的功能是完成一个有连接协议的连接过程,对于TCP来说就是那个三次握手过程。

面向连接的协议,在建立连接的时候总会有一方先发送数据,那么谁调用了connect谁就是先发送数据的一方。

参数一:指定数据发送的套接字;

参数二:指定数据发送的目的地址,也就是服务器端的地址。


一个简单的例子:

(服务器端)

/* 服务器端 */
#include
#include
#include
#include
#pragma comment(lib,"WS2_32.lib")

int main(int argc,char*argv[])
{
  /*加载winsock文件*/
  WSADATA wsaData;                    //WSADATA结构被用来储存调用AfxSocketInit全局函数返回的Windows Sockets初始化信息    定义在Winsock.h
  WORD sockVersion=MAKEWORD(2,0);     //使用WINSOCK2版本
 
  ::WSAStartup(sockVersion,&wsaData);   //第一个参数是WINSOCK 版本号,第二个参数是指向WSADATA的指针.
                                        //该函数返回一个INT型值,通过检查这个值来确定初始化是否成功   

  /*创建服务器端的套接字*/
  SOCKET s=::socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);
                                    //三个参数分别代表 使用TCP/IP;传输过程使用TCP;不适用其他特殊协议

  if(s==INVALID_SOCKET)
  {   
	  printf("Failed socket()\n");
      ::WSACleanup();
      system("pause");
	  return 0;
  }

  /*socket中装入地址信息*/
  sockaddr_in sin;
  sin.sin_family=AF_INET;              //sin_family指代协议族,在socket编程中只能是AF_INET
  sin.sin_port=htons(13);              //表示服务器监听的端口号为13
  sin.sin_addr.S_un.S_addr=INADDR_ANY; //存储IP地址,INADDR_ANY就是指定地址为0.0.0.0的地址,这个地址事实上表示不确定地址,或“所有地址”、“任意地址”。

  /*绑定地址及端口号*/
  if(::bind(s,(LPSOCKADDR)&sin,sizeof(sin))==SOCKET_ERROR)
  {   
	  printf("Failed bind()\n");
      ::WSACleanup();
      system("pause");
	  return 0;
  }

  /*监听客户端的连接请求*/
  if(::listen(s,2)==SOCKET_ERROR)
  {   
	  printf("Failed listen()\n");
      ::WSACleanup();
      system("pause");
	  return 0;
  }

  sockaddr_in remoteAddr;
  int nAddrLen=sizeof(remoteAddr);
  SOCKET client;

  time_t t = time( 0 );
  char tmp[64];
  strftime( tmp, sizeof(tmp), "%Y/%m/%d %X %A\n\t", localtime(&t) );//提取系统时间

/*循环接受连接请求*/
  while(TRUE)
  {   
	  client=::accept(s,(SOCKADDR*)&remoteAddr,&nAddrLen);//accept默认会阻塞进程,直到有一个客户连接建立后返回,它返回的是一个新可用的套接字,这个套接字是连接套接字。
      if(client==INVALID_SOCKET)
	  {   
		  printf("Failed accept()\n");
	      continue;
	  }
	  printf("接收到一个客户端的连接:%s\r\n\n等待下一个客户端的连接……\n\n",inet_ntoa(remoteAddr.sin_addr));

	  ::send(client,tmp,strlen(tmp),0); /*发送本地时间给客户端*/

	  ::closesocket(client); /*关闭连接*/
  }

  ::closesocket(s);/*关闭套接字*/

  ::WSACleanup();
  system("pause");
  return 0;
}

(客户端)

/* 客户端  */
#include
#include
#include
#pragma comment(lib,"WS2_32.lib")

int main(int argc,char*argv[])
{
  /*加载winsock文件*/
  WSADATA wsaData;
  WORD sockVersion=MAKEWORD(2,0);
  ::WSAStartup(sockVersion,&wsaData);

  /*创建服务器端的套接字*/
  SOCKET s=::socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);

  if(s==INVALID_SOCKET)
  {   
	  printf("Failed socket()\n");
      ::WSACleanup();
	  system("pause");
  }

  /*socket中装入地址信息*/
  sockaddr_in servAddr;
  servAddr.sin_family=AF_INET;
  servAddr.sin_port=htons(13); /*接收服务器13端口号*/
  servAddr.sin_addr.S_un.S_addr=inet_addr("127.0.0.1");/*本地IP地址为127.0.0.1*/

  /*连接服务器*/
  if(::connect(s,(sockaddr*)&servAddr,sizeof(servAddr))==-1)
  {   
	  printf("Failed connect()\n");
      ::WSACleanup();
	  system("pause");
  }

  /*接收数据并打印到屏幕上*/
  char buff[256];
  int nRecv=::recv(s,buff,256,0);
  if(nRecv>0)
  {   
	  buff[nRecv]='\0';
      printf("连接成功\n");
      printf("接收到数据:%s\n",buff);
      system("pause");
  }
  return 0;
}



推荐阅读
  • 在C++程序中,文档A的每一行包含一个结构体数据,其中某些字段可能包含不同数量的数字。需要将这些结构体数据逐行读取并存储到向量中,随后不仅在控制台上显示,还要输出到新创建的文档B中。希望得到指导,感谢! ... [详细]
  • oracle c3p0 dword 60,web_day10 dbcp c3p0 dbutils
    createdatabasemydbcharactersetutf8;alertdatabasemydbcharactersetutf8;1.自定义连接池为了不去经常创建连接和释放 ... [详细]
  • iOS 不定参数 详解 ... [详细]
  • 本文介绍如何使用 Python 的 DOM 和 SAX 方法解析 XML 文件,并通过示例展示了如何动态创建数据库表和处理大量数据的实时插入。 ... [详细]
  • 字节流(InputStream和OutputStream),字节流读写文件,字节流的缓冲区,字节缓冲流
    字节流抽象类InputStream和OutputStream是字节流的顶级父类所有的字节输入流都继承自InputStream,所有的输出流都继承子OutputStreamInput ... [详细]
  • 属性类 `Properties` 是 `Hashtable` 类的子类,用于存储键值对形式的数据。该类在 Java 中广泛应用于配置文件的读取与写入,支持字符串类型的键和值。通过 `Properties` 类,开发者可以方便地进行配置信息的管理,确保应用程序的灵活性和可维护性。此外,`Properties` 类还提供了加载和保存属性文件的方法,使其在实际开发中具有较高的实用价值。 ... [详细]
  • 如何将TS文件转换为M3U8直播流:HLS与M3U8格式详解
    在视频传输领域,MP4虽然常见,但在直播场景中直接使用MP4格式存在诸多问题。例如,MP4文件的头部信息(如ftyp、moov)较大,导致初始加载时间较长,影响用户体验。相比之下,HLS(HTTP Live Streaming)协议及其M3U8格式更具优势。HLS通过将视频切分成多个小片段,并生成一个M3U8播放列表文件,实现低延迟和高稳定性。本文详细介绍了如何将TS文件转换为M3U8直播流,包括技术原理和具体操作步骤,帮助读者更好地理解和应用这一技术。 ... [详细]
  • 本文详细解析了 Android 系统启动过程中的核心文件 `init.c`,探讨了其在系统初始化阶段的关键作用。通过对 `init.c` 的源代码进行深入分析,揭示了其如何管理进程、解析配置文件以及执行系统启动脚本。此外,文章还介绍了 `init` 进程的生命周期及其与内核的交互方式,为开发者提供了深入了解 Android 启动机制的宝贵资料。 ... [详细]
  • 在Android平台中,播放音频的采样率通常固定为44.1kHz,而录音的采样率则固定为8kHz。为了确保音频设备的正常工作,底层驱动必须预先设定这些固定的采样率。当上层应用提供的采样率与这些预设值不匹配时,需要通过重采样(resample)技术来调整采样率,以保证音频数据的正确处理和传输。本文将详细探讨FFMpeg在音频处理中的基础理论及重采样技术的应用。 ... [详细]
  • 本文整理了一份基础的嵌入式Linux工程师笔试题,涵盖填空题、编程题和简答题,旨在帮助考生更好地准备考试。 ... [详细]
  • 本文介绍了如何使用Python爬取妙笔阁小说网仙侠系列中所有小说的信息,并将其保存为TXT和CSV格式。主要内容包括如何构造请求头以避免被网站封禁,以及如何利用XPath解析HTML并提取所需信息。 ... [详细]
  • malloc 是 C 语言中的一个标准库函数,全称为 memory allocation,即动态内存分配。它用于在程序运行时申请一块指定大小的连续内存区域,并返回该区域的起始地址。当无法预先确定内存的具体位置时,可以通过 malloc 动态分配内存。 ... [详细]
  • 本文详细介绍了如何使用Python的多进程技术来高效地分块读取超大文件,并将其输出为多个文件。通过这种方式,可以显著提高读取速度和处理效率。 ... [详细]
  • 本文节选自《NLTK基础教程——用NLTK和Python库构建机器学习应用》一书的第1章第1.2节,作者Nitin Hardeniya。本文将带领读者快速了解Python的基础知识,为后续的机器学习应用打下坚实的基础。 ... [详细]
  • 在处理 XML 数据时,如果需要解析 `` 标签的内容,可以采用 Pull 解析方法。Pull 解析是一种高效的 XML 解析方式,适用于流式数据处理。具体实现中,可以通过 Java 的 `XmlPullParser` 或其他类似的库来逐步读取和解析 XML 文档中的 `` 元素。这样不仅能够提高解析效率,还能减少内存占用。本文将详细介绍如何使用 Pull 解析方法来提取 `` 标签的内容,并提供一个示例代码,帮助开发者快速解决问题。 ... [详细]
author-avatar
没什么65丶1_750
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有