socket编程

什么是socket(套接字)

socket是一种计算机间约定好的传输方式(有点抽象)。其本身为一串数字,unix将一切视为文件。每个文件都有自己的文件标识符(一串数字),那么网络连接也是一个文件,他的文件标识符就是socket。

  • IP

    • IPv4:一个32位整型数,4个字节,表现为点分十进制字符串,eg:192.168.247.135

    • IPv6:一个128位整形,十六个字节,分成八份。每份两个字节,用十六进制表示,0000-ffff。eg:2001:0db8:3c4d:0015:0000:0000:1a2f:1a2b

    • 如何查看本机IP?

      打开CMD,输入ipconfig

  • 端口

    • 端口的作用是定位到主机上的某一个进程。
    • 一个unsigned short,十六位,0~65535

网络分层模型OSI/ISO

分若干层,长这样:

TCP、UDP属于传输层协议,IPv4、IPv6属于网络层协议。

  • 我们只需处理应用层数据,并指定传输层、网络层所用协议即可。

大小端及其转换

  • 小端:主机字节序

    • 数据的低位字节存储到内存的低地址位 , 数据的高位字节存储到内存的高地址位。
    • 0x12345678 ---->> 78 56 34 12 内存地址低—>高
  • 大端:网络字节序

    • 据的低位字节存储到内存的高地址位 , 数据的高位字节存储到内存的低地址位。
    • 0x12345678 ---->> 12 34 56 78 内存地址低—>高
    // 有一个16进制的数, 有32位 (int): 0xab5c01ff
    // 字节序, 最小的单位: char 字节, int 有4个字节, 需要将其拆分为4份
    // 一个字节 unsigned char, 最大值是 255(十进制) ==> ff(16进制) 
                     内存低地址位                内存的高地址位
    --------------------------------------------------------------------------->
    小端:         0xff        0x01        0x5c        0xab
    大端:         0xab        0x5c        0x01        0xff
    
  • 转换:

    • 一般转换

    一般pc机用小端方式储存数据,那么我们在发送数据前,就要将数据从小端转换为大端。接收到数据后,又要从大端转换为小端。

    #include <arpa/inet.h>
    // u:unsigned
    // 16: 16位, 32:32位
    // h: host, 主机字节序
    // n: net, 网络字节序
    // s: short
    // l: int
    
    // 这套api主要用于 网络通信过程中 IP 和 端口 的 转换
    // 将一个短整形从主机字节序 -> 网络字节序
    uint16_t htons(uint16_t hostshort);   
    // 将一个整形从主机字节序 -> 网络字节序
    uint32_t htonl(uint32_t hostlong);    
    
    // 将一个短整形从网络字节序 -> 主机字节序
    uint16_t ntohs(uint16_t netshort)
    // 将一个整形从网络字节序 -> 主机字节序
    uint32_t ntohl(uint32_t netlong);
    
    • IP地址转换

    IP地址虽为整形(int,4字节),但实际以字符串来表示。以下函数可将字符串类型的IP地址进行大小端转换。

    // 主机字节序的IP地址转换为网络字节序
    // 主机字节序的IP地址是字符串, 网络字节序IP地址是整形
    int inet_pton(int af, const char *src, void *dst); 
    

    af:

    AF_INET: ipv4 格式的 ip 地址,

    AF_INET6: ipv6 格式的 ip 地址

    src:

    要转换的ip地址:102.168.0.1

    dst:

    一个指针,转换得到的大端整形IP地址被放入这块内存。

     #include <arpa/inet.h>
     // 将大端的整形数, 转换为小端的点分十进制的IP地址        
     const char *inet_ntop(int af, const void *src, char *dst, socklen_t size);
    

    与上相似,size为dst内存的大小。

TCP流程

