UDP parallel zu TCP

1private volatile AtomicBoolean cancelPending = new AtomicBoolean(false);

1while(cancelPending.get()){
2 try {
3 Thread.sleep(10);
4 } catch (InterruptedException e) {
5 // TODO Auto-generated catch block
6 e.printStackTrace();
7 }
8 }

1public void stop() {
2 cancelPending.set(true);
3 }
4
5 public void start() {
6 cancelPending.set(false);
7 }

1mBackground3 = new Thread(new Runnable()
2 {
3 public void run()
4 {
5 Log.w("TCP THREAD", "Starte run");
6 Log.w("finish status", ""+finish);
7
8 Socket socket = null;
9 DataOutputStream dataOutputStream = null;
10 DataInputStream dataInputStream = null;
11 Log.w("TCP THREAD", "Socket und Streams initialisiert");
12 do{
13
14 try {
15
16start();
17
18 socket = new Socket("192.168.2.2", 8888); //Connect on server socket
19
20 stop();
21
22 dataInputStream = new DataInputStream(socket.getInputStream());;
23 String message = dataInputStream.readUTF();
24 Log.w("INCOMMING MESSAGE", "content: "+message+" <- received");
25
26
27 } catch (UnknownHostException e) {
28 e.printStackTrace();
29 } catch (IOException e) {
30 e.printStackTrace();
31 }
32 finally{
33 if (socket != null){
34 try {
35 socket.close();
36 } catch (IOException e) {
37 e.printStackTrace();
38 }
39 }
40
41 if (dataOutputStream != null){
42 try {
43 dataOutputStream.close();
44 } catch (IOException e) {
45 e.printStackTrace();
46 }
47 }
48
49 if (dataInputStream != null){
50 try {
51 dataInputStream.close();
52 } catch (IOException e) {
53 e.printStackTrace();
54 }
55 }
56 }
57
58 }while(finish==true);
59 }
60 });

1java.net.SocketException: Connection reset by peer: socket write error
2 at java.net.SocketOutputStream.socketWrite0(Native Method)
3 at java.net.SocketOutputStream.socketWrite(Unknown Source)
4 at java.net.SocketOutputStream.write(Unknown Source)
5 at java.io.DataOutputStream.write(Unknown Source)
6 at java.io.DataOutputStream.writeUTF(Unknown Source)
7 at java.io.DataOutputStream.writeUTF(Unknown Source)
8 at Server.main(Server.java:33)