Android進程間大數(shù)據(jù)通信LocalSocket詳解
前言
說起Android進行間通信，大家第一時間會想到AIDL，但是由于Binder機制的限制，AIDL無法傳輸超大數(shù)據(jù)。
那么我們如何在進程間傳輸大數(shù)據(jù)呢？
Android中給我們提供了另外一個機制：LocalSocket
它會在本地創(chuàng)建一個socket通道來進行數(shù)據(jù)傳輸。
那么它怎么使用？
首先我們需要兩個應用：客戶端和服務端
服務端初始化
override fun run() {
server = LocalServerSocket("xxxx")
remoteSocket = server?.accept()
...
}
先創(chuàng)建一個LocalServerSocket服務，參數(shù)是服務名，注意這個服務名需要唯一，這是兩端連接的依據(jù)。
然后調用accept函數(shù)進行等待客戶端連接，這個函數(shù)是block線程的，所以例子中另起線程。
當客戶端發(fā)起連接后，accept就會返回LocalSocket對象，然后就可以進行傳輸數(shù)據(jù)了。
客戶端初始化
var localSocket = LocalSocket()
localSocket.connect(LocalSocketAddress("xxxx"))
首先創(chuàng)建一個LocalSocket對象
然后創(chuàng)建一個LocalSocketAddress對象，參數(shù)是服務名
然后調用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)問題。
比如傳輸圖片或視頻，假設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ù)的時候如果一次讀取貌似無法跨包，這樣就導致了上面的結果，只能讀一個包，后面的就錯亂了。
那么這種超大數(shù)據(jù)該如何傳輸呢，我們用循環(huán)將其一點點寫入，也一點點讀出，并根據(jù)結果不斷的修正偏移。代碼：
寫入
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詳解的詳細內容，更多關于Android LocalSocket的資料請關注腳本之家其它相關文章！
相關文章
這篇文章主要幫助大家輕松實現(xiàn)Android鎖屏功能,具有一定的參考價值，感興趣的小伙伴們可以參考一下2016-11-11
今天小編就為大家分享一篇Android ndk獲取手機內部存儲卡的根目錄方法，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2018-08-08
這篇文章主要介紹了Android 清除工程中沒用到的資源詳解的相關資料,這里舉例說明如何實現(xiàn)，需要的朋友可以參考下2016-11-11
詳解Flutter中StatefulBuilder組件的使用
StatefulBuilder小部件可以在這些區(qū)域的狀態(tài)發(fā)生變化時僅重建某些小區(qū)域而無需付出太多努力。本文將來詳細講講它的使用，需要的可以參考一下2022-05-05
本文主要介紹AndroidStudio 如何使用aar的資料，這里整理了詳細的資料，幫助大家學習理解此部分的知識，有需要的小伙伴可以參考下2016-09-09
這篇文章主要為大家詳細介紹了android實現(xiàn)記事本app的相關代碼 ，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-12-12
Android開發(fā)中WebView的詳細使用方法和常見操作
這篇文章詳細介紹了Android中WebView組件的使用方法和常見操作,包括基本初始化、啟用JavaScript、處理頁面導航、與JavaScript交互、加載本地HTML內容、文件上傳與下載、進度條與加載指示、處理網(wǎng)頁錯誤以及安全性設置,需要的朋友可以參考下2024-11-11
Android開發(fā)實現(xiàn)廣告無限循環(huán)功能示例
這篇文章主要介紹了Android開發(fā)實現(xiàn)廣告無限循環(huán)功能,結合完整實例形式分析了Android廣告圖片輪播功能的具體實現(xiàn)步驟與相關功能、布局等操作技巧,需要的朋友可以參考下2017-11-11
這篇文章主要介紹了Android 靜默安裝實現(xiàn)方法的相關資料,靜默安裝的方法，靜默安裝就是繞過安裝程序時的提示窗口，直接在后臺安裝，需要的朋友可以參考下2017-04-04
工作中遇到了一個需求，讓應用中的一個列表按照分類顯示，并且能提示當前是在哪個分類，度娘了一番，參考了前輩們的博客后實現(xiàn)了，現(xiàn)在分享給大家，有需要的可以參考借鑒。2016-09-09