前言

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

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

Android中給我們提供了另外一個(gè)機(jī)制：LocalSocket

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

那么它怎么使用？

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

服務(wù)端初始化

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

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

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

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

客戶端初始化

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

首先創(chuàng)建一個(gè)LocalSocket對(duì)象

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

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

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

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

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

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

因?yàn)閟ocket是雙向的，所以兩端都可以進(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ù)是主動(dòng)動(dòng)作，每次發(fā)送都需要另開線程，所以如果是多次，我們需要使用一個(gè)線程池來進(jìn)行管理

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

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

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

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

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

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

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

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

比如定義一個(gè)簡(jiǎn)單的協(xié)議：傳輸?shù)臄?shù)據(jù)分兩部分，第一部分是一個(gè)int值，表示后面byte數(shù)據(jù)的長(zhǎng)度；第二部分就是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 > 0) {
 var buffer = ByteArray(length)
 input.read(buffer)
            ...
        }
    }
}
Thread(runnable).start()

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

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

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

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

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

無法讀取到所有數(shù)據(jù)，只能讀到一部分。而且會(huì)造成后面數(shù)據(jù)的混亂，因?yàn)樽x取位置錯(cuò)位了。

讀取的長(zhǎng)度大約是65535個(gè)字節(jié)，這是因?yàn)門CP被IP包包著，也會(huì)有包大小限制65535。

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

那么這種超大數(shù)據(jù)該如何傳輸呢，我們用循環(huán)將其一點(diǎn)點(diǎn)寫入，也一點(diǎn)點(diǎ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) <= 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 > 0) {
 var buffer = ByteArray(1024)
 var total = 0
            while (total + 1024 <= 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()

這樣可以避免因?yàn)榉职鴮?dǎo)致讀取的長(zhǎng)度不匹配的問題

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

最新評(píng)論