Android進程間大數據通信LocalSocket怎么創建

這篇文章主要介紹“Android進程間大數據通信LocalSocket怎么創建”，在日常操作中，相信很多人在Android進程間大數據通信LocalSocket怎么創建問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對大家解答”Android進程間大數據通信LocalSocket怎么創建”的疑惑有所幫助！接下來，請跟著小編一起來學習吧！

服務端初始化

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

先創建一個LocalServerSocket服務，參數是服務名，注意這個服務名需要唯一，這是兩端連接的依據。

然后調用accept函數進行等待客戶端連接，這個函數是block線程的，所以例子中另起線程。

當客戶端發起連接后，accept就會返回LocalSocket對象，然后就可以進行傳輸數據了。

客戶端初始化

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

首先創建一個LocalSocket對象

然后創建一個LocalSocketAddress對象，參數是服務名

然后調用connect函數連接到該服務即可。就可以使用這個socket傳輸數據了。

數據傳輸

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

通過localSocket.inputStream和localSocket.outputStream可以獲取到輸入輸出流，通過對流的讀寫進行數據傳輸。

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

因為socket是雙向的，所以兩端都可以進行收發，即讀寫

發送數據

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)

發送數據是主動動作，每次發送都需要另開線程，所以如果是多次，我們需要使用一個線程池來進行管理

如果需要多次發送數據，可以將其進行封裝成一個函數

接收數據

接收數據實際上是進行while循環，循環進行讀取數據，這個最好在連接成功后就開始，比如客戶端

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

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

傳輸復雜數據

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

首先需要定義一套協議。

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

寫數據

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)

讀數據

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()

這樣就可以傳輸復雜數據，不會導致數據錯亂。

傳輸超大數據

上面雖然可以傳輸復雜數據，但是當我們的數據過大的時候，也會出現問題。

比如傳輸圖片或視頻，假設byte數據長度達到1228800，這時我們通過

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

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

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

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

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

寫入

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進程間大數據通信LocalSocket怎么創建”的學習就結束了，希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習，快去試試吧！若想繼續學習更多相關知識，請繼續關注億速云網站，小編會繼續努力為大家帶來更多實用的文章！