myserver.cのソース

     1	/*** TCP Server for inetd ***/
     2	
     3	#include <stdio.h>
     4	#include <sys/types.h>
     5	#include <sys/errno.h>
     6	#include <string.h>
     7	#include <ctype.h>
     8	#include <sys/socket.h>
     9	#include <netinet/in.h>
    10	#include <netdb.h>
    11	
    12	#define	DATAFILE	"/Users/j04009/slab2/data"
    13	#define	DELIMITS	" \t\n\r"
    14	
    15	char	datavalue[256];
    16	
    17	
    18	int	GetLineFromPeer(int new_sockfd, char *line)
    19	{
    20	int	i;
    21	
    22	for(i = 0 ; ; )
    23		{
    24		if(1 != read(new_sockfd,line + i,1))
    25			continue;
    26		else
    27			{
    28			i++;
    29			*(line + i) = (char)0;
    30			}
    31	
    32		if(((char)('\n')) == (*(line + i - 1)))
    33			return i;
    34		}
    35	}
    36	
    37	char	*GetKeywordData(char *key)
    38	{
    39	FILE	*fp;
    40	char	buff[256];
    41	
    42	if((FILE *)NULL == (fp = fopen(DATAFILE,"r")))
    43		return (char *)NULL;
    44	
    45	for(;;)
    46		{
    47		char	*p;
    48		char	*pp;
    49	
    50		fgets(buff,256,fp);
    51	
    52		if(feof(fp))
    53			break;
    54	
    55		if(ferror(fp))
    56			break;
    57	
    58		if((char *)NULL == (p = strtok(buff,DELIMITS)))
    59			continue;
    60	
    61		if((char *)NULL == (pp = strtok((char *)NULL,DELIMITS)))
    62			continue;
    63	
    64		if(0 == strcmp(p,key))
    65			{
    66			fclose(fp);
    67			strcpy(datavalue,pp);
    68			return datavalue;
    69			}
    70		}
    71	
    72	fclose(fp);
    73	return (char *)NULL;
    74	}
    75	
    76	
    77	int	main()
    78	{
    79	  int sockfd;
    80	  int new_sockfd;
    81	  int writer_len;
    82	  struct sockaddr_in reader_addr;
    83	  struct sockaddr_in writer_addr;
    84	
    85	  /*ソケットの生成*/
    86	  if((sockfd = socket(AF_INET,SOCK_STREAM,0)) < 0){
    87	       perror("reader:socket");
    88	       exit(1);
    89	  }
    90	
    91	  /*通信ポート・アドレスの設定*/
    92	  bzero((char *) &reader_addr, sizeof(reader_addr));
    93	  reader_addr.sin_family = AF_INET;
    94	  reader_addr.sin_addr.s_addr = htonl(INADDR_ANY);
    95	  reader_addr.sin_port = htons(5682);
    96	
    97	  /*ソケットにアドレスを結びつける*/
    98	  if(bind(sockfd, (struct sockaddr *)&reader_addr, sizeof(reader_addr)) < 0){
    99	    perror("reader:bind");
   100	    exit(1);
   101	  }
   102	
   103	  /*コネクト要求をいくつまで待つかを設定*/
   104	  if(listen(sockfd,5) < 0){
   105	    perror("reader:listen");
   106	    close(sockfd);
   107	    exit(1);
   108	  }
   109	
   110	char	RecvBuff[256];
   111	
   112	for(;;) /*デーモンとして動かすのでエラー以外でプログラムを終了させる命令を消した*/
   113	{
   114	  int flag = 1;      /*下にあるwhile文の抜けるために使う*/
   115	
   116	  /*コネクト要求を待つ*/
   117	  if((new_sockfd = accept(sockfd,(struct sockaddr *)&writer_addr, &writer_len)) < 0){
   118	    perror("reader:accept");
   119	    exit(1);
   120	  }else{
   121	    while(flag)
   122	      {
   123		char	*p;
   124		char	SendBuff[256];
   125		char	*pp;
   126		
   127		(void)GetLineFromPeer(new_sockfd, RecvBuff);	/* Get 1 line from peer */
   128		
   129		if(((char)('=')) == *(RecvBuff))	/* クライアントが接続を切ったときに動く */
   130		  {
   131		    close(new_sockfd);  /*ソケットを廃棄*/
   132		    flag = 0;           /*flagを偽(0)とする*/
   133		    break;              /*このときflagの値によりwhileを抜ける*/
   134		  }else{
   135		  if((char *)NULL != (p = strchr(RecvBuff,'=')))
   136		    {
   137		      *p = (char)0;
   138		      
   139		      if((char *)NULL == (pp = GetKeywordData(RecvBuff)))
   140			sprintf(SendBuff,"%s=\n",RecvBuff);
   141		      else
   142			sprintf(SendBuff,"%s=%s\n",RecvBuff,pp);
   143		      
   144		      (void)write(new_sockfd,SendBuff,strlen(SendBuff));
   145		    }
   146		}
   147	      }
   148	  }
   149	 }
   150	}

myclient.cのソース

ここは課題2で使うclient.cと変わらないのでソースは省略する．
　

実行結果

[nw0409:~/slab2] j04009% ps aux | grep inetd
j04009  1718   0.0  0.0     8860      8 std  R+    4:58PM   0:00.00 grep inetd
[nw0409:~/slab2] j04009% ./myserver &
[1] 1719
[nw0409:~/slab2] j04009% ps | grep myserver
 1719 std  S      0:00.01 ./myserver
 1721 std  R+     0:00.00 grep myserver
[nw0409:~/slab2] j04009% ./myclient 
Connected.
Input Keyword = warning: this program uses gets(), which is unsafe.
123
Keyword = [123] / Data = [456]

Input Keyword = shiro
Keyword = [shiro] / Data = [kuro]

Input Keyword = abc
Keyword = [abc] / Data = []

Input Keyword = 
Disocnnected.
[nw0409:~/slab2] j04009% ps | grep myserver
 1719 std  S      0:00.01 ./myserver
 1724 std  R+     0:00.00 grep myserver
[nw0409:~/slab2] j04009% 

• http://research.nii.ac.jp/~ichiro/syspro98/server.html　"サーバプログラム"
  
• http://stylefree.net/Program/Program.htm
  " ネットワークプログラミング講座(OS Windows 言語 C) "