字节跳动一面:请谈下Android消息机制

一、消息机制概述

1.消息机制的简介

在Android中使用消息机制,我们首先想到的就是Handler。没错,Handler是Android消息机制的上层接口。Handler的使用过程很简单,通过它可以轻松地将一个任务切换到Handler所在的线程中去执行。通常情况下,Handler的使用场景就是更新UI。
如下就是使用消息机制的一个简单实例:

public class Activity extends android.app.Activity {private Handler mHandler = new Handler(){@Overridepublic void handleMessage(Message msg) {super.handleMessage(msg);System.out.println(msg.what);}};@Overridepublic void onCreate(Bundle savedInstanceState, PersistableBundle persistentState) {super.onCreate(savedInstanceState, persistentState);setContentView(R.layout.activity_main);new Thread(new Runnable() {@Overridepublic void run() {...............耗时操作Message message = Message.obtain();message.what = 1;mHandler.sendMessage(message);}}).start();}
}

在子线程中,进行耗时操作,执行完操作后,发送消息,通知主线程更新UI。这便是消息机制的典型应用场景。我们通常只会接触到Handler和Message来完成消息机制,其实内部还有两大助手来共同完成消息传递。

2.消息机制的模型

消息机制主要包含:MessageQueue,Handler和Looper这三大部分,以及Message,下面我们一一介绍。

**Message:**需要传递的消息,可以传递数据;

**MessageQueue:**消息队列,但是它的内部实现并不是用的队列,实际上是通过一个单链表的数据结构来维护消息列表,因为单链表在插入和删除上比较有优势。主要功能向消息池投递消息(MessageQueue.enqueueMessage)和取走消息池的消息(MessageQueue.next);

**Handler:**消息辅助类,主要功能向消息池发送各种消息事件(Handler.sendMessage)和处理相应消息事件(Handler.handleMessage);

**Looper:**不断循环执行(Looper.loop),从MessageQueue中读取消息,按分发机制将消息分发给目标处理者。

3.消息机制的架构

**消息机制的运行流程:**在子线程执行完耗时操作,当Handler发送消息时,将会调用MessageQueue.enqueueMessage,向消息队列中添加消息。当通过Looper.loop开启循环后,会不断地从线程池中读取消息,即调用MessageQueue.next,然后调用目标Handler(即发送该消息的Handler)的dispatchMessage方法传递消息,然后返回到Handler所在线程,目标Handler收到消息,调用handleMessage方法,接收消息,处理消息。

**MessageQueue,Handler和Looper三者之间的关系:**每个线程中只能存在一个Looper,Looper是保存在ThreadLocal中的。主线程(UI线程)已经创建了一个Looper,所以在主线程中不需要再创建Looper,但是在其他线程中需要创建Looper。每个线程中可以有多个Handler,即一个Looper可以处理来自多个Handler的消息。 Looper中维护一个MessageQueue,来维护消息队列,消息队列中的Message可以来自不同的Handler。

下面是消息机制的整体架构图,接下来我们将慢慢解剖整个架构。

从中我们可以看出:
Looper有一个MessageQueue消息队列;
MessageQueue有一组待处理的Message;
Message中记录发送和处理消息的Handler;
Handler中有Looper和MessageQueue。

二、消息机制的源码解析

1.Looper

要想使用消息机制,首先要创建一个Looper。
初始化Looper
无参情况下,默认调用prepare(true);表示的是这个Looper可以退出,而对于false的情况则表示当前Looper不可以退出。。

 public static void prepare() {prepare(true);}private static void prepare(boolean quitAllowed) {if (sThreadLocal.get() != null) {throw new RuntimeException("Only one Looper may be created per thread");}sThreadLocal.set(new Looper(quitAllowed));}

这里看出,不能重复创建Looper,只能创建一个。创建Looper,并保存在ThreadLocal。其中ThreadLocal是线程本地存储区(Thread Local Storage,简称为TLS),每个线程都有自己的私有的本地存储区域,不同线程之间彼此不能访问对方的TLS区域。
开启Looper

public static void loop() {final Looper me = myLooper();  //获取TLS存储的Looper对象 if (me == null) {throw new RuntimeException("No Looper; Looper.prepare() wasn't called on this thread.");}final MessageQueue queue = me.mQueue;  //获取Looper对象中的消息队列Binder.clearCallingIdentity();final long ident = Binder.clearCallingIdentity();for (;;) { //进入loop的主循环方法Message msg = queue.next(); //可能会阻塞,因为next()方法可能会无限循环if (msg == null) { //消息为空,则退出循环return;}Printer logging = me.mLogging;  //默认为null,可通过setMessageLogging()方法来指定输出,用于debug功能if (logging != null) {logging.println(">>>>> Dispatching to " + msg.target + " " +msg.callback + ": " + msg.what);}msg.target.dispatchMessage(msg); //获取msg的目标Handler,然后用于分发Message if (logging != null) {logging.println("<<<<< Finished to " + msg.target + " " + msg.callback);}final long newIdent = Binder.clearCallingIdentity();if (ident != newIdent) {}msg.recycleUnchecked(); }
}

