Android中socket初体验

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    android:orientation="vertical" >
    
    <EditText
        android:id="@+id/content"
        android:layout_width="match_parent"
        android:layout_height="wrap_content"
        android:hint="@string/et_hint" />

    <Button
        android:id="@+id/send"
        android:layout_width="match_parent"
        android:layout_height="wrap_content"
        android:text="@string/txt_send" />
    
       <TextView
        android:id="@+id/tv"
        android:layout_width="match_parent"
        android:layout_height="wrap_content" />
</LinearLayout>

package testDemo;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class Server implements Runnable {
    public static void main(String[] args) {
        Thread desktopServerThread = new Thread(new Server());
        desktopServerThread.start();
    }

    @Override
    public void run() {
        try {
            ServerSocket serverSocket = new ServerSocket(8888);
            while (true) {
                
                // 阻塞，等待接收客户请求。
                Socket client = serverSocket.accept();
                System.out.println("接受到客户端的请求。");
                try {
                    BufferedReader in = new BufferedReader(
                            new InputStreamReader(client.getInputStream()));
                    // 读取客户端发过来的信息
                    String read = in.readLine();
                    System.out.println("客户端发送消息为 : " + read);

                    // 向客户端返回信息
                    PrintWriter out = new PrintWriter(new BufferedWriter(
                            new OutputStreamWriter(client.getOutputStream())));
                    if (read != null) {
                        out.println("你发送给服务器的信息为 : " + read);
                        out.flush();
                    }    

                    out.close();
                    in.close();

                } catch (Exception e) {
                    e.printStackTrace();
                } finally {
                    client.close();
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }

    }

}

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;

import android.app.Activity;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.view.View;
import android.view.View.OnClickListener;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;

public class ClientActivity extends Activity {

    private Button send = null;
    private EditText content = null;
    private TextView tv = null;
    String msg = null;
    
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.socket2);
        
        send = (Button)findViewById(R.id.send);
        content = (EditText)findViewById(R.id.content);
        tv = (TextView)findViewById(R.id.tv);
        
        send.setOnClickListener(new OnClickListener(){

            @Override
            public void onClick(View v) {
                setTitle("socket");
                new Thread(thread1).start();
            }
            
        });
    }
    
    /*Handler myHandler = new Handler() {
        
        @Override
        public void handleMessage(Message msg) {
            myHandler.post(thread1);
        }
    };*/
    
    /**
     * 该线程主要是向服务器发送消息和接收消息
     */
    Runnable thread1 = new Runnable() {

        @Override
        public void run() {
            Socket socket = null;
            try {
                InetAddress serverAddr = InetAddress.getByName("192.168.1.110");
                
                socket = new Socket(serverAddr, 8888);
                //想服务器发送消息
                PrintWriter out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())));
                out.println(content.getText().toString());
                out.flush();
                
                //读取服务器返回的消息
                BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                msg = in.readLine();
                //把该子线程当做参数传递，这样在主UI线程就可更新UI
                ClientActivity.this.runOnUiThread(updateThread);
                
            } catch (UnknownHostException e) {
                e.printStackTrace();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        
    };
    
    Runnable updateThread = new Runnable() {

        @Override
        public void run() {
            if (msg != null) {
                tv.setText(msg);
            } else {
                tv.setText("data error.");
            }
        }
        
    };

}