首页
下载
课程学习 存储 区块链 人工智能 游戏开发 音视频 跨平台 大数据 云计算 考试认证 信息化 服务器应用 行业 数据库 安全技术 操作系统 网络技术 编程语言 移动开发
代码
开发工具和环境 操作系统 网络和安全 排序算法 移动开发 后端开发 前端开发 数据库 开发语言
首页
代码
大数据
正文

TCP套接字编程模型及实例

作者：佚名 上传时间：2019-04-20 版权申诉

摘要：

本文讲述了TCP套接字编程模块，包括服务器端的创建套接字、绑定、监听、接受、读/写、终止连接，客户端的创建套接字、连接、读/写、终止连接。先给出实例，进而结合代码分析。

PS：本文权当复习套接字编程的读书笔记。

一、TCP套接字编程模型

同一台计算机上运行的进程可以利用管道、消息队列、信号量、共享内存等进行相互通信，不同计算机上运行的进程可以通过 套接字网络IPC接口 进行相互通信。套接字编程基本步骤如下图所示：

TCP套接字编程模型及实例

图 TCP套接字编程模型[1]

二、源代码

本实例旨在实现简单的echo服务，客户端发送数据给服务端，在服务端打印出来并且回发给客户端，并在客户端显示。

TCP_socket_programming_example源文件 TCP_socket_programming_example.rar

2.1 TCP服务端

  1. //filename:TCPserver.c
  2. #include 
  3. #include 
  4. #include 
  5. #include 
  7. #define BACKLOG 10
  8. #define BUFFER_SIZE 1024
  10. int main(int argc, char *argv[])
  11. {
  12. if(2 != argc)
  13. {
  14. printf("Usage:%s portnumber\n", argv[0]);
  15. return - 1;
  16. }
  18. /***1.create a socket***/
  19. int fd_server = socket(AF_INET, SOCK_STREAM, 0); //TCP
  20. if( - 1 == fd_server)
  21. {
  22. printf("%s\n", strerror(errno));
  23. return - 1;
  24. }
  26. /***2.bind the socket***/
  27. int listen_port = atoi(argv[1]);
  28. struct sockaddr_in addr_server;
  29. //memset(&addr_server, 0, sizeof(addr_server));
  30. addr_server.sin_family = AF_INET;
  31. addr_server.sin_port = htons(listen_port);
  32. addr_server.sin_addr.s_addr = htonl(INADDR_ANY);
  34. if(bind(fd_server, (struct sockaddr*) &addr_server, sizeof(addr_server)) == - 1)
  35. {
  36. printf("%s\n", strerror(errno));
  37. return - 1;
  38. }
  40. /***3.listen the socket***/
  41. if(listen(fd_server, BACKLOG) == - 1)
  42. {
  43. printf("%s\n", strerror(errno));
  44. return - 1;
  45. }
  47. /***4.accept the requirement of some client***/
  48. struct sockaddr_in addr_client;
  49. int len_addr_client = sizeof(addr_client);
  50. int fd_client = accept(fd_server, (struct sockaddr*) &addr_client, &len_addr_client);
  51. if( - 1 == fd_client)
  52. {
  53. printf("%s\n", strerror(errno));
  54. return - 1;
  55. }
  57. /****5.serve the client******/
  58. char buf[BUFFER_SIZE];
  59. int size;
  60. while(1)
  61. {
  62. /***read from client***/
  63. size = recv(fd_client, buf, sizeof(buf), 0);
  64. buf[size] = '\0';
  65. printf("%s\n", buf);
  67. /***write to client***/
  68. size = send(fd_client, buf, strlen(buf), 0);
  69. }
  71. /****6.close the socket******/
  72. close(fd_server);
  73. close(fd_client);
  74. }

2.2 TCP客户端

