Linux TCP客户端、服务器编程模型及实例

Linux TCP客户端、服务器编程模型及实例

服务器模型：

1、绑定IPv4的地址（INADDR_ANY）和端口号（8888）

int listenfd, sockfd, opt = 1;

struct sockaddr_in server, client;

新建socket

listenfd = socket(AF_INET, SOCK_STREAM, 0);

if(listenfd < 0){
perror("Create socket fail.");
return -1;

}

设置地址可重用功能，防止异常退出无法短时间打开server

if((ret = setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt))) < 0)

{

    perror("Error, set socket reuse addr failed");

  return -1;

}

bzero(&server, sizeof(server));

server.sin_family = AF_INET;

server.sin_port   = htons(8888);

server.sin_addr.s_addr  = htonl(INADDR_ANY);

2、将套接字转换成监听套接字

len = sizeof(struct sockaddr);

if(bind(listenfd, (struct sockaddr *)&server, len)<0){
perror("bind error.");

    return -1;

}

listen(listenfd, MAX_LISTEN_QUE);

3、等待客户端连接

sockfd = accept(listenfd, (struct sockaddr *)&client, &len);

if(sockfd < 0)

{
perror("accept error.");
return -1;

}

4、读取客户端数据

read(sockfd,buf,100);

printf("%s\n",buf);

5、写据给客户端

time_now = time(NULL);

bzero(&buf,100);

strcpy(buf,(char *)ctime(&time_now));

printf("time:%s\n",buf);

write(sockfd,buf,strlen(buf));

6、关闭套接字

close(sockfd);

close(listenfd);

实例代码：

头文件apue.h

#include<stdio.h>
#include<stdlib.h>
#include<errno.h>
#include<string.h>
#include<strings.h>
#include<time.h>

#include<sys/socket.h>
#include<sys/types.h>
#include<netinet/in.h>
#include<arpa/inet.h> //inet

源文件3.c

/*************************************************************************
> File Name: 3.c
> Created Time: 2016年12月01日 星期四 10时53分36秒
************************************************************************/
/*
*this is time server
* */

#include"apue.h"
#define MAX_LISTEN 10
int main(int argc,char *argv[])
{
int listenfd,sockfd,opt = 1;
struct sockaddr_in server,client;
int len;
time_t time_now;
char buf[100];

listenfd = socket(AF_INET,SOCK_STREAM,0);
if(listenfd<0)
{
perror("create socket failed\n");
return -1;
}

if(setsockopt(listenfd,SOL_SOCKET,SO_REUSEADDR,&opt,sizeof(opt))<0)
{
perror("set socket reuse addr failed\n");
return -1;
}

bzero(&server,sizeof(server));
server.sin_family = AF_INET;
server.sin_port = htons(8888);
server.sin_addr.s_addr = htonl(INADDR_ANY);//代表该主机上的所有IP地址，如果机器上有多个网卡或者虚拟机的话，若不使用此方法容易出错

len = sizeof(struct sockaddr);
if(bind(listenfd,(struct sockaddr *)&server,len)<0)
{
perror("bind error\n");
return -1;
}

listen(listenfd,MAX_LISTEN);//可以连接的最大数据

while(1) //迭代服务器，同时不能连接多个客户端，当一个客户端关闭后就可以重新连接第二个客户端
{
sockfd = accept(listenfd,(struct sockaddr *)&client,&len);//sockaddr 和sockaddr_in可以相互转化的
if(sockfd<0)
{
perror("accept error\n");
return -1;
}

read(sockfd,buf,100);
printf("%s\n",buf);

time_now = time(NULL);
bzero(&buf,100);
strcpy(buf,(char *)ctime(&time_now));
printf("time:%s\n",buf);
write(sockfd,buf,strlen(buf));
printf("sockfd:%d\n",sockfd);
close(sockfd);
}

close(listenfd);
return 0;
}

客户端模型：

1、创建一个IPv4(AF_INET)的字节流(SOCK_STREAM)套接字

int sockfd;

struct sockaddr_in server_ip;

if((sockfd = socket(AF_INET,SOCK_STREAM,0))<0)

{

    perror("socket error\n");

    return -1;

}

2、连接到IP地址为（192.168.1.108、127.0.0.1），端口号为8888的服务器

 bzero(&server_ip,sizeof(server_ip));

//equal to memset()

server_ip.sin_family  =AF_INET;

server_ip.sin_addr.s_addr = inet_addr("127.0.0.1");

server_ip.sin_port = htons(5678);

if(connect(sockfd,(struct sockaddr*)&server_ip,sizeof(server_ip))<0)

{

    perror("connect error\n");

    return 0;

}

3、写一个数据到服务器

strcpy(buf,(char *)"I am client");

if(write(sockfd,buf,strlen(buf))<0)

{

    printf("error,write error\n");

    return -1;

}

4、接收服务器传回来的数据并显示到标准输出

bytes = read(sockfd,buf,100);

if(bytes<0)

{

    printf("error,read failed\n");

    return -1;

}

5、关闭套接字

close(sockfd);

实例代码：

头文件同上；

源文件2.c

/*************************************************************************
> File Name: 2.c
> Created Time: 2016年12月01日 星期四 09时52分46秒
************************************************************************/
/*
*this is client to get server time
* */
#include"apue.h"

int main(int agtc,char *argv[])
{
int sockfd;
struct sockaddr_in server_ip;
char buf[100];
int bytes;
if((sockfd = socket(AF_INET,SOCK_STREAM,0))<0)
{
perror("socket error\n");
return -1;
}

bzero(&server_ip,sizeof(server_ip));
//equal to memser()
server_ip.sin_family  =AF_INET;
server_ip.sin_addr.s_addr = inet_addr("127.0.0.1");
server_ip.sin_port = htons(8888);

if(connect(sockfd,(struct sockaddr*)&server_ip,sizeof(server_ip))<0)
{
perror("connect error\n");
return 0;
}

bzero(&buf,100);
strcpy(buf,(char *)"I am client");
if(write(sockfd,buf,strlen(buf))<0)
{
printf("error,write error\n");
return -1;
}

bzero(&buf,100);
bytes = read(sockfd,buf,100);
if(bytes<0)
{
printf("error,read failed\n");
return -1;
}

if(bytes ==0)
{
printf("Server close connection\n");
return -1;
}

if(bytes >0)
{
printf("read bytes %d\n",bytes);
printf("time is %s\n",buf);
}

close(sockfd);
return 0;
}

注意：server中添加了setsockopt函数

#include <sys/types.h>

#include <sys/socket.h>

int setsockopt(int sockfd, int level, int optname,const void *optval, socklen_t optlen);

如果运行server的时候，若未正常退出内核有时候会提示地址已经在使用，此时可用此函数来重用地址，否则在几分钟内无法重启server的。