Day37 socket、TCP、UDP

socket类型

流式套接字(SOCK_STREAM) TCP

提供了一个面向连接、可靠的数据传输服务，数据无差错、无重复的发送且按发送顺序接收。内设置流量控制，避免数据流淹没慢的接收方。数据被看作是字节流，无长度限制。

数据报套接字(SOCK_DGRAM) UDP

提供无连接服务。数据包以独立数据包的形式被发送，不提供无差错保证，数据可能丢失或重复，顺序发送，可能乱序接收。

原始套接字(SOCK_RAW)

可以对较低层次协议如IP、ICMP直接访问。
在这里插入图片描述
服务器：
1.创建流式套接字（socket()）------------------------> 有手机
2.指定本地的网络信息（struct sockaddr_in）----------> 有号码
3.绑定套接字（bind()）------------------------------>绑定电话
4.监听套接字（listen()）---------------------------->待机
5.链接客户端的请求（accept()）---------------------->接电话
6.接收/发送数据（recv()/send()）-------------------->通话
7.关闭套接字（close()）----------------------------->挂机

客户端：
1.创建流式套接字（socket()）----------------------->有手机
2.指定服务器的网络信息（struct sockaddr_in）------->有对方号码
3.请求链接服务器（connect()）---------------------->打电话
4.发送/接收数据（send()/recv()）------------------->通话
5.关闭套接字（close()）--------------------------- >挂机

函数接口

socket

int socket(int domain, int type, int protocol);
//作用：创建一个socket通信描述符
domain：指定通信的域（通信协议）
    AF_UNIX, AF_LOCAL   本地通信
    AF_INET  ipv4
    AF_INET6  ipv6
type：指定socket的类型
    SOCK_STREAM：流式套接字，接下来我们的通信使用TCP协议
    SOCK_DGRAM：数据报套接字，接下来我们的通信使用UDP协议
protocol：填0    

返回值：如果成功，返回创建的描述符，如果失败，返回-1

connect

int connect(int sockfd, const struct sockaddr *addr,
                   socklen_t addrlen);
作用：请求连接服务器
参数：
sockfd：上面socket接口得到的描述符
addr：相当于服务器的地址（IP+port）
addrlen:地址的长度，因为前面的地址是可变的，所以要通过参数来协定地址的长度
返回值：
0 -1

sockaddr结构体

//从bind接口的帮助文档中拿到
struct sockaddr {
               sa_family_t sa_family;
               char        sa_data[14];
           }
上述地址结构是一个通用结构，我们在用实际协议进行通信的时候，需要转换成相应协议的结构体。
用man 7 ip来查看ipv4对应的结构体

struct sockaddr_in {
   sa_family_t    sin_family; /* 地址协议族，=socket接口第一个参数 */
   in_port_t      sin_port;   /* 指定端口，端口要用网络字节序(大端) */
   struct in_addr sin_addr;   /* IP地址 */
};

/* Internet address. */
struct in_addr {
   uint32_t       s_addr;     /* address in network byte order */
};

bind

int bind(int sockfd, const struct sockaddr *addr,
                socklen_t addrlen);
作用：绑定服务器地址：IP和端口，相当于对外公开自己的IP和端口，客户端就可以连接了
addr：绑定的IP和端口结构体，注意绑定的是自己的IP和端口
    IP：取真实的某个网卡的地址，也可以直接写0.0.0.0
addrlen：地址的大小

listen

int listen(int sockfd, int backlog);
作用：进入监听状态，以便接收客户端的连接
sockfd：上面的服务器描述符
backlog：同时能处理的客户端的连接数量，写个5 10都可以
返回值：0 -1

accept

int accept(int sockfd, struct sockaddr *addr, socklen_t *addrlen);
接收客户端连接，注意，这是一个阻塞接口，如果没有新的连接过来，那么会等待
sockfd：上面的服务器描述符
addr：客户端的地址(来电显示)
addrlen：客户端地址的长度，是入参，传入然后可能会被接口修改

返回值：如果成功，会返回一个非负的整数，代表接收的新的连接的描述符

recv/send

//recv和send是网络的专用接口，比起read和write只是多了一个flags参数，flag一般情况下会取0，代表阻塞接受和发送
ssize_t recv(int sockfd, void *buf, size_t len, int flags);
返回值：
    >0：接收的字节数
    <0：失败
    =0：代表对端退出了
ssize_t send(int sockfd, const void *buf, size_t len, int flags);

