TCP Server代码示例

//#include

#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <errno.h>
#include <unistd.h>
#include <iostream>
using namespace std;

int
main (int argc, char **argv)
{
    int fd = socket (AF_INET, SOCK_STREAM, 0);
    if (fd == -1)
    {
        cout<<"socket() error: "<<errno<<endl;
        return -1;
    }
    else
        cout<<"socket() ok!"<<endl;
    struct sockaddr_in localaddr;
    localaddr.sin_family = AF_INET;
    localaddr.sin_addr.s_addr = htonl (INADDR_ANY);
    localaddr.sin_port = htons (5125);
    if (bind(fd, (struct sockaddr *)&localaddr, (socklen_t)sizeof(struct sockaddr_in)) == -1)
    {
        cout<<"bind() error\n";
        return -1;
    }
    else
        cout<<"bind() ok!\n";
    //if (listen (fd, SOMAXCONN) == -1)

    if (listen (fd, 2) == -1)
    {
        cout<<"listen() error\n";
        return -1;
    }
    else
        cout<<"listen ok! \n";
    char buf[1024];
    struct sockaddr_in remoteaddr;
    int client_sockfd;
    while (1)
    {
        socklen_t len = (socklen_t)sizeof(struct sockaddr);
        //client_sockfd = accept (fd, (struct sockaddr *) &remoteaddr, &len);

        client_sockfd = accept(fd, NULL, NULL);
        if (client_sockfd != -1)
        {
            cout<<"waiting for ...\n";
            int n = 0;
            while((n=recv(client_sockfd, buf, 1024, 0)) > 0)
            {
                buf[n] = '\0';
                cout<<"server read line: "<<buf<<endl;
                if(strcmp(buf, "reboot")==0)
                    cout<<"reboot!!!!!!!!!!!!!!!!!"<<endl;
            }
            close(client_sockfd);
            cout<<"close client"<<endl;
        }
        else
        {
            cout<<"accept() error!\n";
            break;
        }
    }
    close(fd);
    printf ("close client\n");

    return 0;
}