UNIX域套接字编程和socketpair 函数
一、UNIX Domain Socket IPC
socket API原本是为网络通讯设计的,但后来在socket的框架上发展出一种IPC机制,就是UNIX Domain Socket。虽然网络socket也可用于同一台主机的进程间通讯(通过loopback地址127.0.0.1),但是UNIX Domain Socket用于IPC更有效率:不需要经过网络协议栈,不需要打包拆包、计算校验和、维护序号和应答等,只是将应用层数据从一个进程拷贝到另一个进程。UNIX域套接字与TCP套接字相比较,在同一台主机的传输速度前者是后者的两倍。这是因为,IPC机制本质上是可靠的通讯,而网络协议是为不可靠的通讯设计的。UNIX Domain Socket也提供面向流和面向数据包两种API接口,类似于TCP和UDP,但是面向消息的UNIX Domain Socket也是可靠的,消息既不会丢失也不会顺序错乱。
使用UNIX Domain Socket的过程和网络socket十分相似,也要先调用socket()创建一个socket文件描述符,address family指定为AF_UNIX,type可以选择SOCK_DGRAM或SOCK_STREAM,protocol参数仍然指定为0即可。
UNIX Domain Socket与网络socket编程最明显的不同在于地址格式不同,用结构体sockaddr_un表示,网络编程的socket地址是IP地址加端口号,而UNIX Domain Socket的地址是一个socket类型的文件在文件系统中的路径,这个socket文件由bind()调用创建,如果调用bind()时该文件已存在,则bind()错误返回。
#define UNIX_PATH_MAX 108
struct sockaddr_un {
sa_family_t sun_family; /* AF_UNIX */
char sun_path[UNIX_PATH_MAX]; /* pathname */
};
二、回射/客户服务器程序
通信的流程跟前面说过的tcp/udp 是类似的,下面直接来看程序:
1
2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 |
/*************************************************************************
> File Name: echoser_tcp.c > Author: Simba > Mail: dameng34@163.com > Created Time: Sun 03 Mar 2013 06:13:55 PM CST ************************************************************************/ #include<stdio.h> #define ERR_EXIT(m) \ void echo_ser(int conn) memset(recvbuf, 0, sizeof(recvbuf)); ERR_EXIT("read error"); else if (n == 0) fputs(recvbuf, stdout); close(conn); /* unix domain socket与TCP套接字相比较,在同一台主机的传输速度前者是后者的两倍。*/ unlink("/tmp/test socket"); //地址复用 if (bind(listenfd, (struct sockaddr *)&servaddr, sizeof(servaddr)) < 0) if (listen(listenfd, SOMAXCONN) < 0) int conn; while (1) conn = accept(listenfd, NULL, NULL); if (conn == EINTR) pid = fork(); close(conn); return 0; |
1
2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 |
/*************************************************************************
> File Name: echocli_tcp.c > Author: Simba > Mail: dameng34@163.com > Created Time: Sun 03 Mar 2013 06:13:55 PM CST ************************************************************************/ #include<stdio.h> #include<stdio.h> #define ERR_EXIT(m) \ void echo_cli(int conn) write(conn, sendbuf, strlen(sendbuf)); close(conn); int main(void) struct sockaddr_un servaddr; if (connect(sock, (struct sockaddr *)&servaddr, sizeof(servaddr)) < 0) echo_cli(sock); return 0; |
server 使用fork 的形式来接受多个连接,server调用bind 会创建一个文件,如下所示:
simba@ubuntu:~/Documents/code/linux_programming/UNP/socket$ ls -l /tmp/test\ socket
srwxrwxr-x 1 simba simba 0 Jun 12 15:27 /tmp/test socket
即文件类型为s,表示SOCKET文件,与FIFO(命名管道)文件,类型为p,类似,都表示内核的一条通道,读写文件实际是在读写内核通道。程序中调用unlink(解除硬链接) 是为了在开始执行程序时删除以前创建的文件,以便在重启服务器时不会提示address in use。其他方面与以前说过的回射客户服务器程序没多大区别,不再赘述。
三、UNIX域套接字编程注意点
1、bind成功将会创建一个文件,权限为0777 & ~umask
2、sun_path最好用一个绝对路径
3、UNIX域协议支持流式套接口与报式套接口
4、UNIX域流式套接字connect发现监听队列满时,会立刻返回一个ECONNREFUSED,这和TCP不同,如果监听队列满,会忽略到来的SYN,这导致对方重传SYN。
四、socketpair 函数
功能:创建一个全双工的流管道
原型 int socketpair(int domain, int type, int protocol, int sv[2]);
参数
domain: 协议家族
type: 套接字类型
protocol: 协议类型
sv: 返回套接字对
返回值:成功返回0;失败返回-1
实际上socketpair 函数跟pipe 函数是类似的,也只能在同个主机上具有亲缘关系的进程间通信,但pipe 创建的匿名管道是半双工的,而socketpair 可以认为是创建一个全双工的管道。
可以使用socketpair 创建返回的套接字对进行父子进程通信:
1
2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 |
/*************************************************************************
> File Name: echoser.c > Author: Simba > Mail: dameng34@163.com > Created Time: Fri 01 Mar 2013 06:15:27 PM CST ************************************************************************/ #include<stdio.h> #define ERR_EXIT(m) \ int main(void) if (socketpair(PF_UNIX, SOCK_STREAM, 0, sockfds) < 0) pid_t pid; if (pid > 0) ++val; } else if (pid == 0) int val; read(sockfds[1], &val, sizeof(val)); return 0; |
输出如下:
simba@ubuntu:~/Documents/code/linux_programming/UNP/socket$ ./socketpair
sending data: 1
recv data : 2
sending data: 3
recv data : 4
sending data: 5
recv data : 6
sending data: 7
recv data : 8
sending data: 9
recv data : 10
sending data: 11
recv data : 12
sending data: 13
recv data : 14
sending data: 15
recv data : 16
...................................
即父进程持有sockfds[0] 套接字进行读写,而子进程持有sockfds[1] 套接字进行读写。
参考:
《Linux C 编程一站式学习》
《TCP/IP详解 卷一》
《UNP》
转载于:https://www.cnblogs.com/alantu2018/p/8472989.html
UNIX域套接字编程和socketpair 函数相关推荐
- 【socket】 unix域套接字(socketpair )通信|socketpair和pipe的区别|进程间通信-Unix domain socket
目录 unix域套接字(socketpair )通信|socketpair和pipe的区别 socketpair机制 描述 原理 socketpair和pipe的区别 进程间通信-Unix domai ...
- 域服务器广播消息,广播,组播和UNIX域套接字
1.广播 1.特点 一对多 仅能使用UDP 2.概念 发送方只有一个接收方则称单播 如果同时发给局域网中的所有主机,成为广播 只有用户数据包(使用UDP协议)套接字才能广播 广播地址 1.以192.1 ...
- unix 域套接字实现进程间通信
目录 1.认识域套接字 2.unix域套接字相关API及地址结构介绍 (1) 创建unix域套接字 (2) 填充地址结构 sockaddr_un 3.unix域套接字实现进程间通信( ...
- 学习Unix域套接字总结
开门见山,哲学三问!Unix域套接字是什么?为什么会存在Unix域套接字?如何用Unix域套接字? Unix域套接字是什么,为什么会有Unix用于套接字? Linux系统中不同进程进行通信的手段很多, ...
- linux 套接字 文件 路径,linux – 识别unix域套接字连接的另一端
我正在试图找出一个持有unix域套接字另一端的进程.在某些strace输出中,我已经确定了一个给定的文件描述符,这个文件描述符涉及到我目前正在调试的问题,我想知道哪一个进程在另一端.由于存在与该套接字 ...
- Beats:将 Unix 域套接字中的数据索引到 Elastic Stack
这篇博文将解释什么是 UNIX 域套接字,以及如何将发送到 UNIX 域套接字的索引编入 Elastic Stack - 以及为此存在哪些不同的用例. UNIX 域套接字 - 简短的历史 如果你想让进 ...
- 【技术应用】java基于UNIX域套接字(unix domain socket)连接mysql数据库
前言 Unix domain socket 又叫 IPC(inter-process communication 进程间通信)socket,用于实现同一主机上的进程间通信. socket 原本是为网络 ...
- 网络编程_5(超时检测+UNIX域套接字+抓包工具+包头分析)
一二章请点击:网络编程_1(网络基础+跨主机传输) 三四章请点击:网络编程_2(网络属性+UDP(UDP模型+广播组播)) 第五章请点击:网络编程_3(TCP) 第六章请点击:网络编程_4(IO模型) ...
- 糖儿飞教你学C++ Socket网络编程——5.套接字编程步骤与函数
TCP是一个面向连接的传输层协议,提供高可靠性的字节流传输服务,主要用于一次传输要交换大量报文的情形.为了维护传输的可靠性,TCP增加了许多开销:例如确认.流量控制.计时器以及连接管理等.TCP协议的 ...
最新文章
- 第一天开通博客,记录自己在编程道路上的点点滴滴
- MySql8.0.16安装
- Flutter入门:如何只关闭自身页面
- flink中写入行存储、列存储时设定checkpoint多久时间间隔另存一个新文件
- python如何封装成可调用的库_Python实现打包成库供别的模块调用
- Java开发人员的Erlang
- 一起玩转玩转LiteOS组件:Opus
- 音乐播放器界面如何设计?
- linux shell 试题,linux-shell 练习题
- mysql 保存emoji 4字节宽度字符串
- ProE5.0有限元分析优化设计Mechanica视频教程
- blast2go本地安装,一个防火墙设置引发的血案
- 一般线性规划求最大值
- eltable 无数据文案修改_写文案不断打磨修改,让你的文案简单易懂
- 手机最好的html5浏览器,综合能力的较量 8大手机浏览器半年横评
- 论文写作神器,SCI 写作必备
- 【转】MyEclipse8优化设置
- 2013年5月25日星期六
- kelvin模型蠕变方程_基于改进Kelvin模型的三维蠕变损伤模型研究
- ​[c/c++后台开发面经系列]4 Zoom面经(含答案)