loop()进入循环模式,不断重复下面的操作,直到消息为空时退出循环:
读取MessageQueue的下一条Message(关于next(),后面详细介绍);
把Message分发给相应的target。

当next()取出下一条消息时,队列中已经没有消息时,next()会无限循环,产生阻塞。等待MessageQueue中加入消息,然后重新唤醒。

主线程中不需要自己创建Looper,这是由于在程序启动的时候,系统已经帮我们自动调用了Looper.prepare()方法。查看ActivityThread中的main()方法,代码如下所示:

  public static void main(String[] args) {
..........................Looper.prepareMainLooper();..........................Looper.loop();..........................}

其中``prepareMainLooper()方法会调用prepare(false)`方法。

2.Handler

创建Handler

public Handler() {this(null, false);
}public Handler(Callback callback, boolean async) {.................................//必须先执行Looper.prepare(),才能获取Looper对象,否则为null.mLooper = Looper.myLooper();  //从当前线程的TLS中获取Looper对象if (mLooper == null) {throw new RuntimeException("");}mQueue = mLooper.mQueue; //消息队列,来自Looper对象mCallback = callback;  //回调方法mAsynchronous = async; //设置消息是否为异步处理方式
}

对于Handler的无参构造方法,默认采用当前线程TLS中的Looper对象,并且callback回调方法为null,且消息为同步处理方式。只要执行的Looper.prepare()方法,那么便可以获取有效的Looper对象。

3.发送消息

发送消息有几种方式,但是归根结底都是调用了sendMessageAtTime()方法。

在子线程中通过Handler的post()方式或send()方式发送消息,最终都是调用了sendMessageAtTime()方法。

post方法

 public final boolean post(Runnable r){return  sendMessageDelayed(getPostMessage(r), 0);}
public final boolean postAtTime(Runnable r, long uptimeMillis){return sendMessageAtTime(getPostMessage(r), uptimeMillis);}public final boolean postAtTime(Runnable r, Object token, long uptimeMillis){return sendMessageAtTime(getPostMessage(r, token), uptimeMillis);}public final boolean postDelayed(Runnable r, long delayMillis){return sendMessageDelayed(getPostMessage(r), delayMillis);}

send方法

public final boolean sendMessage(Message msg){return sendMessageDelayed(msg, 0);}public final boolean sendEmptyMessage(int what){return sendEmptyMessageDelayed(what, 0);} 
public final boolean sendEmptyMessageDelayed(int what, long delayMillis) {Message msg = Message.obtain();msg.what = what;return sendMessageDelayed(msg, delayMillis);}public final boolean sendEmptyMessageAtTime(int what, long uptimeMillis) {Message msg = Message.obtain();msg.what = what;return sendMessageAtTime(msg, uptimeMillis);}public final boolean sendMessageDelayed(Message msg, long delayMillis){if (delayMillis < 0) {delayMillis = 0;}return sendMessageAtTime(msg, SystemClock.uptimeMillis() + delayMillis);}

就连子线程中调用Activity中的runOnUiThread()中更新UI,其实也是发送消息通知主线程更新UI,最终也会调用sendMessageAtTime()方法。

 public final void runOnUiThread(Runnable action) {if (Thread.currentThread() != mUiThread) {mHandler.post(action);} else {action.run();}}

如果当前的线程不等于UI线程(主线程),就去调用Handler的post()方法,最终会调用sendMessageAtTime()方法。否则就直接调用Runnable对象的run()方法。

下面我们就来一探究竟,到底sendMessageAtTime()方法有什么作用?
sendMessageAtTime()

 public boolean sendMessageAtTime(Message msg, long uptimeMillis) {//其中mQueue是消息队列,从Looper中获取的MessageQueue queue = mQueue;if (queue == null) {RuntimeException e = new RuntimeException(this + " sendMessageAtTime() called with no mQueue");Log.w("Looper", e.getMessage(), e);return false;}//调用enqueueMessage方法return enqueueMessage(queue, msg, uptimeMillis);}
 private boolean enqueueMessage(MessageQueue queue, Message msg, long uptimeMillis) {msg.target = this;if (mAsynchronous) {msg.setAsynchronous(true);}//调用MessageQueue的enqueueMessage方法return queue.enqueueMessage(msg, uptimeMillis);}

可以看到sendMessageAtTime()`方法的作用很简单,就是调用MessageQueue的enqueueMessage()方法,往消息队列中添加一个消息。
下面来看enqueueMessage()方法的具体执行逻辑。
enqueueMessage()

