Bytestream solange auslesen bis keine Daten mehr vorhanden sind

1package programm.Connection;
2
3import java.io.DataInputStream;
4import java.io.DataOutputStream;
5import java.io.IOException;
6import java.io.InputStream;
7import java.io.OutputStream;
8
9import programm.main.StaticInc;
10/**
11 * Stream in und output handler fuer alle geoeffneten verbindungen
12 * @author Fasibio
13 *
14 */
15public class ConnectionStream extends Thread implements ICommunikator{
16
17 private InputStream input;
18 private OutputStream output;
19
20 private IMessage message;
21 private boolean close;
22
23 /**
24 * Standart Konstruktor
25 * @param input
26 * @param output
27 * @param message
28 */
29 public ConnectionStream(InputStream input, OutputStream output, IMessage message){
30 this.input = input;
31 this.output = output;
32 this.message = message;
33 }
34
35 @Override
36 public void run() {
37 super.run();
38 byte[] buffer = new byte[1024];
39 int bytes;
40 while (!close){
41 try{
42 bytes = input.read(buffer);
43 String readMessage = new String(buffer, 0, bytes);
44 message.newMessage(this, readMessage);
45 }catch (Exception e){
46 message.exceptionThrow(this, e);
47 break;
48 }
49 }
50 message.connectionClosed(this);
51 }
52
53
54 /**
55 * Liefert den InputStream zurueck
56 * @return
57 */
58 public InputStream getInputStream(){
59 return input;
60 }
61
62 /**
63 * Schließt die verbindung
64 */
65 public void close(){
66 this.close = true;
67 }
68
69 /**
70 * Schieckt einen String an den Client
71 * @param json
72 */
73 public void write(String json){
74
75 try {
76 StaticInc.printToConsole(" write to client : "+json);
77 output.write(json.getBytes());
78 output.flush();
79 } catch (IOException e) {
80 e.printStackTrace();
81 }
82 }
83
84 @Override
85 public String getCommunikatorName() {
86
87 return "Connection Stream";
88 }
89
90}

1while (!close)