点击(此处)折叠或打开

  1. //filename:TCPclient.c
  2. #include 
  3. #include 
  4. #include 
  5. #include 
  7. #define BUFFER_SIZE 1024
  9. int main(int argc, char *argv[])
  10. {
  11. if(3 != argc)
  12. {
  13. printf("Usage:%s hostname portnumber\n", argv[0]);
  14. return - 1;
  15. }
  17. /***1.create a socket***/
  18. int fd_client = socket(AF_INET, SOCK_STREAM, 0); //TCP
  19. if( - 1 == fd_client)
  20. {
  21. printf("%s\n", strerror(errno));
  22. return - 1;
  23. }
  24. /***2.connect to the server***/
  25. int portnumber = atoi(argv[2]);
  26. struct sockaddr_in addr_server;
  27. addr_server.sin_family = AF_INET;
  28. addr_server.sin_port = htons(portnumber);
  29. if(0 == inet_pton(AF_INET, argv[1], (void*) &addr_server.sin_addr.s_addr))
  30. {
  31. printf("Invalid address.\n");
  32. return - 1;
  33. }
  35. if(connect(fd_client, (struct sockaddr*) &addr_server, sizeof(addr_server)) == - 1)
  36. {
  37. printf("%s\n", strerror(errno));
  38. return - 1;
  39. }
  42. /****3.get the server******/
  43. char buf[BUFFER_SIZE];
  44. int size;
  45. while(1)
  46. {
  47. /***write to server***/
  48. scanf("%s", buf);
  49. size = send(fd_client, buf, strlen(buf), 0);
  51. /***read from server***/
  52. size = recv(fd_client, buf, BUFFER_SIZE, 0);
  54. buf[size] = '\0';
  55. printf("%s\n", buf);
  57. }
  58. /****4.close the socket******/
  59. close(fd_client);
  60. }

2.3 测试结果

$ ./TCPserver 2000

TCP套接字编程模型及实例

$ ./TCPclient 127.0.0.1 2000

TCP套接字编程模型及实例

三、源码分析

3.1 创建套接字

  1. int socket(int domain, int type, int protocol);//成功返回套接字描述符.出错返回-1

这一步事实上是确定 通信特征 ，各个域domain有自己的格式表示地址，以AF_开头(address family)；type确定套接字类型，如数据报、字节流；协议protocol对同一个域和套接字类型支持的多个协议进行选择，通常为0，即按给定的域和套接字类型选择默认的协议。典型的TCP、UDP如下：

  1. TCP：(AF_INET, SOCK_DGRAM, 0)
  3. UDP：(AF_INET, SOCK_STREAM, 0)

注：

尽管套接字本质是文件描述符，但不是所有用于文件操作的函数都能用于套接字操作，比如lseek，套接字不支持文件偏移量。

3.2 绑定

  1. int bind(int sockfd, const struct sockaddr *addr, socklen_t len);//成功返回0.出错返回-1

bind函数用于将地址绑定到一个套接字。 服务器需要给一个接收客户端请求套接字绑定一个众所周知的地址， 而客户端可以让系统选一个默认地址绑定(无须绑定)。

(1) 套接字地址sockaddr_in

在IPv4因特网域AF_INET中，套接字地址用结构sockaddr_in表示，如下：

  1. struct sockaddr_in
  2. {
  3. sa_family_t sin_family; //unsigned short 地址族
  4. in_port_t sin_sport; //uint16_t
  5. struct in_addr sin_addr; //IPv4
  6. };
  8. struct in_addr
  9. {
  10. in_addr_t s_addr; //uint32_t
  11. };

注：

初始化sockaddr_in结构体时，因为sin_port和sin_addr被封装在网络传输，所以端口号和地址必须用网络字节序；而sin_family只是被内核用来决定数据结构包含什么类型的地址，没有发送到到网络，应该是本机字节顺序。处理器与网络字节序之间转换函数为htonl、htons、ntohl、ntohs(h指host主机，n指network网络，l指long32位，s指short16位)。

理论上，端口号可以是0~65535，但1~1023已由IANA管理，绑定时端口号不少于1024[2]。

此处的地址s_addr是二进制地址格式，如果参数是点分十进制字符串表示，则需通过 函数inet_ntop(将网络字节序的二进制地址转换成点分十进制字符串表示)、inet_pton进行相互转换 。其转换过程如下：

  1. 127.0.0.1 --> 7F.0.0.1 --> 100007F=16777343(网络字节序为大端)