close

int close(int fd);
关闭套接字连接

示例代码

TCP客户端

#include <stdio.h>
#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>
#include <errno.h>
#include <string.h>
#include <unistd.h>
#include <netinet/in.h>
#include <netinet/ip.h> /* superset of previous */
#include <arpa/inet.h>

int main(int argc, char const *argv[])
{
    //创建套接字
    int fd = socket(AF_INET, SOCK_STREAM, 0);
    if(fd < 0)
    {
        perror("socket err");
        return -1;
    }

    //连接到服务器
    struct sockaddr_in server_addr;
    int len = sizeof(server_addr);
    
    //指定连接的服务器的地址（IP+port）
    memset(&server_addr, 0, len);
    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(8888);
    server_addr.sin_addr.s_addr = inet_addr("192.168.0.109");

    int ret = connect(fd, (struct sockaddr *)&server_addr, len);
    if(ret < 0)
    {
        perror("connect err");
        return -1;
    }

    printf("conect success\n");

    char buf[64] = {0};
    while (1)
    {
        memset(buf, 0, 64);
        //从终端接收用户输入，发给服务器，等待服务器的数据，打印
        gets(buf);
        if(strcmp(buf, "quit") == 0)
        {
            break;
        }

        send(fd, buf, 64, 0);

        memset(buf, 0, 64);
        ret = recv(fd, buf, 64, 0);
        if(ret > 0)
        {
            printf("recv data = %s\n", buf);
        }
        else if(ret == 0)
        {
            printf("peer exit\n");
            break;
        }
        else
        {
            perror("recv err\n");
            return -1;
        }
    }

    close(fd);
    

    return 0;
}

TCP服务器

#include <stdio.h>
#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>
#include <errno.h>
#include <string.h>
#include <unistd.h>
#include <netinet/in.h>
#include <netinet/ip.h> /* superset of previous */
#include <arpa/inet.h>

int main(int argc, char const *argv[])
{
    //创建服务器的套接字
    int server_fd = socket(AF_INET, SOCK_STREAM, 0);
    if(server_fd < 0)
    {
        perror("socket err");
        return -1;
    }

    //初始化服务器地址
    struct sockaddr_in server_addr, client_addr;
    int len = sizeof(server_addr);
    
    memset(&server_addr, 0, len);
    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(8888);
#if 0    
    server_addr.sin_addr.s_addr = inet_addr("192.168.0.194");
#else
    server_addr.sin_addr.s_addr = INADDR_ANY;
#endif
    //绑定套接字的地址
    int ret = bind(server_fd, (struct sockaddr *)&server_addr, len);
    if(ret < 0)
    {
        perror("bind err");
        return -1;
    }

    //启动监听
    ret = listen(server_fd, 5);
    if(ret < 0)
    {
        perror("listen err");
        return -1;
    }

    //接收连接
    int clientfd = accept(server_fd, (struct sockaddr *)&client_addr, &len);
    if(clientfd < 0)
    {
        perror("accept err");
        return -1;        
    }

    //打印客户端的地址，注意端口要转成主机字节序
    printf("recv a new connect, ip = %s, port=%d\n",\
            inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port));

    char buf[64] = {0};

    while (1)
    {
        memset(buf, 0, 64);
        //一旦新的连接过来后，后续通信统统使用新的描述符
        len = read(clientfd, buf, 64);
        if(len > 0)
        {
            printf("recv data = %s\n", buf);
        }
        else if(len == 0)
        {
            printf("client exit\n");
            break;
        }
        else
        {
            perror("recv err\n");
            return -1;
        }
    }
    
    close(clientfd);
    close(server_fd);

    return 0;
}

UDP

TCP和UDP的异同点

相同点：

同属于传输层协议

不同点：

TCP：流式套接字，面向连接的，可靠的通信
UDP：数据报套接字，无连接的，不可靠的通信

通信流程

在这里插入图片描述

接口

ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags,
                struct sockaddr *src_addr, socklen_t *addrlen);
作用：接收UDP对端发来的消息
sockfd：描述符
buf：接收缓冲区
len：缓冲区的长度
flags:填0，阻塞接收
src_addr：收到消息后，对端的地址存到这里（IP+PORT）
addrlen：src_addr缓冲区长度

ssize_t sendto(int sockfd, const void *buf, size_t len, int flags,
            const struct sockaddr *dest_addr, socklen_t addrlen);
