何時停止讀取telnet輸入？

Question

目前我有一個basic MUD client四類：WeatherDriver主類，並LineReader把處理的InputStream和LineParser解析String的Queue的，而Connection持有Apache telnet connection。這是基於Apache Weather Telnet example。

LineReader如何知道何時停止閱讀InputStream發送消息到WeatherDriver開始解析？

LineReader：

package teln; 

import static java.lang.System.out; 
import java.io.BufferedReader; 
import java.io.IOException; 
import java.io.InputStream; 
import java.io.InputStreamReader; 
import java.util.LinkedList; 
import java.util.Queue; 

public class LineReader { 

    private String prompt = "/[#]/"; 

    public LineReader() { 
    } 

    public Queue<String> readInputStream(InputStream inputStream) throws IOException { 
     InputStreamReader inputStreamReader = new InputStreamReader(inputStream); 
     StringBuilder sb = new StringBuilder(); 
     BufferedReader br = new BufferedReader(inputStreamReader); 
     String line = br.readLine(); 

     Queue<String> lines = new LinkedList<>(); 
     while (line != null) { //never terminates... 
      sb.append(line); 
      line = br.readLine(); 
      lines.add(line); 
     } 
     out.println(lines); 
     return lines; 
    } 

    public void setPrompt(String prompt) { 
     this.prompt = prompt; //need to determine EOL somehow... 
    } 
} 

連接：

package teln; 

import java.io.IOException; 
import java.io.InputStream; 
import java.net.InetAddress; 
import java.net.SocketException; 
import org.apache.commons.net.telnet.TelnetClient; 

public class Connection { 

    private TelnetClient tc = new TelnetClient(); 

    public Connection() { 
    } 

    public Connection(InetAddress h, int p, String prompt) throws SocketException, IOException { 
     tc.connect(h, p); 
    } 

    public InputStream getInputStream() { 
     return tc.getInputStream(); 
    } 
} 

WeatherDriver：

package teln; 

import static java.lang.System.out; 
import java.io.IOException; 
import java.io.InputStream; 
import java.net.InetAddress; 
import java.net.SocketException; 
import java.net.UnknownHostException; 
import java.util.Properties; 
import java.util.Queue; 

public final class WeatherDriver { 

    private static Connection c; 
    private static LineReader lineReader = new LineReader(); 
    private static LineParser lineParser = new LineParser(); 

    public static void main(String[] args) throws UnknownHostException, SocketException, IOException { 
     Properties props = PropertiesReader.getProps(); 
     InetAddress host = InetAddress.getByName(props.getProperty("host")); 
     int port = Integer.parseInt(props.getProperty("port")); 
     String prompt = props.getProperty("prompt"); 
      out.println("connecting..."); 
     c = new Connection(host, port, prompt); 
     InputStream inputStream = c.getInputStream(); 
     out.println("got stream"); 
     Queue<String> lines = lineReader.readInputStream(inputStream); 
     out.println("got lines"); 
     lineParser.parseLines(lines); 
     out.println("parsed lines"); 
    } 
} 

Answer 1

你行的讀者已經瞭解足夠的 「協議」 的當程序控制檢測終端需要輸入。即必須有某種類型的提示表明「線路轉換」。當它檢測到它時會停止閱讀，並讓您的前端執行下一個操作。

如果遠程系統有不同的方式指示它正在等待輸入（不同類型的提示），並且您需要檢測超時條件並採取一些特殊操作，則會變得複雜。

您可以從繪製狀態圖中受益，該狀態圖顯示遠程程序可以處於的各種狀態以及程序輸出到遠程登錄會話的狀態轉換過程。

Answer 2

Took a page from Pearson，以下內容寫入每個字符（我認爲）。這是printToConsole方法。

package teln; 

import java.io.IOException; 
import java.io.InputStream; 
import java.io.PrintStream; 
import java.net.InetAddress; 
import java.net.SocketException; 
import org.apache.commons.net.telnet.TelnetClient; 

public class Connection { 

    private TelnetClient tc = new TelnetClient(); 
    private boolean isl = false; 
    private String u; 
    private String pw; 
    //private StreamReader sr; 
    private InputStream in; 
    private PrintStream out; 

    private Connection() { 
    } 

    public Connection(InetAddress h, int p, String prompt, String u, String pw) throws SocketException, IOException, InterruptedException { 
     tc.connect(h, p); 
     this.u = u; 
     this.pw = pw; 
     in = tc.getInputStream(); 
     out = new PrintStream(tc.getOutputStream()); 
     printToConsole(); 
    } 

    public void printToConsole() throws IOException { 
     char ch = (char) in.read(); 
     while (true) { 
      System.out.print(ch); 
      ch = (char) in.read(); 
     } 
    } 

    public InputStream getInputStream() { 
     return tc.getInputStream(); 
    } 

    void cmd(String s) throws IllegalArgumentException, IOException { 
     byte[] by = s.getBytes(); 
     for (Byte b : by) { 
      tc.sendCommand(b); 
     } 
    } 
}