详谈Android进程间的大数据通信机制:LocalSocket

这篇具有很好参考价值的文章主要介绍了详谈Android进程间的大数据通信机制:LocalSocket。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

详谈Android进程间的大数据通信机制:LocalSocket

前言

说起Android进行间通信,大家第一时间会想到AIDL,但是由于Binder机制的限制,AIDL无法传输超大数据。

比如我们在之前文章《WebRtc中是如何处理视频数据的?》提到的我们可以得到WebRtc的视频数据,这时候我们如果有一个需求,希望将这些视频数据传送给另外一个APP呢?这个数据量就会很大。

那么我们如何在进程间传输大数据呢?

Android中给我们提供了另外一个机制:LocalSocket

它会在本地创建一个socket通道来进行数据传输。

那么它怎么使用?

首先我们需要两个应用:客户端和服务端

初始化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.inputStreamlocalSocket.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循环不停的进行读取,未读到数据就继续循环,读到数据就进行处理再循环,所以这里只另开一个线程即可,不需要线程池。

传输复杂数据

上面只是简单事例,无法传输复杂数据,如果要传输复杂数据,就需要使用DataInputStreamDataOutputStream

首先需要定义一套协议。

比如定义一个简单的协议:传输的数据分两部分,第一部分是一个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()

先读取一个int,这是接下来数据块的大小,然后直接读取一个这个长度的数据,这样就会把这部分数据完整读取出来。这样当读取下一部份数据的时候正好是开头。

这样就可以传输复杂数据,不会导致数据错乱。

传输超大数据

上面虽然可以传输复杂数据,但是当我们的数据过大的时候,也会出现问题。

比如传输图片或视频,假设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)

同样先写入数据大小,然后循环写入1024大小的数据,记录偏移,最后不足的部分一次性写入即可。

超大数据读取

上面的数据读取代码如下:

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

同样先读取一个int,即数据大小。然后循环读取1024大小的数据,直到不足的时候将剩余部分一起读取出来即可。这样这部分数据就完整读取出来了,然后读取下一部分数据正好在开头。

这样可以避免因为分包而导致读取的长度不匹配的问题

总结

LocalSocket是基于Linux底层IPC通信机制(UNIX-domain socket)的,因此相对于网络通信使用的socket不需要经过网络协议栈,不需要打包拆包、计算校验。所以LocalSocket的效率是很高的。

网上有人进行过测试,结果如下:
详谈Android进程间的大数据通信机制:LocalSocket
可以看到LocalSocket的传输接近AIDL,所以还是非常高效的。文章来源地址https://www.toymoban.com/news/detail-427722.html

到了这里,关于详谈Android进程间的大数据通信机制:LocalSocket的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 【Linux之进程间通信】04.Linux进程间的信号通信

      【Linux之进程间通信】 项目代码获取: https://gitee.com/chenshao777/linux-processes.git (麻烦点个免费的Star哦,您的Star就是我的写作动力!) 04.Linux进程间的信号通信 【目录】   一、进程间信号发送方式   二、进程间信号接收方式   三、进程间信号处理方式 一、进程间信号发

    2024年02月06日
    浏览(40)
  • 一统天下 flutter - 插件: flutter 使用 android 原生控件,并做数据通信

    源码 https://github.com/webabcd/flutter_demo 作者 webabcd 示例如下: libpluginplugin2.dart androidappsrcmainkotlincomexampleflutter_demoMainActivity.kt androidappsrcmainkotlincomexampleflutter_demoMyFlutterPlugin2.kt androidappsrcmainkotlincomexampleflutter_demoMyView.kt androidappsrcmainreslayoutview_my.xml 源码 http

    2024年02月03日
    浏览(50)
  • Linux--进程间的通信-共享内存

    前文: Linux–进程间的通信-匿名管道 Linux–进程间的通信–进程池 Linux–进程间的通信-命名管道 对于两个进程,通过在内存开辟一块空间(操作系统开辟的),进程的虚拟地址通过页表映射到对应的共享内存空间中,进而实现通信 ; 特点和作用: 高效性: 共享内存是一种

    2024年04月26日
    浏览(38)
  • Linux--进程间的通信-匿名管道

    进程间通信(IPC,Interprocess Communication)是指在不同进程之间传输数据和交换信息的一种机制。它允许多个进程在同一操作系统中同时运行,并实现彼此之间的协作 。 进程间通信方式: 管道(Pipe) : 管道是最基本的进程间通信方式 ,它是一种 半双工 的通信方式,通过管

    2024年04月14日
    浏览(40)
  • 【Linux】进程间的通信之共享内存

    利用 内存共享 进行进程间的通信的原理其实分为以下几个步骤: 在物理内存中创建一块共享内存。 将共享内存链接到要通信的进程的页表中,并通过页表进行进程地址空间的映射。 进程地址空间映射完毕以后返回首个虚拟地址,以便于进程之间进行通信。 根据共享内存的

    2024年02月09日
    浏览(45)
  • Linux下的系统编程——进程间的通信(九)

    前言:  前面我们已经对进程已经有了一个简单的了解与认识,那么进程间的通信是什么样的呢,什么是父子进程,什么是兄弟进程,没有血缘关系间的进程是如何实现进程通信的,下面让我们一起学习一下什么是进程间的通信吧。 目录 一、进程间通信常用方式 IPC方式:

    2024年02月09日
    浏览(32)
  • Android中线程间的通信-Handler

    Handler机制在Android中主要用于线程间的通信,特别是处理从子线程向主线程(UI线程)传递消息和更新界面。 Message : Message  是在线程间传递的数据载体,它包含了需要处理的数据和一些额外的信息。 每个  Message  对象可以携带一个  what  值(整数类型),用于标识消息的

    2024年02月03日
    浏览(33)
  • 数据通信网络基础

    • 在人类社会的起源和发展过程中,通信就一直伴随着我们。从20世纪七、八十年代开始, 人类社会已进入到信息时代,对于生活在信息时代的我们,通信的必要性更是不言而喻 的。 • 本节课所说的通信,是指借助数据通信网络进行连接的通信。本课程主要介绍通信及数

    2024年02月04日
    浏览(45)
  • 数据通信——VRRP

    引言 之前把实验做了,结果发现我好像没有写过VRRP的文章,连笔记都没记过。可能是因为对STP的记忆,导致现在都没忘太多。     VRRP全名是虚拟路由冗余协议,虚拟路由,看名字就知道这是运行在三层接口上面的设备。因此无论是三层交换机、路由器还是防火墙上面,都可

    2024年02月13日
    浏览(34)
  • 计算机网络-数据通信基础知识(数据通信模型 相关术语 单工/半双工/全双工 串行/并行 同步/异步 码元 数据传输速率 带宽)

    广域网中有模拟信道,模拟信道能传模拟信号,不能传数字信号 数据从计算机网卡中以数字信号发出,经过调制解调器转换为模拟信号以放到广域网上的模拟信道传输,再由调制解调器转换为数字信号,数字信号经过计算机的转换才将数据展现出来 发送端的调制解调器:发

    2024年01月25日
    浏览(54)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包