Android進(jìn)程間大數(shù)據(jù)通信LocalSocket怎么創(chuàng)建

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

服務(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)度不匹配的問題

到此，關(guān)于“Android進(jìn)程間大數(shù)據(jù)通信LocalSocket怎么創(chuàng)建”的學(xué)習(xí)就結(jié)束了，希望能夠解決大家的疑惑。理論與實(shí)踐的搭配能更好的幫助大家學(xué)習(xí)，快去試試吧！若想繼續(xù)學(xué)習(xí)更多相關(guān)知識(shí)，請(qǐng)繼續(xù)關(guān)注億速云網(wǎng)站，小編會(huì)繼續(xù)努力為大家?guī)砀鄬?shí)用的文章！