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  ipv4AF_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");
#elseserver_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 1024int 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");
#elseserver_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 1024int 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.rhkb.cn/news/275118.html

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

WEB区块链开发组件 - KLineChart

当我们开发区块链的时候&#xff0c;实现K线可能大家会想到EChart&#xff0c;但是EChart做可能需要耗费大量工作量&#xff0c;实现出来的功能估计也是牵强着用。 这时候&#xff0c;我们可能网上会搜索到TradingView,可是这个组件虽然功能非常强大&#xff0c;但是还是要费事…

数据库规范化设计案例解析

1.介绍 数据库规范化设计是数据库设计的一种重要方法&#xff0c;旨在减少数据库中的冗余数据&#xff0c;提高数据的一致性&#xff0c;确保数据依赖合理&#xff0c;从而提高数据库的结构清晰度和维护效率。规范化设计通过应用一系列的规范化规则&#xff08;或称“范式”&a…

看完让你的RSA提升一个台阶 [GKCTF 2021]RRRRsa

阅读须知: 探索者安全团队技术文章仅供参考,未经授权请勿利用文章中的技术资料对任何计算机系统进行入侵操作,由于传播、利用本公众号所提供的技术和信息而造成的任何直接或者间接的后果及损失,均由使用者本人负责,作者不为此承担任何责任,如有侵权烦请告知,我们会立即删除…

ROS2中launch编写及参数含义(xml、python)

ROS2系列文章目录 ROS2中nav_msgs/msg/Path 数据含义及使用 ROS2中std_msgs/msg/Header 数据含义及使用 ROS中TF变换详解 文章目录 ROS2系列文章目录ROS2中launch编写及参数含义&#xff08;xml、python&#xff09;一、ROS官方介绍二、实现案例1.编写主函数、CMakeLists.tx…

基于php的用户登录实现(v2版)(持续迭代)

目录 版本说明 数据库连接 登录页面&#xff1a;login.html 登录处理实现&#xff1a;login.php 用户欢迎页面&#xff1a;welcome.php 密码修改页面&#xff1a;change_password.html 修改执行&#xff1a;change_password.php 用户注册页面&#xff1a;register.html …

中霖教育:中级会计师好考吗?

对于不少会计专业的人士来说&#xff0c;中级会计师资格考试是很多人都想参加的。这一证书好不好考?难度大吗?中霖教育为大家提供参考。 中级会计师资格考试是一项国家认定的专业技术水平考试&#xff0c;考试科目共三科&#xff0c;分别是《中级会计实务》《财务管理》《经…

【视觉三维重建】【论文笔记】Deblurring 3D Gaussian Splatting

去模糊的3D高斯泼溅&#xff0c;看Demo比3D高斯更加精细&#xff0c;对场景物体细节的还原度更高&#xff0c;[官网]&#xff08;https://benhenryl.github.io/Deblurring-3D-Gaussian-Splatting/&#xff09; 背景技术 Volumetric rendering-based nerual fields&#xff1a…

00后卷王的自述,我难道真的很卷?

&#x1f345; 视频学习&#xff1a;文末有免费的配套视频可观看 &#x1f345; 关注公众号【互联网杂货铺】&#xff0c;回复 1 &#xff0c;免费获取软件测试全套资料&#xff0c;资料在手&#xff0c;涨薪更快 前段时间去面试了一个公司&#xff0c;成功拿到了offer&#xf…

python使用PaddleOCR实现《命名实体识别项目》OCR(已实现)(ai领域必看,简单易用)

1.简介&#xff1a; PaddleOCR是飞桨&#xff08;PaddlePaddle&#xff09;推出的一个端到端的光学字符识别开源工具集&#xff0c;支持中文、英文、数字以及特殊符号等各种类型的文字检测、识别和词语整体识别。该工具集使用PaddlePaddle深度学习框架技术&#xff0c;提供了多…

面向IoT物联网的时间序列引擎

1、背景 随着近年来业务的发展&#xff0c;尤其是机器产生的数据占比越来越高的趋势下&#xff0c;时序数据因为其业务价值越来越被更多地关注&#xff0c;也因而催生了专用的时间序列数据库&#xff0c;简称时序数据库&#xff08;TimeSeries Database&#xff0c;TSDB&#x…

