package com.demo.android.chat;



import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.PrintStream;

import java.net.InetAddress;

import java.net.Socket;



import android.os.Handler;





public class ChatClientSocket extends Thread{



	private Socket skt;        // 客戶端連線Socket物件

    private InetAddress host;  // 指定的伺服端IP

    private int port;          // 指定的伺服端連接埠

    

    private BufferedReader theInputStream;

    private PrintStream theOutputStream;

    private Chat chatBox;

	private static String message;



    

	public ChatClientSocket(String ip, int port) {

		try {

            // 取得伺服端的InetAddress物件、通訊連接埠

            host = InetAddress.getByName(ip);

            this.port = port;

        }

        catch (IOException e) {

            e.printStackTrace();

        }

	}

	

	// 指定這個Socket的訊息觀察者

	public void setMessageObserver(Chat box) {

		chatBox = box;

	}



	public String getMessage() {

		return message;

	}

	

	public void run() {

        try {

            message = "嘗試連線......";

            chatBox.UpdateTextView();

            

 

            // 建立Socket物件並嘗試連線

            skt = new Socket(host, port);

            

            message = "連線成功\n";

            chatBox.UpdateTextView();        



            // 從InputStream建立讀取緩衝區

            theInputStream = new BufferedReader(

                new InputStreamReader(skt.getInputStream()));

            // 從OutputStream中建立PrintStream物件

            theOutputStream = new PrintStream(skt.getOutputStream());

 

            // 讀取資料迴圈

            while((message = theInputStream.readLine()) != null) {

                // 將之顯示在TextView上

                message = ": " + message + "\n";

                chatBox.UpdateTextView();

            }

            

            if(message == null) {

                skt.close();

                message = "連線中斷！\n";

                chatBox.UpdateTextView();



            }

            

        }catch (IOException e) {

           message = e.toString();

           chatBox.UpdateTextView();

        }

       

    }

	//將要傳送的訊息傳給server端

	public void dataOutput(String data) {

		theOutputStream.println(data);

	}



}

package com.demo.android.chat;





import android.app.Activity;

import android.os.Bundle;

import android.os.Handler;

import android.view.LayoutInflater;

import android.view.View;

import android.view.View.OnClickListener;

import android.widget.Button;

import android.widget.EditText;

import android.widget.TextView;



public class Chat extends Activity {

    /** Called when the activity is first created. */

	

    private Button go;                   //發送訊息的按鈕

    private Button clientBtn;            //連接伺服器的按鈕

    private Button serverBtn;

    private EditText tfAddress ;         //輸入IP

    private EditText tfPort ;            //輸入Port

    private EditText tfChat ;            //輸入要傳送的訊息

    private TextView result ;            //伺服器端傳送的訊息display在這

    private ChatClientSocket clientSkt;  //客戶端連線處理執行緒



	public static Handler mHandler = new Handler();

	   

    

    final Runnable mUpdateResults = new Runnable() {

        public void run() {

            update();

        }

    };

    

    public void UpdateTextView(){

    	 mHandler.post(mUpdateResults);

    }

    @Override

    public void onCreate(Bundle savedInstanceState) {

        super.onCreate(savedInstanceState);

        setContentView(R.layout.main);

       // Listen for button clicks



		

        result = (TextView) findViewById(R.id.textview);

        tfAddress =(EditText)findViewById(R.id.ip);

        tfPort = (EditText)findViewById(R.id.port);

        tfChat = (EditText)findViewById(R.id.chat);

        clientBtn = (Button)findViewById(R.id.connect);

        go = (Button)findViewById(R.id.go_btn);

        clientBtn.setOnClickListener(connectserver);

        go.setOnClickListener(goserver);

    }

    

    //連接伺服器

    private OnClickListener connectserver = new OnClickListener(){

    	public void onClick(View v){

    		 setClient();

    	}

    };

    

    //傳送訊息給伺服器

    private OnClickListener goserver = new OnClickListener(){

    	public void onClick(View v){

    		// 將資料透過連線執行緒送出

            clientSkt.dataOutput(tfChat.getText().toString());

            // 清除下方文字欄位內容

            tfChat.setText("");

            

    	}

     };

	

    public void setServerBtn(Button serverBtn) {

 		this.serverBtn = serverBtn;

 	}

 	public Button getServerBtn() {

		return serverBtn;

 	}

 	

 	//對textView進行更新

 	private void update() {

    	result.append(clientSkt.getMessage());

    }

 	

    private void setClient() {

    	// 取得指定的IP與連接埠

        int port = Integer.parseInt(tfPort.getText().toString());

        // 建立客戶端連線執行緒

        clientSkt = new ChatClientSocket(tfAddress.getText().toString(), port);

        clientSkt.setMessageObserver(this);

        // 啟動執行緒進行連線

        clientSkt.start();

	}

    

}