root/trunk/24.SocketTest/src/soo/net/SocketTest.java

package soo.net;

import java.io.*;
import java.net.Socket;

import android.app.Activity;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.util.Log;
import android.view.View;
import android.widget.*;

public class SocketTest extends Activity  {     
        EditText et1, et2;
        Button b1, b2, b3;
        Thread th;
        
        private Handler h = new Handler(){
                @Override
                public void handleMessage(Message msg){
                        et1.append("Server >> " + msg.obj.toString() + "\n");
                }
        };
        
    @Override
    public void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.main);
        
        et1 = (EditText)findViewById(R.id.editText01);
        et2 = (EditText)findViewById(R.id.editText02);
        b1 = (Button)findViewById(R.id.button01);
        b2 = (Button)findViewById(R.id.button02);
        b3 = (Button)findViewById(R.id.button03);
        
        b1.setOnClickListener(new View.OnClickListener() {
                        @Override
                        public void onClick(View v) {
                                connect();
                        }
                });
        b2.setOnClickListener(new View.OnClickListener() {
                        @Override
                        public void onClick(View v) {
                                String msg = et2.getText().toString();
                                write(msg);
                                et1.append(msg + "\n");
                                et2.setText("");
                        }
                });
        b3.setOnClickListener(new View.OnClickListener() {
                        @Override
                        public void onClick(View v) {
                        
                        th = new Thread(new Runnable(){
                                String str = "";
                                
                                @Override
                                public void run(){
                                        try{
                                                while(true){
                                                        str = dis.readUTF();
                                                        Log.i("server MSG  : ", str);
                                                        Message msg = h.obtainMessage();
                                                        msg.obj = str;
                                                        SocketTest.this.h.sendMessage(msg);
                                                }
                                        }catch(Exception e){
                                                Log.e("th-run()" , e.toString());
                                        }
                                }
                        });
                        th.start();
                        }
                });
    }
    
    private Socket s;
    private InputStream is;
    private OutputStream os;
    private DataInputStream dis;
    private DataOutputStream dos;
    
    private void connect(){
        try{
                s = new Socket("192.168.0.42", 5000);
                Log.i("socket created", s.toString());
                is = s.getInputStream();
                os = s.getOutputStream();
                dis = new DataInputStream(is);
                dos = new DataOutputStream(os);
                
        }catch(Exception e){
                Log.e("socket not exists", s.toString());
        }
    }
    
    private void write(String msg){
        try{
                dos.writeUTF(msg);
                dos.flush();
        }catch(IOException ie){
        }
    }
}