zoukankan      html  css  js  c++  java
  • tcp/ip程序

    #include<stdio.h>
    #include<stdlib.h>
    #include<errno.h>
    #include<string.h>
    #include<sys/types.h>
    #include<sys/socket.h>
    #include<sys/un.h>
    #include<sys/wait.h>      //*进程用的头文件*/
    #include<netinet/in.h>
    #include<arpa/inet.h>
     
     #define MAXLINE  50  //通信内容的最大长度
    int main()
    {
        int sock_fd,new_fd;//sock_fd用于监听,new_fd用于连接
        struct sockaddr_in srv_addr;//服务器的地址信息
        struct sockaddr_in client_addr;//客户机的地址信息
        int size; //地址结构数据的长度
        pid_t  pid;  //子进程id
        ssize_t n;
        char buf[MAXLINE]; //用于存放通信的内容
        
        /*创建套接字*/
        sock_fd=socket(AF_INET,SOCK_STREAM,0);//采用IPv4协议
        if(sock_fd==-1)
        {
            perror("creat socket failed");
            exit(1);
        }
        
        /*服务器地址参数*/
        srv_addr.sin_family=AF_INET;  
        srv_addr.sin_port=htons(3490);
        srv_addr.sin_addr.s_addr=htonl(INADDR_ANY);
        bzero(&srv_addr.sin_zero,sizeof(struct sockaddr_in));//bzero位清零函数,将sin_zero清零,sin_zero为填充字段,必须全部为零
        
        int on=1; //表示开启reuseaddr
        if(setsockopt(sock_fd,SOL_SOCKET,SO_REUSEADDR,&on,sizeof(on))<0)  //打开地址、端口重用
            perror("setsockopt");
        
        /*绑定地址和端口*/
        if(bind(sock_fd,(struct sockaddr*)&srv_addr,sizeof(struct sockaddr))==-1)
        {
            perror("bind failed");
            exit(1);
        }
        
        /*连接到服务器
        if(connect(sock_fd,(struct sockaddr*)&srv_addr,sizeof(sock_fd))==-1)
        {
            perror("bind failed");
            exit(1);
        }*/
        
        /*设置监听模式,等待客户机的监听*/
        if((listen(sock_fd,5))==-1)
        {
            perror("listen failed");
            exit(1);
        }
        
        /*接受连接,采用非阻塞是的模式调用accep*/
        while(1)
        {
            size=sizeof(struct sockaddr_in);
            new_fd=accept(sock_fd,(struct sockaddr*)&client_addr,&size);
            if(new_fd==-1)
            {
                perror("accept failed");
                continue;//restart accept when EINTR
            }
            
            printf("server:got connection from IP= %s prot= %d 
    ",inet_ntoa(client_addr.sin_addr),ntohs(client_addr.sin_port));//连接成功,打印客户机IP地址和端口号
            /*char *inet_nota(struct sockaddr_in in);
            头文件:
            arpa/inet.h
            Winsock2.h
            参数:
            一个网络上的IP地址
            返回值:
              如果正确,返回一个字符指针,指向一块存储着点分格式IP地址的静态缓冲区(同一线程内共享此内存);错误,返回NULL。
            uint31_t ntohs(uint32_t net32bitvalue);
            头文件:
            #include<netinet/in.h>
            把net32bitvalue有网络字节序转换为主机字节序。
            */
                if(send(new_fd,"Hello client,I am 192.168.229.125!
    ",50,0)==-1)  //192.168.229.125为子进程IP,可更改
                               perror("send failed");
    
            pid=fork();  //父进程建立套接字的连接之后,创建子进程用于通信
            if(!pid)//创建新的子进程
            {
               // if(send(new_fd,"Hello client,I am 192.168.229.125!
    ",50,0)==-1)  //192.168.229.125为子进程IP,可更改
                  // perror("send failed");
                close(sock_fd);//子进程不需要监听,所以子进程关闭监听套接字
                while(1)
            {
                    memset(buf,0,sizeof(buf));
                 n=read(new_fd,buf,MAXLINE);
                if(n==0)
                   break;    
                write(new_fd,buf,n);
                fputs(buf,stdout);
                if(n<0)
                   perror("read from client error");    
               // exit(EXIT_SUCCESS);
                    }
            exit(EXIT_SUCCESS);
            }
            else
                close(new_fd);//父进程不需要连接,所以关闭连接套接字
    
            //while(waitpid(-1,NULL,WNOHANG)>0);//等待子进程结束,进行新的连接
        }
    }

    服务器程序

    支持服务器重启,并发服务器

    客户机程序

    #include<stdio.h>
    #include<stdlib.h>
    #include<errno.h>
    #include<string.h>
    #include<sys/types.h>
    #include<sys/socket.h>
    #include<sys/un.h>
    #include<sys/wait.h>      //*进程用的头文件*/
    #include<netinet/in.h>
    #include<arpa/inet.h>
    
    #define MAXBYTEMUN   100
    int main(int argc,char *argv[])
    {
        int sock_fd,numbytes;
        char buf[MAXBYTEMUN];
        struct hostent *he;
        struct sockaddr_in client_addr;//客户机的地址信息
        
        if(argc!=2)
        {
            fprintf(stderr,"usage: client IPAddress
    ");   //执行客户端程序时,输入客户端程序名称和其IP地址
            exit(1);    
        }
        
        /*创建套接字*/
        sock_fd=socket(AF_INET,SOCK_STREAM,0);//采用IPv4协议
        if(sock_fd==-1)
        {
            perror("creat socket failed");
            exit(1);
        }
        
        /*服务器地址参数*/
        client_addr.sin_family=AF_INET;  
        client_addr.sin_port=htons(3490);
        client_addr.sin_addr.s_addr=inet_addr(argv[1]);
        bzero(&client_addr.sin_zero,sizeof(struct sockaddr_in));//bzero位清零函数,将sin_zero清零,sin_zero为填充字段,必须全部为零
        
        
        /*连接到服务器*/
        if(connect(sock_fd,(struct sockaddr*)&client_addr,sizeof(struct sockaddr))==-1)
        {
            perror("connect failed");
            exit(1);
        }
                if((numbytes=recv(sock_fd,buf,MAXBYTEMUN,0))==-1)
                     {       
                       perror("receive failed");
                       exit(1);
                     }
                     buf[numbytes]='';//在字符串末尾加上,否则字符串无法输出
                     printf("Received: %s
    ",buf);
    
        while(fgets(buf,MAXBYTEMUN,stdin)!=NULL)
        {
               /* if((numbytes=recv(sock_fd,buf,MAXBTYEMUN,0))==-1)
                    {
                          perror("receive failed");
                       exit(1);
                    }
                    buf[numbytes]='';//在字符串末尾加上,否则字符串无法输出
                    printf("Received: %s
    ",buf);
                   // close(sock_fd);*/
            write(sock_fd,buf,strlen(buf));
            if(read(sock_fd,buf,MAXBYTEMUN)==0)
                perror("client: server terminated prematurely");
            fputs(buf,stdout);
        }
    
        /*接受数据
        if((numbytes=recv(sock_fd,buf,MAXBTYEMUN,0))==-1)
        {
            perror("receive failed");
            exit(1);
        }
    
        buf[numbytes]='';//在字符串末尾加上,否则字符串无法输出
        printf("Received: %s
    ",buf);
        close(sock_fd);*/
        return 0;
    }

    参考:

    http://blog.chinaunix.net/uid-26220063-id-3027117.html

    http://blog.csdn.net/whuslei/article/details/6667471/

    http://blog.chinaunix.net/uid-24517549-id-4044883.html

  • 相关阅读:
    zookeeper 介绍
    多线程、并发及线程的基础问题
    RabbitMQ
    关于JAVA IO流的学习
    SQL 的基本常识
    What is Bt?
    Python turtle库的学习笔记
    字符串简单模式匹配算法与IndexOf方法比较
    谈如何选书
    使用JavaScriptSerializer进行序列化日期类型应该注意的问题
  • 原文地址:https://www.cnblogs.com/wujing-hubei/p/5539464.html
Copyright © 2011-2022 走看看