golang的rabbitmq实现连接池

要在Go中实现RabbitMQ的连接池，你可以使用`github.com/streadway/amqp`库结合`sync.Pool`来管理连接对象。这是一个简单的连接池实现示例：

import (
    "github.com/streadway/amqp"
    "sync"
)

type RabbitMQPool struct {
    connStr string
    pool    *sync.Pool
}

func NewRabbitMQPool(connStr string) *RabbitMQPool {
    return &RabbitMQPool{
        connStr: connStr,
        pool: &sync.Pool{
            New: func() interface{} {
                conn, err := amqp.Dial(connStr)
                if err != nil {
                    panic(err) // 处理连接错误，这里简单起见直接panic
                }
                return conn
            },
        },
    }
}

func (p *RabbitMQPool) GetConnection() *amqp.Connection {
    return p.pool.Get().(*amqp.Connection)
}

func (p *RabbitMQPool) ReleaseConnection(conn *amqp.Connection) {
    p.pool.Put(conn)
}

在上面的示例中，`RabbitMQPool`结构体代表了一个RabbitMQ连接池。`NewRabbitMQPool`函数用于创建一个新的连接池对象，传入RabbitMQ的连接字符串作为参数。

`GetConnection`方法用于从连接池中获取一个可用的连接对象。`ReleaseConnection`方法用于将连接对象放回连接池中。

这样，你就可以在你的代码中使用连接池来获取和释放RabbitMQ连接，而无需每次都重新创建和关闭连接。例如：

pool := NewRabbitMQPool("amqp://guest:guest@localhost:5672/")

// 获取连接
conn := pool.GetConnection()
defer pool.ReleaseConnection(conn)

// 使用连接进行操作，比如发送消息等
// ...

记得在适当的地方处理连接错误和关闭连接。

请注意，这只是一个简单的示例，你可以根据你的实际需求进行适当的修改和扩展，比如添加连接的最大数量、定时检查连接状态等。