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

RabbitMQ是一个开源的消息中间件，它在云原生应用中扮演着重要的角色。云原生应用是一种构建和部署在云平台上的应用程序，它具备弹性、可扩展和可靠性等特点。下面将介绍RabbitMQ在云原生应用中的应用，并探讨其对最新技术趋势的影响。一、云原生应用的挑战云原生应用的设计和架构具有一些独特的挑战。例如

RocketMQ是大家耳熟能详的消息队列，开源项目rocketmq-spring可以帮助开发者在SpringBoot项目中快速整合RocketMQ。这篇文章会介绍SpringBoot项目使用rocketmq-springSDK实现消息收发的操作流程，同时笔者会从开发者的角度解读SDK的设计逻辑。1S

一、背景引入这篇文章，我们来聊聊在线上生产环境使用消息中间件技术的时候，从前到后的全链路到底如何保证数据不能丢失。这个问题，在互联网公司面试的时候高频出现，而且也是非常现实的生产环境问题。如果你的简历中写了自己熟悉MQ技术（RabbitMQ、RocketMQ、Kafka），而且在项目里有使用的经验，

异步模式Asynchronous不会等待这个任务结束才开始执行下一个任务，开启之后立即执行下一个任务，后续逻辑一般会通过回调函数的方式定义，异步模式对js非常重要，没有异步任务单线程的js语言就无法同时处理大量耗时任务，单线程下面的异步最大的难点就是代码的执行顺序混乱，Queue是消息队列队列也叫回

1、面试官为啥要出这样一个开放式问题​这篇文章简单给大家来聊一个互联网大厂的Java面试题：如果让你设计一个消息中间件，你会怎么做？其实这个问题之前大致给大家聊过，本质就是面试官在考察一个高级以上的Java工程师的系统设计能力。给你一个平时大家都常用的一个消息中间件作为命题，让你现场开放式发挥，立马

大家好，我是三友~~这篇文章我准备来聊一聊RocketMQ消息的一生。不知你是否跟我一样，在使用RocketMQ的时候也有很多的疑惑：消息是如何发送的，队列是如何选择的？消息是如何存储的，是如何保证读写的高性能？RocketMQ是如何实现消息的快速查找的？RocketMQ是如何实现高可用的？消息是在

之前我在一篇文章中曾经提过，不应该利用WM_KILLFOCUS消息中对表单的字段进行有效性校验。今天的文章，我将介绍另外一个反面例子，来表现当使用WM_KILLFOCUS消息处理焦点相关的问题时所带来的混乱。假设，有一个编辑框控件使用了气球提示来显示反馈信息。举个例子，对于一个密码输入控件，当键盘上

一、前情提示上一篇文章《​​百亿级流量的系统架构该怎么设计，今天就来教会你！​​》分析了一下如何利用消息中间件对系统进行解耦处理。同时，我们也提到了使用消息中间件还有利于一份数据被多个系统同时订阅，供多个系统来使用于不同的目的。目前的一个架构如下图所示。在这个图里，我们可以清晰的看到，实时计算平台发

1、前情回顾上一篇文章：《​​给你一份精心设计的消息中间件高扩展架构，赶紧写进简历吧！​​》，我们分析了如何利用消息中间件对两系统进行解耦处理。同时，我们也提到了，使用消息中间件还有利于一份数据被多个系统同时订阅，供多个系统用于不同目的。目前的一个架构如下图所示。在这个图里，我们可以清晰的看到，实时

大家好，我是君哥。今天分享RocketMQ的Broker挂了，会带来什么影响。面试官：你好，如果RocketMQ集群中的一个Broker挂了，会造成什么影响呢？ 我：Broker挂了，首先会导致Producer发送消息失败。对于普通消息，Producer同步发送的情况下会有重试机制，重试时

1事务概念在分布式系统中，为了保证数据的高可用，通常，我们会将数据保留多个副本(replica)，这些副本会放置在不同的物理的机器上。为了对用户提供正确的CRUD等语义，我们需要保证这些放置在不同物理机器上的副本是一致的。分布式事务在现在遍地都是分布式部署的系统中几乎是必要的。我们的项目用到了数据库

大家好，我是君哥。事务消息是分布式事务的一种解决方案，RocketMQ有成熟的事务消息模型，今天就来聊一聊RocketMQ事务消息实现机制。假如有一个电商场景，用户下单后，账户服务从用户账户上扣减金额，然后通知库存服务给用户发货，这两个服务需要在一个分布式事务内完成。这时，账户服务作为Produce

关键要点分布式消息传递系统支持两种类型的语义：流式传输和排队。每个都最适合某些类型的用例。ApachePulsar的独特之处在于它同时支持流式处理和排队用例。Pulsar的多层架构允许用户比其他消息传递系统更方便地扩展主题的数量和大小。Pulsar提供了可扩展性、可靠性和功能的适当平衡，以取代Ite

记录发送钉钉的几种格式消息的使用方式。目前通过webhook向钉钉发送消息，必须要有安全配置：自定义关键词：最多可以设置​​10​​个关键词，消息中​​至少包含其中1个关键词​​才可以发送成功。加签：就是通过​​timestamp​​和​​secret​​进行拼接后得到的一个字符串timestamp

大家好，我是君哥。RocketMQ消息消费有两种模式，PULL和PUSH,今天我们来看一下这两种模式有什么区别。PUSH模式首先看一段RocketMQ推模式的一个官方示例：复制publicstaticvoidmain(String[]args)throwsInterruptedException,M

哈喽，大家好，我是指北君。开发中，服务与服务之间通信通常会用到消息中间件，如果我们使用了某一个MQ，那么消息中间件与我们的系统算是高耦合。将来有一天，要替换成另外的MQ，我们的改动就会比较大。为了解决这个问题，我们可以使用SpringCloudStream来整合我们的消息中间件，降低耦合度，使服务可

消息丢失如何排查?当我们在使用mq的时候，经常会遇到消息消费异常的问题，原因有很多种，比如：producer发送失败consumer消费异常consumer根本就没收到消息「那么我们该如何排查了?」其实借助RocketMQ-Dashboard就能高效的排查，里面有很多你想象不到的功能。首先我们先查找

 今天我们就来一起学习下消息队列设计的底层模块，Broker的架构设计。MasterBroker与SlaveBroker消息如何同步我们前面知道，要想Broker支持高可用，则将其设计成主从架构，前面的分布式存储也讲了好多这种架构，可以自行查看历史文章哈。首先，我们就来看第一个问题，为了保

【51CTO.com原创稿件】RPC(RemoteProcedureCall)：远程过程调用，它是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术的思想。RPC是一种技术思想而非一种规范或协议，常见RPC技术和框架有：应用级的服务框架：阿里的Dubbo/Dubbox、GooglegR

一、消息队列概述消息队列中间件是分布式系统中重要的组件，主要解决应用解耦，异步消息，流量削锋等问题，实现高性能，高可用，可伸缩和最终一致性架构。目前使用较多的消息队列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ。二、消息队列应用场景以下介绍消息队列在