socket的疑问。。

tensaix2j

我想试build 一个简单的dos based chat program，
请问下，在client side那里，是没次send 一个msg 就要create 一个socket，send了然后close 掉，还是从头到尾都只用一个socket，在program结束才close 掉那个socket？

我不会是很明白。。

goatstudio

结束聊天了... 才 close 掉 socket, server 也一样.

tensaix2j

奇怪，为何只有第一次send的msg有收到，第二次就收不到了。。

1. 
   
2. 
   
3. // create socket
   
4.         s = socket(AF_INET,SOCK_STREAM,0);
   
5. 
   
6.         if(s==INVALID_SOCKET)
   
7.         {
   
8.                 printf("Can't create socket\n");
   
9.                 sockEnd();
   
10.                 return 2;
    
11.         }
    
12. 
    
13.         // send data
    
14.         connect(s,(struct sockaddr *) &remote_addr,sizeof(struct sockaddr_in));
    
15. 
    
16.         for (;;)
    
17.         {
    
18.        
    
19.                 scanf("%128[^\n]",msg);
    
20.                 FLUSH;
    
21.                                
    
22.                 if(send(s,msg,strlen(msg),0)==-1)
    
23.                 {
    
24.                         printf("Can't send message\n");  
    
25.                        
    
26.                         return 3;  
    
27.                 }
    
28.         
    
29.                 if (strcmp(msg,"quitclient")==0)
    
30.                 {
    
31.                         break;
    
32.                 }
    
33.        
    
34.         }
    
35. 
    
36.         // close the channel
    
37.         if(closesocket(s))
    
38.         {
    
39.                 printf("Error on closing socket\n");
    
40.                 return 4;
    
41.         }
    
42. 
    

复制代码

tensaix2j

server side:

1. 
   
2. /* creates socket */
   
3.         s = socket(AF_INET,SOCK_STREAM,0);
   
4. 
   
5.         if(s==INVALID_SOCKET)
   
6.         {
   
7.                 printf("Can't create socket\n");
   
8.                 sockEnd();
   
9.                 return 2;
   
10.         }
    
11. 
    
12. 
    
13.         /* links socket to address and port */
    
14.         if(bind(s,(struct sockaddr *) &any_addr, sizeof(struct sockaddr_in))) {  
    
15.        printf("Can't bind socket to address\n");  
    
16.        sockEnd();   
    
17.        return 3;  
    
18.         }  
    
19.        
    
20. 
    
21.        
    
22.                 /* listens on port; maximum 5 requests pending */
    
23.                 listen(s,5);
    
24.        
    
25.         for(;;)
    
26.         {
    
27.                 /* when someone connects creates a new socket for data exchange */
    
28.                 ss=accept(s,(struct sockaddr *) &any_addr,&addrlen);
    
29. 
    
30.                 if(ss==INVALID_SOCKET) {
    
31.                         perror("accept");
    
32.                         return 4;
    
33.                 }
    
34.                 serverThread(ss);
    
35.        
    
36.         }
    
37. 
    
38.         if(closesocket(s))
    
39.         {
    
40.                 perror("closesocket");
    
41.                 return 5;
    
42.         }
    

复制代码

1. 
   
2. void serverThread(SOCKET ss)
   
3. {
   
4. 
   
5.         pid_t pid;
   
6.         char buffer[BUFLEN];
   
7.         int rec;
   
8.         int addrlen;
   
9. 
   
10.         addrlen=sizeof(struct sockaddr_in);
    
11.         pid=getpid();
    
12.         /* waits for incoming data */
    
13.        
    
14.                 rec=recv(ss,buffer,BUFLEN,0);
    
15.                
    
16.                 if(rec==-1)
    
17.                 {
    
18.                         printf("Can't receive messages\n");  
    
19.                         sockEnd();   
    
20.                         return ;  
    
21.                 }
    
22.                
    
23.                 buffer[rec]=0x00;
    
24. 
    
25.                 if (strcmp(buffer,"quitserver")==0)
    
26.                 {
    
27.                         closesocket(ss);
    
28.                         exit(1);
    
29.                 }
    
30.                
    
31. 
    
32.                
    
33.                 puts(buffer);
    
34.                        
    
35.        
    
36. 
    
37.         /* close the channel */
    
38.         if(closesocket(ss))
    
39.                 printf("Error on closing socket\n");
    
40. }
    
41. 
    

复制代码

jangancari

我没有做过DOS 的socket ， 只尝试过wxwidgets 的， 不过， 我觉得问题应该出在server listen 那边

