Tcp多线程服务器和客户端程序

Tcp多线程服务器和客户端程序

//服务器程序:

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <arpa/inet.h>

#include <sys/types.h>

#include <sys/socket.h>

#include <unistd.h>

#define PORT 8082

#define BUFSIZE 512

char buf[BUFSIZE+1];

void* fun(void* x)

{

       //printf("enter thread!\r\n");

       int new_fd=*((int*)x);

   while(1)

       {

       int z=read(new_fd,buf,BUFSIZE);//第 6 步 读取套接字

   if(z==0){printf("client close !");break;};

   buf[z]='\0';

   printf("%s\r\n",buf);//打印

   };

}

int newfd[512];

int inewfd=0;

int main()

   //第 1 步 创建套接字

   int sockfd=socket(AF_INET,SOCK_STREAM,0);

   //第 2 步 设置地址结构体

   struct sockaddr_in svraddr;

   svraddr.sin_family=AF_INET;//使用 internet 协议

   svraddr.sin_port=htons(PORT);

   inet_aton("0.0.0.0",&svraddr.sin_addr);

   //第 3 步 绑定

   int ret=bind(sockfd,(struct sockaddr*)&svraddr,sizeof(svraddr));

       if(ret<0){printf("error bind!\r\n");exit(-1);};

   //第 4 步 监听

   listen(sockfd,128);

   {

   newfd[inewfd++]=accept(sockfd,NULL,NULL); //第 5 步 接收

   pthread_t ntid;

       pthread_create(&ntid,NULL,fun,(void*)&(newfd[inewfd-1])); 

   }

// 注意 gcc server.c -o server -lpthread

//客户端程序 cli.c

   //第 1 步 创建一个体套接字

   //第 2 步 设置 addr 结构体

   inet_aton("127.0.0.1",&svraddr.sin_addr);

   //第 3 步 连接服务器

   connect(sockfd,(struct sockaddr*)&svraddr,sizeof(svraddr));

   scanf("%s",buf);

   write(sockfd,buf,strlen(buf)); //第 4 步 向套接字中写入字符串

本文转自陈仲阳0 51CTO博客，原文链接:http://blog.51cto.com/wolfword/1224933