c/c++ unix ipc

一个例子

  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. }
  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. }
时间: 2024-10-04 16:28:35

c/c++ unix ipc的相关文章

01 UNIX IPC 第一弹 综述

UNIX IPC 第一弹 综述 0. 为什么会有这边文章? 一直对这方面的技术只有些模棱两可的了解,但又没有个统一完整的认识,在学习了<Modern Operating System>和<Advanced Programming in the UNIX Environmet>的相关章节后,做一个总结. 1. 什么是进程(process)?为什么要有进程? 进程是可执行程序加载到内存后,在CPU上执行的代码,包括一些相关的资源及状态,是一个动态的,变化的状态. 进程是系统资源分配的基

Unix IPC之Posix消息队列(1)

部分参考:http://www.cnblogs.com/Anker/archive/2013/01/04/2843832.html IPC对象的持续性:http://book.51cto.com/art/201006/207275.htm 消息队列可以认为是一个消息链表,某个进程往一个消息队列中写入消息之前,不需要另外某个进程在该队列上等待消息的达到,这一点与管道和FIFO相反.Posix消息队列与System V消息队列的区别如下: 1. 对Posix消息队列的读总是返回最高优先级的最早消息,

UNIX IPC: POSIX 消息队列 与 信号

POSIX消息队列可以注册空队列有消息到达时所触发的信号,而信号触发对应的信号处理函数. 下面是一份基本的消息队列和信号处理结合的代码(修改自UNIX网络编程:进程间通信) #include <stdio.h> #include <stdlib.h> #include <unistd.h> #include <sys/types.h> #include <sys/stat.h> #include <mqueue.h> #include

UNIX IPC: POSIX 消息队列

首先在我的MAC OSX上试了一下虽然有_POSIX_MESSAGE_PASSING的宏定义,但是用gcc编译会提示没有mqueue.h头文件,先放一边.在Ubuntu上使用正常,不过POSIX消息队列通过ipcs命令是看不到的,需要通过如下方式进行查看: mount -t mqueue none /mnt ls -al /mnt ls列出的文件即为程序中创建的POSIX消息队列,消息队列的名称需要以“/”开头否则会提示参数非法.通过cat查看这个文件可以知道这个队列的一些参数如: [email

Unix IPC之pipe

pipe创建函数: #include <unistd.h> /* Create a one-way communication channel (pipe). If successful, two file descriptors are stored in PIPEDES; bytes written on PIPEDES[1] can be read from PIPEDES[0]. Returns 0 if successful, -1 if not. */ int pipe (int

Unix IPC之基于共享内存的计数器

目的 本文主要实现一个基于共享内存的计数器,通过父子进程对其访问. 本文程序需基于<<Unix网络编程-卷2>>的环境才能运行.程序中大写开头的函数为其小写同名函数的包裹函数,增加了错误处理信息. 1 函数介绍 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 #include <sys/mman> /**  * Map addresses starting near ADDR an

Unix IPC之共享内存区(1)

1 共享内存区 共享内存区是可用IPC形式中最快的,只有映射和解除映射需要进入内核的系统调用,映射后对共享内存区的访问和修改不再需要系统调用(内核只要负责好页表映射和处理页面故障即可),但通常需要同步手段. 一个客户-服务器间传递文件数据的例子中,FIFO或消息队列等IPC方式通常需要4次内核-进程间的数据复制(但是Posix消息队列可使用内存映射I/O实现,就不一定4次了),每次都需要切换地址空间,开销很大:共享内存区只需要2次跨内核的数据复制. 2  mmap mmap的三个目的: 1.  

Unix IPC之Posix消息队列(2)

/* Query status and attributes of message queue MQDES. */ extern int mq_getattr (mqd_t __mqdes, struct mq_attr *__mqstat) __THROW __nonnull ((2)); /* Set attributes associated with message queue MQDES and if OMQSTAT is not NULL also query its old att

Unix IPC之Posix消息队列(3)

struct mq_attr { long mq_flags; /* message queue flag : 0, O_NONBLOCK */ long mq_maxmsg; /* max number of messages allowed on queue*/ long mq_msgsize; /* max size of a message (in bytes)*/ long mq_curmsgs; /* number of messages currently on queue */