1

みんな！ソケットを使用して最初の Java アプリケーションを作成しようとしています。そして、ソケットからの読み取りに問題があります。ServerThread のソース コードは次のとおりです。

public class ServerThread extends Thread{
private final int SERVER_PORT = 444;
private ServerSocket serv;
public ServerThread(){

    try {
        serv = new ServerSocket(SERVER_PORT);
    } catch (IOException ex) {
        Logger.getLogger(ServerThread.class.getName()).log(Level.SEVERE, null, ex);
    }
}

@Override
public void run(){
    while(true){
        try {
            Socket client = serv.accept();
            client.setSoTimeout(0);
            client.setTcpNoDelay(true);
            client.setSendBufferSize(65536);
            if(client.isConnected()){
                new Thread(new MsgSrv(client)).start();
                System.out.println("Client connected");
            }
        } catch (IOException ex) {
            Logger.getLogger(ServerThread.class.getName()).log(Level.SEVERE, null, ex);
        }

    }
} }

クライアント接続を処理するクラスは次のとおりです。

public class MsgSrv extends Thread{
private BufferedWriter out;
private BufferedReader in;
private boolean isFinished = false;
private String buff;
private Socket sock;
public MsgSrv(Socket sc){
    try {
        sock = sc;
        in = new BufferedReader(new InputStreamReader(sc.getInputStream()));
        out = new BufferedWriter(new OutputStreamWriter(sc.getOutputStream()));
    } catch (IOException ex) {
        Logger.getLogger(MsgSrv.class.getName()).log(Level.SEVERE, null, ex);
    }

}
public void run(){
    while(!isFinished){
        try {
            buff=in.readLine();
            System.out.println(buff);
            out.write("Hello");
        } catch (IOException ex) {
            Logger.getLogger(MsgSrv.class.getName()).log(Level.SEVERE, null, ex);
            isFinished=true;
        }
    }
}}

クライアント アプリケーションは文字列をサーバーに送信し、回答を読み取ろうとします。しかし、何も起こりません。in.readLine何も返さず、サーバーからの応答を永遠に待ちます。問題を解決するのを手伝ってもらえますか? データを読み取るために、私はすでに DataInputStream、BufferedReader クラスを使用しました。クライアント アプリのソース:

public class JavaApplication4 {

/**
 * @param args the command line arguments
 */
public static Socket connectSock;
public static PrintWriter out;
public static DataInputStream in;
public static void main(String[] args) {
    try {

        connectSock = new Socket("127.0.0.1", 444);
        if(connectSock.isConnected()){
            in = new DataInputStream(connectSock.getInputStream());
            out = new PrintWriter(connectSock.getOutputStream(), true);
            out.println("!hello!");
            out.flush();
            String s;
            while(true){
                s = in.readUTF();
                System.out.println(s);
            }

               }else
        {
            System.out.println("bad socket");
            System.exit(0);
        }
    } catch (UnknownHostException ex) {
        Logger.getLogger(JavaApplication4.class.getName()).log(Level.SEVERE, null, ex);
    } catch (IOException ex) {
        Logger.getLogger(JavaApplication4.class.getName()).log(Level.SEVERE, null, ex);
    }

}}
4

1 に答える 1

0

オブジェクトを使用しPrintWriterて文字列を送信するように、オブジェクトを使用して文字Scanner列を読み取ります。このような。

input = server.getInputStream();
Scanner scanner = new Scanner(input);

while (scanner.hasNextLine()) {
     s = (String) scanner.nextLine();
}

編集：

このようにクライアントを変更し、使用時に文字列 ("\n") の最後に改行があることを確認する場合scanner.nextLine();

if(connectSock.isConnected()){           
        Scanner scanner = new Scanner(connectSock.getInputStream());
        out = new PrintWriter(connectSock.getOutputStream(), true);
        out.println("!hello!");
        out.flush();
        String s;
        while (scanner.hasNextLine()) {
            s = (String) scanner.nextLine();

        }

           }else
    {
于 2013-09-26T06:24:52.673 に答える