http://www.jackxiang.com/index.php zh-cn http://www.jackxiang.com/post// jack <xdy108@126.com> Sun, 01 Aug 2010 15:10:13 +0000 http://www.jackxiang.com/post// 所谓服务器程序，指的是在网络通信时这个程序始终处于等待状态，可以接受用户的连接请求，并且对用户发送的信息进行处理，本节的实例是面向连接的套接字通信服务器程序。程序的重点是端口的监听和接收发送的信息。

代码17-7  TCP服务器程序：\源文件\17\17.25.c

#include<sys/types.h>

#include<sys/socket.h>

#include<netinet/in.h>

#include<arpa/inet.h>

#include<unistd.h>                              /*包含头文件。*/

#define PORT 5678                               /*定义端口号。*/

#define MAX 10                                  /*最多的连接数。*/

main()

{

   int sockfd,newsockfd,is_connected[MAX],fd;       /*定义相关的变量。*/

   struct sockaddr_in addr;

   int addr_len = sizeof(struct sockaddr_in);

   fd_set myreadfds;

   char msgbuffer[256];

   char msg[] ="This is the message from server.Connected.\n";

  

   if ((sockfd = socket(AF_INET,SOCK_STREAM,0))<0)  /*建立一个socket。*/

   {

      perror("socket");

      exit(1);

   }

   else

   {

      printf("socket created .\n");              /*socket建立成功，输出提示。*/

      printf("socked id: %d \n",sockfd);

   }

  

   bzero(&addr,sizeof(addr));                   /*清空addr所在的内存。*/

   addr.sin_family =AF_INET;

   addr.sin_port = htons(PORT);

   addr.sin_addr.s_addr = htonl(INADDR_ANY);

   if(bind(sockfd,&addr,sizeof(addr))<0)    /*绑定端口。*/

   {

      perror("connect");

      exit(1);

   }

   else

   {

       printf("connected.\n");

       printf("local port:%d\n",PORT)    ;

   }

   if(listen(sockfd,3)<0)                       /*开始监听。*/

   {

      perror("listen");

      exit(1);

   }

   else

   {

      printf("listenning......\n");  

   }

   for(fd=0;fd<MAX;fd++)

   {

      is_connected[fd]=0;                        /*设置所有的标记为0。*/

   }

  

   while(1)                                 /*进入一个循环，处理所有的连接。*/

   {

      FD_ZERO(&myreadfds);                   /*清空一个标志。*/

      FD_SET(sockfd,&myreadfds);             /*设置标志。*/

      for(fd=0;fd<MAX;fd++)

      {

         if(is_connected[fd])            /*判断有没有连接。*/

         {

            FD_SET(fd,&myreadfds);            /*设置标志。*/

         }

      }

      if(!select(MAX,&myreadfds,NULL,NULL,NULL)) /*如果到达了最大的连接数则进

                                                    入下次循环。*/

      {

           continue;

      }

      for(fd=0;fd<MAX;fd++)                  /*进入一个循环。*/

      {            

         if(FD_ISSET(fd,&myreadfds))         /*判断标志。*/

         {

            if(sockfd==fd)                    /*如果新建的socket与fd相同。*/

            {

               if((newsockfd = accept (sockfd,&addr,&addr_len))<0)

                                            /*接受一个连接，新建一个socket。*/

               {

                  perror("accept");

               }

               write(newsockfd,msg,sizeof(msg));      /*给客户端发送一段信息。*/

               is_connected[newsockfd] =1;            /*设置标志。*/

               printf("cnnect from %s\n",inet_ntoa(addr.sin_addr));

                                                    /*输出客户端的IP。*/

            }

            else

            {          

               bzero(msgbuffer,sizeof(msgbuffer));    /*清空字符串。*/

               if(read(fd,msgbuffer,sizeof(msgbuffer))<=0)

                                                    /*读取结果。*/

               {

                  printf("connect closed.\n");     /*输出连接关闭。*/

                  is_connected[fd]=0;                  /*设置标志。*/

                  close(fd);                           /*关闭一个socket。*/

                }

                else

                {

                   write(fd,msgbuffer,sizeof(msgbuffer));

                                            /*发送接收到的信息。*/

                   printf("message:%s \n",msgbuffer);

                                            /*输出接收到的信息。*/

                }

             }

         }

      }

   }

}

输入下面的命令，编译这个程序。需要加-o参数指定一个输出文件名。

gcc 17.25.c -o tcpser

输入下面的命令，对这个程序添加可执行权限。

