父进程群发消息给子进程的方法

freeeyes

最近在研究一些功能，父进程需要通知子进程一些消息。
于是写了一个例子，借助本地socketpair。
于是实现了一个例子，测试通过。
感觉这个目前还有缺陷，当管道破裂的时候如何重建？还需要自己想想。

1. // ACETimer.cpp : 定义控制台应用程序的入口点。
2. //
3. /*
4. #include "ace/ACE.h"
5. #include "ace/SString.h"
6. #include "ace/Malloc.h"
7. #include "ace/Malloc_T.h"
8. #include "ace/Task_T.h"
9. #include "ace/Local_Memory_Pool.h"
10. #include "ace/Time_Value.h"
11. #include "ace/OS_main.h"
12. #include "ace/OS_NS_sys_stat.h"
13. #include "ace/OS_NS_sys_socket.h"
14. #include "ace/OS_NS_unistd.h"
15. #include "ace/High_Res_Timer.h"
16. #include "ace/INET_Addr.h"
17. */
19. #include <unistd.h>
20. #include <stdio.h>
21. #include <stdlib.h>
22. #include <sys/types.h>
23. #include <sys/socket.h>
25. using namespace std;
27. //子线程个数
28. #define CHILDREN_COUNT 2
30. int main(int argc, char *argv[])
31. {
32. #ifndef WIN32
33.        
34.         int nTest = 1;
36.         pid_t pid = 0;
37.         //pipe(filedes);
38.        
39.         //子进程和父进程的fd通讯信息
40.         int ayfd[CHILDREN_COUNT][2];
41.        
42.         for(int i = 0; i < CHILDREN_COUNT; i++)
43.         {
44.                 printf("[main]i=%d.\n", i);
45.                
46.                 socketpair(AF_UNIX, SOCK_STREAM, 0, ayfd[i]);
47.                
48.                 pid = fork();
50.                 if(pid == 0)
51.                 {
52.                         //子进程
53.                         printf("[Child]child process run(%d).\n", i);
54.                         char szData[50] = {'\0'};
55.                         while(true)
56.                         {
57.                                 //printf("[Child]child recv begin.\n");
58.                                 int nLen = read(ayfd[i][0], szData, sizeof(szData));
59.                                 if(nLen > 0)
60.                                 {
61.                                         printf("[Child]Recv Data[child %d](%s).\n", i, szData);
62.                                         printf("[child]nTest=%d.\n", nTest);
63.                       close(ayfd[i][1]); //关闭写
64.                                 }
65.                                 else
66.                                 {
67.                                         //ACE_Time_Value tvSleep(0, 10000);
68.                                         //ACE_OS::sleep(tvSleep);
69.                                         usleep(10000);
70.                                 }
71.                         }
72.                 }
73.         }
74.        
75.         printf("[Father]pid=%d.\n", pid);
76.         //父进程
77.         printf("[Father]Father process run.\n");
78.         char szData[50] = {'\0'};
79.         sprintf(szData, "Hello child.");
80.        
81.         //关闭所有读
82.         for(int j = 0; j < CHILDREN_COUNT; j++)
83.         {
84.                 close(ayfd[j][0]);  
85.         }
86.         while(true)
87.         {
88.                 printf("[Father]Send Begin.\n");
89.                 for(int j = 0; j < CHILDREN_COUNT; j++)
90.                 {
91.                         int nLen = write(ayfd[j][1], szData, sizeof(szData));
92.                         printf("[Father]Send Data(%d).\n", nLen);
93.                 }
94.                
95.                 nTest++;
96.                 /*
97.                 ACE_Time_Value tvSleep(10, 0);
98.                 ACE_OS::sleep(tvSleep);               
99.                 */
100.                 sleep(10);
101.   }
102.   //close(filedes[1]);                
104. #endif
105.         return 0;
106. }

复制代码

这部分代码只支持Linux，不考虑windows。