【消息中间件】RocketMQ的默认发送流程，你简单的回答下？
前言大家好，我是小郭，上一篇文章我们介绍了RocketMQ消息发送中的默认消息发送者，打开源码跟踪了消息发送者从未启动到运行中的一个过程，今天我们就开始学习下默认消息发送流程，学习他的实现思路，也帮助我们工作中，遇到了问题不会手足无措。思考问题消息发送者是如何做负载均衡的？消息发送者是如何保证高可用的？消息发送批量消息如何保证一致性的？默认发送流程-工作原理源码入口：org.apache.roc....
【消息中间件】RocketMQ消息发送-请求与响应
前言大家好，我是小郭，前面的文章介绍了，RocketMQ的搭建，以及RocketMQ的NameServer，接下来我们配合着官方提供的demo，进行实际的消息发送学习，主要学习发送方式、发送参数的含义，以及发送中的一些问题。消息发送的方式可靠同步发送，需要等待服务器响应结果。可靠异步发送，不等待服务器响应结果直接返回，当收到Broker的响应结果后调用SendCallback回调函数。单向发送，....
【消息中间件】你还不会在Docker下安装RocketMQ吗？
网络异常，图片无法展示|前言大家好，我是小郭，工欲善其事，必先利其器，在学习消息中间件-RocketMQ之前，先来准备一下学习环境的搭建，下面分享一下Docker环境中安装RocketMQ和RocketMQ-Console。1. 在Docker中安装RocketMQ主要五个步骤，我们就可以完成RocketMQ的搭建。Step1: Dokcer搜索RocketMQdocker search roc....
【消息中间件】默认RocketMQ消息发送者是如何启动的？
前言上一篇文章，主要介绍了RocketMQ消息发送-请求与响应，了解了消息发送的请求参数和响应结果，今天我们主要来学习默认消息发送者的源码，看看消息发送主要是做了那哪些事情。思考问题对于过期的请求，发送者是如何处理的？MQClientFactory的作用是什么？默认消息发送者-工作原理源码入口：org.apache.rocketmq.client.producer.DefaultMQProduc....
消息中间件（RocketMQ）笔记
1、rocketmq是分布式消息中间件，消息队列。支持同步、异步、单向。 （1）同步：发送请求后，会同步等待Broker服务器返回结果，支持发送失败重试，适用于比较重要的消息通知场景。 （2）异步：异步发送请求，不会阻塞当前线程，不支持失败重试，适用于对响应时间要求更高的场景。 （3）单向：单向发送原理和异步一致，但不支持回调。适用于响应时间非常短，对可靠性要求不高的场景，例如日志收集。2、四大....
云原生中间件RocketMQ-消费者消费模式之广播模式
PushConsumer消费模式-广播模式广播消费： 当使用广播消费模式时， 消息队列 RocketMQ 会将每条消息推送给集群内所有注册过的客户端， 保证消息至少被每台机器消费一次。相比于集群模式，广播模式的特点为： 每个消费者都会消费所订阅的Topic + Tag下的所有queue中的所有消息。适用场景&注意事项：广播消费模式下不支持顺序消息。广播消费模式下不支持重置消费位点。每条消....
云原生中间件RocketMQ源码包结构和集群架构模型
源码包结构进入rocket的github官方地址：https://github.com/apache/rocketmq可以看到当前最新的 releases 版本是4.9.4，下载最新的源码包到本地。执行以下命令解压源码包，并通过maven打包构建。unzip rocketmq-all-4.9.4-source-release.zip cd rocketmq-all-4.9.4-source-re....
windows环境下消息中间件RocketMq的搭建
1、下载RocketMqrocketMq是阿里巴巴的消息中间件，不过阿里巴巴已经把rocketmq交给开源组织apache维护了，所以下载地址是http://rocketmq.apache.org/release_notes/release-notes-4.3.0/下载之后解压2、环境变量配置2.1 名称服务器ip地址2.2 rocketmq安装路径(可选，最好配置)3、启动 3.1 ...
消息中间件ActiveMQ、RabbitMQ、RocketMQ、ZeroMQ、Kafka如何选型？
最近要为公司的消息队列中间件进行选型，市面上相关的开源技术又非常多，如ActiveMQ、RabbitMQ、ZeroMQ、Kafka，还有阿里巴巴的RocketMQ等。这么多技术，如何进行选型呢？首先对于阿里的RocketMQ，因为是阿里开源的，对于国内开源的保持谨慎的态度，暂时不采取该中间件。所以只能在ActiveMQ、RabbitMQ、ZeroMQ、Kafka中间选一款作为消息队列中间件。下面....
消息中间件-RocketMq
mq messageQuence消息队列作用:解耦 流量削峰 处理数据问题: 一致性 可用性 复杂性2.mq产品比较特性avtiveMQRabbitMQRocketMQkafka开发语音javaerLangjavascala单机吞吐量万级万级10w10w时效性msusmsms可用性高(主从架构)高(主从架构)非常高(分布式)非常高(分布式)功能特性比较成熟,文档多性能好扩展性好大数据应用3.快速....
本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。
中间件更多rocketmq相关
中间件
为企业提供高效、稳定、易扩展的中间件产品。
+关注