UNIX下利用inetd daemon 管理应用系统的守护进程

xzh2002

UNIX下利用inetd daemon 管理应用系统的守护进程

               中国银行西安市分行信息科技处             胡旋



   在当今网际互连中 TCP/IP 已成为事实上的标准，大部分应用程序均采用C/S操作模式、TCP/IP编程并运行。即客户端向服务器发出请求，服务器运行守护进程，随时监听和捕捉客户端的请求并进行相应的处理。对于较大类型的应用系统，如银行综合业务处理系统，将产生各种类型的后台服务进程，这些进程均在无休止的等待，增加系统负载，耗费系统资源，并且管理起来也不方便。



    UNIX操作系统为用户提供inetd daemon 进行网络服务管理。它将所有的后台应用程序置于它的管理之下，在客户端没有请求时，所有的后台应用程序都不启动，一旦客户端有特定的请求上来，它将根据/etc/services 和/etc/inetd.conf 文件描述的请求端口号和服务名调动相应的应用程序进行处理，而其它后台应用程序是不启动的。被启动的应用程序完成了特定任务后就终结自己的进程，这就减轻了系统负载，节约了系统资源，极大地提高了系统效率，是实现应用系统网络互连的一个实用工具。



inetd daemon 在开机时由/etc/rc.tcpip文件启动，一旦inetd daemon 启动即从 /etc/inetd.conf 文件中读取它的配置信息，然后在特定的套接字上监听连接请求，该文件的作用是告诉 inetd daemon 各端口号上的请求如何处理。即该服务采用何种套接字类型，是字节流还是数据报，采用什么协议（TCP/UDP）,应用程序等待否，在监听套接字之前是否释放套接字，应用程序的名字、参数及路径等。整个流程可用下图表示:



    inetd daemon 在运行中可通过SRC命令(startsrc stopsrc lssrc等)进行控制。所以,可以很方便地对后台应用程序进行管理。



    下面简要介绍如何在inetd daemon 中增加一个新的后台处理程序，假定该程序是电话银行的后台处理程序tbankd。

1.修改 /etc/services 文件，增加新的应用程序的端口号和服务名。

   服务名         端口号/网络类型

   tbank          3000/tcp

2.修改 /etc/inetd.conf 配置文件，增加新的一行配置:

服务名套接字类型  采用的协议 等待否  用户名 应用程序及路径 参数

tbank  stream      tcp        nowait   root  /u0/tbank/bin/tbankd

3.应用程序编程注意事项

    服务器上的应用程序 tbankd 从标准输入 stdin 中读取客户端发来的请求数据，返回的处理信息也写入 stdin。

4.重新启动 inetd daemon

先用 stopsrc  -s inetd 命令关闭 inetd daemon,

再用 startsrc -s inetd 命令启动.

    或用refresh -s inetd  省去关闭启动过程,直接通知inetd daemon 配置文件已改变，启用新的配置文件。

5.查看inetd daemon 运行状况：

    键入lssrc -a 后系统显示:

    Subsystem         Group            PID     Status

    inetd             tcpip            26912   active

    表示 inetd daemon 已正常启动 进程号为 26912



6.inetd daemon 运行流程图 :





    本地主机            远程主机                                     从标准输入

  前台通信请求方        服务器方                                         接收请求

                                                                      read(0)



  创建套接字                                 后台处理程序一            处理





                                                                     向标准输入

  建立链接              inetd daemon                                   返回处理结果

                                                                     write(0)





  向服务器发出

  请求数据报文                               后台处理程序二             ...





                                                 .

  阻塞等待服务器                                 .

  返回数据报文                                   .







  收到结果报文                               后台处理程序N              ...







   其它处理



7.程序实例 :

    该程序是一个实用的基本模型，用户可在此基础上开发出自己的应用程序。

1. /*client 客户端程序*/
   
2. 
   
3. #include    <stdio.h>;
   
4. 
   
5. #include    <sys/types.h>;
   
6. 
   
7. #include    <sys/times.h>;
   
8. 
   
9. #include    <sys/socket.h>;
   
10. 
    
11. #include    <netinet/in.h>;
    
12. 
    
13. 
    
14. 
    
15. #define  HEADLEN 6
    
16. 
    
17. main(argc,argv)
    
18. 
    
19. int argc;
    
20. 
    
21. char ** argv;
    
22. 
    
23. {
    
24. 
    
25.     int sockfd;
    
26. 
    
27.     struct sockaddr_in  serv_addr;/*存服务器方的地址*/
    
28. 
    
29.     char info[4096],head[7];
    
30. 
    
31.     int infolen;
    
32. 
    
33.     int rc;
    
34. 
    
35. 
    
36. 
    
37.     if (argc!=2)
    
38. 
    
39.     {
    
40. 
    
41.         fprintf(stderr,"client ipaddress\n");
    
42. 
    
43.         exit(-1);
    
44. 
    
45.     }
    
46. 
    
47.     /*参数是服务器的IP地址*/
    
48. 
    
49.     bzero((char *)&serv_addr, sizeof(serv_addr));
    
50. 
    
51.     /*服务器地址变量清0*/
    
52. 
    
53.         serv_addr.sin_family        = AF_INET;
    
54. 
    
55.     /*网络地址类型使用ARPA internet 地址*/
    
56. 
    
57.     serv_addr.sin_addr.s_addr   = inet_addr(argv[1]);
    
58. 
    
59.     /*服务器IP地址转换为长整型IP地址, 并赋予地址结构变量*/
    
60. 
    
61.     serv_addr.sin_port=htons(6000);
    
62. 
    
63.     /*与服务器相同的IP端口号, 经主机字节顺序到网络字节顺序的转换*/
    
64. 
    
65.     if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0)
    