/* creates socket */
        s = socket(AF_INET,SOCK_STREAM,0);

        if(s==INVALID_SOCKET)
        {
                printf("Can't create socket\n";
                sockEnd();
                return 2;
        }


        /* links socket to address and port */
        if(bind(s,(struct sockaddr *) &any_addr, sizeof(struct sockaddr_in))) {  
       printf("Can't bind socket to address\n";  
       sockEnd();   
       return 3;  
        }  
      

      
                /* listens on port; maximum 5 requests pending */
                listen(s,5);
      
[colo=red]        for(;
        {
                /* when someone connects creates a new socket for data exchange */
                ss=accept(s,(struct sockaddr *) &any_addr,&addrlen);

                if(ss==INVALID_SOCKET) {
                        perror("accept";
                        return 4;
                }
                serverThread(ss);
      
        }

        if(closesocket(s))
        {
                perror("closesocket";
                return 5;
        }

当收到第一个msg 后， server 就自己在for loop 了， 所以完全听不到下一个msg 。

解决方式可能是放listen 在 for loop 里面。

tensaix2j

好象不行。。
不过我试把recv 放在另一个infinite loop 里如下：

1. 
   
2. for (;;){
   
3.                 rec=recv(ss,buffer,BUFLEN,0);
   
4.                        
   
5.                 if(rec==-1)
   
6.                 {
   
7.                         printf("Can't receive messages\n");  
   
8.                         sockEnd();   
   
9.                         return ;  
   
10.                 }
    
11.                
    
12.                 buffer[rec]=0x00; //put null to end of string
    
13. 
    
14.                 if (strcmp(buffer,"quitserver")==0)
    
15.                 {
    
16.                         closesocket(ss);
    
17.                         exit(1);
    
18.                 }
    
19.                
    
20.                 puts(buffer);
    
21. 
    
22.         }
    

复制代码

是可以不停的收msg。。不过第二个问题来了，如果我run两个client，这个server只收第一个client的msg,对第二client完全置之不理。。

jangancari

原帖由 tensaix2j 于 24-11-2005 11:48 PM 发表
好象不行。。
不过我试把recv 放在另一个infinite loop 里如下：
[code]
for (;{
                rec=recv(ss,buffer,BUFLEN,0);
                       
                if(rec==-1)
                {
                        printf("Can't receive messages\n";  
                        s ...

不同client ， 在server 上要开新的socket。所以， 你应该用1个port 来listen ， 另外一个port 来接受msg 。

Server Algorithm

   listen on port A
   if (client request connection)
   {
     open a new port for connection  (accept)
   }

所以， 不同client 会bind 不同的port。
不过DOS socket programming 应该有多线性的command 才能做到， 你需要找找看哪一个command 可以办到。for loop应该不是解决办法

tensaix2j

原来如此。。
好象有点头绪了，我在研究看看。。

谢谢

tensaix2j

有些linker的问题。。

我include了process.h ，然后在additional dependancy 也放了LIBCMT.LIB MSVCRT.LIB
为何compiler还是不认识 _beginthread 这个function..

jangancari

原帖由 tensaix2j 于 25-11-2005 01:25 AM 发表
有些linker的问题。。

我include了process.h ，然后在additional dependancy 也放了LIBCMT.LIB MSVCRT.LIB
为何compiler还是不认识 _beginthread 这个function..

linker library 的设定呢？

LIBCMT.LIB 是static link 版， msvcrt 是dynamic link 版； 应该是选择其中之一。

你可能需要加入
#ifndef __MT
#define __MT  

或者在MSVC 的configuration 里 的#define 或other option （我不清楚因为我没有用VC）

如果是dynamic link 的话, __DLL 也要加入


注意， 是两个下划线 (underscore) __  ， 不是一个。


我不会multithreading ， 不太清楚正式coding 会是如何， 以上的资料是根据一般程序的compiler/linker problem来猜测。




参考这两个网页
http://msdn.microsoft.com/librar ... ._beginthreadex.asp
http://msdn.microsoft.com/librar ... .time_libraries.asp

[ 本帖最后由 jangancari 于 25-11-2005 02:47 AM 编辑 ]

80cents

比较ADVANCE的做法是(如果你的CLIENT有一定的数量的话)

SERVER 可以只用一个 LISTENING PORT 和一个 SENDING PORT
不过 LISTENING 时最好要用 MULTITHREAD
因为 MULTITHREAD 可以缓慢 LOOPING 的冲击
当有新的 CONNECTION 进来时 就开新的 THREAD
然后在 THREAD 里用 CLIENT 的 IP 来 CREATE 新的 CONNECTION
就这样，SERVER 可以在同时间 LISTEN TO 不同的 CLIENT
而不是一个CLIENT 罢了

tensaix2j

...原来我忘了把runtime library 换去MT 了。。

原帖由 80cents 于 25-11-2005 09:24 AM 发表
比较ADVANCE的做法是(如果你的CLIENT有一定的数量的话)

SERVER 可以只用一个 LISTENING PORT 和一个 SENDING PORT
不过 LISTENING 时最好要用 MULTITHREAD
因为 MULTITHREAD 可以缓慢 LOOPING 的冲击
当有新 ...

我简单的都做不好。。

tensaix2j

现在出现很多莫名其妙的unresolvables..... 唉～～。。

jangancari

原帖由 tensaix2j 于 25-11-2005 08:16 PM 发表
现在出现很多莫名其妙的unresolvables..... 唉～～。。

unresolvable symbol 是没有link 到一些library ， 把那些unresolve symbol 用goolge 找microsoft 的网页， 就可以知道需要哪一个library 了。

tensaix2j

就是以下四个。。
google过了，得不到解决。。

__RTC_Initbase
__RTC_shutdown
@RTC_CheckStackVars@8
__RTC_CheckEsp

jangancari

原帖由 tensaix2j 于 28-11-2005 02:35 AM 发表
就是以下四个。。
google过了，得不到解决。。

__RTC_Initbase
__RTC_shutdown
@RTC_CheckStackVars@8
__RTC_CheckEsp

我也找了google 好像没有头绪 。。

你的程序一定要用VC/MFC 吗？ 可以用wxwidgets 吗？

meemee

我刚好路过此地，上来凑凑热闹。

原帖由 tensaix2j 于 28-11-2005 02:35 AM 发表
就是以下四个。。
google过了，得不到解决。。

__RTC_Initbase
__RTC_shutdown
@RTC_CheckStackVars@8
__RTC_CheckEsp

你们这么厉害都找不到，不知道我找的对不对。
不对，不要骂我，我是初学者。

http://softwareforums.intel.com/ ... amp;message.id=1617
http://www.planetamd64.com/lofiversion/index.php/t5878.html
http://blog.vckbase.com/netsin/archive/2005/06/06/6066.html