腳本之家服務(wù)器常用軟件

快捷導(dǎo)航

Android進(jìn)程間大數(shù)據(jù)通信LocalSocket詳解

更新時間：2023年03月28日 11:15:35 作者：BennuCTech

這篇文章主要為大家介紹了Android進(jìn)程間大數(shù)據(jù)通信LocalSocket詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

前言

說起Android進(jìn)行間通信，大家第一時間會想到AIDL，但是由于Binder機制的限制，AIDL無法傳輸超大數(shù)據(jù)。

那么我們?nèi)绾卧谶M(jìn)程間傳輸大數(shù)據(jù)呢？

Android中給我們提供了另外一個機制：LocalSocket

它會在本地創(chuàng)建一個socket通道來進(jìn)行數(shù)據(jù)傳輸。

那么它怎么使用？

首先我們需要兩個應(yīng)用：客戶端和服務(wù)端

服務(wù)端初始化

override fun run() {
    server = LocalServerSocket("xxxx")
    remoteSocket = server?.accept()
    ...
}

先創(chuàng)建一個LocalServerSocket服務(wù)，參數(shù)是服務(wù)名，注意這個服務(wù)名需要唯一，這是兩端連接的依據(jù)。

然后調(diào)用accept函數(shù)進(jìn)行等待客戶端連接，這個函數(shù)是block線程的，所以例子中另起線程。

當(dāng)客戶端發(fā)起連接后，accept就會返回LocalSocket對象，然后就可以進(jìn)行傳輸數(shù)據(jù)了。

客戶端初始化

var localSocket = LocalSocket()
localSocket.connect(LocalSocketAddress("xxxx"))

首先創(chuàng)建一個LocalSocket對象

然后創(chuàng)建一個LocalSocketAddress對象，參數(shù)是服務(wù)名

然后調(diào)用connect函數(shù)連接到該服務(wù)即可。就可以使用這個socket傳輸數(shù)據(jù)了。

數(shù)據(jù)傳輸

兩端的socket對象是一個類，所以兩端的發(fā)送和接受代碼邏輯一致。

通過localSocket.inputStream和localSocket.outputStream可以獲取到輸入輸出流，通過對流的讀寫進(jìn)行數(shù)據(jù)傳輸。

注意，讀寫流的時候一定要新開線程處理。

因為socket是雙向的，所以兩端都可以進(jìn)行收發(fā)，即讀寫

發(fā)送數(shù)據(jù)

var pool = Executors.newSingleThreadExecutor()
var runnable = Runnable {
 try {
 var out = xxxxSocket.outputStream
 out.write(data)
 out.flush()
    } catch (e: Throwable) {
        Log.e("xxx", "xxx", e)
    }
}
pool.execute(runnable)

發(fā)送數(shù)據(jù)是主動動作，每次發(fā)送都需要另開線程，所以如果是多次，我們需要使用一個線程池來進(jìn)行管理

如果需要多次發(fā)送數(shù)據(jù)，可以將其進(jìn)行封裝成一個函數(shù)

接收數(shù)據(jù)

接收數(shù)據(jù)實際上是進(jìn)行while循環(huán)，循環(huán)進(jìn)行讀取數(shù)據(jù)，這個最好在連接成功后就開始，比如客戶端

localSocket.connect(LocalSocketAddress("xxx"))
var runnable = Runnable {
    while (localSocket.isConnected){
var input = localSocket.inputStream
input.read(data)
        ...
    }
}
Thread(runnable).start()

接收數(shù)據(jù)實際上是一個while循環(huán)不停的進(jìn)行讀取，未讀到數(shù)據(jù)就繼續(xù)循環(huán)，讀到數(shù)據(jù)就進(jìn)行處理再循環(huán)，所以這里只另開一個線程即可，不需要線程池。

傳輸復(fù)雜數(shù)據(jù)

上面只是簡單事例，無法傳輸復(fù)雜數(shù)據(jù)，如果要傳輸復(fù)雜數(shù)據(jù)，就需要使用DataInputStream和DataOutputStream。

