码迷,mamicode.com
首页 > 其他好文 > 详细

TCP学习之建立一个简单的客户/服务器系统--回射系统

时间:2014-11-04 17:22:37      阅读:312      评论:0      收藏:0      [点我收藏+]

标签:服务器   网络编程   tcp   

TCP学习之建立一个简单的客户/服务器系统--回射系统

相关的资料可以参考Unix网络编程,这个只是修改版,不需要依赖任何文件,可以独立编译通过,而且是在两台不同的主机上进行的。

bubuko.com,布布扣

fggets和fputs这两个函数来自标准I/O函数库,writen和readline见my_unp.h头文件

//my_unp.h
#include<stdarg.h>
#include<syslog.h>
#include<stdio.h>
#include<netinet/in.h>//网络地址结构表示库
#include<sys/socket.h>//TCP套接口库(socket connet bind listen accept)
#include<unistd.h>//Unix标准库(fork exec close)
#include<stdlib.h>//标准库
#include<memory.h>//内存管理
#include<errno.h>//错误号头文件
#include<string.h>//字符串处理
#include<arpa/inet.h>//(inet_pton inet_ntop)

#define MAXLINE 2048
#define SERV_PORT 9877
#define LISTENQ 5

#define bzero(ptr,n)  memset(ptr,0,n)

int daemon_proc;

static void err_doit(int, int, const char*, va_list);

void err_sys(const char *fmt, ...)
{
    va_list ap;
    va_start(ap,fmt);
    err_doit(1,LOG_ERR,fmt,ap);
    va_end(ap);
    exit(1);
}

static void err_doit(int errnoflag, int level, const char *fmt, va_list ap)
{
    int errno_save,n;
    char buf[MAXLINE+1];

    errno_save=errno;

    vsnprintf(buf,MAXLINE,fmt,ap);

    n=strlen(buf);
    
    if(errnoflag)
        snprintf(buf+n,MAXLINE-n,":%s",strerror(errno_save));
    
    strcat(buf,"\n");

    if(daemon_proc)
    {
        syslog(level,buf);
    }
    else
    {
        fflush(stdout);
        fputs(buf,stderr);
        fflush(stderr);
    }
    return;
}

ssize_t writen(int fd, const void *vptr, size_t n)
{
    size_t nleft;
    ssize_t nwriten;
    const char *ptr;

    ptr=(const char*)vptr;
    nleft=n;
    while(nleft>0)
    {
        if((nwriten=write(fd,ptr,nleft))<0)
        {
            if(nwriten<0 && errno==EINTR)
                nwriten=0;
            else
                return(-1);
        }
        nleft-=nwriten;
        ptr+=nwriten;
    }
    return(n);
}

ssize_t readline(int fd,void *vptr,size_t maxlen)
{
    ssize_t n,rc;
    char c,*ptr;

    ptr=(char*)vptr;
    for(n=1;n<maxlen;n++)
    {
        again:
        if((rc=read(fd,&c,1))==1)
        {
            *ptr++=c;
            if(c=='\n')
                break;
        }
        else if(rc==0)
        {
            *ptr=0;
            return(n-1);
        }
        else
        {
            if(errno==EINTR)
                goto again;
            return(-1);
        }
    }
    *ptr=0;
    return(n);
}


void err_quit(const char *fmt, ...)
{
    va_list ap;
    va_start(ap,fmt);
    err_doit(0,LOG_ERR,fmt,ap);
    va_end(ap);
    exit(1);
}


TCP回射服务程序的主程序


#include"my_unp.h"

void str_echo(int sockfd)
{
    ssize_t n;
    char buf[MAXLINE];

    again:
    while((n=read(sockfd,buf,MAXLINE))>0)
        writen(sockfd,buf,n);

    if( n<0 && errno==EINTR )
        goto again;

    else if(n<0)
        err_sys("str_echo:read error");
}


int main(int argc, char **argv)
{
    int listenfd,connfd;
    pid_t childpid;
    socklen_t clilen;
    struct sockaddr_in cliaddr,servaddr;

    listenfd=socket(AF_INET,SOCK_STREAM,0);

    bzero(&servaddr,sizeof(servaddr));

    servaddr.sin_family=AF_INET;
    servaddr.sin_addr.s_addr=htonl(INADDR_ANY);
    servaddr.sin_port=htons(SERV_PORT);

    bind(listenfd,(struct sockaddr*)&servaddr,sizeof(servaddr));

    listen(listenfd,LISTENQ);

    for(;;)
    {
        clilen=sizeof(cliaddr);
        connfd=accept(listenfd,(struct sockaddr*)&cliaddr,&clilen);
        if((childpid=fork())==0)
        {
            close(listenfd);
            str_echo(connfd);
            exit(0);
        }
        close(connfd);
    }

}

并发服务器的调用流程如右图所示

bubuko.com,布布扣

TCP回射客户程序


#include"my_unp.h"

void str_cli(FILE *fp, int sockfd)
{
    char sendline[MAXLINE],recvline[MAXLINE];
    while(fgets(sendline,MAXLINE,fp)!=NULL)
    {

        writen(sockfd,sendline,strlen(sendline));

        if(readline(sockfd,(void*)recvline,MAXLINE)==0)            
            err_quit("str_cli:server terminated prematurely");

        fputs(recvline,stdout);
    }
}

int main(int argc,char **argv)
{

    int sockfd;
    struct sockaddr_in servaddr;
    if(argc!=2)
        err_quit("usage : tcpcli<IPaddress>");
    sockfd=socket(AF_INET,SOCK_STREAM,0);

    bzero(&servaddr,sizeof(servaddr));
    servaddr.sin_family=AF_INET;
    servaddr.sin_port=htons(SERV_PORT);

    inet_pton(AF_INET,argv[1],&servaddr.sin_addr);

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

    str_cli(stdin,sockfd);

    exit(0);
}


正常启动过程

我们首先在一台Linux主机上启动服务器,先用g++编译,然后./serv运行服务器

bubuko.com,布布扣

我们可以查询一下网卡的IP地址,发现服务器的IP为192.168.255.129

bubuko.com,布布扣


我们这里是用VMware装了两个LINUX的虚拟机

bubuko.com,布布扣

网络的连接方式全是

bubuko.com,布布扣

检查一下服务器监听端口的状态

bubuko.com,布布扣


打开另一个LINUX主机,并指定IP地址为192.168.255.129,如上图ifconfig查询所示

编译客户端程序

bubuko.com,布布扣

运行客户端并开始测试


bubuko.com,布布扣


断开之前,再检查一下服务器的监听套结口连接状态

bubuko.com,布布扣

可以看到0.0.0.0:9877为监听套接口,状态为LISTEN

192.168.288.129:9877 到192.168.255.130:35635为已连接套接口,状态为ESTABLISHED,关闭时会变成TIME_WAIT,大概等待1~4分钟之后会完全断开

 

 

抓包分析结果

第一段为三次握手

第二段为hello,world发送过程

第三段为good bye

第四段为断开连接

bubuko.com,布布扣


TCP学习之建立一个简单的客户/服务器系统--回射系统

标签:服务器   网络编程   tcp   

原文地址:http://blog.csdn.net/u013011841/article/details/40787481

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!