首页 文章 精选 留言 我的

精选列表

搜索[实时通信],共10006篇文章
优秀的个人博客,低调大师

Android线程间通信之handler

本文来一起讨论下Android的handler机制。 相信写过android的童鞋,一定对handler很熟悉。因为使用频率实在太高了。尤其是在非ui线程,想要刷新ui控件的时候。因为ui控件的刷新只能在主线程做,但是我们可能有在非ui线程却需要更新ui的需求,比如在一个后台线程下载了图片需要更新到ui上,这时候就需要主线程handler来发送更新的message。 handler的使用如此频繁,我们有必要知道其内部是如何工作的。 一句话概括 handler thread handler 发送什么 触发的线程 创建handler runnable的封装 如何处理消息 message 如何产生消息 发送时机 Looper 创建looper 派发消息 例子 总结 一句话概括 handler, looper, message的组合,能够做什么工作?简单地说,就一句话:在一个线程里,指定在另一个线程里,执行一个任务。 handler thread 什么是handler thread。当一个线程,创建了looper,looper里面拥有message queue,创建了handler,那么,这个线程就是一个handler thread。 handler thread的作用就是,让其他的线程指定handler thread去执行一个任务。比如ui线程就是一个handler thread。我们可以在普通线程中,指定让ui线程去更新ui。 handler handler有两个工作,一是发送任务或者消息;二是处理消息或者执行任务。 发送什么 handler可以发送什么 handler和message queue密切联系,直觉上handler会发送消息到message queue。其实不仅如此,handler既能发送message,也能发送runnbale。换句话说,message queue不只是装message的queue(其实是一个单链表),而且还能装runnable。 触发的线程 handler发送消息或者任务,一般是在其他线程发送的,即发送消息时所在的线程,并不是创建handler的线程(当然,也可以在创建handler的线程发消息,等于自己发给自己)。 而handler处理消息或执行任务,则是在创建自己的线程中执行的。 创建handler handler和looper并不是ui线程独有的。任何一个普通的线程,都可以创建自己的looper,创建自己的handler。 但是有一点需要注意,创建handler前,必须先创建looper。 如果不创建looper,直接new一个handler,比如 newThread(newRunnable(){ publicvoidrun(){ Handlerhandler=newHandler(); } }).start(); 运行时,会直接报错: Can’tcreatehandlerinsidethreadthathasnotcalledLooper.prepare() 来看看handler的构造函数 publicHandler(Callbackcallback,booleanasync){ ... mLooper=Looper.myLooper();//Looper.myLooper用于获取当前线程的looper if(mLooper==null){ thrownewRuntimeException( "Can'tcreatehandlerinsidethreadthathasnotcalledLooper.prepare()"); } mQueue=mLooper.mQueue; ... } handler发送消息到message queue,所以,构造一个handler的时候必须知道message queue,才能确定把消息发送到哪里。 而message queue是由looper来管理的,因此顺序上,必须先创建了looper,才能创建handler。 创建线程的Looper, Looper.prepare(); 所以,创建一个handler的正确写法是: newThread(newRunnable(){ publicvoidrun(){ Looper.prepare(); Handlerhandler=newHandler(); } }).start(); 可能有同学会觉得奇怪,平时用new Handler() 的时候没有先调用Looper.prepare()也一样可以用呀?那是因为,handler是在主线程创建的。 //ActivityThread.java publicstaticvoidmain(String[]args){ ... Looper.prepareMainLooper(); ... } 主线程在启动的时候,就会调用Looper.prepareMainLooper() 创建looper,所以,我们可以在主线程直接创建handler,不需要手动先创建looper。 runnable的封装 可能大家会觉得奇怪,message queue应该装的是message,那么handler.post(runnable),runnable跑哪里去了呢? runnable其实也是发送给了message queue,只不过在发送前,先对runnable进行了封装。 publicfinalbooleanpost(Runnabler){ returnsendMessageDelayed(getPostMessage(r),0); } privatestaticMessagegetPostMessage(Runnabler){ Messagem=Message.obtain(); m.callback=r; returnm; } 用getPostMessage 把runnable包装成一个message,message的callback就是runnable。因此,分辨一个message是不是runnable,其实只要看message的callback是否为空,如果为空,就是普通的message,否则,就是一个runnbale。 如何处理消息 看下dispathMessage publicvoiddispatchMessage(Messagemsg){ if(msg.callback!=null){ handleCallback(msg);//handler.post(runnable)时走这里 }else{ if(mCallback!=null){//handler=newHandler(callback)时走这里 if(mCallback.handleMessage(msg)){ return; } } handleMessage(msg);//handler=newHandler()时走这里 } } 根据handler发送消息的类型,分成2种情况: handler发送了一个message到message queue handler发送了一个runnbale到message queue 根据前面提到的,message.callback其实就是对runnable的封装,所以,如果handler是发送了一个runnable到message queue,那么就会执行这个runnable。 如果handler是发送了一个message到message queue,那么又细分为2种情况 handler创建时设置了callback, 即handler = new Handler(callback); handler创建时未设置callback,即handler = new Handler(); 如果设置了callback,那么message会先被callback处理。 如果callback返回true,说明处理完成,不会再传给handler.handleMessage了。 如果callback返回false,说明处理未完成,会再把message传给handler.handleMessage继续处理。 如果未设置callback,message会直接传给handler.handleMessage处理。 message 如何产生消息 消息如何产生 message可以由构造函数生成。更多的时候,是从可回收的消息对象池里面直接获取的,提供性能。从消息对象池获取一个消息的方式是Message.obtain(),也可以用Handler.obtainMessage()。 另外,不产生消息,也可以发送消息。好绕口,啥意思?handler.sendEmptyMessage(),可以发送一个空消息到message queue,不需要构造一个message对象。 发送时机 消息什么时候发送 消息的处理时机还是由handler来决定(感觉handler管的好宽==)。 handler.sendMessage,把message放到message queue的尾部排队,looper从前往后一个一个取消息。handler.sendMessageAtFrontOfQueue,把message放到message queue的头部,消息可以马上被处理。 handler.sendMessageAtTime,不马上发送消息到message queue,而是在指定的时间点发送。 handler.sendMessageDelayed,不马上发送消息到message queue,而是在指定的时延后再发送。 Looper 创建looper 前面提到,looper就像一个发送机一样,会从message queue中取出消息,然后派发给handler处理。因此,要知道message应该发送到哪个handler,必须先创建looper。 创建looper的方法 Loop.prepare(); 派发消息 通过looper.loop(),looper会不断从message queue取消息,并派发出去。 looper怎么知道message应该派发给哪一个handler呢? 一起看看loop方法 publicstaticvoidloop(){ ... for(;;){ Messagemsg=queue.next();//mightblock if(msg==null){ //Nomessageindicatesthatthemessagequeueisquitting. return; } ... msg.target.dispatchMessage(msg); ... } } 每个msg都有一个target属性,这个target就是发送消息的handler,派发message,就是派发给msg.target对象。 loop方法并不是无限循环的,一旦message queue为空,就会结束,以免长期占用cpu资源。 例子 下图中,线程A是一个handler thread。现在线程B想让线程A处理一个消息message 5。于是,线程B拿到线程A的handler引用,然后调用handler的sendMessage。 message 5被发送到线程A的message queue。 线程A怎么去处理这个消息呢?使用looper.loop方法,每次会从message queue取出一条消息,当取到message 5,说明message 5即将被处理。 真正的消息处理逻辑,是在handler的handleMessage里面自定义的(或者runnable,callback,这里以handleMessage为例)。 looper取到message 5,通过message 5的target属性,知道目标handler,然后把消息发送给handler进行处理。 总结 handler不是独立存在的,一个handler,一定有一个专属的线程,一个消息队列,和一个looper与之关联。 这几个角色是如何协同工作的呢?简单概括为下面四个步骤: handler发送消息到message queue,这个消息可能是一个message,可能是一个runnable looper负责从message queue取消息 looper把消息dispatch给handler handler处理消息(handleMessage或者执行runnable) handler和looper的关系有点类似于生产者和消费者的关系,handler是生产者,生产消息然后添加到message queue;looper是消费者,从message queue取消息。 本文作者:佚名 来源:51CTO

优秀的个人博客,低调大师

SonoBus —— 实时音频推流

SonoBus是一个免费的、优雅的、多平台的、开源的点对点传输解决方案, 用于在互联网或本地网络上的设备之间流媒体高质量、低延迟的对等音频。 SonoBus 是一个易于使用的应用程序,但提供的功能强大: 能够连接到多个用户 创建一个有可选密码的小组 分享来自你的麦克风的音频输入 分享来自文件的音频流 支持单声道/立体声 组内播放 录制所有人的音频 能够使个别用户或所有人都静音 可以通过互联网或本地网络连接 支持节拍器,用于协作制作音乐或远程练习课程 支持高质量的音频,最高可达 256Kbps 输入混音器 支持声相 支持有用的效果器(噪声门、压缩器和均衡器) 可在 JACK 和 ALSA 下工作 跨平台支持(Windows、macOS、Android、iOS 和 Linux)

优秀的个人博客,低调大师

实时同步工具之rsync

1.1什么是rsync软件 rsync软件是开源的、快速的、多功能的、可实现全量及增量的本地或远程数据同步备份的优秀工具,并且可以不进行改变原有数据的属性信息,实现数据的备份迁移特性。 Rsync软件食用与uinx/linux/windows等多种操作系统平台 1.2概念 全量复制:一次性复制 增量复制:只把增加的复制过去(别人家没有的东西复制过去) 1.3 使用场景 1.yum总源和分源之前的同步 2.批量小文件的同步 3.增量同步(nginx配置目录config.d等) 1.4Rsync的特性如下(7个特性信息说明): 01.支持拷贝普通文件与特殊文件如链接文件,设备等。 02.可以有排除指定文件或目录同步的功能,相当于打包命令tar的排除功能。 tarzcvfbackup_1.tar.gz/opt/data-exclude=oldboy 说明:在打包/opt/data时就排除了oldboy命名的目录和文件。 03.可以做到保持原文件或目录的权限、时间(访问时间修改时间创建时间)、软硬链接、属主、组等所有属性均不改变-p。 04.可实现增量同步,既只同步发生变化的数据,因此数据传输效率很高(tar-N)。 将备份/home目录自2008-01-29以来修改过的文件 tar-N2008-01-29-zcvf/backups/inc-backup_$(date+%F).tar.gz/home 将备份/home目录昨天以来修改过的文件 tar-N$(date-dyesterday"+%F")-zcvf/backups/inc-backup_$(date+%F).tar.gz/home 添加文件到已经打包的文件 tar-rfall.tar*.gif 说明:这条命令是将所有.gif的文件增加到all.tar的包里面去。-r是表示增加文件的意思。 05.可以使用rcp,rsh,ssh等方式来配合进行隧道加密传输文件(rsync本身不对数据加密) 06.可以通过socket(进程方式)传输文件和数据(服务端和客户端)*****。重点掌握 07.支持匿名的或认证(无需系统用户)的进程模式传输,可实现方便安全的进行数据备份及镜像 1.5三种同步方式详解 1.5.1本地同步方式 例子:rsync/etc/hosts/tmp 1.5.2通过shell方式,隧道模式 1.5.2.1put:推送 例子:rsync-rp/etc/hostsroot@172.16.1.31:/tmp 1.5.2.2get:拉取 例子:rsync-rproot@172.16.1.31/etc/hosts/opt 1.5.3 守护进程,密码认证 拉格式:rsync-avzrsync_backup@172.16.1.41::backup/文件到哪里 推格式:rsync-avz/etcrsync_backup@172.16.1.41::backup +++--password-file=/etc/rsync.password免密码 参数扩展

资源下载

更多资源
Mario

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长,特征是大鼻子、头戴帽子、身穿背带裤,还留着胡子。与他的双胞胎兄弟路易基一起,长年担任任天堂的招牌角色。

腾讯云软件源

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题,腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构,目前腾讯云软件源站支持公网访问和内网访问。

Nacos

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称,一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集,帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Sublime Text

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能,例如代码缩略图,Python的插件,代码段等。还可自定义键绑定,菜单和工具栏。Sublime Text 的主要功能包括:拼写检查,书签,完整的 Python API , Goto 功能,即时项目切换,多选择,多窗口等等。Sublime Text 是一个跨平台的编辑器,同时支持Windows、Linux、Mac OS X等操作系统。

用户登录
用户注册