代码随想录算法训练营第25天|216.组和总和三、17.电话号码的字母组合

目录 一、力扣216.组合总和三1.1 题目1.2 思路1.3 代码 二、力扣17.电话号码的字母组合2.1 题目2.2 思路2.3 代码 一、力扣216.组合总和三 1.1 题目 1.2 思路 自己的想法&#xff1a;和总和问题思路类似&#xff0c;回溯法。 &#xff08;1&#xff09;k个数的组合&#xff0…

工作纪实46-关于微服务的上线发布姿势

蓝绿部署 在部署时&#xff0c;不需要将旧版本的服务停掉&#xff0c;而是将新版本与旧版本同时运行&#xff0c;新版本测试无误之后再将旧版本停掉。这样可以避免再升级的过程中如果失败服务不可用的问题&#xff0c;因为同时部署了两个版本的程序&#xff0c;使得硬件资源是…

【C语言】深入了解指针(1),进来小白,出去大佬!

一&#xff0c;内存和地址 1&#xff0c;内存 在讲内存和地址之前&#xff0c;我们先举个案例 假设有⼀栋宿舍楼&#xff0c;把你放在楼⾥&#xff0c;楼上有100个房间&#xff0c;但是房间没有编号&#xff0c;你的⼀个朋友来找你玩&#xff0c; 如果想找到你&#xff0c;就…

【CSP试题回顾】201812-1-小明上学

CSP-201812-1-小明上学 解题代码 #include <iostream> #include <vector> using namespace std;long long r, y, g, n, k, t, sumTime;int main() {cin >> r >> y >> g >> n;for (int i 0; i < n; i){cin >> k >> t;if …

Sora爆火,多模态大模型背后的存算思考

近日&#xff0c;随着OpenAI推出Sora&#xff0c;人工智能从文本到文本、文本到图片的生成模式&#xff0c;进阶到文生视频。其文本到视频的模型能够生成长达一分钟的视频&#xff0c;在保持视觉质量的同时并严格遵循用户的提示&#xff0c;使得“扔进一本小说&#xff0c;生成…

解决Ubuntu 16.04/18.04 图形化界面异常、鼠标光标消失、鼠标变成叉叉等问题

bug场景&#xff1a; 一切从一次换源说起…叭叭叭 这篇文章解决的问题&#xff1a; 1.换源&#xff0c;默认源太慢&#xff0c;换成可用的阿里云的源 2.apt-get failed to …问题 3.图形化异常问题 4.get unmet dependence 问题 5. 鼠标光标消失和鼠标变成叉叉问题。 解决方…

ONLYOFFICE 文档开发者版,为您的平台带来强大的文档编辑功能

你是否在寻找一个可自主部署、可定制、易集成的文档编辑器解决方案&#xff1f;如果是这样&#xff0c;那么ONLYOFFICE 文档开发者版&#xff0c;也许就是你想要的答案。下面让我们一起来看看它有哪些特点&#xff0c;并能为您带来哪些好处。 什么是 ONLYOFFICE 文档 ONLYOFFI…

c#递归函数

在 C#中&#xff0c;递归函数是指在函数内部直接或间接调用自身的函数。递归函数在解决一些问题时非常有用&#xff0c;例如遍历树形结构、递归计算等。 using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks…

Github上哪些好用的工具

专注于web漏洞挖掘、内网渗透、免杀和代码审计&#xff0c;感谢各位师傅的关注&#xff01;网安之路漫长&#xff0c;与君共勉&#xff01; Qexo-爱写博客的师傅强烈推荐 漂亮的 Hexo 静态博客编辑器。该项目是基于 Django 的 Hexo 静态博客管理后台&#xff0c;支持文章管理、…

Python实战:采集全国5A景点名单

本文将以采集全国 5A 景点名单为例&#xff0c;详细介绍如何使用 Python 进行数据采集。 本文采集到全国340家5A景区的名单&#xff0c;包括景区名称、地区、 A级、评定年份这些字段。 一、分析数据源 为了获取权威数据&#xff0c;我们来到主管部门的官方网站&#xff0c;在右…