Android进程间大数据通信:LocalSocket

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

作者: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.总结

Android进程间大数据通信:LocalSocket

Binder 原理:
1.学习Binder前必须要了解的知识点
2.ServiceManager中的Binder机制
3.系统服务的注册过程
4.ServiceManager的启动过程
5.系统服务的获取过程
6.Java Binder的初始化
7.Java Binder中系统服务的注册过程

Android进程间大数据通信:LocalSocket

Zygote :

  1. Android系统的启动过程及Zygote的启动过程
  2. 应用进程的启动过程

Android进程间大数据通信:LocalSocket

AMS源码分析 :

  1. Activity生命周期管理
  2. onActivityResult执行过程
  3. AMS中Activity栈管理详解

Android进程间大数据通信:LocalSocket

深入PMS源码:

1.PMS的启动过程和执行流程
2.APK的安装和卸载源码分析
3.PMS中intent-filter的匹配架构

Android进程间大数据通信:LocalSocket

WMS:
1.WMS的诞生
2.WMS的重要成员和Window的添加过程
3.Window的删除过程

Android进程间大数据通信:LocalSocket

《Android Framework学习手册》:https://qr18.cn/AQpN4J

  1. 开机Init 进程
  2. 开机启动 Zygote 进程
  3. 开机启动 SystemServer 进程
  4. Binder 驱动
  5. AMS 的启动过程
  6. PMS 的启动过程
  7. Launcher 的启动过程
  8. Android 四大组件
  9. Android 系统服务 - Input 事件的分发过程
  10. Android 底层渲染 - 屏幕刷新机制源码分析
  11. Android 源码分析实战

Android进程间大数据通信:LocalSocket文章来源地址https://www.toymoban.com/news/detail-410599.html

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

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

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

相关文章

  • 数据通信——VRRP

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

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

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

    2024年01月25日
    浏览(54)
  • HCIA数据通信——路由协议

    数据通信——网络层(OSPF基础特性)_咕噜跳的博客-CSDN博客 数据通信——网络层(RIP与BGP)_咕噜跳的博客-CSDN博客   上述是之前写的理论知识部分,懒得在实验中再次提及了。这次做RIP协议以及OSPF协议。不过RIP协议不常用了,现在IS-IS的使用要比OSPF好。   环回口(Loopbac

    2024年02月06日
    浏览(38)
  • 数据通信——传输层(UDP)

    我们上网观看比赛的时候,一旦网络信号出现问题,那可就太难受了,这意味着卡顿的时间内,你会错过这段时间内的内容。这种特性要归功于UDP(User Datagram Protocol)用户数据报协议。     一般的,数据在通过应用层后会到达传输层,如果传输层使用UDP作为封装手段,那么

    2024年02月11日
    浏览(32)
  • 计算机网络-数据通信基础

      目录 前言 一、数据通信基本概念 二、数据通信相关知识1 总结 正在学习计算机网络体系,把每日所学的知识梳理出来,既能够当作读书笔记,又能分享出来和大家一同学习讨论。 基本概念:信源、信道、信宿;数字信号、模拟信号;模拟通信、数字通信(信道中传送)。

    2024年02月19日
    浏览(40)
  • TCP发送数据、接受数据及TCP通信程序练习

    目录 一、TCP发送数据 二、TCP接收数据 三、TCP通信程序练习 Java中的TCP通信: Java对于基于TCP协议的网络提供了良好的封装,使用Socket对象来代表两端的通信端口,并通过Socket产生IO流来进行网络通信 Java为客户端提供了Socket类,为服务端提供了ServerSocket类 构造方法: 方法名

    2023年04月09日
    浏览(38)
  • 串口通信-发送和接收数据

    目录 通信方式 硬件电路 软件部分 USART外设(同步/异步收发器) 波特率 引脚复用 初始化基本流程 发送 接收 语言简述 常用的函数 使用的结构体 引脚模式 打印数据的三种方法 使用printf 在实际的串口中,只能发送二进制数,也就是十六进制的最直接数据。如果想发送字符,

    2024年02月12日
    浏览(57)
  • 物联网数据通信:优化和安全化

    物联网(Internet of Things, IoT)是一种通过互联网连接和交换数据的物体,这些物体可以是传统的物理设备(如传感器、仪表、车辆等),也可以是数字设备(如智能手机、平板电脑、电视机等)。物联网技术的发展为各行业带来了巨大的创新和效益,但同时也面临着挑战。这篇文章将

    2024年04月24日
    浏览(25)
  • TCP服务器—实现数据通信

    目录 前言 1.接口介绍 2.编写服务器 3.编写客户端 4.编译链接 5.测试 6.总结         今天我们要介绍的是使用TCP协议实现数据通信,相比于之前写的UDP服务器实现数据信,在主体逻辑上并没有差别。客户端向服务器发送信息,服务器接受信息并回显,因为UDP是面向数据报,而

    2024年02月12日
    浏览(35)
  • 工业智能网关如何保障数据通信安全

    工业智能网关是组成工业物联网的重要设备,不仅可以起到数据交换、通信、边缘计算的功能,还可以发挥数据安全保障功能,保障工业物联网稳定、可持续。本篇就为大家简单介绍一下工业智能网关增强和确保数据通信安全的几种措施: 以佰马工业智能网关为例,网关支持

    2024年01月20日
    浏览(50)

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

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

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

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

二维码1

领取红包

二维码2

领红包