使用socket实现进程间通信：（UNIX domain中面向连接通信）

使用套接字除了可以实现网络间不同主机间的通信外，还可以实现同一主机的不同进程间的通信，且建立的通信是双向的通信。
man unix内容如下：
NAME( 名称）
    unix, PF_UNIX, AF_UNIX, PF_LOCAL, AF_LOCAL ? 用于本地内部进程通讯的套接 字。
SYNOPSIS( 总览 )
    #include <sys/socket.h>
    #include <sys/un.h>

unix_socket = socket(PF_UNIX, type, 0);
    error = socketpair(PF_UNIX, type, 0, int *sv);
DESCRIPTION( 描述 )
    PF_UNIX (也称作 PF_LOCAL ) 套接字族用来在同一机器上的提供有效的进程间通讯.Unix 套接字可以是匿名的(由 socketpair(2)创建), 也可以与套接字类型文件相关联. Linux 还支持一种抽象名字空间, 它是独立于文件系统的.
    有效的类型有: SOCK_STREAM 用于面向流的套接字, SOCK_DGRAM 用于面向数据报的套接字,其可以保存消息界限. Unix 套接字总是可靠的,而且不会重组数据报.
    Unix 套接字支持把文件描述符或者进程的信用证明作为数据报的辅助数据传递给 其它进程．
ADDRESS FORMAT( 地址格式 )
    unix 地址定义为文件系统中的一个文件名或者抽象名字空间中的一个单独的字符串. 由 socketpair(2) 创建的套接字是匿名的.对于非匿名的套接字,目标地址 可使用 connect(2) 设置. 本地地址可使用 bind(2) 设置. 当套接字连接上而且它没有一个本地地址时, 会自动在抽象名字空间中生成一个唯一的地址.
    #define UNIX_PATH_MAX   108

struct sockaddr_un {
    sa_family_t     sun_family;     /* AF_UNIX */
    char    sun_path[UNIX_PATH_MAX];        /* 路径名 */
    };
    sun_family 总是包含 AF_UNIX. sun_path 包含空零结尾的套接字在文件系统中的路径名. 如果 sun_path 以空零字节开头,它指向由 Unix 协议模块维护的抽象名字空间. 该套接字在此名字空间中的地址由 sun_path 中的剩余字节给定. 注意抽象名字空间的名字都不是空零终止的.
SOCKET OPTIONS( 套接字选项 )
    由 于 历 史 原 因, 这些套接字选项通过 SOL_SOCKET 类型确定, 即使它们是 PF_UNIX 指定的. 它们可以由 setsockopt(2) 设置. 通过指定 SOL_SOCKET 作 为套接字族用 getsockopt(2) 来读取.
    SO_PASSCRED 允许接收进程辅助信息发送的信用证明. 当设置了该选项且套接字 尚未连接时, 则会自动生成一个抽象名字空间的唯一名字. 值为一个整数布尔标 识.
ANCILLARY MESSAGES( 辅助信息 )
    由 于 历 史 原 因, 这些辅助信息类型通过 SOL_SOCKET 类型确定, 即使它们是 PF_UNIX 指定的. 要发送它们, 可设置结构 cmsghdr 的 cmsg_level 字 段 为 SOL_SOCKET, 并 设 置 cmsg_type 字段为其类型. 要获得更多信息, 请参看 cmsg(3).
    SCM_RIGHTS
    为其他进程发送或接收一套打开文件描述符. 其数据部分包含一个文件 描述符的整型数组. 已传文件描述符的效果就如它们已由 dup(2) 创建 过一样.
    SCM_CREDENTIALS
    发送或者接收 unix 信用证明. 可用作认证.信用证明传送 以 struct ucred 辅助信息的形式传送．
    struct ucred {
    pid_t   pid;     /* 发送进程的进程标识 */
    uid_t   uid;     /* 发送进程的用户标识 */
    gid_t   gid;     /* 发送进程的组标识 */
    };
    发 送者确定的信用证明由内核检查. 一个带有有效用户标识 0 的进程允许指定 不与其自身值相匹配的值.发送者必须确定其自身的进程 标 识( 除非它带 有 CAP_SYS_ADMIN), 其 用 户 标识,有效用户标识或者设置用户标识(除非它带有CAP_SETUID), 以及其组标识,有效组标识或者 设 置 组 标 识( 除非它带有CAP_SETGID). 为 了 接 收 一 条 struct ucred 消息,必须在套接字上激活 SO_PASSCRED 选项.
ERRORS( 错误 )
    ENOMEM
        内存溢出.
    
    ECONNREFUSED
        connect(2) 调用了一个未在监听的套接字对象. 这可能发生在远程套 接字不存在或者文件名不是套接字的时候.
    EINVAL
        传递了无效参数. 通常的产生原因是已传地址的 sun_type 字 段的 AF_UNIX 设置丢失, 或者套接字对应用的操作处于无效状态.
    EOPNOTSUPP
        在非面向流的套接字上调用了流操作,或者试图使用出界的数据选项.
    EPROTONOSUPPORT
        传递的协议是非 PF_UNIX 的.
    ESOCKTNOSUPPORT
        未知的套接字类型.
    EPROTOTYPE
        远程套接字与本地套接字类型不匹配 (SOCK_DGRAM 对SOCK_STREAM).
    EADDRINUSE
        选择的本地地址已经占用,或者文件系统套接字对象已经存在.
    EISCONN
        在 一个已经连接的套接字上调用 connect(2) 或者指定的目标地址在一 个已连接的套接字上.
    ENOTCONN
        套接字操作需要一个目的地址,但是套接字尚未连接.
    ECONNRESET
        远程套接字意外关闭.
    EPIPE
        远程套接字在一个流套接字上关闭了.如果激活,会同时发送一个 SIGPIPE 标识.这可以通过传递 MSG_NOSIGNAL 标识给 sendmsg(2) 或者 recvmsg(2) 来避免.
    EFAULT
        用户内存地址无效.
    EPERM
        发送者在 struct ucred 中传递无效的信用证明.
    当生成一个文件系统套接字对象时, 可能会由通用套接层或者文件系统产生其它错误. 要获得更多信息,可参见合适的手册页.

实践：

使用套接字在UNIX域内实现进程间通信的服务端程序。首先，程序通过调用socket函数，建立了监听连接的套接字，然后调用bind函数，将套接字与地址信息关联起来。调用listen函数实现对该端口的监听，当有连接请求时，通过调用accept函数建立与客户机的连接，最后，调用read函数来读取客户机发送过来的消息，当然也可以使用recv函数实现相同的功能。

server代码：s_unix.c

  1. //s_unix.c
  2. #include <stdio.h>
  3. #include <sys/types.h>
  4. #include <sys/socket.h>
  5. #include <sys/un.h>
  6. #define UNIX_DOMAIN "/tmp/UNIX.domain"
  7. int main(void)
  8. {
  9. socklen_t clt_addr_len;
  10. int listen_fd;
  11. int com_fd;
  12. int ret;
  13. int i;
  14. static char recv_buf[1024];
  15. int len;
  16. struct sockaddr_un clt_addr;
  17. struct sockaddr_un srv_addr;
  18. listen_fd=socket(PF_UNIX,SOCK_STREAM,0);
  19. if(listen_fd<0)
  20. {
  21. perror("cannot create communication socket");
  22. return 1;
  23. }
  24. //set server addr_param
  25. srv_addr.sun_family=AF_UNIX;
  26. strncpy(srv_addr.sun_path,UNIX_DOMAIN,sizeof(srv_addr.sun_path)-1);
  27. unlink(UNIX_DOMAIN);
  28. //bind sockfd & addr
  29. ret=bind(listen_fd,(struct sockaddr*)&srv_addr,sizeof(srv_addr));
  30. if(ret==-1)
  31. {
  32. perror("cannot bind server socket");
  33. close(listen_fd);
  34. unlink(UNIX_DOMAIN);
  35. return 1;
  36. }
  37. //listen sockfd
  38. ret=listen(listen_fd,1);
  39. if(ret==-1)
  40. {
  41. perror("cannot listen the client connect request");
  42. close(listen_fd);
  43. unlink(UNIX_DOMAIN);
  44. return 1;
  45. }
  46. //have connect request use accept
  47. len=sizeof(clt_addr);
  48. com_fd=accept(listen_fd,(struct sockaddr*)&clt_addr,&len);
  49. if(com_fd<0)
  50. {
  51. perror("cannot accept client connect request");
  52. close(listen_fd);
  53. unlink(UNIX_DOMAIN);
  54. return 1;
  55. }
  56. //read and printf sent client info
  57. printf("/n=====info=====/n");
  58. for(i=0;i<4;i++)
  59. {
  60. memset(recv_buf,0,1024);
  61. int num=read(com_fd,recv_buf,sizeof(recv_buf));
  62. printf("Message from client (%d)) :%s/n",num,recv_buf);
  63. }
  64. close(com_fd);
  65. close(listen_fd);
  66. unlink(UNIX_DOMAIN);
  67. return 0;
  68. }

使用套接字在UNIX域内实现进程间通信的客户端程序。相比服务端的程序，客户段较为简单。程序首先通过调用socket函数创建通信所需的套接字，然后，调用connect函数来连接服务器，在成功建立连接后，通过调用write函数向服务器发送指定的消息。

client代码：u_unix.c

  1. //c_unix.c
  2. #include <stdio.h>
  3. #include <sys/types.h>
  4. #include <sys/socket.h>
  5. #include <sys/un.h>
  6. #define UNIX_DOMAIN "/tmp/UNIX.domain"
  7. int main(void)
  8. {
  9. int connect_fd;
  10. int ret;
  11. char snd_buf[1024];
  12. int i;
  13. static struct sockaddr_un srv_addr;
  14. //creat unix socket
  15. connect_fd=socket(PF_UNIX,SOCK_STREAM,0);
  16. if(connect_fd<0)
  17. {
  18. perror("cannot create communication socket");
  19. return 1;
  20. }
  21. srv_addr.sun_family=AF_UNIX;
  22. strcpy(srv_addr.sun_path,UNIX_DOMAIN);
  23. //connect server
  24. ret=connect(connect_fd,(struct sockaddr*)&srv_addr,sizeof(srv_addr));
  25. if(ret==-1)
  26. {
  27. perror("cannot connect to the server");
  28. close(connect_fd);
  29. return 1;
  30. }
  31. memset(snd_buf,0,1024);
  32. strcpy(snd_buf,"message from client");
  33. //send info server
  34. for(i=0;i<4;i++)
  35. write(connect_fd,snd_buf,sizeof(snd_buf));
  36. close(connect_fd);
  37. return 0;
  38. }

编译运行：

[root@localhost liuxltest]# ./s_unix &
[1] 11664
[root@localhost liuxltest]# ./c_unix &

=====info=====
Message from client (1024)) :message from client
Message from client (1024)) :message from client
Message from client (1024)) :message from client
Message from client (1024)) :message from client
[2] 11665
[1]-  Done                    ./s_unix
[2]+  Done                    ./c_unix
[root@localhost liuxltest]#

