请熟悉SOCKET的朋友看看这函数。

ablised

1. 这个程序里面用了2个套接字，一个本地套接字，一个监听外部连接时的套接字。
   
2. 主要不清楚这个本地套接字有什么用，因为觉得哪个监听外部的完全都可以了，大家能解释解释本地套接字作用吗？谢谢了
   
3. int     main(int argc, char *argv[])
   
4. {
   
5.     char        szFile[256], szServicesName[64], szIP[32], szLine[257];
   
6.     long        lPid, lPort, lRet;
   
7. #ifdef  IBM_AIX
   
8.     unsigned long   iLen;
   
9. #else
   
10.     int         iLen;
    
11. #endif
    
12.     int         skMax, skNew, skLocal, skExtern, skServer;
    
13.     fd_set      rset, setsave;
    
14.     struct      _ALSend
    
15.     {
    
16.         long    lPort;
    
17.         struct  sockaddr_in saClient;
    
18.     }stSend;
    
19. 
    
20.     logv_SetFile(TCSERV_LOGFILE);
    
21.     /*  初始化*/
    
22.     if(tcomml_InitDaemon() != RC_SUCCESS)
    
23.     {
    
24.         Trace("初始化驻留进程失败!");
    
25.         fprintf(stdout, "启动tcserv失败!");
    
26.         exit(RC_FAILURE);
    
27.     }
    
28. 
    
29.     /*  得到本进程的监听端口*/
    
30.     lPort = tcomml_GetListenPort();
    
31.     if(0 >= lPort)
    
32.     {
    
33.         printf("tcserv:load listen port Error!\n"); fflush(stdout);
    
34.         exit(RC_FAILURE);
    
35.     }
    
36. 
    
37.     /*  获取交易信息配置*/
    
38.     lRet = tcomml_LoadTrConfig();
    
39.     if(lRet == RC_FAILURE)
    
40.     {
    
41.         printf("tcserv:load trConfig Error!\n"); fflush(stdout);
    
42.         exit(RC_FAILURE);
    
43.     }
    
44.     else
    
45.         g_lCurTrCount = lRet;
    
46. 
    
47.     FD_ZERO(&setsave);
    
48.     skExtern = socki_BindExtern(lPort, 5);        /*******这个函数作用是用指定端口监听外部连接，后面贴有函数******/
    
49.     if(RC_FAILURE == skExtern)
    
50.     {
    
51.         Trace("绑定本地端口出错!");
    
52.         exit(RC_FAILURE);
    
53.     }
    
54.     skMax = skExtern;
    
55.     FD_SET(skExtern, &setsave);
    
56. 
    
57.     /*  产生一个本地监听用的套节子接口*/
    
58.     if((skLocal = socki_BindLocal()) == RC_FAILURE) /******这个是产生的本地套接字，是用SOCKET文件的形式。这个做什么用？后面贴有函数*****/
    
59.     {
    
60.         Trace("产生本地套节子失败");
    
61.         close(skExtern);
    
62.         exit(RC_FAILURE);
    
63.     }
    
64.     if(skLocal > skMax)
    
65.         skMax = skLocal;
    
66. 
    
67.     FD_SET(skLocal, &setsave);
    
68. 
    
69.     while(1)
    
70.     {
    
71.         rset = setsave;
    
72.         select(skMax + 1, &rset, NULL, NULL, NULL);
    
73.         if(FD_ISSET(skLocal, &rset))    [color=Red]/******主要是不清楚这个if分支的作用，因为感觉下面的if分支都完全可以处理****/[/color]
    
74.         {
    
75.             /*  一个本地的请求一定是监测进程*/
    
76.             Trace("收到本地的请求!");
    
77.             iLen = sizeof(stSend.saClient);
    
78.             memset(&stSend, 0, sizeof(struct _ALSend));
    
79.             lRet = recvfrom(skLocal, szLine, 256, 0,
    
80.                     (struct sockaddr*)&stSend.saClient, &iLen);
    
81.             if(0 <= lRet)
    
82.             {
    
83.                 Tstring(lRet, szLine);
    
84.             }
    
85.             continue;
    
86.         }
    
87.         if(FD_ISSET(skExtern, &rset))
    
88.         {
    
89.             iLen = sizeof(stSend.saClient);
    
90.             memset(&stSend, 0, sizeof(struct _ALSend));
    
91.             skNew = accept(skExtern, (struct sockaddr*)&stSend.saClient, &iLen);
    
92.             if(skNew < 0)
    
93.             {
    
94.                 Trace("Accept Extern Error!");
    
95.                 continue;
    
96.             }
    
97.             /*  将得到的IP地址转换为字符串*/
    
98.             memset(szIP, 0, sizeof(szIP));
    
99.             strcpy(szIP, (char*)inet_ntoa(stSend.saClient.sin_addr));
    
100. Trace("收到来自地址%s的请求", szIP);
     
101. 
     
102.             memset(szServicesName, 0, sizeof(szServicesName));
     
103.             if(socki_Auth(skNew, szServicesName, szIP) == RC_FAILURE)
     
104.             {
     
105.                 close(skNew);
     
106.                 Trace("系统认证失败,非法授权用户连接!");
     
107.                 continue;
     
108.             }
     
109. Trace("通过认证");
     
110. 
     
111.             if(0 >= (lPid = tcomml_SelectServer(szServicesName)))        /*这个函数作用是选择可用的服务进程*/
     
112.             {
     
113.                 close(skNew);
     
114.                 Trace("系统忙，无可用的服务进程!");
     
115.                 continue;
     
116.             }
     
117. 
     
118.             /*  写出套节子，需要将端口号和客户端信息同时传递过去*/
     
119.             iLen = sizeof(stSend);
     
120.             stSend.lPort = lPort;
     
121. 
     
122. Trace("连接进程(%d)", lPid);
     
123.             if((skServer = socki_ConnectLocal(lPid)) < 0)        /*****用socket文件的形式，连接刚才的可用服务进程，后面贴有函数****/
     
124.             {
     
125.                 Trace("连接进程(%d)出错", lPid);
     
126.                 close(skNew);
     
127.                 continue;
     
128.             }
     
129.             if(RC_SUCCESS != socki_Writefd(skServer, &stSend, iLen, skNew))        /****是向可用的服务进程发送数据*****/
     
130.             {
     
131.                 Trace("通过(%d)发送套节子(%d)失败", skServer, skNew);
     
132.             }
     
133.             close(skNew);
     
134.             close(skServer);
     
135.             continue;
     
136.         }
     
137.     }
     
138. }

