17_高级进程间通信 UNIX域套接字1

非命名的UNIX域套接字
在这里插入图片描述
第1个参数domain，表示协议族，只能为AF_LOCAL或者AF_UNIX；
第2个参数type，表示类型，只能为0。
第3个参数protocol，表示协议，可以是SOCK_STREAM或者SOCK_DGRAM。用SOCK_STREAM建立的套接字对是管道流，与一般的管道相区别的是，套接字对建立的通道是双向的，即每一端都可以进行读写。不管是数据流还是数据报协议，unix域套接字都是可靠的，不丢包的。
第4个参数，用于保存建立的套接字对。

示例：

#include <stdio.h>    
#include <stdlib.h>    
#include <sys/socket.h>    
#include <string.h>
#include <sys/types.h>
#include <unistd.h>
       
int main(void)  
{    
    int i_fd_arr[2];    
    int i_pid;    
    char psz_wbuf[16] = "0123456789";
    char psz_rbuf[16] = {0};
    
    if ( socketpair( AF_UNIX, SOCK_STREAM, 0, i_fd_arr ) < 0 )  
    {    
        perror( "socketpair" );
        return -1;
    }
  
    if ( ( i_pid = fork() ) < 0 )  
    {    
        perror( "fork" );
        return -1;
    }  
    else if ( 0 == i_pid )  
    {    
        //child    
        close( i_fd_arr[0] );    
        if ( write( i_fd_arr[1], psz_wbuf, strlen( psz_wbuf ) ) < 0 )  
        {
            perror( "write" );
            exit( -1 );
        }
 
        memset( psz_rbuf, 0, sizeof( psz_rbuf ) );
        if ( read( i_fd_arr[1], psz_rbuf, 16 ) < 0 )  
        {
            perror( "read" );
            exit( -1 );
        }
        printf( "child read: %s\n", psz_rbuf );
    }
    else
    {    
        //parent  
        close( i_fd_arr[1] );  
        if ( read( i_fd_arr[0], psz_rbuf, 16 ) < 0 )  
        {
            perror( "read" );
            exit( -1 );
        }
        printf( "parent read: %s\n", psz_rbuf );
 
        memset( psz_wbuf, 0, sizeof( psz_wbuf ) );
        strncpy( psz_wbuf, "9876543210", sizeof( psz_wbuf ) - 1 );
        if ( write( i_fd_arr[0], psz_wbuf, strlen( psz_wbuf ) ) < 0 )  
        {
            perror( "write" );
            exit( -1 );
        }
    }
    return 0;    
}

命名UNIX域套接字

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

TCP示例：

server.c

#include <stdio.h>    
#include <sys/socket.h>    
#include <sys/un.h>    
#include <string.h>
#include <unistd.h>
    
int main(void)  
{    
    int i_listenfd = 0, i_clientfd = 0;       
    struct sockaddr_un addr_server, addr_client;    
    char psz_path[32] = "./server_unixsocket_file";
    int i_caddr_len = sizeof(struct sockaddr_un); 
    int i_saddr_len = sizeof(struct sockaddr_un);    
    char psz_rbuf[32] = {0};    
    char psz_wbuf[32] = "i am server.";
    int i_readlen = 0;
  
    //create a UNIX domain stream socket    
    if ( ( i_listenfd = socket( AF_UNIX, SOCK_STREAM, 0 ) ) < 0 )  
    {    
        perror( "socket" );
        return -1;
    }
  
    //in case it already exists    
    unlink( psz_path );    
  
    //fill in socket address structure    
    memset( &addr_server, 0, sizeof( addr_server ) );    
    addr_server.sun_family = AF_UNIX;
    strncpy( addr_server.sun_path, psz_path, sizeof( addr_server.sun_path ) - 1 );    
  
    //bind the name to the descriptor
    if ( bind( i_listenfd, ( struct sockaddr * )&addr_server, i_saddr_len ) < 0 )  
    {
        perror( "bind" );    
        return -1;    
    }    
  
    if ( listen( i_listenfd, 10 ) < 0 )
    {    
        perror( "listen" );
        return -1;
    }    
 
    while(1)
    {
        if ( ( i_clientfd = accept( i_listenfd, ( struct sockaddr * )&addr_client,
            ( socklen_t * )&i_caddr_len ) ) < 0 )  
        {    
            perror("accept");
            return -1;
        }    
        
        printf( "client is: %s\n", addr_client.sun_path );    
      
        if ( ( i_readlen = read( i_clientfd, psz_rbuf, sizeof( psz_rbuf ) - 1 ) ) < 0 )
        {
            perror( "read" );
            return -1;
        }
        psz_rbuf[i_readlen] = '\0';
        printf( "receive msg:%s\n", psz_rbuf );    
      
        if ( write( i_clientfd, psz_wbuf, strlen( psz_wbuf ) + 1 ) < 0 )  
        {    
            perror("write");    
            return -1;    
        }
    }
  
    unlink( psz_path );    
    return 0;    
}

