作者:BennuCTech
前言
说起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()
这样可以避免因为分包而导致读取的长度不匹配的问题
想要了解更多Framework底层知识点的小伙伴可以参考一下,我在学习过程中,查阅和收集了一堆的参考学习文档,比如有Handler、Binder、AMS、WMS、PMS、事件分发机制、UI绘制……等等,为了便于自己查阅,将其知识点整合在一起并命名为了《Android Framework 核心学习手册》:https://qr18.cn/AQpN4J
《Framework 核心知识点汇总手册》:https://qr18.cn/AQpN4J
Handler 机制实现原理部分:
1.宏观理论分析与Message源码分析
2.MessageQueue的源码分析
3.Looper的源码分析
4.handler的源码分析
5.总结
Binder 原理:
1.学习Binder前必须要了解的知识点
2.ServiceManager中的Binder机制
3.系统服务的注册过程
4.ServiceManager的启动过程
5.系统服务的获取过程
6.Java Binder的初始化
7.Java Binder中系统服务的注册过程
Zygote :
- Android系统的启动过程及Zygote的启动过程
- 应用进程的启动过程
AMS源码分析 :
- Activity生命周期管理
- onActivityResult执行过程
- AMS中Activity栈管理详解
深入PMS源码:
1.PMS的启动过程和执行流程
2.APK的安装和卸载源码分析
3.PMS中intent-filter的匹配架构
WMS:
1.WMS的诞生
2.WMS的重要成员和Window的添加过程
3.Window的删除过程
文章来源:https://www.toymoban.com/news/detail-410599.html
《Android Framework学习手册》:https://qr18.cn/AQpN4J
- 开机Init 进程
- 开机启动 Zygote 进程
- 开机启动 SystemServer 进程
- Binder 驱动
- AMS 的启动过程
- PMS 的启动过程
- Launcher 的启动过程
- Android 四大组件
- Android 系统服务 - Input 事件的分发过程
- Android 底层渲染 - 屏幕刷新机制源码分析
- Android 源码分析实战
文章来源地址https://www.toymoban.com/news/detail-410599.html
到了这里,关于Android进程间大数据通信:LocalSocket的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!