深圳幻海软件技术有限公司

作者｜王维，中国移动云能力中心IaaS产品部rpc产品组研发工程师，主要负责消息队列云原生方向的设计与研发工作胡宗棠，中国移动云能力中心laaS产品部消息队列&rpc团队的负责人，主要负责消息队列、rpc、配置管理等云原生中间件的架构设计与技术研发工作1.背景介绍移动云RocketMQ消息队

消息积压是我们在使用消息队列时经常遇到的问题，它的直接原因是系统中某个部分出现了性能问题，没有来得及处理上游发送的消息。优化性能避免消息积压当我们引入消息系统后，站在消息系统的角度，整个系统可以分为三部分：1.消息生产者，2.消息队列，3.消息消费者。我们在谈论优化性能避免积压消息时，重点会放在消息

开通微信小号，创建微信虚拟身份，把聊天信息设置为提醒事项，创建微信备忘录，使用翻译输入，查看末领取红包，这些隐藏功能不知道，微信只用来聊天可太亏了。1、微信备忘录依次点击我—收藏—右上角“+”号，可以在界面下方找到待办事项，填入备忘信息，点击右上角，选择“在聊天中置顶”。2、查看末领取红包在聊天群里

一、背景引入这篇文章，我们来聊一下消息中间件高可用架构的一些原理。对于一个合格的高级Java工程师而言，你肯定会碰到在系统里用到MQ的场景，那么这个时候你需要基于你的业务场景和需求，考虑在使用MQ的时候可能遇到的一些技术问题。接着，你必须得针对这些技术问题设计一套完整的技术方案。你需要从消息的订阅模

引言ApacheRocketMQ诞生至今，历经十余年大规模业务稳定性打磨，服务了100%阿里集团内部业务以及阿里云数以万计的企业客户。作为金融级可靠的业务消息方案，RocketMQ从创建之初就一直专注于业务集成领域的异步通信能力构建。本篇将从业务集成场景的诉求开始，介绍RocketMQ作为业务消息集

1、背景最近一周一来，总是有项目组中反馈遇到了消息重复推送的问题，连续出现单条消息短时被多个消费者消费的问题：同时给出了证据，相同的msgId的消息被打印了两条，并且两者相隔7s。讲真，由于最近负责的事情比较多，并且RocketMQ又无法保证消息被重复消费，所以一开始并未引起我的充分重视，而是简单的

作者｜傅宽，单位：中国移动智慧家庭运营中心​Labs导读OpenWrt提供了一个系统总线ubus，它类似于Linux桌面操作系统的d-Bus，目标是提供系统级的进程间通信（IPC）功能。ubus在设计理念上与d-Bus基本保持一致，提供了系统级总线功能，与d-Bus相比减少了系统内存占用空间，这样可

前言我们都在讨论分布式，特别是面试的时候，不管是招初级软件工程师还是高级，都会要求懂分布式，甚至要求用过。传得沸沸扬扬的分布式到底是什么东东，有什么优势？借用火影忍术风遁·螺旋手里剑看过火影的同学肯定知道漩涡鸣人的招牌忍术：多重影分身之术。这个术有一个特别厉害的地方，过程和心得：多个分身的感受和经历

编译|朱先忠策划|Ethan日常开发中，我们通常会在同一个体系架构中部署了多个不同角色的应用程序，而这些应用程序需要某种机制来通知彼此发生了哪些事件。这些事件可能是临时的（在运行时临时所做的更改），也可能是数据库事件（由于数据库中的更改）。如何应对这种复杂多变的分布式事件，一直是件相当棘手的问题。而

译者|李睿审校|梁策孙淑娟什么是观众参与?在线观众参与的一个简单示例是：带有主持人的直播和供观众成员实时互动的聊天系统。其他观众参与解决方案包括观影派对、投票、测验和排行榜等活动，涵盖在线聊天或提问回答等功能，供参与者在分享体验的同时进行交流。1.设备和用户在场了解观众参与的一个方面是能够知道谁在参

本指南将引导您完成设置发布和订阅消息的RabbitMQAMQP服务器以及创建SpringBoot应用程序以与该RabbitMQ服务器交互的过程。你将建造什么您将构建一个应用程序，该应用程序使用SpringAMQP发布消息RabbitTemplate并使用MessageListenerAdapter.

大家好，我是君哥。作为优秀的消息流平台，Pulsar的使用越来越多，这篇文章讲解Pulsar的Java客户端。部署PulsarPulsar的部署方式主要有3种，本地安装二进制文件、docker部署、在Kubernetes上部署。本文采用docker部署一个单节点的Pulsar集群。实验环境是2核CP

 目录一、分布式事务前奏二、柔性事务解决方案架构(一)、基于可靠消息的最终一致性方案概述(二)、TCC事务补偿型方案(三)、最大努力通知型三、基于可靠消息的最终一致性方案详解(一)、消息发送一致性(二)、保证消息一致的变通做法(三)、常规MQ消息处理流程和特点(四)、消息重复发送问题和业务

前言上世纪90年代末，随着JavaEE(EnterpriseEdition)的出现，特别是EnterpriseJavaBeans的使用需要复杂的描述符配置和死板复杂的代码实现，增加了广大开发者的学习曲线和开发成本，由此基于简单的XML配置和普通Java对象(PlainOldJavaObjects)的

场景不知道大家有没有遇到这样的情况，就是去自动取款机取钱的时候，比如说你去取1000块钱，这个时候系统会先帮你把1000块钱扣除，然后自动取款机再把钱吐出来。但是如果取款机出现问题，会发现钱被扣了，但是钱没有取出来。我第一次遇到这个问题的时候很担心，当时跨行取取了3000块钱，短信提醒我钱已经被扣了

 本文介绍了Kafka、RabbitMQ、ZeroMQ、RocketMQ、ActiveMQ17个方面综合对比作为消息队列使用时的差异。一资料文档Kafka：中。有kafka作者自己写的书，网上资料也有一些。rabbitmq：多。有一些不错的书，网上资料多。zeromq：少。没有专门写zer

消息队列已经逐渐成为企业应用系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能。图片来自Pexels当前使用较多的消息队列有RabbitMQ、RocketMQ、ActiveMQ、Kafka、ZeroMQ、MetaMQ等，而部分数据库如Redis、MySQL以及Ph

Kafka是一个消息系统，原本开发自LinkedIn，用作LinkedIn的活动流(ActivityStream)和运营数据处理管道(Pipeline)的基础。图片来自Pexels现在它已被多家不同类型的公司作为多种类型的数据管道和消息系统使用。活动流数据是几乎所有站点在对其网站使用情况做报表时都要

   Kafka中的术语broker：中间的kafkacluster，存储消息，是由多个server组成的集群。topic：kafka给消息提供的分类方式。broker用来存储不同topic的消息数据。producer：往broker中某个topic里面生产数据。con

【51CTO.com原创稿件】ApacheKafka是一款流行的分布式数据流平台，它已经广泛地被诸如NewRelic(数据智能平台)、Uber、Square(移动支付公司)等大型公司用来构建可扩展的、高吞吐量的、且高可靠的实时数据流系统。例如，在NewRelic的生产环境中，Kafka群集每秒能够处