文章 2023-01-16 来自:开发者社区

Docker 安装 RocketMQ 并结合 SpringBoot 使用实例

在《浅入浅出消息队列》一文中,我们了解了消息队列的作用、优缺点和使用场景,相信你对消息队列已经有了一个大致的概念,文末给自己埋的坑说日后会写一篇实战教程,正好现在实习结束了,也许久没有写实战教程了,于是这就来填坑了。前置知识阅读本文前,建议有一些前置知识,包括且不限于:常见的 Linux 命令消息队列的相关知识Docker 的基本使用docker-compose 的基础知识SpringBoot ....

Docker 安装 RocketMQ 并结合 SpringBoot 使用实例
文章 2022-11-20 来自:开发者社区

Springboot 集成 Rocketmq 消费者|学习笔记

开发者学堂课程【RocketMQ 知识精讲与项目实战(第二阶段):Springboot 集成 Rocketmq 消费者】学习笔记,与课程紧密联系,让用户快速学习知识。课程地址:https://developer.aliyun.com/learning/course/703/detail/12398Springboot 集成 Rocketmq 消费者内容介绍:一、添加依赖二、配置文件三、启动类四、....

Springboot 集成 Rocketmq 消费者|学习笔记
文章 2022-11-20 来自:开发者社区

Springboot 集成 Rocketmq 生产者|学习笔记

开发者学堂课程【RocketMQ 知识精讲与项目实战(第二阶段):Springboot 集成 Rocketmq 生产者】学习笔记,与课程紧密联系,让用户快速学习知识。课程地址:https://developer.aliyun.com/learning/course/703/detail/12397Springboot 集成 Rocketmq 生产者内容介绍:一、准备工作二、添加依赖三、配置文件四....

Springboot 集成 Rocketmq 生产者|学习笔记
文章 2022-09-29 来自:开发者社区

SpringBoot整合RocketMQ发送消息过滤

Tag过滤通过消费者端指定要订阅消息的Tag,如果订阅多个Tag的消息,Tag间使用或运算符(||)连接SQL过滤SQL过滤是一种通过特定表达式对事先埋入到消息中的用户属性进行筛选过滤的方式。通过SQL过滤,可以实现对消息的复杂过滤。不过,只有使用PUSH模式的消费者才能使用SQL过滤。SQL过滤表达式中支持多种常量类型与运算符。支持的常量类型:数值:比如:123,3.1415字符:必须用单引号....

文章 2022-09-29 来自:开发者社区

SpringBoot整合RocketMQ发送批量消息

发送限制生产者进行消息发送时可以一次发送多条消息,这样可以提升发送效率,需注意以下几点:批量发送的消息必须具有相同的Topic批量发送的消息必须具有相同的刷盘策略批量发送的消息不能是延时消息与事务消息批量发送大小默认情况下,一批发送的消息总大小不能超过4MB字节。如果想超出该值,有两种解决方案:方案一:将批量消息进行拆分,拆分为若干不大于4M的消息集合分多次批量发送方案二:在Producer端与....

文章 2022-09-27 来自:开发者社区

springboot 如何优雅的使用 alibaba rocketmq 消息队列

文章保证,一路执行下去不会报错,报错你找我。如果觉得有用,希望屏幕前的大佬,点赞➕关注只有想到的方面多时,才能在够实际运用中发现更多的问题,这也是作者给读者最好的礼物使用这篇文章 docker 安装 rocketmq,肯定没问题<br/>新建 springboot 项目新建一个 springboot 项目,pom 文件如下,rocketmq 使用 apache 封装的 jar<....

文章 2022-09-26 来自:开发者社区

SpringBoot整合RocketMQ发送事务消息

事务消息1. 概念分布式事务:一次操作由若干分支操作组成,这些分支操作分属不同应用,分布在不同服务器上。分布式事务需要保证这些分支操作要么全部成功,要么全部失败,分布式事务于普通事务一样,就是为了保证操作结果的一致性事务消息:RocketMQ提供了类似X/Open XA的分布式事务功能,通过事务消息能达到分布式事务的最终一致。XA是一种分布式事务解决方案,一种分布式事务处理模式半事务消息:暂不能....

文章 2022-09-26 来自:开发者社区

SpringBoot整合RocketMQ发送延时消息

1. 延时等级延时时长不支持随意时长的延迟,是通过特定的延迟等级来指定的,默认变量有1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h,分别对应1~18等级。例如等级为3,对应于10s如果需要自己定义延时等级,需要在broker加载的配置文件中配置messageDelayLevelmessageDelayLevel = 1s 5s....

文章 2022-09-26 来自:开发者社区

SpringBoot整合RocketMQ发送顺序消息

1. 有序性分类根据有序范围的不同,可以分为两种消息的有序性:分区有序和全局有序分区有序有多个Queue参与,其仅可保证在该Queue分区队列上的消息顺序,称为分区有序在定义Producer时我们可以指定消息队列选择器,而这个选择器是我们自己实现了MessageQueueSelector接口定义的。在定义选择器的选择算法时,一般需要使用选择key。这个选择key可以是消息key也可以是其它数据。....

文章 2022-09-24 来自:开发者社区

SpringBoot整合RocketMQ发送普通消息

消息发送分类1、同步发送消息生产者发出一条消息后,会在收到MQ返回的ACK之后才发下一条消息。此类消息可靠性最高,但消息发送效率低2、异步发送消息生产者发出消息后无需等待MQ返回ACK,直接发送下一条消息。此类消息可靠性可以得到保障,消息发送效率也可3、单向发送消息生产者仅负责发送消息,不等待、不处理MQ的ACK,此类方式MQ也不返回ACK,消息发送效率最高,但消息可靠性较差配置信息生产者roc....

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

微服务

构建可靠、高效、易扩展的技术基石

+关注