boolean enqueueMessage(Message msg, long when) {// 每一个Message必须有一个targetif (msg.target == null) {throw new IllegalArgumentException("Message must have a target.");}if (msg.isInUse()) {throw new IllegalStateException(msg + " This message is already in use.");}synchronized (this) {if (mQuitting) {  //正在退出时,回收msg,加入到消息池msg.recycle();return false;}msg.markInUse();msg.when = when;Message p = mMessages;boolean needWake;if (p == null || when == 0 || when < p.when) {//p为null(代表MessageQueue没有消息) 或者msg的触发时间是队列中最早的, 则进入该该分支msg.next = p;mMessages = msg;needWake = mBlocked; } else {//将消息按时间顺序插入到MessageQueue。一般地,不需要唤醒事件队列,除非//消息队头存在barrier,并且同时Message是队列中最早的异步消息。needWake = mBlocked && p.target == null && msg.isAsynchronous();Message prev;for (;;) {prev = p;p = p.next;if (p == null || when < p.when) {break;}if (needWake && p.isAsynchronous()) {needWake = false;}}msg.next = p;prev.next = msg;}if (needWake) {nativeWake(mPtr);}}return true;
}

MessageQueue是按照Message触发时间的先后顺序排列的,队头的消息是将要最早触发的消息。当有消息需要加入消息队列时,会从队列头开始遍历,直到找到消息应该插入的合适位置,以保证所有消息的时间顺序。

4.获取消息

当发送了消息后,在MessageQueue维护了消息队列,然后在Looper中通过loop()方法,不断地获取消息。上面对loop()方法进行了介绍,其中最重要的是调用了queue.next()方法,通过该方法来提取下一条信息。下面我们来看一下next()方法的具体流程。
next()

