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

前言近期ChatGPT可以说是太火了，问答、写论文、写诗、写代码，只要输入精确的prompt，他的表现总是让人惊喜。本着打不过就加入的原则。要是把ChatGPT拉入群聊中，会是怎样一番场景？说做就做，花了1个晚上捣鼓了一个小Demo【ChatGPT群聊助手】，凭借它的“聪明才智”，应该可以搞定我的网

Part01   什么是消息推送  消息推送其实每天都在我们的手机上发生，如图1所示，除非你的手机没有安装APP或关闭了系统的通知栏权限。这些推送消息无时不刻地提醒和引导我们打开APP，然后成为他们的活跃用户，这也是消息推送所要达到的目的。图1手机上

大家好，我是 华仔,又跟大家见面了。原文完整版在星球里面，如果感兴趣可以扫文末二维码加入。上篇主要带大家深度剖析了「号称承载Kafka客户端消息快递仓库RecordAccmulator的架构设计」，消息被暂存到累加器中，今天主要聊聊「发送网络I/O的Sender线程的架构设计」，深度剖析下

一、前情提示上一篇文章《​​MQ保证读写消息不丢失，这个你都不会就等着被开除吧...​​》,我们初步介绍了之前制定的那些消息中间件数据不丢失的技术方案遗留的问题。一个最大的问题，就是生产者投递出去的消息，可能会丢失。丢失的原因有很多，比如消息在网络传输到一半的时候因为网络故障就丢了，或者是消息投递到

一、写在前面之前写过一篇文章​​《项目里接入了MQ消息中间件以后，我摸鱼的时间更长了~》​​，我们用一个简单易懂的电商场景给大家引入说明了一个消息中间件的使用场景。同时，我们还基于RabbitMQ的HelloWorld级别的代码，给出了订单服务和仓储服务如何基于MQ中间件收发消息的示例。二、业务场景

RocketMQ作为阿里系的一款开源的MQ中间件，经历了双十一的高并发场景的消息流转，能够处理万亿级别的消息。这篇文章将作为《RocketMQ进阶》专栏的第一篇文章，介绍一下实际生产中如何搭建一个高可用的RocketMQ集群。集群整体架构图如下：为什么要用MQ？消息队列是一种“先进先出”的数据结构其

​在电商、支付等系统中，一般都是先创建订单（支付单），再给用户一定的时间进行支付，如果没有按时支付的话，就需要把之前的订单（支付单）取消掉。这种类似的场景有很多，还有比如到期自动收货、超时自动退款、下单后自动发送短信等等都是类似的业务问题。本文就从这样的业务问题出发，探讨一下都有哪些技术方案，这些方

大量业务使用消息中间件进行系统间的解耦、异步化、削峰填谷设计实现。公司内部前期基于RabbitMQ实现了一套高可用的消息中间件平台。随着业务的持续增长，消息体量随之增大，对消息中间件平台提出了更高的要求，此外在运维过程中也遇到了高可用难以保障，功能特性不足等诸多问题。基于遇到的这些问题，决定引入Ro

ApacheKafka（简称Kafka）是由LinkedIn公司开发的分布式消息流平台，于2011年开源。Kafka是使用Scala和Java编写的，当下已成为最流行的分布式消息流平台之一。Kafka基于发布/订阅模式，具有高吞吐、可持久化、可水平扩展、支持流数据处理等特性。ApachePulsar

大家好，我是三友，我又来了~~最近仍然畅游在RocketMQ的源码中，这几天刚好翻到了消费者的源码，发现RocketMQ的对于push消费方式的实现简直太聪明了，所以趁着我脑子里还有点印象的时候，赶紧来写一篇文章，来掰扯一下，防止过两天就忘得一干二净了。MQ消费方式消费方式就是指消费者如何从MQ中获

一、前情回顾上篇文章《​​为什么要使用MQ消息中间件?这几个问题必须拿下!​​》，给大家讲了讲消息中间件引入系统架构的作用，主要是解决哪些问题的。其比较常见的实践场景是：复杂系统的解耦复杂链路的异步调用瞬时高峰的削峰处理二、正式开始这篇文章给大家讲讲，如果你在系统架构里引入了消息中间件之后，会有哪些

一、前情回顾针对那种工作年限比较长的资深的同学，可能会开始就候选人所在公司使用的消息中间件，深入里面的技术细节，比如让你聊聊RocketMQ的架构原理和核心源码。但是另外一种面试风格，会先从你们的项目和业务入手进行考察，比如像下面这样：消息中间件在你们生产项目里具体是哪个业务场景下落地的？这个业务场

大家好，我是君哥。今天聊一聊RocketMQ的顺序消息实现机制。在有些场景下，使用MQ需要保证消息的顺序性，比如在电商系统中，用户提交订单、支付订单、订单出库这3个消息应该保证顺序性，如下图：对于RocketMQ来说，主要是通过Producer和Consumer来保证消息顺序的。1、Producer

作者| 渐意一、前言无论是在大数据处理领域，还是在消息处理领域，任务系统都有一个很关键的能力-任务触发去重。这个能力在一些对准确性要求极高的场景(如金融领域)中是必不可少的。作为Serverless化任务处理平台，ServerlessTask也需要提供这类保障，在用户应用层面及自身系统内部

在微服务架构中，会将一个完整的应用程序拆分成一组服务。这些服务之间需要经过协作，通过接口调用，才能组成一个完整的应用。不同的服务部署在不同的机器上，或者同一个机器的多个容器中，进程间进行通信就不可避免了，也变得非常重要。按种类来分，进程间的通信方式有很多种，比如远程过程调用的RESTfulAPI和g

前言这次分享RabbitMQ自带的保护RabbitMQ免于过载的功能-FlowController(「流量控制」)，如果不明白原理和场景使用RabbitMQ时，遇到FlowController容易一脸懵逼不知所措，今天我们就来了解它的原理。什么是流量控制?流控制是一个在计算机网络和网络软件中存在了几

大家好，我是君哥。今天分享一道有意思的面试题。面试官：RocketMQ消息积压了，增加消费者有用吗?我：这个要看具体的场景，不同的场景下情况是不一样的。面试官：可以详细说一下吗?我：如果消费者的数量小于MessageQueue的数量，增加消费者可以加快消息消费速度，减少消息积压。比如一个Topic有

消息中间件(MessageOrientedMiddleware，简称MOM)在企业开发中变得越来越重要。本文介绍消息中间件中的四种消息投递模型，主要是介绍模型的核心特性，以及不同模型之前的区别。这四种模型分别是：PTP模型Pub/Sub模型Partition模型Transfer模型其中PTP模型和P

  继续答星球水友提问：盘口数据频繁变化，如何做缓存与推送，如何降低数据库压力?并没有做过相关的业务，结合自己的架构经验，说说自己的思路和想法，希望对大家有启示。一、业务抽象有很多客户端关注盘口，假设百万级别;数据量不一定很大，上市交易的股票个数，假设万级别;写的量比较大，每秒钟

 1、为什么要使用消息队列?分析:一个用消息队列的人，不知道为啥用，有点尴尬。没有复习这点，很容易被问蒙，然后就开始胡扯了。回答:这个问题,咱只答三个最主要的应用场景(不可否认还有其他的，但是只答三个主要的),即以下六个字:解耦、异步、削峰(1)解耦传统模式:  传统模