client.c

#include <stdio.h>    
#include <sys/un.h>    
#include <sys/socket.h>    
#include <string.h>
#include <unistd.h>
    
int main(void)  
{    
    int i_fd = 0;    
    struct sockaddr_un addr;    
    char psz_path[32] = "./client_unixsocket_file";    
    char serverpath[32] = "./server_unixsocket_file";    
    int i_addr_len = sizeof( struct sockaddr_un );    
    char psz_wbuf[32] = "i am client.";
    char psz_rbuf[32] = {0}; 
    int i_readlen = 0;
  
    if ( ( i_fd = socket( AF_UNIX, SOCK_STREAM, 0 ) ) < 0 )  
    {    
        perror("socket");
        return -1;
    }
  
    memset( &addr, 0, sizeof( addr ) );    
    addr.sun_family = AF_UNIX;
    strncpy( addr.sun_path, psz_path, sizeof( addr.sun_path ) - 1 );    
    unlink( psz_path );
  
    if ( bind( i_fd, ( struct sockaddr * )&addr, i_addr_len ) < 0 )  
    {    
        perror("bind");
        return -1;
    }
  
    //fill socket adress structure with server's address    
    memset( &addr, 0, sizeof( addr ) );    
    addr.sun_family = AF_UNIX;
    strncpy( addr.sun_path, serverpath, sizeof( addr.sun_path ) - 1 );    
  
    if ( connect( i_fd, ( struct sockaddr * )&addr, i_addr_len ) < 0 )  
    {
        perror("connect");
        return -1;
    }
  
    if ( write( i_fd, psz_wbuf, strlen( psz_wbuf ) + 1 ) < 0 )  
    {
        perror( "write" );    
        return -1;
    }    
  
    if ( ( i_readlen = read( i_fd, psz_rbuf, sizeof( psz_rbuf ) - 1 ) ) < 0 )  
    {    
        perror("write");    
        return -1;    
    }
    psz_rbuf[i_readlen] = '\0';
    printf( "receive msg:%s\n", psz_rbuf );    
    unlink( psz_path );
    return -1;
}

UDP示例：
server

#include <stdio.h>      
#include <sys/socket.h>      
#include <sys/un.h>      
#include <string.h>  
#include <unistd.h>  
      
int main(void)    
{      
    int i_listenfd = 0/*, i_clientfd = 0*/;         
    struct sockaddr_un addr_server, addr_client;      
    char psz_path[32] = "./server_unixsocket_file";  
    int i_caddr_len = sizeof(struct sockaddr_un);   
    int i_saddr_len = 0;      
    char psz_rbuf[32] = {0};      
    char psz_wbuf[32] = "i am server.";  
    int i_readlen = 0;  
    
    //create a UNIX domain stream socket      
    if ( ( i_listenfd = socket( AF_UNIX, SOCK_DGRAM, 0 ) ) < 0 )  
    {      
        perror( "socket" );  
        return -1;  
    }  
    
    //in case it already exists      
    unlink( psz_path );      
    
    //fill in socket address structure      
    memset( &addr_server, 0, sizeof( addr_server ) );      
    addr_server.sun_family = AF_UNIX;  
    strncpy( addr_server.sun_path, psz_path, sizeof( addr_server.sun_path ) - 1 );      
    
    //bind the name to the descriptor  
    i_saddr_len = strlen( addr_server.sun_path ) + sizeof( addr_server.sun_family );  
    if ( bind( i_listenfd, ( struct sockaddr * )&addr_server, i_saddr_len ) < 0 )    
    {  
        perror( "bind" );      
        return -1;      
    }      
  
    while(1)  
    {  
        i_readlen = recvfrom( i_listenfd, psz_rbuf, sizeof( psz_rbuf ) - 1, 0,  
            ( struct sockaddr * )&addr_client, ( socklen_t *)&i_caddr_len );  
        if ( i_readlen < 0 )  
        {  
            perror( "read" );  
            return -1;  
        }  
        printf( "client is: %s\n", addr_client.sun_path );
        psz_rbuf[i_readlen] = '\0';  
        printf( "receive msg:%s\n", psz_rbuf );    
        
        if ( sendto( i_listenfd, psz_wbuf, strlen( psz_wbuf ) + 1, 0,  
            ( struct sockaddr * )&addr_client, i_caddr_len ) < 0 )  
        {  
            perror( "write" );  
            return -1;  
        }  
    }  
    
    unlink( psz_path );  
    return 0;      
}