作用：发送消息给UDP对端
sockfd：描述符
buf：发送缓冲区
len：发送的长度
flags:填0，阻塞发送
dest_addr：发送的目的地址（IP+PORT）
addrlen：dest_addr的长度

PS:UDP的端口和TCP的端口是独立的！！

代码示例

UDP服务器

#include <stdio.h>
#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>
#include <errno.h>
#include <string.h>
#include <unistd.h>
#include <netinet/in.h>
#include <netinet/ip.h> /* superset of previous */
#include <arpa/inet.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>

#define KB 1024

int main(int argc, char const *argv[])
{
    //创建服务器的套接字
    int server_fd = socket(AF_INET, SOCK_DGRAM, 0);
    if(server_fd < 0)
    {
        perror("socket err");
        return -1;
    }

    //初始化服务器地址
    struct sockaddr_in server_addr, client_addr;
    int len = sizeof(server_addr);
    
    memset(&server_addr, 0, len);
    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(8888);
#if 0 
    server_addr.sin_addr.s_addr = inet_addr("127.0.0.1");
#else
    server_addr.sin_addr.s_addr = INADDR_ANY;
#endif
    //绑定套接字的地址
    int ret = bind(server_fd, (struct sockaddr *)&server_addr, len);
    if(ret < 0)
    {
        perror("bind err");
        return -1;
    }

    //接收消息，收到客户端消息，然后把客户端的消息再返回给客户端
    char buf[KB] = {0};
    struct sockaddr_in cli_addr;

    socklen_t addrlen = sizeof(struct sockaddr_in);
    while (1)
    {
        memset(buf, 0, KB);
        //服务器一定是先接收的
        len = recvfrom(server_fd, buf, KB, 0,
                (struct sockaddr *)&cli_addr, &addrlen);
        if(len < 0)
        {
            perror("recv err");
            return -1;
        }

        printf("recv from %s--%d,data=%s\n", inet_ntoa(cli_addr.sin_addr),
                ntohs(cli_addr.sin_port), buf);

        //接收成功，而且对端地址存储到了cli_addr中
        sendto(server_fd, buf, len, 0,
            (struct sockaddr *)&cli_addr, addrlen);
    }

    close(server_fd);
    return 0;
}

UDP客户端

#include <stdio.h>
#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>
#include <errno.h>
#include <string.h>
#include <unistd.h>
#include <netinet/in.h>
#include <netinet/ip.h> /* superset of previous */
#include <arpa/inet.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>

#define KB 1024

