2

ソケットを使用してJavaで簡単なクライアント/サーバーチャットをしています。問題は、プログラムが相互に接続していることですが、何らかの理由で両側からデータを取得/受信できません。サーバーを切断すると、クライアントは「接続のリセット」というエラーを表示します。これは、接続されているがデータを交換していないことを示しています。

コードは、ここから取得した Java チュートリアルから取得したものと同じコードです。

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package javaapplication3;

/**
 *
 * @author Amr
 */
import java.net.*;
import java.io.*;

public class KnockKnockServer {
    public static void main(String[] args) throws IOException {

        ServerSocket serverSocket = null;
        try {
            serverSocket = new ServerSocket(4440);
        } catch (IOException e) {
            System.err.println("Could not listen on port: 4444.");
            System.exit(1);
        }

        Socket clientSocket = null;
        try {
            clientSocket = serverSocket.accept();
            System.out.println(Inet4Address.getLocalHost());
        } catch (IOException e) {
            System.err.println("Accept failed.");
            System.exit(1);
        }

        PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true);
        BufferedReader in = new BufferedReader(
                new InputStreamReader(
                clientSocket.getInputStream()));
        String inputLine, outputLine;


        while ((inputLine = in.readLine()) != null) {
             outputLine = "heelo";
             out.println(outputLine);
             if (outputLine.equals("Bye."))
                break;
        }
        out.close();
        in.close();
        clientSocket.close();
        serverSocket.close();
    }
}

import java.io.*;
import java.net.*;

public class KnockKnockClient {
    public static void main(String[] args) throws IOException {

        Socket kkSocket = null;
        PrintWriter out = null;
        BufferedReader in = null;

        try {
            kkSocket = new Socket(Inet4Address.getLocalHost(), 4440);
            out = new PrintWriter(kkSocket.getOutputStream(), true);
            in = new BufferedReader(new InputStreamReader(kkSocket.getInputStream()));
        } catch (UnknownHostException e) {
            System.err.println("Don't know about host: taranis.");
            System.exit(1);
        } catch (IOException e) {
            System.err.println("Couldn't get I/O for the connection to: taranis.");
            System.exit(1);
        }

        BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.in));
        String fromServer;
        String fromUser;

        while ((fromServer = in.readLine()) != null) {
            System.out.println("Server: " + fromServer);
            if (fromServer.equals("Bye."))
                break;

            fromUser = stdIn.readLine();
        if (fromUser != null) {
                System.out.println("Client: " + fromUser);
                out.println(fromUser);
        }
        }

        out.close();
        in.close();
        stdIn.close();
        kkSocket.close();
    }
}
4

3 に答える 3

5

接続をセットアップした後、サーバーが最初に行うことは次のとおりです。

while ((inputLine = in.readLine()) != null)

つまり、クライアントが何かを言うのを待ちます。

お客様が最初に行うことは、

while ((fromServer = in.readLine()) != null)

つまり、サーバーが何かを言うのを待ちます。

2 つのうちの 1 つが最初に何かを送信するようにすると、動作するはずです。

于 2013-04-23T08:18:49.433 に答える
1

クライアントとサーバーの両方に、ブロックBufferedReaderするメソッドを使用して、それぞれから読み取る単一のスレッドがあります。readLine()

クライアントとサーバーの両方が、どちらかが何かを送信する前に相互に読み取りを行うことを期待しているため、両方ともただそこに座ってブロックします。fork して、 から読み取るスレッドとBufferedReaderに書き込むスレッドを用意するか、次のPrintWriterものが必要です。

outputLine = "heelo";
out.println(outputLine);

while ループの外側。

于 2013-04-23T08:19:08.183 に答える