首先需要定義一套協(xié)議。

比如定義一個簡單的協(xié)議：傳輸?shù)臄?shù)據(jù)分兩部分，第一部分是一個int值，表示后面byte數(shù)據(jù)的長度；第二部分就是byte數(shù)據(jù)。這樣就知道如何進(jìn)行讀寫

寫數(shù)據(jù)

var pool = Executors.newSingleThreadExecutor()
var out = DataOutputStream(xxxSocket.outputStream)
var runnable = Runnable {
 try {
 out.writeInt(data.size)
 out.write(data)
 out.flush()
    } catch (e: Throwable) {
        Log.e("xxx", "xxx", e)
    }
}
pool.execute(runnable)

讀數(shù)據(jù)

var runnable = Runnable {
 var input = DataInputStream(xxxSocket.inputStream)
 var outArray = ByteArrayOutputStream()
    while (true) {
        outArray.reset()
 var length = input.readInt()
 if(length &gt; 0) {
 var buffer = ByteArray(length)
 input.read(buffer)
            ...
        }
    }
}
Thread(runnable).start()

這樣就可以傳輸復(fù)雜數(shù)據(jù)，不會導(dǎo)致數(shù)據(jù)錯亂。

傳輸超大數(shù)據(jù)

上面雖然可以傳輸復(fù)雜數(shù)據(jù)，但是當(dāng)我們的數(shù)據(jù)過大的時候，也會出現(xiàn)問題。

比如傳輸圖片或視頻，假設(shè)byte數(shù)據(jù)長度達(dá)到1228800，這時我們通過

var buffer = ByteArray(1228800)
input.read(buffer)

無法讀取到所有數(shù)據(jù)，只能讀到一部分。而且會造成后面數(shù)據(jù)的混亂，因為讀取位置錯位了。

讀取的長度大約是65535個字節(jié)，這是因為TCP被IP包包著，也會有包大小限制65535。

但是注意！寫數(shù)據(jù)的時候如果數(shù)據(jù)過大就會自動進(jìn)行分包，但是讀數(shù)據(jù)的時候如果一次讀取貌似無法跨包，這樣就導(dǎo)致了上面的結(jié)果，只能讀一個包，后面的就錯亂了。

那么這種超大數(shù)據(jù)該如何傳輸呢，我們用循環(huán)將其一點點寫入，也一點點讀出，并根據(jù)結(jié)果不斷的修正偏移。代碼：

寫入

var pool = Executors.newSingleThreadExecutor()
var out = DataOutputStream(xxxSocket.outputStream)
var runnable = Runnable {
 try {
 out.writeInt(data.size)
 var offset = 0
 while ((offset + 1024) &lt;= data.size) {
 out.write(data, offset, 1024)
            offset += 1024
        }
 out.write(data, offset, data.size - offset)
 out.flush()
    } catch (e: Throwable) {
        Log.e("xxxx", "xxxx", e)
    }
}
pool.execute(runnable)

讀取

var input = DataInputStream(xxxSocket.inputStream)
var runnable = Runnable {
 var outArray = ByteArrayOutputStream()
    while (true) {
        outArray.reset()
 var length = input.readInt()
 if(length &gt; 0) {
 var buffer = ByteArray(1024)
 var total = 0
            while (total + 1024 &lt;= length) {
 var count = input.read(buffer)
                outArray.write(buffer, 0, count)
                total += count
            }
 var buffer2 = ByteArray(length - total)
 input.read(buffer2)
            outArray.write(buffer2)
 var result = outArray.toByteArray()
            ...
        }
    }
}
Thread(runnable).start()

這樣可以避免因為分包而導(dǎo)致讀取的長度不匹配的問題

以上就是Android進(jìn)程間大數(shù)據(jù)通信LocalSocket詳解的詳細(xì)內(nèi)容，更多關(guān)于Android LocalSocket的資料請關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: