Android進程間大數(shù)據(jù)通信LocalSocket詳解
前言
說起Android進行間通信，大家第一時間會想到AIDL，但是由于Binder機制的限制，AIDL無法傳輸超大數(shù)據(jù)。
那么我們?nèi)绾卧谶M程間傳輸大數(shù)據(jù)呢？
Android中給我們提供了另外一個機制：LocalSocket
它會在本地創(chuàng)建一個socket通道來進行數(shù)據(jù)傳輸。
那么它怎么使用？
首先我們需要兩個應用：客戶端和服務端
服務端初始化
override fun run() {
server = LocalServerSocket("xxxx")
remoteSocket = server?.accept()
...
}
先創(chuàng)建一個LocalServerSocket服務，參數(shù)是服務名，注意這個服務名需要唯一，這是兩端連接的依據(jù)。
然后調(diào)用accept函數(shù)進行等待客戶端連接，這個函數(shù)是block線程的，所以例子中另起線程。
當客戶端發(fā)起連接后，accept就會返回LocalSocket對象，然后就可以進行傳輸數(shù)據(jù)了。
客戶端初始化
var localSocket = LocalSocket()
localSocket.connect(LocalSocketAddress("xxxx"))
首先創(chuàng)建一個LocalSocket對象
然后創(chuàng)建一個LocalSocketAddress對象，參數(shù)是服務名
然后調(diào)用connect函數(shù)連接到該服務即可。就可以使用這個socket傳輸數(shù)據(jù)了。
數(shù)據(jù)傳輸
兩端的socket對象是一個類，所以兩端的發(fā)送和接受代碼邏輯一致。
通過localSocket.inputStream和localSocket.outputStream可以獲取到輸入輸出流，通過對流的讀寫進行數(shù)據(jù)傳輸。
注意，讀寫流的時候一定要新開線程處理。
因為socket是雙向的，所以兩端都可以進行收發(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ā)送都需要另開線程，所以如果是多次，我們需要使用一個線程池來進行管理
如果需要多次發(fā)送數(shù)據(jù)，可以將其進行封裝成一個函數(shù)
接收數(shù)據(jù)
接收數(shù)據(jù)實際上是進行while循環(huán)，循環(huá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)不停的進行讀取，未讀到數(shù)據(jù)就繼續(xù)循環(huán)，讀到數(shù)據(jù)就進行處理再循環(huán)，所以這里只另開一個線程即可，不需要線程池。
傳輸復雜數(shù)據(jù)
上面只是簡單事例，無法傳輸復雜數(shù)據(jù)，如果要傳輸復雜數(shù)據(jù)，就需要使用DataInputStream和DataOutputStream。
首先需要定義一套協(xié)議。
比如定義一個簡單的協(xié)議：傳輸?shù)臄?shù)據(jù)分兩部分，第一部分是一個int值，表示后面byte數(shù)據(jù)的長度；第二部分就是byte數(shù)據(jù)。這樣就知道如何進行讀寫
寫數(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()
這樣就可以傳輸復雜數(shù)據(jù)，不會導致數(shù)據(jù)錯亂。
傳輸超大數(shù)據(jù)
上面雖然可以傳輸復雜數(shù)據(jù)，但是當我們的數(shù)據(jù)過大的時候，也會出現(xiàn)問題。
比如傳輸圖片或視頻，假設(shè)byte數(shù)據(jù)長度達到1228800，這時我們通過
var buffer = ByteArray(1228800) input.read(buffer)
無法讀取到所有數(shù)據(jù)，只能讀到一部分。而且會造成后面數(shù)據(jù)的混亂，因為讀取位置錯位了。
讀取的長度大約是65535個字節(jié)，這是因為TCP被IP包包著，也會有包大小限制65535。
但是注意！寫數(shù)據(jù)的時候如果數(shù)據(jù)過大就會自動進行分包，但是讀數(shù)據(jù)的時候如果一次讀取貌似無法跨包，這樣就導致了上面的結(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) <= 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()
這樣可以避免因為分包而導致讀取的長度不匹配的問題
以上就是Android進程間大數(shù)據(jù)通信LocalSocket詳解的詳細內(nèi)容，更多關(guān)于Android LocalSocket的資料請關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
Flutter學習LogUtil封裝與實現(xiàn)實例詳解
這篇文章主要為大家介紹了Flutter學習LogUtil封裝與實現(xiàn)實例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2022-09-09
Android性能調(diào)優(yōu)利器StrictMode應用分析
StrictMode意思為嚴格模式，是用來檢測程序中違例情況的開發(fā)者工具。最常用的場景就是檢測主線程中本地磁盤和網(wǎng)絡(luò)讀寫等耗時的操作。這篇文章給大家介紹Android性能調(diào)優(yōu)利器StrictMode應用分析，感興趣的朋友一起看看吧2018-01-01
這篇文章主要給大家介紹了關(guān)于Android時間設(shè)置的3個小彩蛋,文中通過實例代碼介紹的非常詳細,對各位Android開發(fā)者們具有一定的參考學習價值,需要的朋友可以參考下2023-03-03
Android模擬實現(xiàn)華為系統(tǒng)升級進度條
這篇文章主要介紹了如何通過Android模擬實現(xiàn)華為在系統(tǒng)升級時顯示的進度條。文中的實現(xiàn)過程講解詳細，感興趣的小伙伴可以動手試一試2022-01-01
Android 提供了一套完整的 API，允許應用程序自由地發(fā)送和接收廣播。發(fā)送廣播需要借助之前學習的 Intent，而接收廣播的方法則需要引入一個新的概念 —— BroadcasterReceiver2021-10-10
本文主要介紹Android 登錄界面實現(xiàn)，這里主要講解類似Twitter的登錄界面的實現(xiàn)，有興趣的小伙伴可以參考下2016-08-08
Android控件之CheckBox、RadioButton用法實例分析
這篇文章主要介紹了Android控件之CheckBox、RadioButton用法,以實例形式較為詳細的分析了CheckBox和RadioButton實現(xiàn)復選按鈕及單選按鈕功能的相關(guān)技巧,具有一定參考借鑒價值,需要的朋友可以參考下2015-09-09
這篇文章給大家簡單介紹了Android中視圖動畫的基本屬性以及使用示例，對大家的學習有一定的參考價值，有需要的朋友們下面來一起看看吧。2016-09-09
RecyclerView使用payload實現(xiàn)局部刷新
這篇文章主要為大家詳細介紹了RecyclerView使用payload實現(xiàn)局部刷新，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2021-10-10
這篇文章主要為大家詳細介紹了android實現(xiàn)簡單拍照功能，具有一定的參考價值，感興趣的小伙伴們可以參考一下2018-06-06