- @Author：Runsen 来源：尚硅谷 下面建议读者学习尚硅谷的B站的SpringBoot视频，我是学雷丰阳视频入门的。 具体链接如下：B站尚硅谷SpringBoot教程 文章目录 AmqpAdmin 监听rabbitmq 创建交换器，队列 总结 大家好，我是润森 AmqpAdmin AmqpAdmin是 R... @Author：Runsen 来源：尚硅谷 下面建议读者学习尚硅谷的B站的SpringBoot视频，我是学雷丰阳视频入门的。 具体链接如下：B站尚硅谷SpringBoot教程 文章目录 AmqpAdmin 监听rabbitmq 创建交换器，队列 总结 大家好，我是润森 AmqpAdmin AmqpAdmin是 R...
- 1 ACK和NACK 当设置autoACK=false 时，就可以使用手工ACK。 其实手工方式包括了手工ACK、手工NACK。 手工 ACK 时，会发送给Broker一个应答，代表消息处理成功，Broker就可回送响应给ProNACK 则表示消息处理失败，如果设置了重回队列，Broker端就会将没有成功处理的消息重新发送 使用方式 Con消费时，若由于业务异常... 1 ACK和NACK 当设置autoACK=false 时，就可以使用手工ACK。 其实手工方式包括了手工ACK、手工NACK。 手工 ACK 时，会发送给Broker一个应答，代表消息处理成功，Broker就可回送响应给ProNACK 则表示消息处理失败，如果设置了重回队列，Broker端就会将没有成功处理的消息重新发送 使用方式 Con消费时，若由于业务异常...
- RabbitMQ本身没有延时队列功能，无法直接指定一个队列类型为延时队列，然后去延时处理。有两种实现方案：插件和功能搭配。 这里只介绍其二。可以将TTL+DLX相结合，就能组成一个延时队列。 案例 下完订单后20min未付款，就关闭该订单，如果使用RabbitMQ，就需要结合TTL+DLX。 解决方案 先把订单消息设置好15分钟TTL，到点过期后队列将消息转发... RabbitMQ本身没有延时队列功能，无法直接指定一个队列类型为延时队列，然后去延时处理。有两种实现方案：插件和功能搭配。 这里只介绍其二。可以将TTL+DLX相结合，就能组成一个延时队列。 案例 下完订单后20min未付款，就关闭该订单，如果使用RabbitMQ，就需要结合TTL+DLX。 解决方案 先把订单消息设置好15分钟TTL，到点过期后队列将消息转发...
- 1 消息过载 假设RabbitMQ服务器有上万条未处理消息，随便打开一个消费端，会造成巨量消息瞬间全部推送过来，然而我们单个客户端无法同时处理这么多数据。 还比如说单个Pro一分钟产生了几百条数据，但是单个Con一分钟可能只能处理60条，这时Pro-Con不平衡。通常Pro没办法做限制，所以Con就需要做一些限流措施，否则如果超出最大负载，可能导致Con性能下降，服... 1 消息过载 假设RabbitMQ服务器有上万条未处理消息，随便打开一个消费端，会造成巨量消息瞬间全部推送过来，然而我们单个客户端无法同时处理这么多数据。 还比如说单个Pro一分钟产生了几百条数据，但是单个Con一分钟可能只能处理60条，这时Pro-Con不平衡。通常Pro没办法做限制，所以Con就需要做一些限流措施，否则如果超出最大负载，可能导致Con性能下降，服...
- 1 什么是TTL 即生存时间。也就是说： RabbitMQ支持消息的过期时间，可以在消息发送时指定RabbitMQ支持为每个队列设置消息的超时时间，从消息入队开始计算，只要超过队列的超时时间配置，那么消息会被自动清除 2 管控台演示 新增一个队列 新增一个交换机 绑定 队列中也显示了相关的绑定信息 发送消息 10s后，消息被清除为0 ... 1 什么是TTL 即生存时间。也就是说： RabbitMQ支持消息的过期时间，可以在消息发送时指定RabbitMQ支持为每个队列设置消息的超时时间，从消息入队开始计算，只要超过队列的超时时间配置，那么消息会被自动清除 2 管控台演示 新增一个队列 新增一个交换机 绑定 队列中也显示了相关的绑定信息 发送消息 10s后，消息被清除为0 ...
- 1 什么是幂等性 用户对于同一操作发起的一次请求或者多次请求的结果是一致的。 比如数据库的乐观锁,在执行更新操作前,先去数据库查询version,然后执行更新语句,以version作为条件,如果执行更新时有其他人先更新了这张表的数据,那么这个条件就不生效了,也就不会执行操作了,通过这种乐观锁的机制来保障幂等性. 2 Con幂等性 2.1 什么是Con幂等性 消... 1 什么是幂等性 用户对于同一操作发起的一次请求或者多次请求的结果是一致的。 比如数据库的乐观锁,在执行更新操作前,先去数据库查询version,然后执行更新语句,以version作为条件,如果执行更新时有其他人先更新了这张表的数据,那么这个条件就不生效了,也就不会执行操作了,通过这种乐观锁的机制来保障幂等性. 2 Con幂等性 2.1 什么是Con幂等性 消...
- Exchange：接收消息，并根据路由键转发消息所绑定的队列。注意交换机并非一个单独运行的进程，而是一个有着“地址”的列表而已。 蓝区 - Send Message：把消息投递到交换机，由 RoutingKey 路由到指定队列。 1 交换机属性 声明交换机时可以附带许多属性： Name 交换机名称Type 交换机类型，direct、topic、 fanout、 ... Exchange：接收消息，并根据路由键转发消息所绑定的队列。注意交换机并非一个单独运行的进程，而是一个有着“地址”的列表而已。 蓝区 - Send Message：把消息投递到交换机，由 RoutingKey 路由到指定队列。 1 交换机属性 声明交换机时可以附带许多属性： Name 交换机名称Type 交换机类型，direct、topic、 fanout、 ...
- 1 概述 RabbitMQ允许你为messages和queues设置TTL（存活时间）。这可以使用可选的queue 参数或策略来完成（建议使用后一个选项）。 Message TTL可以应用于单个队列，一组队列或逐个消息地应用。 TTL设置也可以由操作策略强制执行。 队列中的 Per-Queue消息TTL Message TTL可以通过使用策略设置message... 1 概述 RabbitMQ允许你为messages和queues设置TTL（存活时间）。这可以使用可选的queue 参数或策略来完成（建议使用后一个选项）。 Message TTL可以应用于单个队列，一组队列或逐个消息地应用。 TTL设置也可以由操作策略强制执行。 队列中的 Per-Queue消息TTL Message TTL可以通过使用策略设置message...
- 背景 RabbitMQ 自 V3.5.0 有优先级队列实现。使用客户端提供的可选参数可将任何队列转换为优先级（但与使用可选参数而不是策略的其他功能不同）。其实现支持有限数量的优先事项：255。但推荐值介于： 1 ~ 10。 使用客户端提供的可选参数 要声明优先级队列，使用 x-max-priority 参数。此参数应为介于 1 和 255 之间的正整数，指示队列应... 背景 RabbitMQ 自 V3.5.0 有优先级队列实现。使用客户端提供的可选参数可将任何队列转换为优先级（但与使用可选参数而不是策略的其他功能不同）。其实现支持有限数量的优先事项：255。但推荐值介于： 1 ~ 10。 使用客户端提供的可选参数 要声明优先级队列，使用 x-max-priority 参数。此参数应为介于 1 和 255 之间的正整数，指示队列应...
- 1 什么是DLX？ 利用DLX，当消息在一个队列中变成死信后，它能被重新发布到另一个Exchange中，这个Exchange就是DLX。 本质就是该消息不会再被任何消费端消费（但你可以自定义某消费者单独处理这些死信）。 2 DLX产生场景 消息被拒绝(basic.reject/basic.nack)，且requeue = false消息因TTL过期队列达到最大长度... 1 什么是DLX？ 利用DLX，当消息在一个队列中变成死信后，它能被重新发布到另一个Exchange中，这个Exchange就是DLX。 本质就是该消息不会再被任何消费端消费（但你可以自定义某消费者单独处理这些死信）。 2 DLX产生场景 消息被拒绝(basic.reject/basic.nack)，且requeue = false消息因TTL过期队列达到最大长度...
- 1 服务端确认 - Transaction模式 注意，此事务非数据库的事务概念！ //将channel设置成事务模式 - channel.txSelect(); //提交事务 - channel.txCommit(); //事务回滚 - channel.txRollback(); 123456 当消息的发布者在将消息发送出去之后，消息到底有没有正确到达... 1 服务端确认 - Transaction模式 注意，此事务非数据库的事务概念！ //将channel设置成事务模式 - channel.txSelect(); //提交事务 - channel.txCommit(); //事务回滚 - channel.txRollback(); 123456 当消息的发布者在将消息发送出去之后，消息到底有没有正确到达...
- 1 安装 brew install rabbitmq 1 默认安装路径 安装成功后，文件在该路径下：/usr/local/Cellar/rabbitmq/版本号/ 2 启动服务器 2.1 命令行启动 进入安装路径后输入 sbin/rabbitmq-server 1 启动服务器，启动成功之后会显示completed with N plugins，我这里... 1 安装 brew install rabbitmq 1 默认安装路径 安装成功后，文件在该路径下：/usr/local/Cellar/rabbitmq/版本号/ 2 启动服务器 2.1 命令行启动 进入安装路径后输入 sbin/rabbitmq-server 1 启动服务器，启动成功之后会显示completed with N plugins，我这里...
- 最开始我们都是编写while循环，通过consumer.nextDelivery方法获取下一条消息，然后进行消费处理。 其实还有另一种选择，使用自定义的Consumer，它更方便，解耦性更强，也是在实际工作中最常用的使用方式。 自定义Con实现只需要继承 DefaultConsumer 类，重写 handleDelivery 方法即可。 代码实现 自定义Con ... 最开始我们都是编写while循环，通过consumer.nextDelivery方法获取下一条消息，然后进行消费处理。 其实还有另一种选择，使用自定义的Consumer，它更方便，解耦性更强，也是在实际工作中最常用的使用方式。 自定义Con实现只需要继承 DefaultConsumer 类，重写 handleDelivery 方法即可。 代码实现 自定义Con ...
- 前言 主题模式下，消费者能够接收到符合某一主题的的消息，消息的匹配规则如下： * (star) 匹配一个字符； # (hash)匹配0~n个字符； 架构如下： image.png 代码 build.gradle plugins { id 'java' } group 'com.nick' version '1.0-SNAPSHOT' sourceComp... 前言 主题模式下，消费者能够接收到符合某一主题的的消息，消息的匹配规则如下： * (star) 匹配一个字符； # (hash)匹配0~n个字符； 架构如下： image.png 代码 build.gradle plugins { id 'java' } group 'com.nick' version '1.0-SNAPSHOT' sourceComp...
- 前言 本文介绍java客户端如何实现工作队列，入下图所示，生产者P生产消息，消息传送到队列，C1,C2轮流消费消息。 image.png 代码 build.gradle plugins { id 'java' } group 'com.nick' version '1.0-SNAPSHOT' sourceCompatibility = 1.8 reposi... 前言 本文介绍java客户端如何实现工作队列，入下图所示，生产者P生产消息，消息传送到队列，C1,C2轮流消费消息。 image.png 代码 build.gradle plugins { id 'java' } group 'com.nick' version '1.0-SNAPSHOT' sourceCompatibility = 1.8 reposi...
上滑加载中
推荐直播
-
香橙派AIpro的远程推理框架与实验案例2025/07/04 周五 19:00-20:00
郝家胜 -华为开发者布道师-高校教师
AiR推理框架创新采用将模型推理与模型应用相分离的机制，把香橙派封装为AI推理黑盒服务，构建了分布式远程推理框架，并提供多种输入模态、多种输出方式以及多线程支持的高度复用框架，解决了开发板环境配置复杂上手困难、缺乏可视化体验和资源稀缺课程受限等痛点问题，真正做到开箱即用，并支持多种笔记本电脑环境、多种不同编程语言，10行代码即可体验图像分割迁移案例。
即将直播 -
鸿蒙端云一体化应用开发2025/07/10 周四 19:00-20:00
倪红军 华为开发者布道师-高校教师
基于鸿蒙平台终端设备的应用场景越来越多、使用范围越来越广。本课程以云数据库服务为例，介绍云侧项目应用的创建、新建对象类型、新增存储区及向对象类型中添加数据对象的方法，端侧（HarmonyOS平台）一体化工程项目的创建、云数据资源的关联方法及对云侧数据的增删改查等操作方法，为开发端云一体化应用打下坚实基础。
即将直播
热门标签