66. 
    
67.     /*创建TCP协议的字节流套接字*/
    
68. 
    
69.     {
    
70. 
    
71.         fprintf(stderr, "Client : Can not open stream socket\n");
    
72. 
    
73.         exit(-1);
    
74. 
    
75.     }
    
76. 
    
77.     /*与服务进程建立连接*/
    
78. 
    
79.     if (connect(sockfd,(struct sockaddr *)&serv_addr,sizeof(serv_addr)) < 0)
    
80. 
    
81.     {
    
82. 
    
83.         fprintf(stderr,"err connect ....\n");
    
84. 
    
85.         exit(-1);
    
86. 
    
87.     }
    
88. 
    
89.     /*此时连接已建立, 可通过对套接字的读写实现通信*/
    
90. 
    
91.     /*客户进程向服务进程发送请求信息*/
    
92. 
    
93.     sprintf(info,"000026向服务器发出查询张三的请求");
    
94. 
    
95.     infolen=strlen(info);
    
96. 
    
97.     if ( (rc=write(sockfd, info, infolen)) == -1 )
    
98. 
    
99.         fprintf(stderr, "TCPSend failed !!\n");
    
100. 
     
101.     /*接受服务器返回的头信息*/
     
102. 
     
103.     memset(head,0,sizeof(head));
     
104. 
     
105.    if (( rc=read(sockfd, head, HEADLEN)) == -1
     
106. 
     
107.         || rc<HEADLEN
     
108. 
     
109.         || (infolen=atoi(head))<=0 )
     
110. 
     
111.     {
     
112. 
     
113.         fprintf(stderr, "read head failed rc:%d!!\n",rc);
     
114. 
     
115.         exit(-1);
     
116. 
     
117.     }
     
118. 
     
119.     /*接受服务器返回的报文信息*/
     
120. 
     
121.     memset(info,0,sizeof(info));
     
122. 
     
123.     if ( (rc=read(sockfd, info, infolen)) == -1 )
     
124. 
     
125.           fprintf(stderr, "TCPRecv failed !!\n");
     
126. 
     
127.     /*客户进程接收服务进程返回的帐户信息*/
     
128. 
     
129.     fprintf(stderr,"%s\n",info);
     
130. 
     
131.     shutdown(sockfd, 2);
     
132. 
     
133.     close(sockfd);
     
134. 
     
135. }
     
136. 
     
137. 
     
138. 
     
139. 
     
140. 
     
141. /*tbankd后台服务程序*/
     
142. 
     
143. #include    <stdio.h>;
     
144. 
     
145. #define      HEADLEN  6
     
146. 
     
147. FILE *fp_log;
     
148. 
     
149. 
     
150. 
     
151. main(argc,argv)
     
152. 
     
153. int argc;
     
154. 
     
155. char ** argv;
     
156. 
     
157. {
     
158. 
     
159.     char info[1024],head[7];
     
160. 
     
161.     int infolen;
     
162. 
     
163.     int rc;
     
164. 
     
165.     char * send_info;
     
166. 
     
167. 
     
168. 
     
169.     fp_log=fopen("/_tbank.log","a");
     
170. 
     
171.     memset(head,0,sizeof(head));
     
172. 
     
173.     /*接受客户机发来的头信息*/
     
174. 
     
175.    if (( rc=read(0, head, HEADLEN)) == -1
     
176. 
     
177.         || rc<HEADLEN
     
178. 
     
179.         || (infolen=atoi(head))<=0 )
     
180. 
     
181.     {
     
182. 
     
183.         fprintf(fp_log, "read head failed rc:%d!!\n",rc);
     
184. 
     
185.         exit(-1);
     
186. 
     
187.     }
     
188. 
     
189.     memset(info,0,sizeof(info));
     
190. 
     
191.    if ((rc=read(0, info, infolen)) == -1 || rc<infolen )
     
192. 
     
193.     /*接受客户机发来的信息*/
     
194. 
     
195.     {
     
196. 
     
197.         fprintf(fp_log, "read info failed !!\n");
     
198. 
     
199.         exit(-1);
     
200. 
     
201.     }
     
202. 
     
203.     fprintf(fp_log,"收到的客户端的请求:%s\n",info);
     
204. 
     
205.     send_info="000021张三当前余额1000.00元";
     
206. 
     
207.     /*向客户机发送该帐户信息*/
     
208. 
     
209.    infolen=strlen(send_info);
     
210. 
     
211.    if ((rc=write(0, send_info, infolen) )== -1)
     
212. 
     
213.         fprintf(fp_log, "TCPSend failed !!\n");
     
214. 
     
215.     close(fp_log);
     
216. 
     
217. }

复制代码

liu2005

非常感谢！