ประกาศครับ

จริงๆมัน connect server และส่งข้อมูลได้ แต่มีปัญหาตอนอ่านข้อมูล ด้วย Class นี้แหละครับ

แบบที่ท่านแนะนำ มันคล้ายๆ ตัวอย่างนี้ หรือปล่าวครับ

ตัวอย่างที่ผมลองใช้ Runable ครับ

ผมก็ลองทำดูแล้ว แบบที่ใช้ Runnable
มันก็ส่งได้อย่างเด่วครับ มันอ่าน Buffer จาก Server ไม่ได้

code ที่ใช้ส่งข้อความไป server ก็ตามนี้ครับ

    if(str.equals("Send")){
        try{
            PrintWriter pw = new PrintWriter(new BufferedWriter(new OutputStreamWriter(S                                    
                     .getOutputStream())), true);
            pw.println(msgText.getText());
            pw.flush();
            msgText.setText("");
        }
        catch(Exception E){
            serverText.setText("Error Send :"+E.toString());
        }
    }

ส่วน Code อ่าน Buffer จาก Server ก็ Class ข้างบนครับประมานนั้น

ตัวโปรแกรมที่ผมเขียนครับ
รูปภาพ ตัวโปรแกรม

Console สีดำฝั่งซ้าย เป้น Server ครับ สังเกตุว่า ส่งข้อความหา Server ได้ แต่หน้าจอ Android อ่าน Buffer จาก Server ไม่ได้ ที่เห้นขึ้น XXXXX มันขึ้นก่อนจะเด้งมาฟ้อง Error ข้างล่างของ Eclipse ครับ

คือกดส่งครั้งแรก ไม่ error และขอความหน้าจอ Android ไม่ขึ้น กดรอบสอง ข้อความขึ้นแล้วเด้งไป Error

แต่ก็ยังส่งได้ปกติ

ต้องขอบคุนสำหรับคำแนะนำของท่านจริงๆครับ ตอนนี้ผมสามารถแก้ปัญหานี้ได้แล้วตามคำแนะนำของท่าน
เอะใจตรงที่ท่านบอกว่า " handler object ตัวนี้เป็น Class ที่จะป้องกันภาวะ Racing (หลาย Thread แย่งกันใช้ resource)"

รูปตัวโปรแกรมที่ ใช้งานได้แล้ววว ^^

ที่มันมีปํญหาตอนแรกที่ผมเปลี่ยนมาใช้ Runnable เพราะผมเอา สองส่วนนี้ มาร่วมไว้ใน Runnable เดี่ยวกัน มันเลยเด้งฟ้องทุกครั้งที่ผมกด Send

//ส่วนแรก

mainText.append(msg+"\n"); // Show MSG on Mainboard

//ส่วนสอง

if(msg.equals("Server is Shutting Down"))

{

userText.setEnabled(true);

disconnectBtn.setEnabled(false);

connectBtn.setEnabled(true);

mainText.setText("");

serverText.setText("Server is Shutting Down .. .");

break;

}

ผมเลยลองแยกมันออกมาใหม่ ให้มันอยู่คนล่ะ Runnable ปรากฏว่าใช้ได้
ผมเลยเปลี่ยน TextView เป้น Listview มันจะได้ดูง่ายๆหน่อย

Class สำหรับอ่าน Buffer จาก Server ที่แก้ใหม่ครับ เผื่อใครจะใช้เป้นแนวทาง ..

public class ClientThread implements Runnable {

    Socket socket = null;
    String msg;
    BufferedReader br;
    ClientThread(Socket r)
    {
        socket=r;
    }
    public void run() {
        try {
            BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            while ((msg = in.readLine()) != null) {
                Log.d("Server msg: ", msg);

                if(msg.equals("Server is Shutting Down"))
                {
                    handler.post(new Runnable() {
                        @Override
                        public void run() {
                            userText.setEnabled(true);
                            disconnectBtn.setEnabled(false);
                            connectBtn.setEnabled(true);
                            receivedMessages.add("Server is Shutting Down..");
                        }
                    });

                }else{
                    handler.post(new Runnable() {
                        @Override
                        public void run() {
                            // Show Message in ListView
                            receivedMessages.add(msg);
                        }
                    });
                }
            }
            in.close();
            socket.close(); 

        } catch (Exception e) {
            handler.post(new Runnable() {
                @Override
                public void run() {
                    serverText.setText("Oops. Connection interrupted. Please reconnect your phones.");
                }
            });
            e.printStackTrace();
        }
    }
}

ขอบคุนมากๆครับ