嵌入式学习——3——域套接字UNIX

1、域套接字UNIX

1、域套接字是最原始的套接字通信方式,是完成同一主机之间多个进程间通信

2、由于不需要跨主机进行通信了,那么就无需使用ip地址和端口号了

3、通信本质:依然使用的是内核空间

4、域套接字的通信介质为套接字文件 bcd-lsp

5、域套接字也分为流式域套接字报式域套接字

6、跟网络通信中相关函数的区别

#include <sys/types.h>

#include <sys/socket.h>

int socket(int domain, int type, int protocol);

功能:为网络通信提供一个端点,并返回该端点的文件描述符,文件描述符使用原则为最小未分配原则

参数:

domain:通信域,可以选择协议族

        Name                                 Purpose                 Man page

         AF_UNIX, AF_LOCAL      非跨主机通信         详细信息请看 man 7 unix

type:         指定通信语义,常用的通信语义如下

        SOCK_STREAM 支持传输层的TCP通信方式

        SOCK_DGRAM 支持传输层的UDP通信方式

        SOCK_RAW 支持原始套接字通信

protocol: 当第二个参数中没有指定对应传输协议时,第三个参数要指定,如果第二个参数中已经确定了传输协议,那么第三个参数填0即可

        1.如果参数type是 SOCK_STREAM或SOCK_DGRAM时,参数protocol可以填0

        2.如果参数type没有指定是TCP还是UDP通信时,第三个参数protocol可以使用                 IPPROTO_TCP或IPPROTO_UDP来确定

返回值:成功返回一个新的套接字文件描述符,失败返回-1 并置位错误码

7、地址信息结构体的不同

#include <sys/types.h>

#include <sys/socket.h>

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

功能:为给定的套接字文件描述符绑定IP地址和端口号

参数:

sockfd :要被绑定的套接字文件描述符

addr :   通用地址信息结构体,实际的地址信息,取决于地址族,

                AF_INET 参见 man 7 ip ,                         ‘

               ’AF_UNIX 参见 man 7 unix

对于本地通信的套接字地址信息结构体:

        struct sockaddr_un {

                sa_family_t sun_family;    /* 通信域 */

                char sun_path[108];          /* 套接字文件路径 */

        };

         /* 套接字文件路径 */  必须是不存在的文件

addrlen: addr 的大小

返回值: 成功 0,失败 -1 并置位错误码

8、判断文件是否存在,以及删除文件

#include <unistd.h>

int access(const char *pathname, int mode);

功能:判断给定的文件是否具有给定的权限

参数1:要判断的文件路径

参数2:要判断的权限

                R_OK:读权限

                W_OK:写权限

                X_OK:可执行权限

                F_OK:是否存在

返回值:如果文件存在并具有要求的所有权限,则返回0,否则返回-1并置位错误码

int unlink(const char *pathname);

功能:删除指定的文件

参数:要删除的文件路径

返回值:成功 0,失败 -1  并置位错误码

2、流式域套接字

        2.1 服务器端实现

int main()
{//1、为通信创建一个端点int sfd = socket(AF_UNIX, SOCK_STREAM, 0);if(sfd == -1){perror("socket error");return -1;}//判断要绑定的套接字文件是否存在?if(access("./unix", F_OK) == 0){//说明文件存在,要将其删除if(unlink("./unix") ==-1){perror("unlink error");return -1;}}//2、绑定ip和端口号//2.1 准备地址信息结构体struct sockaddr_un sun;sun.sun_family = AF_UNIX;    //通信域strcpy(sun.sun_path , "./unix");         //套接字文件路径//2.2 绑定工作:必须绑定一个不存在的套接字文件if(bind(sfd, (struct sockaddr*)&sun, sizeof(sun)) ==-1){perror("bind error");return -1;}printf("bind success\n");//3、将套接字设置成被动监听状态if(listen(sfd, 128)==-1){perror("listen error");return -1;}printf("listen success\n");//4、阻塞等待客户端的连接//4.1 定义用于接受客户端信息的容器struct sockaddr_un cun;socklen_t addrlen = sizeof(cun);int newfd = accept(sfd, (struct sockaddr*)&cun, &addrlen);if(newfd == -1){perror("accept error");return -1;}printf("[%s]:发来连接请求\n", cun.sun_path);//5、与客户端进行相互通信char rbuf[128] = "";            //读取消息内容的容器while(1){//清空容器bzero(rbuf, sizeof(rbuf));//从套接字中读取数据//int res = read(newfd, rbuf, sizeof(rbuf));int res = recv(newfd, rbuf, sizeof(rbuf), 0);if(res == 0){printf("客户端已经下线\n");break;}//将读取的消息展示出来printf("[%s]:%s\n", cun.sun_path, rbuf);//将收到的消息处理一下,回复给客户端strcat(rbuf, "*_*");//讲消息发送给客户端send(newfd, rbuf, strlen(rbuf), 0);printf("发送成功\n");}//6、关闭套接字close(newfd);close(sfd);return 0;
}

        2.2 客户端实现