Server:

  1. 建立用于监听的套接字:

    SOCKET socket(int af, int type, int protocol);
    

    af:AF_INET or AF_INET6,代表IPV4、IPV6(PF一样)

    type:SOCK_STREAM or SOCK_DGRAM,前者对应TCP,后者对应UDP

    protocol:IPPROTO_TCP or IPPTOTO_UDP,也可赋0,表示根据前两个参数自行选取。

  1. 监听套接字本机的IP、端口绑定。(填写自己的地址)

    int bind(int sockfd, const struct sockaddr *addr, socklen_t addrlen);
    

    参数:

    sockfd:上一步得到的用于监听的描述符

    *addr:一个指向sockaddr类型结构体的指针,其中存储着本地的IP地址以及端口。

    • sockaddr结构体长这样:

      struct sockaddr{
          sa_family_t  sin_family;   //地址族(Address Family),也就是地址类型,16个字节,AF_INET
          char         sa_data[14];  //IP地址+端口号,端口2字节,IP地址4字节,空闲(0)8个字节
      };
      

      第二项将IP与端口揉在一起,不好填。我们用sockaddr_in填

    • sockaddr_in结构体长这样:

      struct sockaddr_in{
          sa_family_t     sin_family;   //地址族(Address Family),也就是地址类型
          uint16_t        sin_port;     //16位的端口号
          struct in_addr  sin_addr;     //32位IP地址
          char            sin_zero[8];  //不使用,一般用0填充
      };
      
      //其中,in_addr长这样:
      struct in_addr{
          in_addr_t  s_addr;  //32位的IP地址。in_addr_t 在头文件 <netinet/in.h> 中定义,等价于 unsigned long
      };
      
  • 使用中,先使用sockaddr_in初始化,再将其转换为sockaddr类型。如下例:

    //创建套接字
    int serv_sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    
    //创建sockaddr_in结构体变量
    struct sockaddr_in serv_addr;
    memset(&serv_addr, 0, sizeof(serv_addr));  //每个字节都用0填充
    serv_addr.sin_family = AF_INET;  //使用IPv4地址
    serv_addr.sin_addr.s_addr = inet_addr("127.0.0.1");  //具体的IP地址
    serv_addr.sin_port = htons(1234);  //端口
    
    //将套接字和IP、端口绑定
    connect(serv_sock, (struct sockaddr*)&serv_addr, sizeof(serv_addr));
    

addrlen:参数2所对应结构体内存的大小,由sizeof计算得出。

成功返回0,失败返回-1。

  1. 设置监听,监听有无客户端连接。

    int listen(SOCKET sock, int backlog);
    

    让套接字进入被动监听状态。

    backlog :为请求队列的最大长度。

    请求队列:

    当套接字正在处理客户端请求时,如果有新的请求进来,套接字是没法处理的,只能把它放进缓冲区,待当前请求处理完毕后,再从缓冲区中读取出来处理。如果不断有新的请求进来,它们就按照先后顺序在缓冲区中排队,直到缓冲区满。这个缓冲区,就称为请求队列(Request Queue)。

    缓冲区的长度(能存放多少个客户端请求)可以通过 listen() 函数的 backlog 参数指定,但究竟为多少并没有什么标准,可以根据你的需求来定,并发量小的话可以是10或者20。

    如果将 backlog 的值设置为 SOMAXCONN,就由系统来决定请求队列长度,这个值一般比较大,可能是几百,或者更多。

    当请求队列满时,就不再接收新的请求,对于 Linux,客户端会收到 ECONNREFUSED 错误,对于 Windows,客户端会收到 WSAECONNREFUSED 错误。

    注意:listen() 只是让套接字处于监听状态,并没有接收请求。接收请求需要使用 accept() 函数。

    成功返回0,失败返回-1

  1. 等待客户端连接请求,不来就阻塞,来了就建立新的连接,得到新的用于通信的套接字

    SOCKET accept(SOCKET sock, struct sockaddr *addr, int *addrlen);
    

    参数同bind。

    不同的是,bind中sockaddr保存的是本机的IP与端口,而此函数中的sockaddr需要新建一个结构体,不用初始化,执行函数时会自动保存客户端的IP地址与端口号。

    accept() 返回一个新的套接字来和客户端通信,addr 保存了客户端的IP地址和端口号,而 sock 是服务器端的套接字。后面和客户端通信时,要使用这个新生成的套接字,而不是原来服务器端的套接字。

    最后需要说明的是:listen() 只是让套接字进入监听状态,并没有真正接收客户端请求,listen() 后面的代码会继续执行,直到遇到 accept()。accept() 会阻塞程序执行(后面代码不能被执行),直到有新的请求到来。

  1. 收发文件

    int send(SOCKET sock, const char *buf, int len, int flags);
    

    sock:即用于通信的socket,也就是accept等号左边那玩意。

    buf:指向一块内存。注意,const只读,也就是说我们只读这块内存的数据,不用写。*

    len:内存的大小

    flags:特殊的属性,一般不使用,指定为0

    返回:大于0-->实际发送的字节数,等于0-->对方断开连接,-1-->接受失败

int recv(SOCKET sock, char *buf, int len, int flags);

这里的*buf是可以写的。

  1. 关闭套接字

    close(SOCKET sock)

Client:

  1. 创建用于通信的套接字

    socket()

  2. 连接服务器,需要知道服务器的IP与端口

    connect()

    int connect(SOCKET sock, const struct sockaddr *addr, int addrlen); 
    

    参数与bind、accept一样。

    其中,sockaddr存的是本机(Client)的IP与端口,所以与bind完全一致,要初始化。

  3. 收发文件

    send、recv

  4. 关闭套接字

    close()

