Code Client/serveur avec thread sur Android

j'ai une application qui consiste à établir une connexion entre un client et un serveur. J'ai essayé de développer ce code en utilisant un thread pour le client et un thread pour le serveur , mais j'ai pas réussi à envoyer des octet .
qui peut m'aider à corriger ce code

/************Code Serveur****************/

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
 
int TCPport =Integer.parseInt((evPort.getEditableText().toString())); 
	                InetAddress sockaddr = InetAddress.getByName(evIPAdress.getEditableText().toString());
	                ServerSocket serveur = new ServerSocket(TCPport,1,sockaddr);     	    
 
	                T1.append("Recherche en cours... \r\n");
           		 client = serveur.accept(); // client demande de cnx au serveur
 
	               try
	            	{
 
 
	            		T1.append("connecté avec "+client.getInetAddress().getHostName()+"\r\n");
 
	            	     in = new BufferedReader(new InputStreamReader(client.getInputStream())); 
	            	     T1.append("--Start to listen !--\r\n");
 
	            	     while(true)     
	            		 {	 
	            	    	 A=in.readLine();
	            		     if(A==null)
	            		    	 break;
	            		     T1.append(A+"\r\n");
 
	            	     }}

/****************Code Client***************/

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
 
int TCPport =Integer.parseInt((evPort.getEditableText().toString())); 
     	                InetAddress sockaddr = InetAddress.getByName(evIPAdress.getEditableText().toString());
 
             S = new Socket();
 
             SocketAddress sockaddrC = new InetSocketAddress(sockaddr,TCPport);
             S.connect(sockaddrC);
 
 
 
 
 
             try{
            	 in = new BufferedReader(new InputStreamReader(S.getInputStream())); 
                while(true)
             {A=in.readLine();
 
                	if(A==null)
                		break;
                T1.append(A+"\n\r");
              }
             }
             catch(Exception Ex){
            	 T1.append("EX client//"+Ex.getMessage()); 
             }
 
             OutputStream  A = S.getOutputStream();
             out = new PrintWriter(A);
 
 
             out.write("zzzzzzzzzzzzzzzz");
             out.flush();  	
             S.close();//fermer sockeT
             out.close();//fermer le printWriter
 
         } catch(Exception e){
         	 Toast.makeText(test.this, "bCon"+e.getMessage(), Toast.LENGTH_LONG).show();
 
         }
         }
     };