Rabbitmq可靠消息投递,消息确认机制

前言 我们知道,消息从发送到签收的整个过程是 Producer-->Broker/Exchange-->Broker/Queue-->Consumer,因此如果只是要保证消息的可靠投递,我们需要考虑的仅是前两个阶段,因为消息只要成功到达队列,就算投递成功。 比如投递消息时指定的Exchange不存在 ... »

Kafka Eagle 管理平台

Kafka-Eagle简介 源代码地址:https://github.com/smartloli/kafka-eagle Kafka Eagle是什么 Kafka Eagle是一款用于监控和管理Apache Kafka的完全开源系统,目前托管在Github,由笔者和一些开源爱好者共同维护。它提供了完 ... »

Go之NSQ简介,原理和使用

NSQ简介 NSQ是Go语言编写的一个开源的实时分布式内存消息队列,其性能十分优异。 NSQ 是实时的分布式消息处理平台,其设计的目的是用来大规模地处理每天数以十亿计级别的消息。它具有分布式和去中心化拓扑结构,该结构具有无单点故障、故障容错、高可用性以及能够保证消息的可靠传递的特征 适合小型项目使用 ... »

部署rabbitMQ镜像集群实战测试

部署rabbitMQ镜像集群 版本信息 rabbit MQ: 3.8.5 Erlang: 官方建议最低21.3 推荐22.x 这里用的是23 环境准备 主机规划 主机 节点 172.16.14.3 磁盘节点 172.16.14.4 内存节点 172.16.14.5 磁盘节点 内存节点: 内存节点将所 ... »

Kafka源码解析(二)---Log分析

上一篇文章讲了LogSegment和Log的初始化,这篇来讲讲Log的主要操作有哪些。 一般来说Log 的常见操作分为 4 大部分。 高水位管理操作 日志段管理 关键位移值管理 读写操作 其中关键位移值管理主要包含Log Start Offset 和 LEO等。 高水位HighWatermark 高 ... »

Centos7快速安装RocketMQ

1. 为什么要用MQ 消息队列是一种“先进先出”的数据结构 其应用场景主要包含以下3个方面 应用解耦 系统的耦合性越高,容错性就越低。以电商应用为例,用户创建订单后,如果耦合调用库存系统、物流系统、支付系统,任何一个子系统出了故障或者因为升级等原因暂时不可用,都会造成下单操作异常,影响用户使用体验。 ... »

RabbitMQ从入门到精通(三)

[TOC] 1. 自定义消费者使用 我们之前呢都是在代码中编写while循环,进行 方法进行获取下一条消息,然后进行消费处理! 其实我们还可以使用自定义的Consumer,它更加的方便,解耦性更加的强,也是在实际工作中最常用的使用方式! 自定义消费端实现只需要继承 类,重写 方法即可   ... »

[分布式学习]消息队列之rocketmq笔记

"文档地址" "RocketMQ架构" "哔哩哔哩上的视频" mq有很多,近期买了《分布式消息中间件实践》这本书,学习关于mq的相关知识。mq大致有有4个功能: 1. 异步处理。比如业务端需要给用户发送邮件,不需要等发送完了之后才让业务端的调用代码返回。 2. 服务解耦。服务之间调用不需要在代码上写 ... »

RabbitMQ学习笔记

简介 RabbitMQ是实现了高级消息队列协议(AMQP)的开源消息中间件,基于Erlang语言编写。 AMQP是什么 AMQP 0-9-1(高级消息队列协议)是一种消息传递协议,它允许一致的客户端应用程序与一致的消息传递中间件代理进行通信。 消息传递代理接收来自发布者(发布它们的应用程序,也称为生 ... »

消息队列之利器锋芒

随着企业的发展,所用的系统越来越复杂。系统势必会发展成分布式系统。消息队列中间件是分布式系统中重要的组件,主要解决应用耦合,异步消息,流量削锋,可靠投递,广播,最终一致性等问题。实现高性能,高可用,可伸缩和最终一致性架构。 当前使用较多的 消息队列 有 RabbitMQ、RocketMQ、Activ ... »

初识RabbitMQ

好久没有更新技术博客了,今天正好有点时间,自学了一下RabbitMQ,现在就将我所学到的东西分享给大家,让你们也能同我一起进步,在程序员的技术道路上,一直前进下去。 首先学习技术,我觉得还是能在官网去学习,这样才能学到最权威,最新的技术。毕竟是初学者,如果就一味的通过百度去学习技术,有可能会遇到不断 ... »

性能提升五十倍:消息队列延时聚合通知的重要性

前言 这个话题对我而言,是影响很久的事情。从第一次使用消息队列开始,业务背景是报名系统通知到我们的系统。 队列通知 队列通知 正常流量下数据都能正常通知过来,但遇到导入报名人时,采用了Task异步通知,数据量一大,队列就死了。当时是尽量采用同步方式,减少并发量。 营销系统 营销系统 后来业务上有了专 ... »

Java SpringBoot集成RabbitMq实战和总结

摘要:在公司里一直在用RabbitMQ,由于api已经封装的很简单,关于RabbitMQ本身还有封装的实现没有了解,最近在看RabbitMQ实战这本书,结合网上的一些例子和spring文档,实现了RabbitMQ和spring的集成,对着自己平时的疑惑做了一些总结。 [TOC] 关于RabbitMQ ... »

[译]RabbitMQ教程C#版 - 主题

先决条件 本教程假定RabbitMQ已经安装,并运行在 标准端口(5672)。如果你使用不同的主机、端口或证书,则需要调整连接设置。 从哪里获得帮助 如果您在阅读本教程时遇到困难,可以通过邮件列表 "联系我们" 。 主题 (使用.NET客户端) 在 "教程[4]" 中,我们改进了我们日志系统。我们用 ... »

[译]RabbitMQ教程C#版 - 路由

先决条件 本教程假定RabbitMQ已经安装,并运行在 标准端口(5672)。如果你使用不同的主机、端口或证书,则需要调整连接设置。 从哪里获得帮助 如果您在阅读本教程时遇到困难,可以通过邮件列表 "联系我们" 。 路由 (使用.NET客户端) 在 "教程[3]" 中,我们构建了一个简单的日志系统, ... »