Android进程间大数据通信LocalSocket详解
前言
说起Android进行间通信，大家第一时间会想到AIDL，但是由于Binder机制的限制，AIDL无法传输超大数据。
那么我们如何在进程间传输大数据呢？
Android中给我们提供了另外一个机制：LocalSocket
它会在本地创建一个socket通道来进行数据传输。
那么它怎么使用？
首先我们需要两个应用：客户端和服务端
服务端初始化
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详解的详细内容，更多关于Android LocalSocket的资料请关注脚本之家其它相关文章！
相关文章
这篇文章主要为大家介绍了Flutter学习LogUtil封装与实现实例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2022-09-09
StrictMode意思为严格模式，是用来检测程序中违例情况的开发者工具。最常用的场景就是检测主线程中本地磁盘和网络读写等耗时的操作。这篇文章给大家介绍Android性能调优利器StrictMode应用分析，感兴趣的朋友一起看看吧2018-01-01
这篇文章主要给大家介绍了关于Android时间设置的3个小彩蛋,文中通过实例代码介绍的非常详细,对各位Android开发者们具有一定的参考学习价值,需要的朋友可以参考下2023-03-03
这篇文章主要介绍了如何通过Android模拟实现华为在系统升级时显示的进度条。文中的实现过程讲解详细，感兴趣的小伙伴可以动手试一试2022-01-01
Android 提供了一套完整的 API，允许应用程序自由地发送和接收广播。发送广播需要借助之前学习的 Intent，而接收广播的方法则需要引入一个新的概念 —— BroadcasterReceiver2021-10-10
本文主要介绍Android 登录界面实现，这里主要讲解类似Twitter的登录界面的实现，有兴趣的小伙伴可以参考下2016-08-08
Android控件之CheckBox、RadioButton用法实例分析
这篇文章主要介绍了Android控件之CheckBox、RadioButton用法,以实例形式较为详细的分析了CheckBox和RadioButton实现复选按钮及单选按钮功能的相关技巧,具有一定参考借鉴价值,需要的朋友可以参考下2015-09-09
这篇文章给大家简单介绍了Android中视图动画的基本属性以及使用示例，对大家的学习有一定的参考价值，有需要的朋友们下面来一起看看吧。2016-09-09
这篇文章主要为大家详细介绍了RecyclerView使用payload实现局部刷新，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2021-10-10
这篇文章主要为大家详细介绍了android实现简单拍照功能，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2018-06-06
最新评论