Client

#include <stdio.h>    
#include <sys/un.h>    
#include <sys/socket.h>    
#include <string.h>
#include <unistd.h>
    
int main(void)  
{    
    int i_fd = 0;    
    struct sockaddr_un addr;    
    char psz_clientpath[32] = "./client_unixsocket_file";    
    char psz_serverpath[32] = "./server_unixsocket_file";    
    int i_addr_len = 0;   
    char psz_wbuf[32] = "i am client.";
    char psz_rbuf[32] = {0}; 
    int i_readlen = 0;
  
    if ( ( i_fd = socket( AF_UNIX, SOCK_DGRAM, 0 ) ) < 0 )  
    {    
        perror("socket");
        return -1;
    }
    
    memset( &addr, 0, sizeof( addr ) );    
    addr.sun_family = AF_UNIX;
    strncpy( addr.sun_path, psz_clientpath, sizeof( addr.sun_path ) - 1 );    
    unlink( psz_clientpath );
    i_addr_len = strlen( addr.sun_path ) + sizeof( addr.sun_family );
    if ( bind( i_fd, ( struct sockaddr * )&addr, i_addr_len ) < 0 )  
    {    
        perror("bind");
        return -1;
    }
    
  
    //fill socket adress structure with server's address    
    memset( &addr, 0, sizeof( addr ) );    
    addr.sun_family = AF_UNIX;
    strncpy( addr.sun_path, psz_serverpath, sizeof( addr.sun_path ) - 1 );    
 
    i_addr_len = strlen( addr.sun_path ) + sizeof( addr.sun_family ); 
    if ( sendto( i_fd, psz_wbuf, strlen( psz_wbuf ) + 1, 0,
        ( struct sockaddr * )&addr, i_addr_len ) < 0 )  
    {
        perror( "write" );    
        return -1;
    }    
  
    if ( ( i_readlen = recvfrom( i_fd, psz_rbuf, sizeof( psz_rbuf ) - 1, 0,
        ( struct sockaddr * )&addr, ( socklen_t * )&i_addr_len ) ) < 0 )  
    {
        perror("write");    
        return -1;    
    }
    psz_rbuf[i_readlen] = '\0';
    printf( "receive msg:%s\n", psz_rbuf );    
    unlink( psz_clientpath );
    return -1;
}

示例代码抄录自：https://blog.csdn.net/bytxl/article/details/47861469
用于加深理解

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

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

相关文章

视觉巡线小车——STM32+OpenMV（三）

视觉巡线小车——STM32+OpenMV（三）

目录 前言 一、OpenMV代码 二、STM32端接收数据 1.配置串口 2.接收数据并解析 总结 前言 通过视觉巡线小车——STM32OpenMV&#xff08;二&#xff09;&#xff0c;已基本实现了减速电机的速度闭环控制。要使小车能够自主巡线&#xff0c;除了能够精准的控制速度之外&#xff0…
阅读更多...
【BUG】已解决：raise KeyError(key) from err KeyError: (‘name‘, ‘age‘)

【BUG】已解决：raise KeyError(key) from err KeyError: (‘name‘, ‘age‘)

已解决&#xff1a;raise KeyError(key) from err KeyError: (‘name‘, ‘age‘) 欢迎来到英杰社区https://bbs.csdn.net/topics/617804998 欢迎来到我的主页&#xff0c;我是博主英杰&#xff0c;211科班出身&#xff0c;就职于医疗科技公司&#xff0c;热衷分享知识&#xf…
阅读更多...
第十课：telnet（远程登入）

第十课：telnet（远程登入）

