首页
编程日记
车载电脑
游戏
tomcat
php
RocketMQ
2024/9/11 2:45:11
聊聊PushConsumer与SimpleConsumer拉取消息的区别
序 本文主要研究一下rocketmq5的PushConsumer与SimpleConsumer拉取消息的区别 ProcessQueueImpl org/apache/rocketmq/client/java/impl/consumer/ProcessQueueImpl.java private void receiveMessageImmediately(String attemptId) {final ClientId clientId consumer.get…
阅读更多...
Centos7 安装RocketMQ(二进制版)
一、介绍 RocketMQ:云原生“消息、事件、流”实时数据处理平台,覆盖云边端一体化数据处理场景 在阿里孕育 RocketMQ的雏形时期,我们将其用于异步通信、搜索、社交网络活动流、数据管道,贸易流程中。随着我们的贸易业务吞吐量的上…
阅读更多...
使用docker创建rocketMQ主从结构,使用
1、 创建目录 mkdir -p /docker/rocketmq/logs/nameserver-a mkdir -p /docker/rocketmq/logs/nameserver-b mkdir -p /docker/rocketmq/logs/broker-a mkdir -p /docker/rocketmq/logs/broker-b mkdir -p /docker/rocketmq/store/broker-a mkdir -p /docker/rocketmq/store/b…
阅读更多...
RocketMQ学习(二)
文章目录 1. 案例介绍1.1 业务分析1)下单2)支付 1.2 问题分析问题1如何保证数据的完整性?使用MQ保证在下单失败后系统数据的完整性 问题2如何处理第三方支付平台的异步通知通过MQ进行数据分发,提高系统处理性能 2. 技术分析2.1 技…
阅读更多...
消息队列选型(RabbitMq、RocketMq、Kafaka)
文章目录 前言RabbitMq优点缺点 RocketMq优点缺点 Kafaka优点缺点 总结 前言 当引入消息队列时,常见的选择包括ActiveMQ、Kafka、RabbitMQ和RocketMQ。然而,近年来,ActiveMQ的活跃度已经下降,很多公司已经不再使用这款消息队列中…
阅读更多...
RocketMQ 部署
RocketMQ 部署 1、安装依赖(Java) [rootMicroservices ~]# mkdir -p /data/businessServer/ [rootMicroservices ~]# cd /data/businessServer/# 获取安装包(下载较慢) [rootMicroservices businessServer]# wget https://githu…
阅读更多...
RocketMQ 实战:在 macOS 上安装与前端访问全流程指南
RocketMQ 是一款高性能的分布式消息队列中间件,在微服务架构中得到了广泛应用。本文将引导您在 macOS 上安装 RocketMQ,并使用 RocketMQ 控制台进行前端访问和管理。同时,我们将涵盖如何优雅地关闭相关服务,以确保系统的稳定性。 …
阅读更多...
【消息队列】消息中间件介绍
目录 电商系统引发的思考实现支付业务时使用串行操作(同步)串行操作存在的问题根据上述的几个问题,在设计系统时可以明确要达到的目标 消息中间件【MQ(Message Queue)】使用场景1.应用解耦2.异步提速3.流量削峰举个栗子…
阅读更多...
CentOS 部署 RocketMQ 详细指南
1. RocketMQ 5.3.0 简介 什么是 RocketMQ? Apache RocketMQ 是一个分布式消息中间件,最初由阿里巴巴开发并开源。它基于发布-订阅(Pub-Sub)模式,具有高性能、低延迟和高可靠性等特点。RocketMQ 支持大规模消息流处理…
阅读更多...
基于 RocketMQ 的云原生 MQTT 消息引擎设计
作者:沁君 概述 随着智能家居、工业互联网和车联网的迅猛发展,面向 IoT(物联网)设备类的消息通讯需求正在经历前所未有的增长。在这样的背景下,高效和可靠的消息传输标准成为了枢纽。MQTT 协议作为新一代物联网场景中…
阅读更多...
SpringCloud Alibaba】(十三)学习 RocketMQ 消息队列
目录 1、MQ 使用场景与选型对比1.1、MQ 的使用场景1.2、引入 MQ 后的注意事项1.3、MQ 选型对比 2、下载、安装 RocketMQ 及 RocketMQ 控制台2.1、下载安装 RocketMQ2.2、测试 RocketMQ 环境2.3、RocketMQ 控制台【图形化管理控制台】2.3.1、下载、安装2.3.2、验证 RocketMQ 控制…
阅读更多...
RocketMQ搭建集群监控平台
一、概述 RocketMQ有一个对其扩展的开源项目incubator-rocketmq-externals,这个项目中有一个子模块叫rocketmq-console,这个便是管理控制台项目了,先将incubator-rocketmq-externals拉到本地,因为我们需要自己对rocketmq-console…
阅读更多...
rotcketmq实践 吞吐量 发送重试 重试消费 异步 批量发送
吞吐量对比 Kafka、RabbitMQ、RocketMQ消息中间件的对比—— 消息发送性能 测试目的 对比Kafka、RabbitMQ、RocketMQ发送小消息(124字节)的性能。这次压测我们只关注服务端的性能指标,所以压测的标准是: 不断增加发送端的压力,直到系统吞吐量不再上升,而响应时间拉长。这时服…
阅读更多...
Apache RocketMQ知识点表格总结及示例
RocketMQ的使用大概还是四五年前的时候,最近几年参与的项目基本上都是使用的RabbitMQ,就我个人来说,我也更喜欢使用RabbitMQ,不过消息队列的功能都差不多,大同小异。原理也类似。我喜欢使用RabbitMQ,是因为RabbitMQ安装…
阅读更多...
RocketMQ:broker配置说明
RocketMQ broker配置项的简要说明:serverSelectorThreads: 服务器选择器线程数,用于处理网络请求。brokerRole: 指定Broker的角色,如ASYNC_MASTER表示异步主节点。serverSocketRcvBufSize: 服务器套接字接收缓冲区大小。osPageCacheBusyTimeO…
阅读更多...
经验笔记:选择消息中间件——RabbitMQ vs RocketMQ vs Apache Kafka
经验笔记:选择消息中间件——RabbitMQ vs RocketMQ vs Apache Kafka 一、引言 消息中间件是现代分布式系统的重要组成部分,用于在不同的服务之间传递消息,实现解耦和异步通信。选择合适的消息中间件对于确保系统高效运行、增强可维护性和扩…
阅读更多...