Day37 socket、TCP、UDP

news2025/6/20 7:29:27

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

在这里插入图片描述

示例代码

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;
}

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

InnoDB存储引擎对MVCC的实现

InnoDB存储引擎对MVCC的实现

MVCC MVCC的目的 在搞清楚MVCC之前,我们要搞懂一个问题,MVCC到底解决的是什么问题? 我用一句话概括,那就是为了解决读-写可以一起的问题! 在我们的印象里,InnoDB可以读读并发,不能读写并发,或者写写并发 这是很正常的想法,因为如果读写并发的化,会有并发问题 而对于写写…
阅读更多...
设计模式：什么是设计模式？①

设计模式：什么是设计模式？①

一、什么是设计模式&#xff1f; 1. 是一类程序设计思想 2. 是在大量实践过程中摸索总结出的标准经验提炼 3. 具有多样性和丰富性&#xff0c;不同情况应用的思想不同 二、设计模式的好处 1. 代码生产力和效率的提升 2. 让代码表现更为规整&#xff0c;简洁。阅读维护管理的成本…
阅读更多...
InfluxDB SHOW SERIES语句按照什么顺序返回？

InfluxDB SHOW SERIES语句按照什么顺序返回？

本作品采用知识共享署名-非商业性使用-相同方式共享 4.0 国际许可协议进行许可。 本作品 (李兆龙 博文, 由 李兆龙 创作)&#xff0c;由 李兆龙 确认&#xff0c;转载请注明版权。 文章目录 引言样例SHOW SERIES比较原理结论结束语 引言 influxdb的计算引擎为了做到自底而上的…
阅读更多...
曲线曲面 - 连续性, 坐标变换矩阵

曲线曲面 - 连续性, 坐标变换矩阵

连续性 有两种&#xff1a;参数连续性&#xff08;Parametric Continuity&#xff09;、几何连续性&#xff08;Geometric Continuity&#xff09;参数连续性&#xff1a; 零阶参数连续性&#xff0c;记为&#xff0c;指相邻两段曲线在结合点处具有相同的坐标 一阶参数连续性&…
阅读更多...
前缀和+哈希表：联手合击Leetcode 560.和为k的子数组

前缀和+哈希表：联手合击Leetcode 560.和为k的子数组

题目 给你一个整数数组 nums 和一个整数 k &#xff0c;请你统计并返回 该数组中和为 k 的子数组的个数 。 子数组是数组中元素的连续非空序列。 示例 1&#xff1a; 输入&#xff1a;nums [1,1,1], k 2 输出&#xff1a;2示例 2&#xff1a; 输入&#xff1a;nums [1,2…
阅读更多...
GPT-4技术解析：与Claude3、Gemini、Sora的技术差异与优势对比

GPT-4技术解析：与Claude3、Gemini、Sora的技术差异与优势对比

【最新增加Claude3、Gemini、Sora、GPTs讲解及AI领域中的集中大模型的最新技术】 2023年随着OpenAI开发者大会的召开&#xff0c;最重磅更新当属GPTs&#xff0c;多模态API&#xff0c;未来自定义专属的GPT。微软创始人比尔盖茨称ChatGPT的出现有着重大历史意义&#xff0c;不亚…
阅读更多...
【笔记】OpenHarmony和HarmonyOS区别及应用开发简介

【笔记】OpenHarmony和HarmonyOS区别及应用开发简介

一、概念 OpenHarmony(OH) &#xff1a; OpenAtom OpenHarmonyHarmonyOS(HO)&#xff1a;开发 | 华为开发者联盟 (huawei.com) HO当前最高是3.1&#xff0c;在华为mate 60上面也是。关于4.0、5.0和next这类版本说法都是面向用户的&#xff0c;不是开发人员。对于程序员&#…
阅读更多...
算法相关计算

算法相关计算

1 内存管理相关 1 .1 float 6.9 f 的内存计算方法 二进制小数的计算&#xff1a; &#xff08;1&#xff09;小数的二进制算法和整数的大致相反&#xff0c;就是不断的拿小数部分乘以2取积的整数部分&#xff0c;然后正序排列。比如求0.9的二进制&#xff1a; 0.9*21.8 取 1…
阅读更多...
opencv边缘检测之Canny算法

opencv边缘检测之Canny算法

文章目录 简介实战 简介 Canny在1986年提出了一种边缘检测算法&#xff0c;因其卓越的性能和准确性而广泛应用于各种图像分析领域。opencv中提供了这种算法&#xff0c;其操作步骤如下 高斯滤波&#xff1a;采用 5 5 5\times5 55的高斯核函数进行滤波&#xff0c;对图像进行…
阅读更多...
chrome插件chrome.storage数据写入失败QUOTA_BYTES_PER_ITEM quota exceeded

chrome插件chrome.storage数据写入失败QUOTA_BYTES_PER_ITEM quota exceeded

