Android进程间大数据通信LocalSocket详解

更新时间：2023年03月28日 11:15:35 作者：BennuCTech

这篇文章主要为大家介绍了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 &gt; 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) &lt;= 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 &gt; 0) {
 var buffer = ByteArray(1024)
 var total = 0
            while (total + 1024 &lt;= 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的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

轻松实现Android锁屏功能
这篇文章主要帮助大家轻松实现Android锁屏功能,具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2016-11-11
Android ndk获取手机内部存储卡的根目录方法
今天小编就为大家分享一篇Android ndk获取手机内部存储卡的根目录方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2018-08-08
Android APP瘦身（清除工程中没用到的资源）详解
这篇文章主要介绍了Android 清除工程中没用到的资源详解的相关资料,这里举例说明如何实现，需要的朋友可以参考下
2016-11-11
详解Flutter中StatefulBuilder组件的使用
StatefulBuilder小部件可以在这些区域的状态发生变化时仅重建某些小区域而无需付出太多努力。本文将来详细讲讲它的使用，需要的可以参考一下
2022-05-05
AndroidStudio 如何使用aar详解
本文主要介绍AndroidStudio 如何使用aar的资料，这里整理了详细的资料，帮助大家学习理解此部分的知识，有需要的小伙伴可以参考下
2016-09-09
android实现记事本app
这篇文章主要为大家详细介绍了android实现记事本app的相关代码，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2017-12-12
Android开发中WebView的详细使用方法和常见操作
这篇文章详细介绍了Android中WebView组件的使用方法和常见操作,包括基本初始化、启用JavaScript、处理页面导航、与JavaScript交互、加载本地HTML内容、文件上传与下载、进度条与加载指示、处理网页错误以及安全性设置,需要的朋友可以参考下
2024-11-11
Android开发实现广告无限循环功能示例
这篇文章主要介绍了Android开发实现广告无限循环功能,结合完整实例形式分析了Android广告图片轮播功能的具体实现步骤与相关功能、布局等操作技巧,需要的朋友可以参考下
2017-11-11
Android 静默安装实现方法
这篇文章主要介绍了Android 静默安装实现方法的相关资料,静默安装的方法，静默安装就是绕过安装程序时的提示窗口，直接在后台安装，需要的朋友可以参考下
2017-04-04
Android实现qq列表式的分类悬浮提示
工作中遇到了一个需求，让应用中的一个列表按照分类显示，并且能提示当前是在哪个分类，度娘了一番，参考了前辈们的博客后实现了，现在分享给大家，有需要的可以参考借鉴。
2016-09-09