面向链接的客户机/服务器代码实例

 

 

最近很想培养一两个可以继续做服务器开发的弟子出来，但是苦于一时找不到合适的例子，而最近又实在是太懒惰了。哎，感谢原作者。
原文地址：http://hi.baidu.com/whs08/blog/item/cadea5fb63b2cb136c22eb60.html

声明：代码未经过测试。

这个服务器通过一个连接向客户发送字符串"Hello world!"

服务器首先创建出一个Socket ,然后将该Socket与本地端口绑定，成功之后在相应的Socket监听，当accept捕捉到一个连接服务器请求时，就会生成一个一个新的的Socket,并通过这个新的socket向客户端发送字符串"Hello World!",然后关闭该Socket.

fork()函数生成一个子进程来处理数据传输部分。

Server.c

#include
#include
#include
#include
#include
#include
#include
#include
#define MYPORT 3490 /*服务器监听端口号 */
#define BACKLOG 10 /* 最大同时连接请求数 */
int main(int argc ,char **argsv[])
{
int sockfd ,new_fd;
struct sockaddr_in my_addr;/*本机地址信息*/
struct sockaddr_in their_addr;/*客户地址信息*/
int sin_size;

    /*服务器端通常调用顺序 socket(),bind(),listen*/


if(-1 == (sockfd = socket(AF_INET,SOCK_STREAM,0)))
{/*检测错误*/
   perror("socket error");
   exit(1);
}

my_addr.sin_family = AF_INET;
my_addr.sin_port = htons(MYPORT);/*字节顺序转换函数*/
my_addr.sin_addr.s_addr = INADDR_ANY ;
bzero(&(my_addr.sin_zero),8);/*清零*/
//或者用memset(&addr,0,sizeof(struct sockaddr_in));

if(-1 == bind(sockfd,(struct sockaddr *)&my_addr,sizeof(struct sockaddr)))
{/*检测错误*/
   perror("bind error");
   exit(1);
}

if(-1 == listen(sockfd,BACKLOG))
{/*检测错误*/
   perror("listen error");
   exit(1);
}

while(1)
{
   sin_size = sizeof(struct sockaddr_in);
   if(-1 == (new_fd = accept(sockfd,(struct sockaddr *)&their_addr,&sin_size)))
   {
    perror("accept error");
      continue;
   }
   printf("server : get connetion from %s",inet_ntoa(their_addr.sin_addr));
   if(!fork())/*子进程代码*/
   {
    if(-1 == send(new_fd,"Hello, world !",14,0))
    {
     perror("send error");
     continue;
    }
    close(new_fd);
    exit(0);
   }
   close(new_fd);   /* 父进程不再需要该socket */
   //waitpid(-1,NULL,WNOHANG) > 0 /*等待子进程结束，清除子进程所占用资源*/
}
}

#include <stdio.h> #include <stdlib.h> #include <errno.h> #include <string.h> #include <sys/types.h> #include <netinet/in.h> #include <sys/socket.h> #include <sys/wait.h> #define MYPORT 3490 /*服务器监听端口号 */ #define BACKLOG 10 /* 最大同时连接请求数 */ int main(int argc ,char **argsv[]) { int sockfd ,new_fd; struct sockaddr_in my_addr;/*本机地址信息*/ struct sockaddr_in their_addr;/*客户地址信息*/ int sin_size;     /*服务器端通常调用顺序 socket(),bind(),listen*/ if(-1 == (sockfd = socket(AF_INET,SOCK_STREAM,0))) {/*检测错误*/    perror("socket error");    exit(1); } my_addr.sin_family = AF_INET; my_addr.sin_port = htons(MYPORT);/*字节顺序转换函数*/ my_addr.sin_addr.s_addr = INADDR_ANY ; bzero(&(my_addr.sin_zero),8);/*清零*/ //或者用memset(&addr,0,sizeof(struct sockaddr_in)); if(-1 == bind(sockfd,(struct sockaddr *)&my_addr,sizeof(struct sockaddr))) {/*检测错误*/    perror("bind error");    exit(1); } if(-1 == listen(sockfd,BACKLOG)) {/*检测错误*/    perror("listen error");    exit(1); } while(1) {    sin_size = sizeof(struct sockaddr_in);    if(-1 == (new_fd = accept(sockfd,(struct sockaddr *)&their_addr,&sin_size)))    {     perror("accept error");       continue;    }    printf("server : get connetion from %s",inet_ntoa(their_addr.sin_addr));    if(!fork())/*子进程代码*/    {     if(-1 == send(new_fd,"Hello, world !",14,0))     {      perror("send error");      continue;     }     close(new_fd);     exit(0);    }    close(new_fd);   /* 父进程不再需要该socket */    //waitpid(-1,NULL,WNOHANG) > 0 /*等待子进程结束，清除子进程所占用资源*/ } }
Client.c

#include
#include
#include
#include
#include
#include
#include
#include
#define PORT 3490
#define MAXDATASIZE 100 /*每次最大数据传输量 */
int main(int argc, char *argv[])
{
int sockfd, numbytes;
char buf[MAXDATASIZE];
struct hostent *he;
struct sockaddr_in their_addr;

if (argc != 2) {
   fprintf(stderr,"usage: client hostname");
exit(1);
}

if((he=gethostbyname(argv[1]))==NULL) {
   herror("gethostbyname");
   exit(1);
}

if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
   perror("socket");
   exit(1);
}

their_addr.sin_family=AF_INET;
their_addr.sin_port=htons(PORT);
their_addr.sin_addr = *((struct in_addr *)he->h_addr);
bzero(&(their_addr.sin_zero),8);

if (connect(sockfd, (struct sockaddr *)&their_addr, sizeof(struct sockaddr)) == -1) {
   perror("connect");
   exit(1);
}
if ((numbytes=recv(sockfd, buf, MAXDATASIZE, 0)) == -1) {
    perror("recv");
       exit(1);
}

buf[numbytes] = '\0';
printf("Received: %s",buf);
close(sockfd);
return 0;
}