Message next() {final long ptr = mPtr;if (ptr == 0) { //当消息循环已经退出,则直接返回return null;}int pendingIdleHandlerCount = -1; // 循环迭代的首次为-1int nextPollTimeoutMillis = 0;for (;;) {if (nextPollTimeoutMillis != 0) {Binder.flushPendingCommands();}//阻塞操作,当等待nextPollTimeoutMillis时长,或者消息队列被唤醒,都会返回nativePollOnce(ptr, nextPollTimeoutMillis);synchronized (this) {final long now = SystemClock.uptimeMillis();Message prevMsg = null;Message msg = mMessages;if (msg != null && msg.target == null) {//当消息Handler为空时,查询MessageQueue中的下一条异步消息msg,为空则退出循环。do {prevMsg = msg;msg = msg.next;} while (msg != null && !msg.isAsynchronous());}if (msg != null) {if (now < msg.when) {//当异步消息触发时间大于当前时间,则设置下一次轮询的超时时长nextPollTimeoutMillis = (int) Math.min(msg.when - now, Integer.MAX_VALUE);} else {// 获取一条消息,并返回mBlocked = false;if (prevMsg != null) {prevMsg.next = msg.next;} else {mMessages = msg.next;}msg.next = null;//设置消息的使用状态,即flags |= FLAG_IN_USEmsg.markInUse();return msg;   //成功地获取MessageQueue中的下一条即将要执行的消息}} else {//没有消息nextPollTimeoutMillis = -1;}//消息正在退出,返回nullif (mQuitting) {dispose();return null;}...............................}
}

nativePollOnce是阻塞操作,其中nextPollTimeoutMillis代表下一个消息到来前,还需要等待的时长;当nextPollTimeoutMillis = -1时,表示消息队列中无消息,会一直等待下去。
可以看出next()方法根据消息的触发时间,获取下一条需要执行的消息,队列中消息为空时,则会进行阻塞操作。

5.分发消息

在loop()方法中,获取到下一条消息后,执行msg.target.dispatchMessage(msg),来分发消息到目标Handler对象。
下面就来具体看下dispatchMessage(msg)方法的执行流程。
dispatchMessage()

public void dispatchMessage(Message msg) {if (msg.callback != null) {//当Message存在回调方法,回调msg.callback.run()方法;handleCallback(msg);} else {if (mCallback != null) {//当Handler存在Callback成员变量时,回调方法handleMessage();if (mCallback.handleMessage(msg)) {return;}}//Handler自身的回调方法handleMessage()handleMessage(msg);}
}
private static void handleCallback(Message message) {message.callback.run();}

分发消息流程:
当Message的msg.callback不为空时,则回调方法msg.callback.run();
当Handler的mCallback不为空时,则回调方法mCallback.handleMessage(msg)
最后调用Handler自身的回调方法handleMessage(),该方法默认为空,Handler子类通过覆写该方法来完成具体的逻辑。

消息分发的优先级:
Message的回调方法:message.callback.run(),优先级最高;
Handler中Callback的回调方法:Handler.mCallback.handleMessage(msg),优先级仅次于1;
Handler的默认方法:Handler.handleMessage(msg),优先级最低。

对于很多情况下,消息分发后的处理方法是第3种情况,即Handler.handleMessage(),一般地往往通过覆写该方法从而实现自己的业务逻辑。

三、总结

以上便是消息机制的原理,以及从源码角度来解析消息机制的运行过程。可以简单地用下图来理解。

学习分享

①「Android面试真题解析大全」PDF完整高清版+②「Android面试知识体系」学习思维导图压缩包——————可以我的【Github】阅读下载,最后觉得有帮助、有需要的朋友可以点个赞

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.rhkb.cn/news/42064.html

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

字节跳动核心竞争力到底是什么?

2012年创建的字节跳动&#xff0c;短短几年时间发展到估值接近千亿美元的互联网大鳄&#xff0c;拥有今日头条、抖音、西瓜视频等多个爆品app&#xff0c;除了搭上了移动互联网的春风&#xff0c;其企业自身的核心竞争力也得到了极大的体现。因此&#xff0c;对其核心竞争力进行…

张一鸣是如何练就字节跳动的

作者 | 花边科技 来源 | 花边科技&#xff08;ID&#xff1a;huabiankeji&#xff09; 张一鸣的长相很普通&#xff0c;个子不高、身材中等、戴着眼镜、一脸书生气&#xff0c;属于典型的掉在人堆里就找不到了的类型。工作中&#xff0c;他极度克制&#xff0c;几乎没有情绪波动…

一文揭密字节跳动薪资职级,资深开发居然能拿......

曾经的互联网是PC的时代&#xff0c;随着智能手机的普及&#xff0c;移动互联网开始飞速崛起。而字节跳动抓住了这波机遇&#xff0c;2015年&#xff0c;字节跳动全面加码短视频&#xff0c;从那以后&#xff0c;抖音成为了字节跳动用户、收入和估值的最大增长引擎。 自从字节逐…

字节还能如何“跳动”

字节跳动的下一个增长点会是什么&#xff1f; 裁员频传的字节 据《晚点 LatePost》报道&#xff0c;被给予厚望的字节跳动旗下教育品牌大力教育&#xff0c;正在进行新一轮调整&#xff1a;向 3 - 8 岁孩子提供 AI 动画课程的瓜瓜龙开始裁撤辅导老师&#xff0c;计划在 8 月底…

【字节跳动内推】字节跳动互娱研发-成都抖音的HC真的多!-帮看状态改简历

来字节-成都抖音 一起Dance吧&#xff01;少年&#xff01;ps&#xff1a;客户端开发HC很多的&#xff01;&#xff01;&#xff01;ios底层是C语言&#xff0c;android底层是java&#xff0c;现在用kotllin&#xff0c;师弟师妹们只要学C、C、java都可以try一try的&#xff08…

迅猛扩张的字节跳动,踢到了一些铁板

边裁员边扩张&#xff0c;字节跳动究竟在下一盘什么棋&#xff1f; 字节跳动堪称成长最快速的互联网企业之一。10月20日&#xff0c;据福布斯的实时富豪榜显示&#xff0c;字节跳动创始人张一鸣身价达到594亿美元&#xff0c;一举超过马化腾&#xff0c;成为中国第二大富豪&…

字节跳动byteDance

文章目录 一、第一次笔试1.完美字符串2.最优连续子序列3.多米诺骨牌4.生产调度 二、第二次笔试1.二叉树的叶子结点数2.编码协议3.插入广告4.求余的最大值 三、第三次笔试四、第四次笔试五、0922面试15:00六、第六次笔试1、员工奖励2、矩形最大面积3、分蛋糕4、阶乘使用魔法 七、…

EA使用——ER图的画法

强烈推荐一个大神的人工智能的教程&#xff1a;http://www.captainai.net/zhanghan ●背景 进入了机房重构的阶段&#xff0c;首先是设计数据库&#xff0c;按照正常的是先画出ER图&#xff0c;然后根据ER图去创建数据库&#xff0c;可是刚开始没有理清思路就先创建了数据库&a…

画er图。

学校规定: 一个学生可以选多门课&#xff0c;一门课可被若干学生选&#xff0c;一个教师授多门课&#xff0c;一门课只能由一个教师授。 学生的属性有学生姓名&#xff0c;学号。教师的属性有教师编号&#xff0c;姓名。 课程的属性有课程号&#xff0c;课程名。 画er图如下…

【R语言】——pheatmap包绘制聚类热图1(保姆级教程)

一、前言 1 热图介绍 通常&#xff0c;热图是对所获得的数据或其他因素进行归一化处理后&#xff0c;用颜色的变化来直观表示不同样本间的变化情况。本质上其是由一个个用预设颜色表示数值大小的小方格组成的数据矩阵&#xff0c;并通过对因子或样本的聚类&#xff0c;观察不…

画出相关的ER图

学校规定&#xff1a; 一个学生可选修多门课&#xff0c;一门课有若干个学生选修&#xff1b;一个教师可讲授多门课&#xff0c;一门课只有一个教师讲授&#xff1b;一个学生选修一门课程&#xff0c;仅有一个成绩。学生的属性有学号、学生姓名&#xff1b;教师的属性有教师编…

使用Visual Paradigm画ER图/Visual ER图

window安装教程&#xff1a;https://www.jianshu.com/p/8e31cb519cdf?tdsourcetags_pctim_aiomsg Visual Paradigm&#xff1a;多功能设计制图工具。 一&#xff1a;new-project 新建项目 二&#xff1a;new entity relationship diagram new entity relationship diagra…

推荐一个开源好用的ER图、流程图作图软件-draw.io

相信大家已经体验过不少作图软件&#xff0c;我个人用过微软的 Visio、金山的wps 作图、在线的 process.on 等。但是我个人的体验都不是很好&#xff1a;微软的 visio&#xff0c;只能在 windows 上使用&#xff0c;在mac 上通过虚拟机的体验不是很好&#xff1b;金山wps mac 版…

ER图

1、某商业集团的销售管理系统 数据库中有三个实体集&#xff0c; 一是“商店”实体集&#xff0c;属性有商店编号、商店名、地址等&#xff1b; 二是“商品”实体集&#xff0c;属性有商品号、商品名、规格、单价等&#xff1b; 三是“职工”实体集&#xff0c;属性有职工编号…

为什么要画ER图?有哪些画图规范?

一、概念 E-R图也称实体-联系图(Entity Relationship Diagram)&#xff0c;提供了表示实体类型、属性和联系的方法&#xff0c;用来描述现实世界的概念模型 举例&#xff1a; 二、组成部分 实体&#xff1a;一般认为&#xff0c;客观上可以相互区分的事物就是实体&#xff0…

ER图--绘图

课本P217 【例】用ER图来表示某个工厂物资管理的概念模型。 仓库&#xff1a;仓库号&#xff0c;面积&#xff0c;电话号码 零件&#xff1a;零件号&#xff0c;名称&#xff0c;规格&#xff0c;单价&#xff0c;描述 供应商&#xff1a;供应商号&#xff0c;姓名&#xff0c;…

数据库画简单ER图

诸位看官&#xff0c;我这是应付考试用的。。。。 一般就两种题型&#xff1a;画ER图、把ER图转化成关系模式。 三种基本的图形 分析个题。&#xff08;在B站上偷的图&#xff0c;UP主&#xff1a;邮递员马龙&#xff09; 其实我觉得属性&#xff0c;他已经自己标明了。不用我们…

ER图 咋画

一、什么是E-R图&#xff1f; E-R图又称实体关系图&#xff0c;是一种提供了实体&#xff0c;属性和联系的方法&#xff0c;用来描述现实世界的概念模型。通俗点讲就是&#xff0c;当我们理解了实际问题的需求之后&#xff0c;需要用一种方法来表示这种需求&#xff0c;概念模型…

怎样绘制ER图

E-R图也称实体-联系图(Entity Relationship Diagram)&#xff0c;1976年由P.Pchen 提出&#xff0c;提供了表示实体类型、属性和联系的方法。 ER图是我们在上数据库课的时候提到的&#xff0c;简单来说就是辅助数据库设计的概念模型。 1.表示方法 实体型&#xff1a;用矩形框&…

ER图(实体关系图)怎么画?

关于绘图&#xff0c;我一般遵循这样的原则&#xff1a; 绘图前先充分理解这类图形&#xff0c;回答它是什么&#xff0c;具有哪些绘图规范&#xff0c;最后才是怎么画。 一、什么是E-R图&#xff1f; E-R图又称实体关系图&#xff0c;是一种提供了实体&#xff0c;属性和联…