Golang微服务框架Kratos应用分布式计划任务队列Asynq
Golang微服务框架Kratos应用分布式计划任务队列Asynq 任务队列（Task Queue） 一般用于跨线程或跨计算机分配工作的一种机制。其本质是生产者消费者模型，生产者发送任务到消息队列，消费者负责处理任务。 任务队列的输入是称为任务(Task)的工作单元。专用的工作进程不断监视任务队列以...
Golang微服务框架Kratos应用分布式任务队列Machinery
Golang微服务框架Kratos应用分布式任务队列Machinery 任务队列（Task Queue） 一般用于跨线程或跨计算机分配工作的一种机制。其本质是生产者消费者模型，生产者发送任务到消息队列，消费者负责处理任务。 任务队列的输入是称为任务(Task)的工作单元。专用的工作进程不断监视任务队...
《微服务实战》 第十五章 RabbitMQ 延迟队列
前言实际业务中，例如秒杀系统，秒杀商品成功会有截止时间，这时需要用到RabbitMQ延迟服务。1、RabbitMQ延迟队列1.1、方式1：RabbitMQ通过死信机制来实现延迟队列的功能TTL ，即 Time-To-Live，存活时间，消息和队列都可以设置存活时间Dead Letter，...
21-微服务技术栈（高级）：消息积压与惰性队列
1.消息堆积问题当生产者发送消息的速度超过了消费者处理消息的速度，就会导致队列中的消息堆积，直到队列存储消息达到上限。之后发送的消息就会成为死信，可能会被丢弃，这就是消息堆积问题。解决消息堆积有两种思路：增加更多消费者，提高消费速度。也就是我们之前说的work queue模式扩大队列容积，提高堆积上...
20-微服务技术栈（高级）：MQ死信队列&TTL&延迟队列
1.初识死信交换机1.1.什么是死信交换机当一个队列中的消息满足下列情况之一时，可以成为死信（dead letter）：消费者使用basic.reject或 basic.nack声明消费失败，并且消息的requeue参数设置为false消息是一个过期消息，超时无人消费要投递的队列消息满了，无法投递如...
18-微服务技术栈（高级）：RabbitMQ仲裁队列与集群扩容
从RabbitMQ 3.8版本开始，引入了新的仲裁队列，他具备与镜像队里类似的功能，但使用更加方便。1.添加仲裁队列在任意控制台添加一个队列，一定要选择队列类型为Quorum类型。在任意控制台查看队列：可以看到，仲裁队列的 + 2字样。代表这个队列有2个镜像节点。因为仲裁队列默认的镜像数为5。如果你...
从0到1 手把手搭建spring cloud alibaba 微服务大型应用框架（十三）rocketmq 篇（3）: 消息读写队列，消息存储，消息发送，消息消费关联流程和原理
本文承接上文《从0到1 手把手搭建spring cloud alibaba 微服务大型应用框架（十三）rocketmq 篇（2）:路由注册，消息发送核心流程原理》闲话少说，我们直接上图，我这特意用颜色标注了一下，注意观察颜色相同的部分流程描述消息生产-存储流程1.首选生产者从本地缓存或...
Kratos微服务框架下实现分布式任务队列
Kratos微服务框架下实现分布式任务队列任务队列（Task Queue）一般用于线程或计算机之间分配工作的一种机制。其本质是生产者消费者模型，生产者发送任务到消息队列，消费者负责处理任务。提起分布式任务队列（Distributed Task Queue），就不得不提Python的Celery。而A...
【Spring Cloud】新闻头条微服务项目：使用Reids延迟队列实现文章定时发布（下）
目录一：未来数据定时刷新1.redis key值匹配方案一：keys模糊匹配方案二：scan2.redis管道3.定时刷新功能实现 二：分布式锁解决集群下的方法抢占执行1.问题描述2.分布式锁3.redis分布式锁 4.实现（1）方法添加（2） 代码修改5.数据库同步三：...
【Spring Cloud】新闻头条微服务项目：使用Reids延迟队列实现文章定时发布（上）
前言：最近在做一个基于SpringCloud+Springboot+Docker的新闻头条微服务项目，用的是黑马的教程，现在项目开发进入了尾声，我打算通过写文章的形式进行梳理一遍，并且会将梳理过程中发现的Bug进行修复，有需要改进的地方我也会继续做出改进。这一系列的文章我将会放入微服务项目专栏中&a...
本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。