当运行s_unix程序后，该程序将处于监听状态。这时，可以通过netstat命令查看程序运行情况，s_unix的套接字类型为流套接字，并处于监听状态。
[root@localhost liuxltest]# 
[root@localhost liuxltest]# ./s_unix &
[1] 12056
[root@localhost liuxltest]# netstat -an |grep /tmp
unix  2      [ ACC ]     STREAM     LISTENING     64014  /tmp/ssh-CekOJ11069/agent.11069
unix  2      [ ACC ]     STREAM     LISTENING     6216   /tmp/.font-unix/fs7100
unix  2      [ ACC ]     STREAM     LISTENING     62042  /tmp/ssh-XOCgkr9439/agent.9439
unix  2      [ ACC ]     STREAM     LISTENING     62316  /tmp/ssh-mojoaQ9648/agent.9648
unix  2      [ ACC ]     STREAM     LISTENING     65267  /tmp/UNIX.domain
unix  2      [ ACC ]     STREAM     LISTENING     65210  /tmp/ssh-NlKtA12012/agent.12012
[root@localhost liuxltest]#

Unix socket进程间通信相关推荐

  1. Another MySQL daemon already running with the same unix socket的解决

    问题出现: 每周一需要备份一次数据库,即从服务器MySQL导出sql文件,再导入到我机器上虚拟机的MySQL里.但是今天早上连不上,我进入控制台用#service mysqld start强行启动,报 ...

  2. memcache多语言unix socket访问

    unix socket文件目录: /usr/local/memcache/socket php访问示例: $m = new Memcached(); $ret = $m->addServer(' ...

  3. Nginx 中 fastcgi_pass 监听端口 unix socket和tcp socket差别

    Nginx连接fastcgi的方式有2种:unix domain socket和TCP,Unix domain socket 或者 IPC socket是一种终端,可以使同一台操作系统上的两个或多个进 ...

  4. ubuntu下面解决mysqld_safe Directory '/var/run/mysqld' for UNIX socket file don't exists

    事情是这样的,原先创建MySQL中的root用户,指定的host为localhost,就想改一下为某个网段的,结果改完之后就退出了,然后就悲剧了,无法连接了.网上找的大部分解决办法是: ubuntu下 ...

  5. mysql启动报错：Another MySQL daemon already running with the same unix socket.

    [root@localhost ~]#/etc/init.d/mysqld restart Stopping mysqld:                                       ...

  6. Can‘t start server : Bind on unix socket: Address already in use

    文章目录 问题定位: mysql的端口3306, 已经运行了一个mysq服务端占用3306,再次运行就会出现这个问题Can't start server : Bind on unix socket: ...

  7. MySQL不能启动 Can't start server : Bind on unix socket: Permission denied

    [问题描述] MySQL不能启动 Can't start server : Bind on unix socket: Permission denied [解决方案] 查看my.cnf文件,找到.so ...

  8. another mysql daemon_MySQL错误Another MySQL daemon already running with the same unix socket.

    安装Cacti的过程中配置了数据库,但由于是在虚拟机里做的,习惯性的关机直接是Force off硬关机,刚配置完的cacti在我非正常关机重起后出现了问题,问题如下: [root@server2 ~] ...

  9. eBPF BCC 实现UNIX socket抓包

    在之前,我写了一个<eBPF bpftrace 实现个UNIX socket抓包试试>,但是很受限啊,不能完整打印包数据信息,今天又写了一个BCC的,感觉没问题了. 不多说,直接上代码: ...

最新文章

  1. 使用datatables实现列宽设置、水平滚动条、显示某列部分内容
  2. 利用nginx的fastcgi_cache模块来做缓存
  3. Redis进阶-无所不知的info命令诊断redis
  4. 穿越栅栏 Overfencing
  5. 阿里云 centos mysql_在阿里云的CentOS环境中安装配置MySQL的教程
  6. 浏览器兼容console对象的简要解决方案
  7. 转-TabHost组件(二)（实现底部菜单导航）
  8. [GCN] 图卷积知识梳理 -持续更新
  9. 给做技术的换一道菜尝尝：一月冲皇冠？凶残级淘宝店主，无法阻挡的爆款名城！...
  10. 三星30pin引脚_USB3.0针脚定义、引脚定义(精校版本)
  11. 抖音 Android 包体积优化探索：资源二进制格式的极致精简
  12. Android 简单图片浏览器
  13. 谈谈自己对教育的理解（K12）
  14. Mysql主从同步报错解决：Error executing row event: Table zabbix.history-uint doesnt exist
  15. 电子元件中场效应晶体管与晶体三极管，谁能领袖群伦
  16. termux安装kodbox-方便简单图形界面操作
  17. 文件包含之本地包含的利用
  18. 【前端】Angular的布局（响应式布局）笔记3
  19. 【深度学习】入门之keras
  20. 【推荐】Windows安装的几种工具

热门文章

  1. COMSOL激光超声仿真
  2. UDP服务器判断客户端是否掉线
  3. 软件工程课程设计——教务辅助管理系统
  4. 强化学习系列文章(二十八)：进化强化学习EvoRL的预实验
  5. 毕业设计答辩经典问题-项目实现步骤和流程
  6. 【Luogu】CF688B Lovely Palindromes
  7. css3实现图片折叠效果
  8. e52450相当于i几处理器_【有趣】第3期：八路E7的结局如何？盘点历代至尊版处理器现价...
  9. 中小企业如何建立企业文化
  10. 软考高项 : （12）论项目风险管理