int main()
{//1、创建用于通信的套接字文件描述符int cfd = socket(AF_UNIX, SOCK_STREAM, 0);if(cfd == -1){perror("socket error");return -1;}//判断要绑定的套接字文件是否存在?if(access("./linux", F_OK) == 0){//说明文件存在,要将其删除if(unlink("./linux") ==-1){perror("unlink error");return -1;}}//2、绑定IP地址和端口号 //2.1 填充客户端地址信息结构体struct sockaddr_un cun;cun.sun_family = AF_UNIX;strcpy(cun.sun_path, "./linux");//2.2 绑定if( bind(cfd, (struct sockaddr*)&cun, sizeof(cun)) ==-1){perror("bind error");return -1;}printf("bind success\n");//3、连接服务器//3.1 准备对端地址信息结构体struct sockaddr_un sun;sun.sun_family = AF_UNIX;strcpy(sun.sun_path, "./unix");//3.2 连接服务器if(connect(cfd, (struct sockaddr*)&sun, sizeof(sun))==-1){perror("connect error");return -1;}printf("connect success\n");//4、数据收发char wbuf[128] = "";char rbuf[128] = "";while(1){//从终端上获取要发送的数据fgets(wbuf, sizeof(wbuf), stdin);wbuf[strlen(wbuf)-1] = '\0';           //将读取的换行改成'\0'//将数据发送给服务器send(cfd, wbuf, strlen(wbuf), 0);printf("发送成功\n");//接收服务器发来的消息bzero(rbuf, sizeof(rbuf));recv(cfd, rbuf, sizeof(rbuf), 0);printf("服务器发来的消息为:%s\n", rbuf);}//5、关闭套接字close(cfd);return 0;
}

3、报式域套接字

        3.1 服务器端实现

int main(int argc, const char *argv[])
{//1、创建用于通信的套接字文件描述符int sfd = socket(AF_UNIX, SOCK_DGRAM, 0);if(sfd == -1){perror("socket error");return -1;}//判断要绑定的套接字文件是否存在?if(access("./unix", F_OK) == 0){//说明文件存在,要将其删除if(unlink("./unix") ==-1){perror("unlink error");return -1;}}//2、绑定IP地址和端口号//2.1 填充地址信息结构体struct sockaddr_un sun;sun.sun_family = AF_UNIX;strcpy(sun.sun_path, "./unix");//2.2 绑定if(bind(sfd, (struct sockaddr*)&sun, sizeof(sun)) ==-1){perror("bind error");return -1;}printf("bind success\n");//3、数据收发char rbuf[128] = "";//准备接受对端的地址信息struct sockaddr_un cun;socklen_t addrlen = sizeof(cun);while(1){//清空容器bzero(rbuf,sizeof(rbuf));//读取数据recvfrom(sfd, rbuf, sizeof(rbuf), 0, (struct sockaddr*)&cun, &addrlen);printf("[%s]:%s\n", cun.sun_path, rbuf);//将收到的消息,加个笑脸回过去strcat(rbuf, "*_*");if(sendto(sfd, rbuf, strlen(rbuf), 0, (struct sockaddr*)&cun, sizeof(cun))==-1){perror("write error");return -1;}printf("发送成功\n");}//4、关闭套接字close(sfd);return 0;
}

        3.2 客户端实现

