go-rabbitmq 是一个用于封装 RabbitMQ 操作的 Go 语言库，提供了连接和通道的重连与复用功能，旨在提高 RabbitMQ 的使用效率和稳定性。
-
Connection 的重连复用
- 实现了连接的自动重连机制，确保在连接丢失后可以重新建立连接并继续操作。优化主动关闭时和正处于重连情况的处理逻辑。
-
Logger 对象的复用
- 提供了 Logger 对象的复用功能，以便在不同的操作中保持一致的日志记录。
-
Channel 的重连复用
- 实现了通道的自动重连机制，支持在通道断开后重新建立通道并继续使用。
-
基础 Publish 的 Demo
- 提供了一个简单的示例，展示如何使用复用的通道来发布消息。支持直连和路由两种方式。
- 已实现Publish的多个发送并能够成功重连发送
- 提供Simple模式Demo
- 提供Work模式Demo
- 提供Publish模式Demo
- 提供Routing模式dome
- 提供Topic模式dome
-
Quene的重试创建持久化
- 提供了一个简单的示例，展示如何使用复用的通道来发布消息。支持直连和路由两种方式。
6 Consume封装以及参数的选项设计模式函数定义
- 提供了一个对Consume的封装，能够实现Connection的复用，Consumer独占Channel通道来消费消息。
- 已经实现重连机制以及自动声明交换机和队列
- 提供Simple模式Demo
- 提供Publish模式Demo
- 提供Routing模式dome
- 提供Topic模式dome
-
Log传递优化
- log输出会突然停止，但是一直在发送
-
完善 Publish 的发送 Demo
- simple模式dome
- work模式dome
- Publish模式dome
- Routing模式dome
- Topic模式dome
- Rpc模式dome
-
实现 Consume 的消费 Demo
提供消费消息的示例代码，并实现相关参数配置，包括是否需要在释放时重置通道。(已实现结构定义，消费函数实现)- simple模式dome
- work模式dome
- Publish模式dome
- Routing模式dome
- Topic模式dome
- 并发情况下多消费者重连机制
- Rpc模式dome
-
Channel是否需要来维护sync.Pool
如果继续按这个方法实现，要将channel重连状态单独为，在ConnectionManager上层统一维护所有channel状态- 修改为正常创建独享
使用 go get 安装 go-rabbitmq 库：
go get github.com/whyy1/go-rabbitmq