如何远程管理网络设备&#xff1f; 只要保证PC和路由器的ip是互通的&#xff0c;那么PC就可以远程管理路由器&#xff08;用telnet技术管理&#xff09;。 我们搭建一个下面这样的简单的拓扑图进行介绍 首先我们点击云&#xff0c;把云打开&#xff0c;点击增加 我们绑定vmn…
阅读更多...
idea如何让包结构分层

idea如何让包结构分层

文章目录 前言1.选中前项目包结构2.取消后项目包结构3.情况二 前言 在大型项目中&#xff0c;代码的分层管理至关重要。IDEA编辑器提供了强大的package分层结构功能&#xff0c;帮助开发者更好地组织和管理代码。通过合理配置&#xff0c;我们可以清晰地看到各个package之间的…
阅读更多...
【BUG】已解决：java.lang.reflect.InvocationTargetException

【BUG】已解决：java.lang.reflect.InvocationTargetException

已解决&#xff1a;java.lang.reflect.InvocationTargetException 欢迎来到英杰社区https://bbs.csdn.net/topics/617804998 欢迎来到我的主页&#xff0c;我是博主英杰&#xff0c;211科班出身&#xff0c;就职于医疗科技公司&#xff0c;热衷分享知识&#xff0c;武汉城市开发…
阅读更多...
Mysql-索引结构

Mysql-索引结构

一.什么是索引&#xff1f; 索引(index)是帮助MySQL高效获取数据的数据结构(有序)。在数据之外,数据库系统还维护着满足特定查找算法的数据结构,这些数据结构以某种方式引用(指向)数据,这样就可以在这些数据结构上实现高级查找算法,这种数据结构就是索引 二.无索引的情况 找到…
阅读更多...
【效率提升】程序员常用Shell脚本

【效率提升】程序员常用Shell脚本

文章目录 常用Shell脚本一. 定期更新分区数据二、获取系统资源的使用情况 常用Shell脚本 一. 定期更新分区数据 在某些场景下&#xff0c;我们需要对N年前某一分区的数据进行删除&#xff0c;并添加今年该对应分区的数据&#xff0c;实现数据的流动式存储。 #!/bin/bash dt$…
阅读更多...
NFT革命：数字资产的确权、营销与元宇宙的未来

NFT革命：数字资产的确权、营销与元宇宙的未来

目录 1、NFT&#xff1a;数字社会的数据确权制度 2、基于低成本及永久产权的文化发现 3、PFP&#xff1a;从“小图片”到“身份表达”&#xff0c;再到社区筛选 4、透明表达&#xff1a;NFT 在数字化营销中的商业价值 5、可编程性&#xff1a;赋予 NFT 无限可能的应用 5.…
阅读更多...
微信被好友屏蔽朋友圈/拉黑/删除？教你几招悄悄验证

微信被好友屏蔽朋友圈/拉黑/删除？教你几招悄悄验证

微信这一国民级的社交软件&#xff0c;基本上渗入了大家日常生活的方方面面&#xff0c;沟通、支付、购物、娱乐都可以在上面一站式解决。微信功能虽然很全面&#xff0c;但某些功能细节设计也会让人感到困惑&#xff0c;比如我们被朋友拉黑或者删除&#xff0c;微信是不会通知…
阅读更多...
C程序优化与指针传址

C程序优化与指针传址

最近在写程序时遇到了一些问题&#xff0c;记录一下&#xff1a; 开始程序使用全局变量&#xff0c;程序如下&#xff1a;程序的缺点是全局变量的泛滥。 笔者觉得有些不妥&#xff0c;于是将它修改成这样&#xff1a; 使用结构体进行封装&#xff0c;避免了全局变量&#xff0…
阅读更多...
Gitee使用教程2-克隆仓库（下载项目）并推送更新项目

Gitee使用教程2-克隆仓库（下载项目）并推送更新项目

一、下载 Gitee 仓库 1、点击克隆-复制代码 2、打开Git Bash 并输入复制的代码 下载好后&#xff0c;找不到文件在哪的可以输入 pwd 找到仓库路径 二、推送更新 Gitee 项目 1、打开 Git Bash 用 cd 命令进入你的仓库&#xff08;我的仓库名为book&#xff09; 2、添加文件到 …
阅读更多...
转移C盘中的conda环境（包括.condarc文件修改，environment.txt文件修改，conda报错）

转移C盘中的conda环境（包括.condarc文件修改，environment.txt文件修改，conda报错）

