2

I am starting to use aio to write a simple client server program.My client program:

int main(int argc, char const *argv[])
{

    int port = 6000;  
    struct sockaddr_in my_address;  
    memset(&my_address, 0, sizeof(my_address));  
    my_address.sin_family = AF_INET;  
    my_address.sin_addr.s_addr = htonl(0x7f000001); // 127.0.0.1
    my_address.sin_port = htons(port);

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

    connect(fd, (struct sockaddr*)&my_address, sizeof(my_address));

    char * str = "hello";

    struct aiocb my_aio;
    memset((void*)&my_aio, 0, sizeof(struct aiocb));
    my_aio.aio_fildes = fd;
    my_aio.aio_buf = str;
    my_aio.aio_nbytes = strlen(str);
    aio_write(&my_aio);
    return 0;
}

My server program:

int main(int argc, char *argv[])
{
     int sockfd, newsockfd, portno, clilen;
     char buffer[256];
     struct sockaddr_in serv_addr, cli_addr;
     int n;
     if (argc < 2) {
         fprintf(stderr,"ERROR, no port provided\n");
     }
     sockfd = socket(AF_INET, SOCK_STREAM, 0);
     if (sockfd < 0) 
        error("ERROR opening socket");
     bzero((char *) &serv_addr, sizeof(serv_addr));
     portno = atoi(argv[1]);
     serv_addr.sin_family = AF_INET;
     serv_addr.sin_addr.s_addr = INADDR_ANY;
     serv_addr.sin_port = htons(portno);
     if (bind(sockfd, (struct sockaddr *) &serv_addr,sizeof(serv_addr)) < 0) 
        error("ERROR on binding");

     listen(sockfd,5);
     clilen = sizeof(cli_addr);
     newsockfd = accept(sockfd, (struct sockaddr *) &cli_addr, &clilen);
     sleep(5);
     bzero(buffer,256);
     n = read(newsockfd,buffer,255);
     if (n < 0) error("ERROR reading from socket");
     printf("Here is the message: %s\n",buffer);

     return 0; 
}

I expect my server side to print out hello, but it does not. Thanks in advance.

4

1 に答える 1

1

コードは別の方法で動作しますmainが、非同期書き込みが完了する前に終了します。したがって、非同期書き込みが完了する前にソケットが閉じられます。呼び出しのperror("aio_write")後にa を追加して、発生しているエラーを確認しただけで、サーバーに正常に送信されました。aio_writehello

aio_suspendを終了する前に未処理の操作が完了していることを確認するために使用することをお勧めしますmain

于 2016-04-11T09:44:15.943 に答える