死信

  • RocketMQ源码解读——Broker消息存储

    RocketMQ源码解读——Broker消息存储 我们这一篇来看broker的消息存储过程。 broker启动时会启动一个NettyRemotingServer,我们之前说过,rocketmq通过netty做信息传递,这个NettyRemotingServer初始化时,会把Nett...

    后端开发 2020年8月4日 0 0 0
  • SpringBoot整合RabbitMQ之典型应用场景实战三

    实战前言 RabbitMQ 作为目前应用相当广泛的消息中间件,在企业级应用、微服务应用中充当着重要的角色。特别是在一些典型的应用场景以及业务模块中具有重要的作用,比如业务服务模块解耦、异步通信、高并发限流、...

    2020年8月4日 0 0 3
  • Rabbitmq总结

    为什么用rabbitmq? 使用mq主要为了实现解耦、提高系统的健壮性和响应速度,将一些与主链路不需要同步执行的逻辑,直接抛给队列异步处理(注意:开发中采用异步线程发送队列消息,同步的话当队列发生阻塞时,会影...

    2020年8月4日 0 0 2
  • Rabbitmq延迟队列实现定时任务

    场景 开发中经常需要用到定时任务,对于商城来说,定时任务尤其多,比如优惠券定时过期、订单定时关闭、微信支付2小时未支付关闭订单等等,都需要用到定时任务,但是定时任务本身有一个问题,一般来说我们都是通...

    2020年8月4日 0 0 0
  • RabbitMQ 入门知识

    我们在项目里用到了 MQ,但是之前我们发现了很多 MQ 的问题:比如消费者挂了,消费内容堆积,消费者重复循环死亡等情况,之前我对于 MQ 一无所知,这些问题都无法回答——我们的代码看上去很标准,也很简单,似乎没...

    2020年8月4日 0 0 1
  • RabbitMQ高级特性-死信队列

    死信什么是死信消息没有任何消费者去消费就变为死信消息变为死信有以下几种情况消息被拒绝(basic.reject/basic.nack),并且requeue=false消息TTL过期队列达到最大长度死信

    2020年8月4日 0 0 2
  • 用 RabbitMQ 的死信队列来做定时任务

    在开发中做定时任务是一个非常常见的业务场景,在代码层面 Node.js 可以用 setTimeout、setInerval 这种基础语法或用 node-schedule 这些类似的库来达到部分目的,在第三方服务上可以用 Redis 的 Keyspace Notifi...

    2020年8月4日 0 0 0
  • Node.js结合RabbitMQ延迟队列实现定时任务

      存在的一些问题 消耗系统内存,如果定时任务很多,长时间得不到释放,将会一直占用系统进程耗费内存。 单线程如何保障出现系统崩溃后之前的定时任务不受影响?多进程集群模式下一致性的保证? setTimeout...

    2020年8月4日 0 0 1
  • SpringBoot系列(整合RabbitMQ)

    问题: springboot整合RabbitMQ 简单使用。 百度 安装和启动。 原理: 生产者发送消息给 rabbit(交换机,队列,key) 消费者监听队列 处理结果 延迟队列原理: "假延迟队列(先进先出策略,先放进去一个30秒,再放进...

    2020年8月4日 0 0 1
  • 消息队列(四)阿里RocketMQ

    消息队列 RocketMQ 是阿里巴巴集团自主研发的专业消息中间件,基于高可用分布式集群技术,提供消息订阅和发布、消息轨迹查询以及定时(延时)消息、资源统计、监控报警等一系列消息云服务,是企业级互联网架构的...

    2020年8月4日 0 0 1