int main(int argc, char const *argv[])
{
    //创建套接字
    int fd = socket(AF_INET, SOCK_DGRAM, 0);
    if(fd < 0)
    {
        perror("socket err");
        return -1;
    }

    //连接到服务器
    struct sockaddr_in server_addr;
    int len = sizeof(server_addr);
    
    //指定连接的服务器的地址（IP+port）
    memset(&server_addr, 0, len);
    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(8888);
    server_addr.sin_addr.s_addr = inet_addr("127.0.0.1");

    char buf[KB] = {0};
    socklen_t addrlen = sizeof(struct sockaddr_in);
    while (1)
    {
        memset(buf, 0, KB);
        gets(buf);
        sendto(fd, buf, strlen(buf), 0, (struct sockaddr *)&server_addr, addrlen);

        memset(buf, 0, KB);
        len = recvfrom(fd, buf, KB, 0, NULL, NULL);
        printf("recv from server data = %s\n", buf);
    }
    
    close(fd);

    return 0;
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/433851.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

寻找合适的分数线

寻找合适的分数线

解法&#xff1a; 统计个数用数组做桶即可 #include<iostream> #include<vector> #include<algorithm> using namespace std; #define endl \n int main() {vector<int> tong(301, 0);int n, m, a;cin >> n >> m;while (n--) {cin >&…
阅读更多...
C++——using 关键字

C++——using 关键字

C++——using 关键字 using 在C++中的用途有很多，是非常就经典的关键字复用，它的作用大致可以分为三类： using 指令using 声明using 别名1. using 指令 简单点说，using 指令只能作用于命名空间，引入命名空间中的名字。 2. using 声明 2.1 对命名空间成员的 using 声明 u…
阅读更多...
Android基础面试常常死在这几个问题上，大厂Android高级多套面试专题整理集合

Android基础面试常常死在这几个问题上，大厂Android高级多套面试专题整理集合

前言 本人毕业于非211、985一本&#xff0c;学的是计算机网络&#xff0c;大一在一位师哥的引导下接触了Android开发&#xff0c;随着近一步的接触&#xff0c;慢慢的喜欢上了Android开发。于是大二开始&#xff0c;我开始自学Android开发。 大四的时候开始找实习工作&#x…
阅读更多...
【OJ】日期差值与日期累加

【OJ】日期差值与日期累加

个人主页 &#xff1a; zxctscl 如有转载请先通知 文章目录 1. KY111 日期差值1.1 题目分析1.2 代码 2. KY258 日期累加2.1 题目分析2.2 代码 1. KY111 日期差值 1.1 题目分析 日期之间比较可能会出现给的两个年月日都不相同&#xff0c;这个就不好作差&#xff0c;每个月给的…
阅读更多...
【论文精读】大语言模型融合知识图谱的问答系统研究

【论文精读】大语言模型融合知识图谱的问答系统研究

&#x1f497;&#x1f497;&#x1f497;欢迎来到我的博客&#xff0c;你将找到有关如何使用技术解决问题的文章&#xff0c;也会找到某个技术的学习路线。无论你是何种职业&#xff0c;我都希望我的博客对你有所帮助。最后不要忘记订阅我的博客以获取最新文章&#xff0c;也欢…
阅读更多...
飞书云文档API操作详细介绍

飞书云文档API操作详细介绍

1.场景分析 公司内部很多文档都是由多人进行维护的&#xff0c;随时发生变更&#xff0c;因此在利用这些数据的时候就需要直接读取云文档的数据&#xff0c;从而执行下一步动作。团队云文档api执行权限一般需要管理员审核才能使用。如果你就是管理员&#xff0c;那么恭喜你&am…
阅读更多...
进程的奥德赛：并发世界中的核心概念与动态管理

进程的奥德赛：并发世界中的核心概念与动态管理

✨✨ 欢迎大家来访Srlua的博文&#xff08;づ&#xffe3;3&#xffe3;&#xff09;づ╭❤&#xff5e;✨✨ &#x1f31f;&#x1f31f; 欢迎各位亲爱的读者&#xff0c;感谢你们抽出宝贵的时间来阅读我的文章。 我是Srlua&#xff0c;在这里我会分享我的知识和经验。&#x…
阅读更多...
【轮式平衡机器人】——TMS320F28069片内外设之ePWM

【轮式平衡机器人】——TMS320F28069片内外设之ePWM

声明&#xff1a;本系列博客参考有关专业书籍&#xff0c;截图均为自己实操&#xff0c;仅供交流学习&#xff01; 引入 脉冲宽度调制&#xff08;PWM&#xff09;是一种对模拟信号进行数字编码的方法&#xff0c;硬件原理是根据相应载荷的变化来调制晶体管栅极或基极的偏置&…
阅读更多...
代码随想录算法训练营第11天

代码随想录算法训练营第11天

20. 有效的括号 方法&#xff1a; 1. 如果 !st.empty() return false2.如果st.top() ! s[i] return false3. 如果 st.empty() return false注意&#xff1a; 以下这种写法 不满足 题目要求的第二点&#xff0c;不能以正确的顺序闭合 if(s[i] st.top()){return true;s…
阅读更多...
世界级通讯社发稿-法新社海外发稿渠道-大舍传媒

世界级通讯社发稿-法新社海外发稿渠道-大舍传媒

世界级通讯社发稿-法新社海外发稿渠道-大舍传媒 美联社&#xff1a;全球最大的通讯社之一 美联社&#xff08;Associated Press&#xff09;是全球最大的通讯社之一&#xff0c;成立于1846年&#xff0c;总部位于美国纽约。该社拥有一支庞大的全球新闻团队&#xff0c;涵盖了…
阅读更多...
x86使用PID模式检测磁盘是否存在--代码实现

x86使用PID模式检测磁盘是否存在--代码实现

磁盘 视频教程以及实际代码可以看这一个教程 ATA PIO Mode - OSDev Wiki 下面的大部分来自这一个网址的翻译 在磁盘的第一个扇区里面可以有4个描述分区的描述符 电脑有两个总线, Primary Bus, Secondary Bus, 这两个都有一个Msater Driver和一个Slave Driver According to t…
阅读更多...
Ceph qos 限速

Ceph qos 限速

因为1 Mbps 1,000,000 bps rbd_qos_bps_limit、rbd_qos_read_bps_limit和rbd_qos_write_bps_limit都是与RBD&#xff08;Rados Block Device&#xff09;的QoS&#xff08;Quality of Service&#xff0c;服务质量&#xff09;相关的参数&#xff0c;用于限制I/O操作的速率。这…
阅读更多...
【EI会议征稿通知】第四届人工智能，大数据与算法国际学术会议 (CAIBDA 2024)

【EI会议征稿通知】第四届人工智能，大数据与算法国际学术会议 (CAIBDA 2024)

第四届人工智能&#xff0c;大数据与算法国际学术会议 (CAIBDA 2024) 2024 4th International Conference on Artificial Intelligence, Big Data and Algorithms 由河南省科学院、河南大学主办&#xff0c;河南省科学院智慧创制研究所、河南大学学术发展部、河南大学人工智能…
阅读更多...
【MATLAB源码-第157期】基于matlab的海马优化算法（SHO)机器人栅格路径规划，输出做短路径图和适应度曲线。