如果地址s_addr为ANADDR_ANY，套接字端点可以被绑定到所有系统网络接口，即可以收到这个系统所安装的所有网卡的数据包。

(2) 通用地址格式sockaddr

地址格式与特定的通信域有关(如AF_INET、AF_INET6)，为使不同地址格式地址能够传入套接字函数，地址被强制转换成通用的地址结构sockaddr，如下(以Linux为例)：

  1. struct sockaddr
  2. {
  3. unsigned short sa_family; /* address family, AF_xxx */
  4. char sa_data[14]; /* 14 bytes of protocol address */
  5. };

3.3 监听listen

  1. int listen(int sockfd, int backlog);//成功返回0，出错返回-1

一旦服务器调用listen，套接字就能接收连接请求。backlog用于表示该进程所要入队的连接请求数量，实际值由系统决定，但上限由SOMAXCONN指定。一旦队列满，系统会拒绝多余连接请求。

3.4 接受连接请求accept

  1. //成功返回套接字描述符，出错返回-1
  2. int accept(int sockfd, struct sockaddr *restrict addr, socklen_t *restrict len);

使用accept获得连接请求并建立连接， 新的套接字描述符连接到调用connect的客户端 。传给accept的原始套接字(sockfd)没有关联到这个连接，而是接收保持可用状态并接受其他请求连接，这样做是为了使新的套接字描述符和原始套接字具有相同的地址族domain和套接字类型type。

如果服务器调用accept并且当前没有连接请求，服务器会阻塞直到一个请求到来。 如果不关心客户端标识，可以将参数addr和len设为NULL。

注：

关键字restrict是C99新引入的，所有修改该指针所指向内容的操作全部都是基于(base on)该指针的，即不存在其它进行修改操作的途径；从而帮助编译器进行更好的代码优化，生成更有效率的汇编代码[4]。

3.5 建立连接connect

  1. //成功返回0，出错返回-1
  2. int connect(int sockfd, const struct sockaddr *addr, socklen_t len);

addr是想与之通信的服务器地址，如果sockfd没有绑定到一个地址，connect会给调用者绑定一个默认的地址。成功连接需要以下条件：要连接的机器开启且正在运行，服务器绑定到一个想与之连接的地址，服务器的等待连接队列有足够的空间。

3.6 读取数据

  1. ssize_t read(int fd, void *buf, size_t nbytes); //成功返回读到的字节数，已到文件末尾返回0，出错返回-1
  3. ssize_t recv(int sockfd, const void *buf, size_t nbytes, int flags); //成功返回字节计数的消息长度，无可用消息或对方已经按序结束返回0，出错返回-1
  5. ssize_t recvfrom(int sockfd,void *restrict buf, size_t len, int flags, struct sockaddr *restrict addr, socketlen_t *restruct addrlen); //成功返回字节计数的消息长度，无可用消息或对方已经按序结束返回0，出错返回-1
  7. ssize_t recvmsg(int sockfd, struct msghdr *msg, int flags);//成功返回字节计数的消息长度，无可用消息或对方已经按序结束返回0，出错返回-1

可以使用read通过套接字通信，但 read只能交换数据 ，若想指定选项、从多个客户端接收数据包，则需选择套接字函数 recv(指定标志控制接收数据的方式)、recvfrom(得到数据发送者的源地址)、resvmsg(将接收到数据送入多个缓冲区或接收辅助数据)。

TCP套接字编程模型及实例

3.7 写入数据

  1. ssize_t write(int fd, void *buf, size_t count); //成功返回写入字节数，出错返回-1
  3. ssize_t send(int sockfd, const void *buf, size_t nbytes, int flags); //成功返回发送的字节数，出错返回-1
  5. ssize_t sendto(int sockfd, const void *buf, size_t nbytes, int flags,
  6. const struct sockaddr *destaddr, socklen_t destlen); //成功返回发送的字节数，出错返回-1
  8. ssize_t sendmsg(int sockfd, const struct msghdr *msg, int flags); //成功返回发送的字节数，出错返回-1

注：send与sendto的flags含义相同，sendmsg的flags与前两者不同

