- ThreeThread

最新配信
RSS
RDF
ATOM

Blog -

カテゴリ :: Android » Tips

執筆 :: NickQ 2011-8-11 16:15

これで、その４ですがやっと接続後の処理への理解になります。

前回までに接続の確立まで行いましたが

個人的に注意点として

・接続した後に、有効範囲からどちらかが居なくなる。

・どちらかの電源が切れる。

いつ切れるか解らない処理も考えながら作らないと実用的にはならない。

まだまだ、先は長いですが今回は、接続以降にどの様な処理があるか理解します。いつもの様に、Threadで実現します。宣言部

private class ConnectedThread extends Thread {
    private final BluetoothSocket mmSocket;
    private final InputStream mmInStream;
    private final OutputStream mmOutStream;
	//中略
}

中で使うメンバーを定義します、見た事がある奴も居ます。コンストラクタですが、BluetoothSocketからStreamを取得します。

以降、Streamとして処理が出来ます。

    public ConnectedThread(BluetoothSocket socket) {
        mmSocket = socket;
        InputStream tmpIn = null;
        OutputStream tmpOut = null;
 
        // Get the input and output streams, using temp objects because
        // member streams are final
        try {
            tmpIn = socket.getInputStream();
            tmpOut = socket.getOutputStream();
        } catch (IOException e) { }
 
        mmInStream = tmpIn;
        mmOutStream = tmpOut;
    }

次にrun()メソッドが実行されます。

先に、Handlerについてですが、ThreadからUIに対して処理が行えません

これは非同期処理中に直接ThreadからUIへ更新を掛ける為です。考えれば非同期処理からUIを触りたい処理ばかりなのですが、やり方があります。

それは、Handlerを使う方法です。Handlerは送られてきたメッセージを受け取り、処理します非同期処理から非同期にHandlerに渡して

HandlerはそれをUIへ更新します。（正確には、postかmessageを使ってBundleなどとやり取りをするみたいです）

他に非同期処理はAsynctaskなどもあります。今回は、HandlerのMessageを利用してUIとのやり取りを行っています。

（他にも方法はありますがobtainMessageでにやり取りの効率が良いらしいです）

	mHandler.obtainMessage(MESSAGE_READ, bytes, -1, buffer).sendToTarget();

対象のメソッドと引数は obtainMessage(int what, int arg1, int arg2, Object obj) ・MESSAGE_READは、Handlerで受け取った時に

どの処理に対してか識別します。・int bytesは第一引数・bufferは、InputStream（送られて来たデータ）

これを受け取って、UIへHandlerがMessageオブジェクトとして渡しています。と話を戻しますが。

	bytes = mmInStream.read(buffer);

のメソッドでストリームからデータが送られて来るまで待機します。

送られて来たら、UIへHandlerがMessageオブジェクトとして渡しています。

    public void run() {
        byte[] buffer = new byte[1024];  // buffer store for the stream
        int bytes; // bytes returned from read()
 
        // Keep listening to the InputStream until an exception occurs
        while (true) {
            try {
                // Read from the InputStream
                bytes = mmInStream.read(buffer);
                // Send the obtained bytes to the UI Activity
                mHandler.obtainMessage(MESSAGE_READ, bytes, -1, buffer)
                        .sendToTarget();
            } catch (IOException e) {
                break;
            }
        }
    }

また、こちらからデータを書き込む場合の処理を準備します。これは、メインの処理から呼ばれます。

    /* Call this from the main Activity to send data to the remote device */
    public void write(byte[] bytes) {
        try {
            mmOutStream.write(bytes);
        } catch (IOException e) { }
    }

キャンセル時の処理を準備しておきます。

     /* Call this from the main Activity to shutdown the connection */
    public void cancel() {
        try {
            mmSocket.close();
        } catch (IOException e) { }
    }

今回までで、接続からデータの受信（正確にはサーバ側でデータ書き込みは解説してませんが）まで理解出来たかと思います。

もう少し深く理解して、後の処理も考えたいと思っています。

※GoogleDevelopers チュートリアルを使用しています。