int main(int argc, const char *argv[])
{//1、创建用于通信的套接字文件描述符int cfd = socket(AF_UNIX, SOCK_DGRAM, 0);if(cfd == -1){perror("socket error");return -1;}//2、绑定套接字文件//2.1 填充地址信息结构体struct sockaddr_un cun;cun.sun_family = AF_UNIX;strcpy(cun.sun_path, "./linux");//判断要绑定的套接字文件是否存在?if(access("./linux", F_OK) == 0){//说明文件存在,要将其删除if(unlink("./linux") ==-1){perror("unlink error");return -1;}}//2.2 绑定if(bind(cfd, (struct sockaddr*)&cun, sizeof(cun)) ==-1){perror("bind error");return -1;}printf("bind success\n");//3、数据收发char wbuf[128] = "";//填充服务器的地址信息结构体struct sockaddr_un sun;sun.sun_family = AF_UNIX;strcpy(sun.sun_path, "./unix");char rbuf[128] = "";while(1){//清空容器bzero(wbuf,sizeof(wbuf));bzero(rbuf, sizeof(rbuf));//从终端上获取信息fgets(wbuf, sizeof(wbuf), stdin);wbuf[strlen(wbuf)-1] = 0;//讲消息发送给服务器sendto(cfd, wbuf, strlen(wbuf), 0, (struct sockaddr*)&sun, sizeof(sun));printf("发送成功\n");//接受服务器发来的消息recvfrom(cfd, rbuf, sizeof(rbuf), 0,NULL, NULL);printf("收到服务器消息为:%s\n", rbuf);}//4、关闭套接字close(cfd);return 0;
}

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

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

相关文章

低代码技术:数字经济时代的崛起与变革

随着数字经济时代的到来&#xff0c;低代码技术作为一种创新性工具正迅速崛起。本文将介绍低代码技术的定义和特点&#xff0c;并探讨其在数字经济中的重要性和应用。同时&#xff0c;我们将讨论低代码技术对传统软件开发方式的改变以及其带来的商业与创新机会。 引言 随着数字…

如何解决链游中可能出现的延迟或网络拥堵问题?

随着区块链技术的不断发展和普及&#xff0c;链游&#xff08;基于区块链的游戏&#xff09;作为新兴的娱乐形式&#xff0c;正逐渐走进大众的视野。然而&#xff0c;与传统游戏相比&#xff0c;链游在运行过程中可能会遇到一些特有的问题&#xff0c;其中最为突出的就是延迟和…

GB-T 37973-2019 信息安全技术 大数据安全管理指南

编写背景 随着大数据技术的快速发展和广泛应用&#xff0c;数据安全问题日益凸显。大数据安全管理指南的编写旨在指导和规范大数据在采集、存储、处理、传输、共享和销毁等环节的安全管理工作&#xff0c;以确保数据的完整性、可用性和 保密性&#xff0c;同时促进大数据的健康…

Oracle中clob怎么拼接字符

在Oracle数据库中&#xff0c;拼接字符主要有以下几种方法&#xff0c;我会以清晰的方式为您解释&#xff1a; 使用“||”操作符 这是Oracle中常用的字符串拼接方法。 语法示例&#xff1a;SELECT Hello || World AS result FROM dual; 输出结果&#xff1a;Hello World …

ES脚本启动报错修改

使用自写脚本启动ES集群时&#xff0c;添加安全策略时报错如下&#xff1a; Positional arguments not allowed, found [ -E xpack.security.enabledtrue -E xpack.security.transport.ssl.enabledtrue -E xpack.license.self_generated.typebasic -E xpack.security.transpor…

宝塔下应该用 Memcached 还是 Redis?

明月最近在跟几个使用宝塔面板的客户运维的时候发现不少站长不知道如何选择 Memcached 和 Redis&#xff0c;甚至都说不清楚 Memcached 或者 Redis 具体是用来干啥的&#xff1f;甚至还碰到过一个站长 Memcached 和 Redis 都安装了&#xff0c;但一个都没有用&#xff0c;就那么…

希尔排序法

希尔排序为插入排序的优化&#xff0c;即将数组分组&#xff0c;将每一组进行插入排序&#xff0c;每一组排成有序后&#xff0c;最后整体就变有序了。 上面gap2&#xff0c;即5&#xff0c;14&#xff0c;18&#xff0c;27&#xff0c;68为一组&#xff1b;13&#xff0c;20&a…

Numba 的 CUDA 示例(1/4):踏上并行之旅

按照本系列从头开始使用 Python 学习 CUDA 编程 介绍 GPU&#xff08;图形处理单元&#xff09;&#xff0c;顾名思义&#xff0c;最初是为计算机图形学开发的。从那时起&#xff0c;它们几乎在每个需要高计算吞吐量的领域都无处不在。这一进步得益于 GPGPU&#xff08;通用 G…

Java基础:基本语法(一)

Java基础&#xff1a;基本语法&#xff08;一&#xff09; 文章目录 Java基础&#xff1a;基本语法&#xff08;一&#xff09;1. 前言2. 开发环境搭建2.1 Java开发工具包下载2.2 环境变量配置2.3 Java程序的运行过程 3. 数据类型3.1 基本数据类型3.2 引用数据类型 4. 常量与变…

