2

単純な Java ソケット クライアントと単純な C ソケット サーバーの間で文字列をやり取りしようとすると問題が発生します。

次のように機能します。

Java クライアントmsgが C サーバーに送信する

    out.writeBytes(msg);

Cサーバーはメッセージを受け取り、buf

    if ((numbytes = recv(new_fd, buf, MAXDATASIZE-1, 0)) == -1) {
        perror("recv");
        exit(1);
    }

C サーバーはメッセージを Java クライアントに送り返します。

    if ((len = send(new_fd, buf, numbytes, 0)) == -1)
        perror("send");

DataInputStreamただし、Javaクライアントは C サーバーからメッセージBufferedReaderを受信できません。クライアント側で配列を読み込もうとすると、最初の文字しか得られないことがあり、それがブロッキングの問題だと思いますか?char[]byte[]string

どんな助けでもいただければ幸いです

コード：

Cサーバーのメインループ

while(1) {  // main accept() loop
    sin_size = sizeof their_addr;
    new_fd = accept(sockfd, (struct sockaddr *)&their_addr, &sin_size);
    if (new_fd == -1) {
        perror("accept");
        continue;
    }

    inet_ntop(their_addr.ss_family,
        get_in_addr((struct sockaddr *)&their_addr),
        s, sizeof s);
    printf("server: got connection from %s\n", s);

    if ((numbytes = recv(new_fd, buf, MAXDATASIZE-1, 0)) == -1) {
        perror("recv");
        exit(1);
    }

    buf[numbytes] = '\0';

    printf("msg size: '%d' bytes\n",numbytes);
    printf("received msg: %s\n",buf);
    char* array = (char*)buf;
    printf("as char array: %s\n", array);


    if (!fork()) { // this is the child process
        close(sockfd); // child doesn't need the listener
        int len = 0;
        if ((len = send(new_fd, buf, numbytes, 0)) == -1)
            perror("send");
        printf("sent %d bytes\n", len);
        close(new_fd);
        exit(0);
    }
    close(new_fd);  // parent doesn't need this
}

Java クライアント

public void send(String text){
    Socket sock = null;
    DataInputStream in = null;
    DataOutputStream out = null;
    BufferedReader inReader = null;

    try {
        sock = new Socket(HOST, PORT);
        System.out.println("Connected");
        in = new DataInputStream(sock.getInputStream());
        out = new DataOutputStream(sock.getOutputStream());

        out.writeBytes(text + "\n");

        String res = "";

        //get msg from c server and store into res

        System.out.println("Response: " + res);
    } catch (UnknownHostException e) {
        e.printStackTrace();
    } catch (IOException e) {
        e.printStackTrace();
    } finally {
        try {
            sock.close();
            //in.close();
            out.close();
        } catch (IOException e) {
            e.printStackTrace();
        }

    }
}
4

0 に答える 0