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

我们在使用不同的消息队列产品时，会遇到不同的“名词”，今天我们今天来聊一些相关内容，包括队列、主题、分区等。消息队列进化史好的架构不是设计出来的，而是不断演进得来的，消息队列的发展历史，也印证了这一点，消息队列的消息模型主要包括两类：队列模型发布-订阅模型队列模型最初的消息队列就是一个严格意义上的队

平时如果留意手机市场动态的话，你可能会发现，现在手机更新迭代的频率越来越快了，手机的手机越来越高，但是降价也来得越来越快。这其中是市场的自然规律吗?答案是，正确。这既是市场的自然规律，也是手机技术不断发展的结果。手机降价越来越快，降价幅度越来越大，无非就是以下三点原因。新机迭代速度加快，旧机降价为新

据市场调研机构Gartner发布的数据显示，随着消费者获得非定向广告的体验，移动应用程序跟踪的选择退出率将从2021年的85%下降到2023年的60%。Gartner营销部门副总裁兼杰出分析师AndrewFrank表示：“如果消费者熟悉要求跟踪的品牌，大约有四分之一的消费者会允许跟踪，尤其是作为现金

让信用卡号码远离交易过程确实有助于帮助消费者缓解并减轻各类数据泄露风险所带来的困扰，但这并不意味着那帮犯罪分子们会放弃窃取数字化资产的主意。图为一台iPhone6正通过ApplePay功能进行NFC支付。ApplePay目前已经正式上线并投入运作。作为一名普通消费者，我对此感到兴奋莫名，但也与那些从

前言Kafka一开始是LinkedIn这家公司研发的技术，它是一种高吞吐量的分布式发布订阅消息系统，现在已成为大多数公司使用的技术，我们公司也不例外。那么你对kafka的了解有多少呢?那么本文就带你过一过kafka中的一些关键要点。为什么我们需要Kafka？订单发生时通知其他服务在我们深入研究之前，

一、前情提示上一篇文章：​​《RocketMQ消息中间件用起来真的可靠吗？》​​，我们分析了ack机制的底层实现原理（deliverytag机制），还有消除处理失败时的nack机制如何触发消息重发。通过这个，已经让大家进一步对消费端保证数据不丢失的方案的理解更进一层了。这篇文章，我们将会对ack底层

​虽然流可以是处理大量数据的有效方式，但它们也有自己的挑战。让我们看看其中的一些。1.如果消费者无法像制作人创建块那样快速处理块，会发生什么？一个例子：如果消费者比生产者慢50%，会怎么样？如果我们从一个10GB的文件开始，这意味着当生产者处理完所有10GB时，消费者只处理了5GB。剩余的5GB在等

一、前情提示上一篇文章：《​​大牛总结超详细的RabbitMQ入门，看这篇文章就够了！​​》，我们分析了ack机制的底层实现原理（deliverytag机制），还有消除处理失败时的nack机制如何触发消息重发。通过这个，已经让大家进一步对消费端保证数据不丢失的方案的理解更进一层了。这篇文章，我们将会

​前言微服务开发涉及了一些数据处理模块的开发，每个处理业务都会开发独立的微服务，便于后面拓展和流编排。学习了SpringCloudDataFlow等框架，感觉这个框架对于我们来说太重了，维护起来也比较麻烦，于是根据流编排的思想，基于我们目前的技术栈实现简单的流编排功能。简单的说，我们希望自己的流编排

工作中遇到项目使用Disruptor做消息队列,对你没看错，不是Kafka，也不是rabbitmq。Disruptor有个最大的优点就是快，还有一点它是开源的哦,下面做个简单的记录。Disruptor介绍Disruptor是英国外汇交易公司LMAX开发的一个高性能队列，研发的初衷是解决内存队列的延迟

1.前言本篇文章开始Disruptor的源码分析，理解起来相对比较困难，特别是Disruptor的sequenceBarrier的理解，sequenceBarrier包括生产者与消费者之间的gatingSequence以及消费者与消费者之间的dependentSequence。此外，Disrupto

一、简介MQ全称为MessageQueue-消息队列，是一种应用程序对应用程序的消息通信，一端只管往队列不断发布信息，另一端只管往队列中读取消息，发布者不需要关心读取消息的谁，读取消息者不需要关心发布消息的是谁，各干各的互不干扰。市场上现在常用的消息队列有：RabbitMQ、RocketMQ、Kaf

 一、前言我们上一篇分析了Consumer如何加入ConsumerGroup，其实上一篇是一个很宏观的东西，主要讲ConsumerCoordinator怎么与GroupCoordinator通信。等等，老周，ConsumerCoordinator和GroupCoordinator是个啥玩意

 本文转载自微信公众号「零零后程序员小三」，作者003。转载本文请联系零零后程序员小三公众号。什么是KafkaKafka是最初由Linkedin公司开发，Linkedin于2010年贡献给了Apache基金会并成为顶级开源项目，也是一个开源【分布式流处理平台】，由Scala和Java编写，

【51CTO.com原创稿件】ApacheKafka是一个快速、可扩展的、高吞吐的、可容错的分布式“发布-订阅”消息系统，使用Scala与Java语言编写，能够将消息从一个端点传递到另一个端点。图片来自Pexels较之传统的消息中间件(例如ActiveMQ、RabbitMQ)，Kafka具有高吞吐量

Kakfa广泛应用于国内外大厂，例如BAT、字节跳动、美团、Netflix、Airbnb、Twitter等等。今天我们通过这篇文章深入了解Kafka的工作原理。  图片来自Pexels Kafka概述Kakfa是一个分布式的基于发布/订阅模式的消息队列(MessageQ

 今年华为历经千难万险，明年会好吗？近日，华为印度消费者业务负责人称，谷歌应用程序（GMS）的替代品，包括邮件、消息、地图和付款以及关键的基础服务，将很快准备就绪，并且消费者感觉不到GMS和HMS之间的差异。2019年即将过去，要说今年最不容易的科技公司，华为定在其列。一道禁令使华为无法获

之前我们介绍过了Kafka整体架构，Kafka生产者，Kafka生产的消息最终流向哪里呢？当然是需要消费了，要不只产生一系列数据没有任何作用啊，如果把Kafka比作餐厅的话，那么生产者就是厨师的角色，消费者就是客人，只有厨师的话，那么炒出来的菜没有人吃也没有意义，如果只有客人没有厨师的话，谁会去这个

 前言:现如今微服务架构十分流行，而采用微服务构建系统也会带来更清晰的业务划分和可扩展性。同时，支持微服务的技术栈也是多种多样的，本文主要讲述我们为什么选择SpringCloud和它的技术概要。1、为什么微服务架构需要SpringCloud简单来说，服务化的核心就是将传统的一站式应用根据业

 演讲：陈威如，阿里巴巴商学院/湖畔大学教授。零售君说在淘宝大学举办的***期新零售MBA班上，湖畔大学教授陈威如为学员做了题为“新零售时代的供应链变革”的演讲。我们应该用什么来重构人货场？新零售时代的供应链痛点如何解决？现将演讲精华整理如下，Enjoy。用什么重构人货场？对于各位在座的品