0

だから、ソケットからデータを読み込もうとしています。接続を確立し、そのようなものをリッスンしている他のソケットにメッセージを送信しましたが、何も受信していないようです。クライアントコード:

import java.net.*;
import java.io.*;
import java.util.*;
public class TCPClient {
 /*Conecting to server.
 */
 public static void Client(String[] args){
  int port = 47361;
  Scanner in = new Scanner(System.in);
  System.err.print("Starting up...");
  Socket CS1 = null; //Declaring CS1 as a socket
  DataOutputStream DOS1 = null; //Declaring an outputput data stream "DOS1"
  DataInputStream DIS1 = null; //Setting the values to null
  System.err.println("All created.");
  System.out.println("---------");
  System.out.println(" OPTIONS");
  System.out.println("---------");
  System.out.println("0. Connect.");
  System.out.println("1. Change port.");
  System.out.println("2. Cancel start-up.");
  System.out.println("");
  System.out.println("Choose an option.");
  try {
   short ans = in.nextShort();
   if (ans == 2){
    System.err.println("System.exit(0)");
    System.exit(0);
   }
   if (ans == 1){
     System.out.print("Enter the new port: ");
     port = in.nextInt();
     ans = 0;
   }
   if (ans == 0){
    System.out.print("Enter the IP: ");
    CS1 = new Socket(in.next(), port); //Creating an instane of the "CS1" socket
    System.err.print("Request sent on port " + port + ".");
    DOS1 = new DataOutputStream(CS1.getOutputStream());
    DIS1 = new DataInputStream(CS1.getInputStream()); //creating output and input streams
    System.err.println("Instances created!");
    if (DIS1 != null){
     System.err.println("DIS1 is connected!");
    }
    else {
     System.err.println("DIS1 is null!");
    }
    if (DOS1 != null) {
     System.err.println("DOS1 is connected!");
     System.out.print("Enter input: ");
     String FirstMessage = in.nextLine();
     DOS1.writeBytes(FirstMessage);
     String SecondMessage = DIS1.readLine();
     System.out.println(SecondMessage);
     if (SecondMessage.equals(FirstMessage)) {
     }
     else {
      System.out.println("Please check the code, FirstMessage != SecondMessage");
      }
    }
    else {
     System.err.println("DOS1 is null!");
    }
    if (CS1 != null) {
     System.err.println("CS1 is connected!");
    }
    else {
     System.err.println("CS1 is null!");
    }
    DIS1.close();
    DOS1.close();
    CS1.close(); //closing everything
   }
  }
  catch (IOException e){
   System.err.println("IOException: " + e.getMessage());
  }
 }
}

サーバーコード:

import java.net.*;
import java.io.*;
import java.util.*;
public class TCPServer {
 /*Connecting to client
  */
 public static void Server (String[] args) {
  System.err.print("Starting up...");
  ServerSocket SS1 = null;
  DataOutputStream DOS1 = null;
  DataInputStream DIS1 = null;//Setting the values to null
  System.err.println("All created.");
  Scanner in = new Scanner(System.in);
  try {
   SS1 = new ServerSocket(47361); //setting the socket SS1 to port 5000 and creating an instance
   System.err.print("Listening on port 47361...");
   Socket CS1 = SS1.accept(); //accepting the connection request
   DOS1 = new DataOutputStream(CS1.getOutputStream());
   DIS1 = new DataInputStream(CS1.getInputStream());//creating output and input streams
   System.err.println("Instances created!");
   if (DIS1 != null){
    System.err.println("DIS1 is connected!");
    System.err.println(DIS1);
   }
   else {
    System.err.println("DIS1 is null!");
   }
   if (DOS1 != null) {
    System.err.println("DOS1 is connected!");
    System.err.println(DOS1);
   }
   else {
    System.err.println("DOS1 is null!");
   }
   if (SS1 != null) {
    System.err.println("SS1 is connected!");
    System.err.println(SS1);
   }
   else {
    System.err.println("SS1 is null!");
   }
   String FirstMessage = null;
   FirstMessage = DIS1.readLine();
   System.out.println(FirstMessage);
   String SecondMessage = FirstMessage;
   DOS1.writeBytes(SecondMessage);
   DIS1.close();
   DOS1.close();
   SS1.close(); //closing everything
  }
  catch (IOException error){
   System.err.println("IOException " + error.getMessage());
  }
catch (java.util.InputMismatchException error2){
   System.err.println("IOException " + error2.getMessage());
  }
 }
}

これまでのところ、Buffered がなければ、ほとんど EchoServer です。デバッガーを調べたところFirstMessage = DIS1.readLine();、サーバーとString SecondMessage = DIS1.readLine();クライアントの行でスタックします。また、可能な入力を入力した後でも、サーバーとクライアントの両方が入力を待機しています。なぜこれが起こっているのですか？そして、どうすればこれを機能させることができますか？

補足: I/O ストリームまたはソケットが null になることはありません。また、コンパイラは、クラス java.io.DataInputStream が廃止されたことを警告しています。他にどのクラスを使用することをお勧めしますか?

別の補足: 私は IO を初めて使用します。

ありがとう！

4

1 に答える 1

1

いつもの問題。あなたは行を読んでいますが、行を書いていません。書き込み時にメッセージに行末記号を追加します。

于 2015-11-18T17:09:34.340 に答える