波斯马BOSSMA Information Technology

rabbitmq 下的日志

go-micro集成RabbitMQ实战和原理

发布时间:2022年5月7日 / 分类:Go / 抢沙发

在go-micro中异步消息的收发是通过Broker这个组件来完成的,底层实现有RabbitMQ、Kafka、Redis等等很多种方式,这篇文章主要介绍go-micro使用RabbitMQ收发数据的方法和原理。 Broker的核心功能 Broker的核心功能是Publish和Subscribe,也就是发布和订阅。它们的定义是:...

提升RabbitMQ消费速度的一些实践

发布时间:2019年9月5日 / 分类:RabbitMQ / 抢沙发

RabbitMQ是一个开源的消息中间件,自带管理界面友好、开发语言支持广泛、没有对其它中间件的依赖,而且社区非常活跃,特别适合中小型企业拿来就用。这篇文章主要探讨提升RabbitMQ消费速度的一些方法和实践,比如增加消费者、提高Prefetch count、多线程处理、批量Ack等。 ...

消费者应答(ACK)和发布者确认(Confirm)

发布时间:2017年11月2日 / 分类:RabbitMQ / 抢沙发

这篇文章翻译自:http://www.rabbitmq.com/confirms.html 译注:这里将Consumer Acknowledgements翻译为消费者应答,将Acknowledgement简称为Ack,Acknowledgement本意是应答或者承认,肯定的应答实际产生确认的效果。Publisher Confirms翻译为发布者确认,Confirm本意是通过再...

否定应答(NACK)

发布时间:2017年10月30日 / 分类:RabbitMQ / 抢沙发

这篇文章翻译自:http://www.rabbitmq.com/nack.html 消费者在AMQP 0-9-1中可以选择对投递使用手动ACK。 AMQP 0-9-1规范定义了basic.reject方法,使客户端可以拒绝单个已投递的消息,以及指示代理移除他们或者重新入队列。不幸的是,basic.reject没有提供对大批量消息否定应答...

高可用(镜像)队列

发布时间:2017年10月28日 / 分类:RabbitMQ / 抢沙发

这篇文章翻译自:http://www.rabbitmq.com/ha.html 默认情况下,集群中的队列仅位于其中某一个节点上(队列首次定义的节点)。这与交换机和绑定不同,它们总被视为在所有的节点上。队列还可以在多个节点上设置镜像。每个镜像队列包含一个master和多个mirror,如果master由于某...

RabbitMQ内存警报

发布时间:2017年9月28日 / 分类:RabbitMQ / 抢沙发

这篇文章翻译自:http://www.rabbitmq.com/memory.html 当RabbitMQ Server启动时,以及命令rabbitmqctl set_vm_memory_high_watermark fraction 被执行时,RabbitMQ会检测机器安装的内存。默认情况下,当RabbitMQ Server使用内存超过机器内存的40%时,他会触发一个内存报警,同...

RabbitMQ磁盘警报

发布时间:2017年9月22日 / 分类:RabbitMQ / 抢沙发

这篇文章翻译自:http://www.rabbitmq.com/disk-alarms.html 当磁盘剩余空间下降到一定限制时,RabbitMQ将会阻塞生产者。这是一个好主意,因为即使内存中的消息可以被写入磁盘,但是耗尽磁盘会导致服务器崩溃。默认的情况下,当剩余磁盘空间小于50MB时,RabbitMQ会阻塞生产者,...