安装GO环境

#windows 1.下载go的安装包msi,下载完双击运行,指定一个目录进行安装 #msi安装时,会自动设置以下环境变量: #GOPATH(默认设置为C:\Users\hhx\go), #C:\Users\hhx\go\bin, #go安装位置下的bin目录 2.检查是否安装成功,终端中运行go version解释一些环境变量 GOROOT:go的安装位置…

ping不通ip的解决方法

解决ping不通IP的问题可以通过以下几种方法&#xff1a; 1.检查IP配置&#xff1a;确保所有设备的IP地址、子网掩码和默认网关配置正确。如果使用DHCP&#xff0c;请确认设备已设置为自动获取IP地址&#xff0c;并检查DHCP服务器的地址池配置是否正确且未耗尽。 2.检查网络设…

opencascade V3d_PositionLight V3d_SpotLight 源码学习 (位置性)光源

Positional、Spot 和 Directional Light 类的基类。 类V3d_SpotLight 创造和修改光源的衰减因子 F 决定了表面的照明&#xff1a; F 1 / (ConstAttenuation() LinearAttenuation() * Distance) 其中 Distance 是从光源到表面的距离。默认值 (1.0, 0.0) 对应最小的衰减。浓…

【做一道算一道】力扣332.重新安排行程

332.重新安排行程 给定一个机票的字符串二维数组 [from, to]&#xff0c;子数组中的两个成员分别表示飞机出发和降落的机场地点&#xff0c;对该行程进行重新规划排序。所有这些机票都属于一个从 JFK&#xff08;肯尼迪国际机场&#xff09;出发的先生&#xff0c;所以该行程必…

navicat连接过的库忘记密码

1、点击文件->导出连接 2、勾选想要知道密码的库 3、打开导出的文件搜索Password 4、复制Password解密 把下面的php代码复制到在线运行php的网站&#xff0c;替换最下面的decrypt(‘B7246A6E64D4F50A563FA20427A47991’)括号里的内容&#xff0c;然后执行php代码&#xff0…

Linux--进程间通信(1)(匿名管道)

目录 1.了解进程通信 1.1进程为什么要通信 1.2 进程如何通信 1.3进程间通信的方式 2.管道 2.1管道的初步理解 2.2站在文件描述符的角度-进一步理解管道 2.3 管道的系统调用接口&#xff08;匿名管道&#xff09; 2.3.1介绍接口函数&#xff1a; 2.3.2编写一个管道的代…

nd4j-native-platform for Mac 指南

nd4j-native-platform for Mac 指南 在使用nd4j-native-platform作为依赖于Mac OS的项目时&#xff0c;你需要确保正确地配置了Maven或Gradle构建文件以适应Mac操作系统。nd4j-native-platform依赖包含了ND4J库针对特定平台的本地二进制实现&#xff0c;这包括CPU和可能的GPU支…

通过date命令给日志文件添加日期

一、背景 服务的日志没有使用日志工具&#xff0c;每次重启后生成新日志文件名称相同&#xff0c;新日志将会把旧日志文件冲掉&#xff0c;旧日志无法保留。 为避免因旧日志丢失导致无法定位问题&#xff0c;所以需要保证每次生成的日志文件名称不同。 二、解决 在启动时&am…

SQLI-labs-第二十六关和第二十六a关

目录 第二十六关 1、判断注入点 2、判断数据库 3、判断表名 4、判断字段名 5、获取数据库的数据 第二十六a关 第二十六关 知识点&#xff1a;绕过and、or、空格、注释符等过滤 思路 通过源代码&#xff0c;我们可以知道&#xff0c;数据库对用户的输入进行了过滤&…

【校园网网络维修】当前用户使用的IP与设备重定向地址中IP不一致,请重新认证

出现的网络问题&#xff1a;当前用户使用的IP与设备重定向地址中IP不一致&#xff0c;请重新认证 可能的原因&#xff1a; 把之前登录的网页收藏到浏览器&#xff0c;然后直接通过这个链接进行登录认证。可能是收藏网址导致的ip地址请求参数不一致。 解决方法&#xff1a; 方法…

基于JCEF实现网页资源性能分析

文章目录 1、需求2、实现代码3、运行效果 1、需求 在使用chrome浏览器访问页面时&#xff0c;浏览器自带的开发者工具可以查看页面每个资源的资源大小和加载时间。 这个功能可以让我们直接知道接口或资源的耗时情况和大小情况&#xff0c;如果存在性能问题&#xff0c;可以进…