最近，工作中要为现在的老系统做拆分和升级，刚好遇到了分布式事务、幂等控制、异步消息乱序和补偿方案等问题，刚好基于实践结合个人的看法记录一下一些方案和思路。
异步消息的主要目的是解决跨系统的通信。所谓异步消息，即消息发送者无需等待消息接收者的处理及返回，甚至无需关心消息是否发送与接收成功。在异步消息中有两个极其重要的概念，即消息代理和目的地。当消息发送者发送消息后，消息将由消息代理管理，消息代理保证消息传递到目的地。 异步消息的目的地主要有两种形式，即队列和主题。
我们知道MessageQueue就一个构造函数 代码在MessageQueue.java 68行
Android消息机制对于每一个Android开发者来说都不陌生，在日常的开发中我们不可避免的要经常涉及这部分的内容。从开发角度来说，Handler是Android消息机制的上层接口，这使得在开发过程中只需要和Handler交互即可。Handler的使用过程很简单，通过它可以轻松的将一个任务切换Handler所在的线程中去执行。很多人认为Handler的作用是更新UI，这的确没错，但是更新UI仅仅是Handler的一个特殊的使用场景。具体来说是这样的；有时候需要再子线程中进行耗时的I/O操作，可能是读取文件或访问网络等。。。。。
在 Android 系统中的 Handler 机制 中 , 涉及到了 Handler , Message , Looper , MessageQueue 等组件 , 其中 MessageQueue 是消息队列 , 其中包含了很多 单链表 元素 ;
比较目前主流的三种MQ, ActiveMQ虽然也很好但是, 现在除了传统的行业, 以及老系统, 基本很少被使用了, 所以就不考虑ActiveMQ了, 因为很多传统行业一般也都是RabbitMQ
两者的区别在哪？ 异步相对于同步来说，页面非阻塞，减少了用户等待的时间体验相对来说比较好
乍一看有点超纲了。细细一想，没超纲。我把这个问题拆分成了两个问题，本文我将紧紧围绕这两个问题，讲解requestLayout背后的故事。
MQ (MessageQueue) ，中文是消息队列，字面来看就是存放消息的队列。也就是事件驱动架构中的Broker。消息队列是一种基于生产者-消费者模型的通信方式，通过在消息队列中存放和传递消息，实现了不同组件、服务或系统之间的异步通信。
在异步消息传输系统中，消息乱序是一个常见的挑战。当消息在发送过程中发生重试时，很可能会导致消息的乱序，这可能对系统的一致性和可靠性产生负面影响。本文将探讨异步消息发送中可能出现的消息乱序问题，以及解决这些问题的方法。
消息队列（Message Queue，简称 MQ）。是基于队列与消息传递技术，在网络环境中为应用系统提供同步或异步、可靠的消息传输的支撑性软件系统。
AMQP(Advanced Message Queuing Protocol,高级消息队列协议)是进程之间传递异步消息的网络协议。
RabbitMQ和RocketMQ都是流行的开源消息队列系统，用于实现分布式系统之间的异步消息传递。但它们在多个方面存在显著的差异。以下是对两者区别的详细分析：
异步消息是一个应用程序向另一个应用程序间接发送消息的一种方式，这种方式无需等待对方的相应。
我们剖除入队规则、同步锁、同步屏障消息、异步消息、唤醒规则等逻辑，将入队的逻辑代码抽出，得到：
消息驱动微服务（Message-Driven Microservices）是一种基于事件驱动架构的微服务模式。在这种模式下，微服务之间通过异步消息传递实现通信，而不是通过同步的REST API调用。消息驱动微服务模式具有高可扩展性、松耦合、可靠性等优点，可以有效地支持大规模分布式系统的构建。本文将详细介绍消息驱动微服务的概念、架构、实现和示例。
在很多互联网应用系统中，请求处理异步化是提升系统性能一种常用的手段，而基于消息系统的异步处理由于具备高可靠性、高吞吐量的特点，因而在并发请求量比较高的互联网系统中被广泛应用。与此同时，这种方案也带来了调用链路处理上的问题，因为大部分应用请求都会要求同步响应实时处理结果，而由于请求的处理过程已经通过消息异步解耦，所以整个调用链路就变成了异步链路，此时请求链路的发起者如何同步拿到响应结果，就需要进行额外的系统设计考虑。 为了更清晰地理解这个问题，小码哥以最近正在做的共享单车的IOT系统为例，给大家来一张图描述下，如图所示：
一、概念 异步消息简介 与远程调用机制以及REST接口类似，异步消息也是用于应用程序之间通信的。 RMI、Hessian、Burlap、HTTP invoker和Web服务在应用程序
从很早开始就认识到 Handler 了，只不过那时修为尚浅，了解的不够深刻，也没有应用自如。不过随着工作时间的增长，对 Handler 又有了更深层次的认识，于是有了这篇博客，希望尽可能的总结出多的知识点。
我们平时习惯于使用 Rabbitmq 和 Kafka 作为消息队列中间件，来给应用程序之间增加 异步消息传递功能。这两个中间件都是专业的消息队列中间件，特性之多超出了大多数人的理解能力。
Handler中的消息队列如上图所示，是一个单链表，各个消息按照执行时间先后排列，消息类型分为三种：普通消息（normal）、屏障消息（barrier）、异步消息（async）。
众所周知，消息队列是应用系统中重要的组件，主要解决应用解耦，异步消息，流量削锋等问题，实现高性能，高可用，可伸缩和最终一致性架构。目前使用较多的消息队列有 ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ.
队列的主要作用是消除高并发访问高峰，加快网站的响应速度。消息队列在大型电子商务类网站，如京东、淘宝、去哪儿等网站有着深入的应用，
一般来说，消息队列是一种异步的服务间通信方式，是分布式系统中重要的组件，主要解决应用耦合，异步消息，流量削锋等问题，实现高性能，高可用，可伸缩和最终一致性架构。
在Android开发中，主线程扮演着至关重要的角色。毫不夸张的说，它就相当于Android的心脏。只要它还在跳动的运行，Android应用就不会终止。
消息通知是项目中遇到的常见场景，通常而言消息通知会涉及到数据库操作，且面临着通知用户多，消息处理需要时间的问题。假设一个接口本身的业务逻辑执行只需要50ms，而消息通知需要500ms，如果串行进行调用，就难免遇到接口长时间阻塞等待结果的情况。所以异步化操作解耦消息通知，在这种场景显得十分必要。
如果你是面试高级Android开发，Handler绝对是必问问题，没有之一。本文结合了2021年4-5月份字节、阿里、网易等公司的面试经历，整理了面试过程中被问及的Handler相关的知识点。会涉及到很多细节知识，大家可以作为面试参考了解一下。
AB两个接口更新同一个表的字段，但是以B接口下发数据为准，上游调用A接口的同时调用C接口，C接口再同时调用B接口，理论情况下更新时间是按着A先插入了tabel的字段，B再进行更新，最终数据是以B接口下发数据为准的，但由于A接口下发业务逻辑复杂，导致短时间A接口未提交事务时B接口被调用就进行了更新并提交事务导致A接口的事务提交覆盖了B操作，但更可怕的就是A还未提交事务，表中无数据可更新，B无法更新的情况如何更新数据？目前方案在B接口调用时放入缓存数据，在A接口被调用时缓存中有数据则更新缓存中的数据，没有则表明此时B还未被调用则不更新，常规的发生异常或者B后提交事务可以解决，但是A未提交事务时，B无法更新的情况如何处理？
消息队列，主要解决异步消息的管理（注册后，短信发送不是必须，可以使用队列）。实现系统之间的双向解耦,同时也能起到消息缓冲，消息分发的作用。当生产者产生大量数据，而消费者无法快速消费，（秒杀数据量过大使系统崩溃，队列可以废弃多余请求），或者是消费者异常了（服务挂掉后使请求丢失，队列可以保存请求）。
消息队列中间件是大型系统中的重要组件，已经逐渐成为企业系统内部通信的核心手段。它具有松耦合、异步消息、流量削峰、可靠投递、广播、流量控制、最终一致性等一系列功能，已经成为异步RPC的主要手段之一。 目前常见的消息中间件有ActiveMQ、RabbitMQ、ZeroMQ、Kafka、MetaMQ、RocketMQ等。
消息队列中间件是分布式系统中重要的组件，主要解决应用解耦，异步消息，流量削锋等问题，实现高性能，高可用，可伸缩和最终一致性架构。目前使用较多的消息队列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ
以上我们通过JavaMailSender接口实现了文本、超文本及带有附件的邮件的发送功能。 在书写这些程序时，采用了硬编码，可能会碰到如下问题：
通常来说，一个应用至少有一个进程，而一个进程至少有一个线程。 线程是 CPU 调度的基本单位，进程是系统资源分配的基本单位。
1.什么是RabbitMQ RabbitMQ是一个由erlang开发的AMQP（Advanced Message Queue 高级消息队列协议 ）的开源实现，能够实现异步消息处理 RabbitMQ是一个消息代理：它接受和转发消息。 你可以把它想象成一个邮局：当你把你想要发布的邮件放在邮箱中时，你可以确定邮差先生最终将邮件发送给你的收件人。在这个比喻中，RabbitMQ是邮政信箱，邮局和邮递员。
消息队列也通常称为消息中间件，提到消息队列，大部分互联网人或多或少都听过该名词。对于后端工程师而言，更是日常开发中必备的一项技能。消息队列主要解决应用耦合、异步消息、流量削锋等问题，具有高性能、高可用、可伸缩和最终一致性等特点。已经逐渐成为企业应用系统内部通信的核心手段，目前使用较多的消息队列有 RabbitMQ、RocketMQ、ActiveMQ、Kafka、ZeroMQ、MetaMQ 等，此外，利用数据库（如 Redis、MySQL等）也可实现消息队列的部分基本功能。 消息队列本身是工程领域内一
本文实例讲述了Android编程实现异步消息处理机制的几种方法。分享给大家供大家参考，具体如下：
在 Java、Python 和 C++ 之间进行快速进程间通信（IPC）可以采用多种方法，说复杂也还好，主要还是要多了解通信协议等问题，RPC（远程过程调用、共享内存（Shared Memory）、管道(Pipe)通信等等都需要注意。下面可以好好看下。
2.在客户端与服务器进行通讯时，客户端调用服务端接口后，必须等待服务端完成处理后返回结果给客户端才能继续执行，这种情况属于同步调用方式。
核心类就是 ThreadLocal ，它提供线程局部变量，每个线程都有自己独立的一份变量，通常是类中的 private static 字段，它们希望将状态与某一个线程相关联，在多线程编程中常用，比如 Android 的绘制同步机制 Choreographer 中也有使用。
这个方法已经在Android Handler机制4之Looper与Handler简介中说过了，我就重点说下流程，大体上分为6步
作为一个有丰富经验的微服务系统架构师，经常有人问我，“应该选择RabbitMQ还是Kafka？”。基于某些原因， 许多开发者会把这两种技术当做等价的来看待。的确，在一些案例场景下选择RabbitMQ还是Kafka没什么差别，但是这两种技术在底层实现方面是有许多差异的。
消息队列是最古老的中间件之一，从系统之间有通信需求开始，就自然产生了消息队列。如果你还没有用过消息队列，那是时候好好学习一下了。本文告诉什么是消息队列，为什么需要消息队列，常见的消息队列有哪些， RabbitMQ 的部署和使用。
如果现有A、B两个应用程序，B应用希望从A应用获取到自己感兴趣的信息，A和B部署在不同的机房，可能还有C、D、E等更多的这样的应用程序需要A的这些消息，这就是我们常说的消息中间件的点对点、发布订阅模式。
Celery是一个简单、灵活且可靠的，处理大量消息的分布式系统，专注于实时处理的异步任务队列，同时也支持任务调度。
消息队列（Message Queue）是一种常见的软件架构模式，用于在分布式系统中传递和处理异步消息。它解耦了发送消息的应用程序和接收消息的应用程序之间的直接依赖关系，使得消息的发送者和接收者可以独立地演化和扩展。
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
对象存储
腾讯会议
实时音视频