conda环境一般是默认安装到C盘的&#xff0c;若建立多个虚拟环境&#xff0c;时间长了&#xff0c;容易让本不富裕的C盘更加雪上加霜&#xff0c;下面给出将conda环境从C盘转移到D盘的方法。 目录 电脑软硬件转移方法查看当前conda目录转移操作第一步&#xff1a;.condarc文件修…
阅读更多...
C语言迷宫

C语言迷宫

目录 开头程序程序的流程图程序输入与输出的效果结尾 开头 大家好&#xff0c;我叫这是我58。今天&#xff0c;我要来看我用C语言编译出来的迷宫游戏。 程序 #define _CRT_SECURE_NO_WARNINGS 1 #include <stdio.h> #include <Windows.h> void printmaze(char s…
阅读更多...
鸿蒙Navigation路由能力汇总

鸿蒙Navigation路由能力汇总

基本使用步骤&#xff1a; 1、新增配置文件router_map&#xff1a; 2、在moudle.json5中添加刚才新增的router_map配置&#xff1a; 3、使用方法&#xff1a; 属性汇总&#xff1a; https://developer.huawei.com/consumer/cn/doc/harmonyos-references/ts-basic-compone…
阅读更多...
在RK3568上如何烧录MAC？

在RK3568上如何烧录MAC？

这里我们用RKDevInfoWriteTool 1.1.4版本 下载地址&#xff1a;https://pan.baidu.com/s/1Y5uNhkyn7D_CjdT98GrlWA?pwdhm30 提 取 码&#xff1a;hm30 烧录过程&#xff1a; 1. 解压RKDevInfoWriteTool_Setup_V1.4_210527.7z 进入解压目录&#xff0c;双击运行RKDevInfo…
阅读更多...
H3CNE（计算机网络的概述）

H3CNE（计算机网络的概述）

1. 计算机网络的概述 1.1 计算机网络的三大基本功能 1. 资源共享 2. 分布式处理与负载均衡 3. 综合信息服务 1.2 计算机网络的三大基本类型 1.3 网络拓扑 定义&#xff1a; 网络设备连接排列的方式 网络拓扑的类型&#xff1a; 总线型拓扑&#xff1a; 所有的设备共享一…
阅读更多...
Flutter 插件之 easy_refresh（下拉刷新、上拉加载）

Flutter 插件之 easy_refresh（下拉刷新、上拉加载）

今天给大家较少一下日常开发中最常见的一个功能，就是 下拉刷新、上拉加载，这个在我们使用分页功能是最常见的。 此前我我也写了一篇关于 下拉刷新、上拉加载。 Flutter 下拉刷新、上拉加载flutter_easyrefresh的使用https://blog.csdn.net/WangQingLei0307/article/details/…
阅读更多...
阿里宜搭对接打通金蝶云星空搜索表单实例详情列表接口与仓库新增接口

阿里宜搭对接打通金蝶云星空搜索表单实例详情列表接口与仓库新增接口

阿里宜搭对接打通金蝶云星空搜索表单实例详情列表接口与仓库新增接口 来源系统:阿里宜搭 宜搭是阿里巴巴自研的低代码应用搭建平台&#xff0c;传统情况下需要2周才能搭建完成的应用&#xff0c;用宜搭2小时就可完成。宜搭于2019年3月上线&#xff0c;用户可以在可视化界面上以…
阅读更多...
AI 模型本地推理 - YYPOLOE - Python - Windows - GPU - 吸烟检测（目标检测）- 有配套资源直接上手实现

AI 模型本地推理 - YYPOLOE - Python - Windows - GPU - 吸烟检测（目标检测）- 有配套资源直接上手实现

Python 运行 - GPU 推理 - windows 环境准备python 代码 环境准备 FastDeploy预编译库下载 conda config --add channels conda-forge && conda install cudatoolkit11.2 cudnn8.2 pip install fastdeploy_gpu_python-0.0.0-cp38-cp38-win_amd64.whlpython 代码 impo…
阅读更多...
WebGL-编译报错，如何定位sendfile报错位置

WebGL-编译报错，如何定位sendfile报错位置

1&#xff09;WebGL-编译报错&#xff0c;如何定位sendfile报错位置 2&#xff09;设置DepthBufferBits和设置DepthStencilFormat的区别 3&#xff09;Unity打包exe后&#xff0c;游戏内拉不起Steam的内购 4&#xff09;使用了Play Asset Delivery提交版本被Google报错 这是第3…
阅读更多...
最新文章

Copyright @ 2022~2023