天下

记录修行的印记

Linux Socket子进程模式服务端Demo 63.cpp

// File: 63.cpp
//客户端代码 62.cpp
#include <stdio.h>
#include 
<unistd.h>
#include 
<stdlib.h>
#include 
<string.h> 
#include 
<strings.h>
#include 
<sys/types.h> 
#include 
<sys/socket.h> 
#include 
<netinet/in.h> 
#include 
<arpa/inet.h>


#define PORT 1234   /* Port that will be opened */ 
#define BACKLOG 5   /* Number of allowed connections */ 
#define MAXDATASIZE 4096  

void process_cli(int connectfd,struct sockaddr_in client);

int main() 

 
int listenfd, connectfd; /* socket descriptors */ 
 pid_t pid;
 
struct sockaddr_in server; /* server's address information */ 
 
struct sockaddr_in client; /* client's address information */ 
 socklen_t sin_size; 

 
/* Create TCP socket  */
 
if ((listenfd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
  
/* handle exception */
  perror(
"Creating socket failed.\n");
  exit(
1);
 }

 
int opt = SO_REUSEADDR;
 setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, 
&opt, sizeof(opt));

 bzero(
&server,sizeof(server));
 server.sin_family
=AF_INET; 
 server.sin_port
=htons(PORT); 
 server.sin_addr.s_addr 
= htonl(INADDR_ANY); 
 
if (bind(listenfd, (struct sockaddr *)&server, sizeof(struct sockaddr)) == -1) { 
  
/* handle exception */
  perror(
"Bind error.\n");
  exit(
1); 
 }    

 
if(listen(listenfd,BACKLOG) == -1){  /* calls listen() */ 
  perror(
"listen() error\n"); 
  exit(
1); 
 } 

 sin_size
=sizeof(struct sockaddr_in); 

 
while(1)
 {
  
/*accept connection */
  
if ((connectfd = accept(listenfd,(struct sockaddr *)&client,&sin_size))==-1) {
   perror(
"accept() error\n"); 
   exit(
1); 
  } 
  
/*  Create child process to service client */
  
if ((pid=fork())>0) {
   
/* parent process */
   close(connectfd);
   
continue;
  }
  
else if (pid==0) {
   
/*child process*/
   close(listenfd);
   process_cli(connectfd, client);
   exit(
0);     
  }
  
else {
   perror(
"fork() error\n");
   exit(
0);
  }
 }
 close(listenfd);   
/* close listenfd */         


void process_cli(int connectfd, struct sockaddr_in client)
{
 
int num;
 
char recvbuf[MAXDATASIZE], sendbuf[MAXDATASIZE];

 
/* prints client's IP */ 
 printf(
"%s:%d Client was connected\n",inet_ntoa(client.sin_addr), ntohs( client.sin_port) );

 
while (1) {
  num 
= recv(connectfd, recvbuf, MAXDATASIZE,0);
  
if (num == 0) {
   close(connectfd);
   printf(
"%s:%d Client was disconnected \n",inet_ntoa(client.sin_addr), ntohs( client.sin_port) );
   
break;
  }
  
if (num == -1) {
   perror(
"recv() error\n"); 
   
break;
  }
  printf(
"recvbuf[0]:%d,recvbuf[num-1]:%d,num:%d\n",recvbuf[0],recvbuf[num-1],num);
  recvbuf[num] 
= '\0';
  printf(
"Received message From Client : %s\n",recvbuf);
  
for (int i = 0; i < num; i++) {
   sendbuf[i] 
= recvbuf[num-i-1];
   
//printf("sendbuf[%d]:%d\n",i,sendbuf[i]);
  }
  
//printf("sendbuf[0]:%d,sendbuf[num-1]:%d,num:%d\n",sendbuf[0],sendbuf[num-1],num);
  send(connectfd,sendbuf,num,0); /* send to the client welcome message */ 
 }
 close(connectfd); 
/*  close connectfd */ 
}


 

posted on 2011-09-08 16:06 天下 阅读(281) 评论(0)  编辑 收藏 引用 所属分类: SocketLinux编程


只有注册用户登录后才能发表评论。
【推荐】超50万行VC++源码: 大型组态工控、电力仿真CAD与GIS源码库
网站导航: 博客园   IT新闻   BlogJava   知识库   博问   管理


<2011年9月>
28293031123
45678910
11121314151617
18192021222324
2526272829301
2345678

导航

统计

常用链接

留言簿(3)

随笔分类(369)

随笔档案(320)

链接

最新随笔

搜索

最新评论