Unchecked runtime.lastError while running storage.set: QUOTA_BYTES_PER_ITEM quota exceeded at Object.callback 在开发浏览器插件的时候&#xff0c;报错提示&#xff1a;超出存储限制&#xff0c;浏览器插件存储官方文档&#xff1a;https://developer.chrome.com/docs…
阅读更多...
selinux规则

selinux规则

selinux状态 相关命令 进程要和文件的安全上下文相匹配&#xff0c;进程才能打开文件 查找这个命令从哪个安装包来的用 yum provides 命令 进程httpd 必须与ls -Z的文件类型一致&#xff0c;要不然在强制模式下面&#xff0c;打开不了 在终端2用此命令&#xff0c;把文件类型改…
阅读更多...
【Ubuntu】将多个python文件打包为.so文件

【Ubuntu】将多个python文件打包为.so文件

1.为什么要将python打包为.so文件&#xff1f; 保护源码 2.实战例子 a.安装相应的包 pip install cython 验证安装是否成功 cython --version b.实战的文件目录和内容 hi.py # This is a sample Python script.# Press ShiftF10 to execute it or replace it with your…
阅读更多...
基于OpenCV的图形分析辨认01

基于OpenCV的图形分析辨认01

目录 一、前言 二、实验目的 三、实验内容 四、实验过程 一、前言 编程语言&#xff1a;Python&#xff0c;编程软件&#xff1a;vscode或pycharm&#xff0c;必备的第三方库&#xff1a;OpenCV&#xff0c;numpy&#xff0c;matplotlib&#xff0c;os等等。 关于OpenCV&…
阅读更多...
Docker的镜像操作

Docker的镜像操作

目录 镜像的操作(**开头为常用请留意) 镜像查找 **拉取镜像 **推送镜像 **查看镜像 **修改镜像名称 **查看镜像的详细信息 ​编辑 删除镜像 查看所有镜像ID 删除全部镜像 **查看镜像的操作历史 镜像迁移 镜像打包 远程发送镜像(需要先打包) 本地镜像tar包恢复 镜像过…
阅读更多...
FPGA——三速自适应以太网设计（2）GMII与RGMII接口

FPGA——三速自适应以太网设计（2）GMII与RGMII接口

FPGA——以太网设计&#xff08;2&#xff09;GMII与RGMII 基础知识&#xff08;1&#xff09;GMII&#xff08;2&#xff09;RGMII&#xff08;3&#xff09;IDDR GMII设计转RGMII接口跨时钟传输模块 基础知识 &#xff08;1&#xff09;GMII GMII:发送端时钟由MAC端提供 下…
阅读更多...
Web安全：报错注入原理分析，报错注入步骤，报错注入常用函数

Web安全：报错注入原理分析，报错注入步骤，报错注入常用函数

「作者主页」&#xff1a;士别三日wyx 「作者简介」&#xff1a;CSDN top100、阿里云博客专家、华为云享专家、网络安全领域优质创作者 「推荐专栏」&#xff1a;对网络安全感兴趣的小伙伴可以关注专栏《网络安全自学教程》 报错注入 一、什么是报错注入二、执行原理1. 代码逻辑…
阅读更多...
node_vue个人博客系统开发

node_vue个人博客系统开发

Day01 一、导入express 1、创建node_serve服务文件夹 2、初始化项目 npm init -y3、导入express框架 npm i express4、创建一个app.js文件，为服务端的入口文件 // 导入express模块 const express = require(express); // 创建express服务 const app = express(); // 调用…
阅读更多...
Promisification、微任务

Promisification、微任务

前提摘要 Promise 对象的构造器&#xff08;constructor&#xff09;语法如下&#xff1a; let promise new Promise(function(resolve, reject) { // executor }); 传递给 new Promise的函数被称为 executor&#xff0c;当 new Promise 被创建&#xff0c;executor 会自动…
阅读更多...
小程序Taro框架 自定义底部Tabbar，处理自定义Tab栏切换卡顿、闪烁

小程序Taro框架 自定义底部Tabbar，处理自定义Tab栏切换卡顿、闪烁

最终效果 最近在用Taro框架开发一个小程序&#xff0c;有一个自定义底部Tabbar的需求&#xff0c;最终效果如下 起步 这页是我第一次接触自定义小程序底部Tabbar&#xff0c;所有第一选择必然是相看官方文档&#xff1a;微信小程序自定义 Tabbar | Taro 文档 &#xff08;如果…
阅读更多...
支部管理系统微信小程序（管理端+用户端）flask+vue+mysql+微信小程序

支部管理系统微信小程序（管理端+用户端）flask+vue+mysql+微信小程序

系统架构如图所示 高校D支部管理系统 由web端和微信小程序端组成&#xff0c;由web端负责管理&#xff0c;能够收缴费用、发布信息、发布问卷、发布通知等功能 部分功能页面如图所示 微信小程序端 包含所有源码和远程部署&#xff0c;可作为毕设课设
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023