基础讲解
1.TCP通信流程
基于TCP通信的Socket基本流程:
1.1 Socket
函数返回值:一个文件描述符: 特别的两个队列。
#include <sys/types.h>
#include <sys/socket.h>
//create an endpoint for communication
int socket(int domain, // 协议:AF_INET (IPv4)、AF_INET6 (IPV6)....int type, // 套接字类型: SOCK_STREAM (TCP)、SOCK_DGRAM (UDP)....int protocol// 协议:IPPROTO_TCP (TCP)、IPPTOTO_UDP (UDP)...; 当protocol为0时,会自动选择type类型对应的默认协议。
);
// 返回值: 返回值是一个非负整数, 代表一个文件描述符,用于标识创建的套接字,并通过这个描述符进行后续的网络I/O操作。
setsockopt
补充使用:防止系统断线后,重连等待!
1.2 Bind
绑定地址: 使用 bind函数
给 socket端点
绑定端口和IP (函数参考: man 2 bind)
#include <sys/types.h>
#include <sys/socket.h>
//bind a name to a socket
int bind(int sockfd, // socket端点文件描述符const struct sockaddr *addr,// 要绑定的IP地址和端口号socklen_t addrlen // 指定的addr代表结构体长度,确保bind函数可以正确解析给定的地址信息:sizeod(addr)
);
//返回值: 成功时返回0。失败返回-1
-
const struct sockaddr *addr参数: 该参数用于提供给socket端点IP和端口信息, 但是
sockaddr
是一个通用的地址结构,实际使用的时候还是要使用sockaddr_in (IPv4)
,sockaddr_in6 (IPv6)
。 -
在选择端口号设置时, 建议应当避开知名端口号的范围(<1024)。
-
使用bind 函数时要注意其地址是大端法描述的,可能需要执行强制类型转换。
-
IP设置:
-
当服务端设置监听IP地址时,对于IPv4,有几个特殊的IP地址可以使用:0.0.0.0 // 表示服务端愿意接受指向服务器主机的任何IP地址的连接。 自己主机IP // 无需赘述, 最正常操作 127.0.0.1 // 这个地址用于测试和开发,仅允许接收来自本机的回环连接。
1.3 Listen
设置监听: 使用listen函数
对设置好端口和IP的服务端socket端点
监听外部连接请求 (函数参考: man 2 listen)
#include <sys/types.h>
#include <sys/socket.h>
//listen for connections on a socket
int listen(int sockfd, // socket端点文件描述符int backlog // 这个参数指定了套接字可以挂起的最大连接数
);
//返回值: 成功返回0, 失败返回-1
- 一旦启用了listen之后,操作系统就知道该套接字是服务端的套接字,操作系统内核就不再启用其发送和接收缓冲区(回收空间),转而在内核区维护两个队列结构: 半连接队列和全连接队列。
1. 代码示例:
用户端
#include "threadPool.h"
//main.c 只调用一次 tcpInit(argv[1],argv[2],&sockfd); //连接的队列
int tcpInit(const char *ip,const char* port, int *psockfd){ //(固定用法)// socket ---setsockopt--- bind--- listen//返回值:socket() 返回一个文件描述符 *psockfd,它代表新创建的套接字,用于后续的网络操作。*psockfd = socket(AF_INET,SOCK_STREAM,0); //ipv4 tcp 默认tcp 0 这里的调用指针的!(生成2队列!)//(固定用法)防止Time_wait函数 不让重连int reuse = 1;int ret = setsockopt(*psockfd,SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse)); ERROR_CHECK(ret,-1,"setsockopt");// (固定用法)struct sockaddr_in addr; //为bind准备入参 ipv4addr.sin_family = AF_INET;addr.sin_port = htons(atoi(port));//端口addr.sin_addr.s_addr = inet_addr(ip);//ipret = bind(*psockfd,(struct sockaddr *)&addr,sizeof(addr));//固定用法 ERROR_CHECK(ret,-1,"bind");listen(*psockfd,50); //socket 制造的队列限制return 0;
}
客户端