【MATLAB源码-第157期】基于matlab的海马优化算法（SHO)机器人栅格路径规划，输出做短路径图和适应度曲线。

操作环境&#xff1a; MATLAB 2022a 1、算法描述 海马优化器&#xff08;Sea Horse Optimizer, SHO&#xff09;是一种近年来提出的新型启发式算法&#xff0c;其设计灵感来源于海洋中海马的行为模式&#xff0c;特别是它们在寻找食物和伴侣时表现出的独特策略。海马因其独特…
阅读更多...
【vue】ant-design弹出框无法关闭和runtimecore提示isFucntion is not function的问题修复

【vue】ant-design弹出框无法关闭和runtimecore提示isFucntion is not function的问题修复

【vue】ant-design弹出框无法关闭和runtimecore提示isFucntion is not function的问题修复&#xff0c;初步分析是vue发布3.4版本以后引起的兼容性问题。 问题截图&#xff1a; 1.isFucntion is not function&#xff0c;是由于vue升级后众多插件版本不匹配造成的问题 2.弹框…
阅读更多...
iOS 自动化测试踩坑(一): 技术方案、环境配置与落地实践

iOS 自动化测试踩坑(一): 技术方案、环境配置与落地实践

移动端的自动化测试&#xff0c;最常见的是 Android 自动化测试&#xff0c;我个人觉得 Android 的测试优先级会更高&#xff0c;也更开放&#xff0c;更容易测试&#xff1b;而 iOS 相较于 Android 要安全稳定的多&#xff0c;但也是一个必须测试的方向&#xff0c;这个系列文…
阅读更多...
计算机能转嵌入式吗？

计算机能转嵌入式吗？

我是电气工程转的嵌入式单片机方向。 那是2011年的事了&#xff0c;当时贴吧也是一片哀嚎。 有找不到工作的&#xff0c;也有干了7,8年月薪不过万的。 这么年过去了&#xff0c;如果你仔细观察每个行业&#xff0c;都有一群骂娘的&#xff0c;也一群混得风生水起的。 主要和圈子…
阅读更多...
IDEA修改git提交者的信息

IDEA修改git提交者的信息

git提交后&#xff0c;idea会记录下提交人的信息&#xff0c;如果不修改提交人信息的话&#xff0c;会有一个默认值。避免每次提交都要填提交人信息&#xff0c;直接设置成自己想要的默认值&#xff0c;该怎么操作&#xff1f; 提交的时候在这里修改提交人信息 避免每次都去设置…
阅读更多...
显示高考天数倒计时——vba实现

显示高考天数倒计时——vba实现

以下代码实现高考倒计时&#xff1a; Sub 高考倒计时() 高考日期 CDate("06,07," & Year(Date)) If Date > 高考日期 Then高考日期 CDate("06-07-" & Year(Date) 1) End If 年月日 Year(Date) & "年" & Month(Date) &am…
阅读更多...
【Python】新手入门（5）：# -*- coding: UTF-8 -*- 的作用详解

【Python】新手入门（5）：# -*- coding: UTF-8 -*- 的作用详解

【Python】新手入门&#xff08;5&#xff09;&#xff1a;# -*- coding: UTF-8 -*- 的作用详解 &#x1f308; 个人主页&#xff1a;高斯小哥 &#x1f525; 高质量专栏&#xff1a;Matplotlib之旅&#xff1a;零基础精通数据可视化、Python基础【高质量合集】、PyTorch零基础…
阅读更多...
最新文章

Copyright @ 2022~2023