可以使用write通过套接字通信，但 write只能交换数据，若想指定选项、发送带外数据 ，则需选择套接字函数 send(指定标志改变处理传输数据的方式)、sendto(允许无连接的套接字上指定一个目标地址)、sendmsg(指定多重缓冲传输数据)。

TCP套接字编程模型及实例

3.8 终止连接

  1. int close(int fd); //成功返回0，出错返回-1
  3. int shutdown(int sockfd, int how);//成功返回0，出错返回-1

关闭套接字close只有在最后一个活动引用被关闭后才释放网络端点，而shutdown提供更精细的控制，套接字通信是双向的，可以用shutdown禁止套接字上的输入/输出，即how为SHUT_RD、SHUT_WR、SHUT_RDWR。除此之外，shutdown允许使一个套接字处于不活动状态(不管引用它的文件描述符数目多少)，便于复制一个套接字(如dup)。

参考资料：

[1] 百度文库《 互联网络程序设计第3章 》

[2] 《UNIX环境高级编程》[M].

[3] 维基百科词条： TCP/UDP端口列表

[4] 博文《 C99中的restrict关键字 》

套接字调用标志源文件 套接字调用标志.xls

from:http://blog.chinaunix.net/uid-9112803-id-3199813.html

免责申明：文章和图片全部来源于公开网络，如有侵权，请通知删除 server@dude6.com

用户评论
相关推荐
TCP套接字编程模型及实例
摘要： 本文讲述了TCP套接字编程模块，包括服务器端的创建套接字、绑定、监听、接受、读/写、终止连接，客户端的创建套接
TCP/IP套接字编程实例及技术解答
本示例演示了如何使用Python进行TCP/IP套接字编程，实现简单的客户端和服务器通信。通过创建套接字、绑定地址、监听连接请求以及发送和接收数据，展示了TCP/IP协议栈的基本功能。同时，提供了一些
Python 3.8
Python
2023-12-03 11:11
TCP/IP套接字编程实例解析
本文将介绍TCP/IP编程实例，包括套接字编程案例、示例代码以及代码释义。最后，我们还将对TCP/IP套接字编程进行总结。套接字编程案例在本节中，我们将提供一些套接字编程案例，这些案例将帮助您更好
6.0
Visual Studio
2023-03-16 04:08
TCP/IP套接字编程实例 - Python
TCP/IP是一种常见的网络通信协议，用于在计算机之间进行数据传输。套接字编程是一种用于实现网络通信的方法，允许开发人员创建网络应用程序。这个示例演示了如何使用Python编写一个简单的TCP/IP服
Python 3.x
Python编程语言
2023-10-22 12:09
TCP套接字编程
TCP套接字编程——网络编程综合性试验介绍
DOC
0B
2019-07-29 16:43
TCP/IP套接字编程实例及问题解答
本文提供一个基于TCP/IP协议的套接字编程示例，涵盖了连接、数据传输和关闭连接的全过程。同时解答了一些常见问题，包括超时处理、错误处理等。# 导入socket库import socket#
Python 3.8.5
Python
2023-11-17 17:21
iOS套接字编程TCP
简单的一个demo，模拟了真实的套接字编程过程。便于初学者学习
ZIP
0B
2019-02-19 07:14
TCP/IP套接字编程实例与技术解答
本示例演示了使用Python进行TCP/IP套接字编程的实例，包括创建套接字、建立连接、发送和接收数据。通过详细注释和解释，展示了TCP/IP通信的基本功能和相关技术解答。# 导入socket库i
Python 3.x
Python
2023-11-19 15:19
tcp套接字编程不含界面
使用tcp套接字进行编程，含有客户端和服务器端程序，有助于理解tcp套接字编程和tcp协议的三次握手
ZIP
0B
2019-01-04 06:18
TCP/IP套接字编程实例：简单聊天室
通过TCP/IP套接字编程实现一个简单的聊天室，使用Python语言和socket库。通过服务器和多个客户端之间的数据传输，展示基本的网络通信原理。# 服务器端代码import socket#
Python 3.x
Python
2023-11-24 16:08