[图片上传失败...(image-a27a45-1648644517809)]

程序实例

服务器端代码 server.cpp

#include <stdio.h>
#include <winsock2.h>
#pragma comment (1lib, "ws2_32.lib")  //加载 ws2_32.dll
int main(){
    //初始化 DLL
    WSADATA wsaData;
    WSAStartup( MAKEWORD(2, 2), &wsaData);
    
    //创建套接字
    //PF_INET:IPV4地址,SOCK_STREAM:面向联接的传输方式(另一种SOCK_DGRAM),IPPROTO_TCP:使用TCP协议
    SOCKET servSock = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP);
    
    //绑定套接字
    sockaddr_in sockAddr; //sockaddr_in是包中定义好的结构体
    memset(&sockAddr, 0, sizeof(sockAddr));  //每个字节都用0填充,void* memset(起始指针,填充数值,内存长度),给指定内存赋值
    sockAddr.sin_family = PF_INET;  //使用IPv4地址
    sockAddr.sin_addr.s_addr = inet_addr("127.0.0.1");  //具体的IP地址
    sockAddr.sin_port = htons(1234);  //端口
    bind(servSock, (SOCKADDR*)&sockAddr, sizeof(SOCKADDR)); //将套接字servSock与特定IP地址与端口绑定。
    
    //进入监听状态,让套接字处于被动监听状态。所谓被动监听,是指套接字一直处于“睡眠”中,直到客户端发起请求才会被“唤醒”
    listen(servSock, 20);
    
    //接收客户端请求
    SOCKADDR clntAddr;
    int nSize = sizeof(SOCKADDR);
    SOCKET clntSock = accept(servSock, (SOCKADDR*)&clntAddr, &nSize); //accept() 函数用来接收客户端的请求。程序一旦执行到 accept() 就会被阻塞(暂停运行),直到客户端发起请求。
    
    //向客户端发送数据
    char *str = "Hello World!";
    send(clntSock, str, strlen(str)+sizeof(char), NULL);
    
    //关闭套接字
    closesocket(clntSock);
    closesocket(servSock);
    
    //终止 DLL 的使用
    WSACleanup();
    
    return 0;
}

客户端代码 client.cpp

#include <stdio.h>
#include <stdlib.h>
#include <WinSock2.h>
#pragma comment(lib, "ws2_32.lib")  //加载 ws2_32.dll
int main(){
    //初始化DLL
    WSADATA wsaData;
    WSAStartup(MAKEWORD(2, 2), &wsaData);
    
    //创建套接字
    SOCKET sock = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP);
    
    //向服务器发起请求
    sockaddr_in sockAddr;
    memset(&sockAddr, 0, sizeof(sockAddr));  //每个字节都用0填充
    sockAddr.sin_family = PF_INET;
    sockAddr.sin_addr.s_addr = inet_addr("127.0.0.1");
    sockAddr.sin_port = htons(1234);
    connect(sock, (SOCKADDR*)&sockAddr, sizeof(SOCKADDR)); // connect() 向服务器发起请求,直到服务器传回数据后,connect() 才运行结束。
    
    //接收服务器传回的数据
    char szBuffer[MAXBYTE] = {0};
    recv(sock, szBuffer, MAXBYTE, NULL);
    
    //输出接收到的数据
    printf("Message form server: %s\n", szBuffer);
    
    //关闭套接字
    closesocket(sock);
    
    //终止使用 DLL
    WSACleanup();
    system("pause");
    
    return 0;
}

WSAStartup()

int WSAStartup(WORD wVersionRequested, LPWSADATA lpWSAData);

初始化。

wVersionRequested 为 WinSock 规范的版本号,低字节为主版本号,高字节为副版本号(修正版本号);WinSock 规范的最新版本号为 2.2。

lpWSAData 为指向 WSAData 结构体的指针。

具体实例:

WSADATA wsaData;
WSAStartup(MAKEWORD(2, 2), &wsaData); //2.2
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 199,830评论 5 468
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 83,992评论 2 376
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 146,875评论 0 331
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 53,837评论 1 271
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 62,734评论 5 360
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,091评论 1 277
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,550评论 3 390
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,217评论 0 254
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,368评论 1 294
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,298评论 2 317
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,350评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,027评论 3 315
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,623评论 3 303
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,706评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 30,940评论 1 255
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 42,349评论 2 346
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 41,936评论 2 341

推荐阅读更多精彩内容