复制代码

[ 本帖最后由 ablised 于 2009-4-5 01:24 编辑 ]

ablised

/****************************************************************************** &nbsp;&nbsp;&nbsp;&nbsp;函 数 名：socki_BindExtern          函数编号： &nbsp;&nbsp;&nbsp;&nbsp;功能描述：建立一个AF_INET的套节子，绑定到指定的端口并设置监听队列深度 &nbsp;&nbsp;&nbsp;&nbsp;入口参数： &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;in_lPort            --端口号 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;in_lQueue           --设置监听队列的深度 &nbsp;&nbsp;&nbsp;&nbsp;返回说明： &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;>0                  --返回得到的套节子 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;RC_FAILURE          --失败 &nbsp;&nbsp;&nbsp;&nbsp;引用变量： &nbsp;&nbsp;&nbsp;&nbsp;开发历史： &nbsp;******************************************************************************/ int     socki_BindExtern(long in_lPort, long in_lQueue) { &nbsp;&nbsp;&nbsp;&nbsp;long    lRet; &nbsp;&nbsp;&nbsp;&nbsp;int     iLen, sockfd, iSockCtl; &nbsp;&nbsp;&nbsp;&nbsp;struct  sockaddr_in stAddr; &nbsp;&nbsp;&nbsp;&nbsp;sockfd = socket(AF_INET, SOCK_STREAM, 0); &nbsp;&nbsp;&nbsp;&nbsp;if(0 > sockfd) &nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Trace("generate socket error"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return RC_FAILURE; &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;iLen = sizeof(iSockCtl); &nbsp;&nbsp;&nbsp;&nbsp;iSockCtl = 1; &nbsp;&nbsp;&nbsp;&nbsp;lRet = setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, (char*)&iSockCtl, iLen); &nbsp;&nbsp;&nbsp;&nbsp;if(-1 == lRet) &nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Trace("set socket REUSEADDR error"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;close(sockfd); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return RC_FAILURE; &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;stAddr.sin_family = AF_INET; &nbsp;&nbsp;&nbsp;&nbsp;stAddr.sin_addr.s_addr = htonl(INADDR_ANY); &nbsp;&nbsp;&nbsp;&nbsp;stAddr.sin_port = htons(in_lPort); &nbsp;&nbsp;&nbsp;&nbsp;lRet = bind(sockfd, (struct sockaddr*)&stAddr, sizeof(stAddr)); &nbsp;&nbsp;&nbsp;&nbsp;if(0 > lRet) &nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Trace("Bind port %d error", in_lPort); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;close(sockfd); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return RC_FAILURE; &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;/*  设置可以监听的最大的数量*/ &nbsp;&nbsp;&nbsp;&nbsp;if(listen(sockfd, in_lQueue) < 0) &nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Trace("listen on socket %d error", sockfd); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;close(sockfd); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return RC_FAILURE; &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;return sockfd; }

ablised

/******************************************************************************     函 数 名：socki_BindLocal           函数编号：     功能描述：建立一个AF_LOCAL式的套节子，并绑定到指定的文件名     入口参数：         in_pszFile          --指定的文件名     返回说明：         >0                  --返回得到的套节子         RC_FAILURE          --失败     引用变量：     开发历史：  ******************************************************************************/ int     socki_BindLocal() {     char    szFile[256];     int     iRet, sockfd;     struct  sockaddr_un servaddr;     memset(szFile, 0, sizeof(szFile));     sprintf(szFile, "%s/bin/.tclocal.%d", getenv("TCHOME"), getpid());     unlink(szFile);                 /*  防止文件已经存在*/     sockfd = socket(AF_LOCAL, SOCK_DGRAM, 0);     memset(&servaddr, 0, sizeof(servaddr));     servaddr.sun_family = AF_LOCAL;     strncpy(servaddr.sun_path, szFile, sizeof(servaddr.sun_path) - 1);     iRet = bind(sockfd, (struct sockaddr*)&servaddr, SUN_LEN(&servaddr));     if(0 != iRet)     {         Trace("bind socket on %s error", szFile);         return RC_FAILURE;     }     return sockfd; } /******************************************************************************     函 数 名：socki_ConnectLocal        函数编号：     功能描述：连接到一个指定文件名的本地套节子     入口参数：         in_pszFile          --指定的文件名     返回说明：         >0                  --返回得到的套节子         RC_FAILURE          --失败     引用变量：     开发历史：  ******************************************************************************/ int     socki_ConnectLocal(long in_lPid) {     char    szFile[256];     int     iRet, sockfd;     struct  sockaddr_un cliaddr;     memset(szFile, 0, sizeof(szFile));     sprintf(szFile, "%s/bin/.tclocal.%d", getenv("TCHOME"), in_lPid);     sockfd = socket(AF_LOCAL, SOCK_DGRAM, 0);     memset(&cliaddr, 0, sizeof(cliaddr));     cliaddr.sun_family  = AF_LOCAL;     strncpy(cliaddr.sun_path, szFile, sizeof(cliaddr.sun_path) - 1);     iRet = connect(sockfd, (struct sockaddr*)&cliaddr, sizeof(cliaddr));     if(0 != iRet)     {         Trace("connect to socket %d error", sockfd);         return RC_FAILURE;     }     return sockfd; }

ablised

没人能讲讲吗？