Android - Socket 編程(WIFI 和 ADB)

昨天正式開始 Android 編程學習與實踐，由於 Android 模擬器在 WinXP 下一直未安裝成功(見帖子: http://www.cnblogs.com/91program/p/5190888.html)，所在將閑置很久的 Android 手機: 聯想 A750 找到用於調試。
A750 是 Android 版本是: 2.3.6，在手機 上打開 USB 調試功能后，就可以通過 USB 線與 PC 連接進行調試了。
調試的主要功能是 Socket 通訊，手機做為服務器端。先用 PC 做為客戶端。后期的客戶端是車機，車機的系統可能是 WinCE 或 Android。
開始之前，先了解了一下 Android 編程的基本知識(后附個人學習記錄的知識點)，然后學習了如下鏈接:http://www.cnblogs.com/lknlfy/archive/2012/03/04/2379628.html 關於 Socket 編程的知識。

其中 一個關鍵的知識點是線程與主進程之間的消息傳遞機制，主要是線程中的消息傳遞到主進程。例如：

mHandler.sendMessage(msg); 

手機端代碼如下(XML就不提供了，很簡單，大家看圖就知識的)：
/*
 * 通過  WIFI 網絡進行 Socket 通訊成功, 手機的 IP: 172.25.103.4(隨個人網絡環境變化)
 * 測試使用 360 隨身 WIFI, PC 機的 IP: 172.25.103.1
 * */

package com.jia.leozhengfirstapp;


import java.io.IOException;
import java.io.InputStream;
import java.io.UnsupportedEncodingException;
import java.net.ServerSocket;
import java.net.Socket;


import android.support.v7.app.ActionBarActivity;
import android.annotation.SuppressLint;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.util.Log;
import android.view.Menu;
import android.view.MenuItem;
import android.widget.TextView;
import android.widget.Toast;




public class MainActivity extends ActionBarActivity {


    private Socket clientSocket = null;
    private ServerSocket mServerSocket = null;


    private Handler mHandler = null;


    private AcceptThread mAcceptThread = null;
    private ReceiveThread mReceiveThread = null;
    private boolean stop = true;

    private TextView ipText;
    private TextView rcvText;
    private TextView ConnectStatusText;

    @SuppressLint("HandlerLeak")
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        ipText = (TextView)findViewById(R.id.textView1);
        rcvText = (TextView)findViewById(R.id.textView3);
        ConnectStatusText = (TextView)findViewById(R.id.textView4);

        ConnectStatusText.setText("連接狀態: 未連接");

        // 消息處理
        mHandler = new Handler()
        {
            @Override
            public void handleMessage(Message msg)
            {
                switch(msg.what)
                {
                    case 0:
                    {
                        String strAddress = (msg.obj).toString();
                        ipText.setText("IP地址: " + strAddress);
                        Log.v("Leo: IP: ", strAddress);
                        ConnectStatusText.setText("連接狀態: 已連接");
                        // 顯示客戶端IP
                        // ipTextView.setText((msg.obj).toString());
                        // 使能發送按鈕
                        // sendButton.setEnabled(true);
                        break;
                    }
                    case 1:
                    {
                        String strRcv = (msg.obj).toString();
                        rcvText.setText("接收到數據: " + strRcv);
                        Log.v("Leo: Rcv: ", strRcv);
                        // 顯示接收到的數據
                        // mTextView.setText((msg.obj).toString());
                        break;
                    }
                }

            }
        };

        mAcceptThread = new AcceptThread();
        // 開啟監聽線程
        mAcceptThread.start();
    }




    @Override
    public boolean onCreateOptionsMenu(Menu menu) {
        // Inflate the menu; this adds items to the action bar if it is present.
        getMenuInflater().inflate(R.menu.main, menu);
        return true;
    }


    @Override
    public boolean onOptionsItemSelected(MenuItem item) {
        // Handle action bar item clicks here. The action bar will
        // automatically handle clicks on the Home/Up button, so long
        // as you specify a parent activity in AndroidManifest.xml.
        int id = item.getItemId();
        if (id == R.id.action_settings) {
            return true;
        }
        return super.onOptionsItemSelected(item);
    }

    // 顯示Toast函數
    private void displayToast(String s)
    {
        Toast.makeText(this, s, Toast.LENGTH_SHORT).show();
    }

    private class AcceptThread extends Thread
    {
        @Override
        public void run()
        {
            try {
                // 實例化ServerSocket對象並設置端口號為 12589
                mServerSocket = new ServerSocket(12589);
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }

            try {
                // 等待客戶端的連接（阻塞）
                clientSocket = mServerSocket.accept();
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }

            mReceiveThread = new ReceiveThread(clientSocket);
            stop = false;
            // 開啟接收線程
            mReceiveThread.start();

            Message msg = new Message();
            msg.what = 0;
            // 獲取客戶端IP
            msg.obj = clientSocket.getInetAddress().getHostAddress();
            // 發送消息
            mHandler.sendMessage(msg);
        }
    }




    private class ReceiveThread extends Thread
    {
        private InputStream mInputStream = null;
        private byte[] buf;
        private String str = null;

        ReceiveThread(Socket s)
        {
            try {
                // 獲得輸入流
                this.mInputStream = s.getInputStream();
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }

        @Override
        public void run()
        {
            while(!stop)
            {
                this.buf = new byte[512];

                // 讀取輸入的數據(阻塞讀)
                try {
                    this.mInputStream.read(buf);
                } catch (IOException e1) {
                    // TODO Auto-generated catch block
                    e1.printStackTrace();
                }

                // 字符編碼轉換
                try {
                    this.str = new String(this.buf, "GB2312").trim();
                } catch (UnsupportedEncodingException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }

                Message msg = new Message();
                msg.what = 1;
                msg.obj = this.str;
                // 發送消息
                mHandler.sendMessage(msg);
            }
        }
    }
}

1) 先通過 WIFI 進行 Socket 通訊
運行后，在手機上顯示的未連接界面如下圖:

在 PC 上運行類似於 SocketTool.exe 的工具，SocketTool.exe 的顯示界面如下：

Socket 連接后，手機上顯示的界面如下圖：

2) 通過 USB 實現 PC 與手機的通訊
在 PC 上實現一個 Java 小應用，應用的主要代碼如下：

try
{
    Runtime.getRuntime().exec("adb forward tcp:12581 tcp:12589");
}
catch (IOException e)
{
    e.printStackTrace();
}


Socket socket = null;
try
{
    InetAddress serverAddr = null;
    OutputStream outStream = null;
    byte[] msgBuffer = null;

    serverAddr = InetAddress.getByName("127.0.0.1");
    System.out.println("TCP 1" + "C: Connecting...");


    socket = new Socket(serverAddr, 12581); // 12581 是 PC 的端口，已重定向到 Device 的 12589 端口

    String message = "PC ADB,send message";
    msgBuffer = message.getBytes("GB2312");

    outStream = socket.getOutputStream();
    outStream.write(msgBuffer);
    Thread.sleep(10000);
}
catch (UnknownHostException e1)
{
    System.out.println("TCP 2" + "ERROR: " + e1.toString());
}
catch (IOException e2)
{
    System.out.println("TCP 3" + "ERROR: " + e2.toString());
} catch (InterruptedException e3)
{
    // Thread.sleep(1000); 增加的異常處理
    e3.printStackTrace();
}
finally
{
    try
    {
        if (socket != null)
        {
            socket.close();     // 關閉時會導致接收到的數據被清空,所以延時 10 秒顯示
        }
    }
    catch (IOException e)
    {
        System.out.println("TCP 4" + "ERROR: " + e.toString());
    }
}

運行后，在手機上顯示的界面如下圖: