RabbitMQ 常见交换机类型


RabbitMQ 提供了 四种核心的交换机类型,每种类型决定了消息如何从交换机路由到队列。以下是详细的介绍:1. Direct Exchange(直连交换机)路由规则:消息的 routing key 必须与队列的 binding key 完全匹配。使用场景:适用于点对点消息传递,例如将消息发送到特定

RabbitMQ 发布订阅模式


介绍发布/订阅模式(Publish/Subscribe Pattern)是 RabbitMQ 中非常重要的消息传递模式之一,它允许你将消息广播给多个消费者。与 Worker Queue 模式不同,发布/订阅模式的核心思想是 一条消息会被多个消费者同时接收。发布/订阅模式的核心概念、在发布/订阅模式中

RabbitMQ 持久化


在 RabbitMQ 中,消息是否会在重启后保留,取决于消息和队列的持久化设置。以下是详细分析:1. 队列持久化,消息不持久化队列持久化:队列的元数据(如队列名称、绑定关系等)会被保存到磁盘,RabbitMQ 重启后队列仍然存在。消息不持久化:消息不会被保存到磁盘,RabbitMQ 重启后消息会丢失

RabbitMQ worker queue


producerpackage mainimport ("log""os""strings"amqp "github.com/rabbitmq/amqp091-go")func failOnError(err error

RabbitMQ 发送文本并接收


Sendpackage mainimport ("context""log""time"amqp "github.com/rabbitmq/amqp091-go")func failOnError(err error,

RabbitMQ发送文本消息


在 RabbitMQ 中,PublishWithContext 方法用于将消息发送到指定的交换机或队列。以下是 PublishWithContext 方法的参数详细说明:方法签名func (ch *Channel) PublishWithContext( ctx context.Context

RabbitMQ 队列声明


这段代码是使用 Go 语言操作 RabbitMQ 的示例,调用了 QueueDeclare 方法来声明一个队列。QueueDeclare 是 RabbitMQ 客户端库中的一个方法,用于声明或创建一个队列。以下是每个参数的含义:函数签名func (ch *Channel) QueueDeclare(

RabbitMQ 安装


docker run -d \ > --name rabbitmq \> -p 5672:5672 \> -p 15672:15672 \> -v

B+树Go实现

笔记  Go 

B+树动画演示https://www.cs.usfca.edu/~galles/visualization/BPlusTree.htmlpackage main/*B+树动画演示https://www.cs.usfca.edu/~galles/visualization/BPlusTree.html

Golang math/big库处理大数字

笔记  Go 

在日常的开发过程中,不可避免的需要使用到超过变量类型的数值计算,在 go 语言中,int64 类型的变量的储存范围是-9223372036854775808 ~ 9223372036854775807,当我们需要计算的数值大于这个范围之后,计算出的结果就会出错,这时候就需要使用到go 语言中专门为大