chmod +x udpcli



客户端指的是在网络通信时主动向服务器发送连接请求，主动发送信息的程序。本节将讲述面向连接的套接字通信的客户端程序。这个程序的主要内容是向服务器申请连接，并且发送用户输入的内容。

代码17-8  TCP客户端程序：\源文件\17\17.26.c

#include <stdio.h>

#include <netinet/in.h>

#include <arpa/inet.h>

#include <unistd.h>

#include <fcntl.h>

#include <sys/stat.h>

#include <sys/types.h>

#include <sys/socket.h>                             /*包含头文件。*/

#define PORT 5678                                   /*定义远程端口。*/

#define REMOTE_IP "127.0.0.1"                       /*定义远程IP。*/

int   main(int argc,char *argv[])

{

   int s ;                                          /*定义相关变量。*/

   struct sockaddr_in addr ;

   char mybuffer[256];

   if( (s=socket(AF_INET,SOCK_STREAM,0))<0 )    /*新建一个socket。*/

   {

      perror("socket");

      exit(1);

   }

   else

   {

      printf("socket created .\n");

      printf("socked id: %d \n",s);

   }

   bzero(&addr,sizeof(addr));                       /*设置addr。*/

   addr.sin_family =AF_INET;

   addr.sin_port=htons(PORT);

   addr.sin_addr.s_addr=inet_addr(REMOTE_IP);

   if(connect(s,&addr,sizeof(addr))<0)              /*连接远程服务器。*/

   {

      perror("connect");

      exit(1);

   }

   else

   {

      printf("connected ok!\n");

      printf("remote ip:%s\n",REMOTE_IP);

      printf("remote port:%d\n",PORT);

    }

   recv(s ,mybuffer,sizeof(mybuffer),0);        /*接收服务器发送的信息。*/

   printf("%s\n",mybuffer);                         /*输出信息。*/

   while(1)                                         /*进入一个循环。*/

   {

      bzero(mybuffer,sizeof(mybuffer));              /*清空mybuffer字符串。*/

      read(STDIN_FILENO,mybuffer,sizeof(mybuffer));  /*读取输入。*/

      if(send(s,mybuffer,sizeof(mybuffer),0)<0)      /*发送信息。*/

      {

         perror("send");                             /*错误处理。*/

         exit(1);

      }

      else

      {

         bzero(mybuffer,sizeof(mybuffer));           /*清空mybuffer内存。*/

         recv(s ,mybuffer,sizeof(mybuffer),0);       /*接收信息。*/

         printf("received:%s\n",mybuffer);           /*输出信息。*/

      }

   }

}

输入下面的命令，编译这个程序。需要加-o参数指定一个输出文件名。

gcc 17.26.c -o tcpcli

输入下面的命令，对这个程序添加可执行权限。

chmod +x udpcli



本节将对面向连接套接字通信的两个实例程序进行测试。在运行这两个程序时，需要先打开服务程序，使相应的端口处于监听状态，然后打开客户端程序，请求连接服务器的端口。

（1）输入下面的命令，运行服务器程序。

./tcpser

（2）程序的运行结果如下所示。

socket created .

socked id: 3

connected.

local port:5678

listenning......

（3）结果显示，已经建立socket，本地端口是5678。程序正在这个端口上进行监听。

（4）这时打开另一个终端，在终端中输入下面的命令，打开客户端程序。

./tcpcli

（5）程序显示的结果如下所示。结果显示程序已经建立了socket连接到了127.0.0.1这个IP上的5678号端口。服务器发送回一条信息。

socket created .

socked id: 3

connected ok!

remote ip:127.0.0.1

remote port:5678

This is the message from server.Connected.

（6）在服务器程序的终端中查看，显示的结果如下所示。

cnnect from 127.0.0.1

（7）结果表示服务器已经接受了客户端的连接请求。

（8）这时进入客户程序的终端，输入“hello”，然后按“Enter”键。显示的结果如下所示。

received:hello

（9）结果表明，程序把输入的字符串发送到了服务器，服务器又返回了这个字符串。

（10）进入到服务器的终端，可以查看到客户端发送的信息如下所示。

message:hello

（11）这两个程序进入了while循环以后，会始终执行程序无法退出。可以按“Ctrl”+“C”组合键结束程序。

]]> http://www.jackxiang.com/post//#blogcomment <user@domain.com> Thu, 01 Jan 1970 00:00:00 +0000 http://www.jackxiang.com/post//#blogcomment