go get -u gitee.com/tym_hmm/rabbitmq-pool-go

var oncePool sync.Once
var instanceRPool *kelleyRabbimqPool.RabbitPool
func initrabbitmq() *kelleyRabbimqPool.RabbitPool {
	oncePool.Do(func() {
        // Инициализируем производителя
		instanceRPool = kelleyRabbimqPool.NewProductPool()
        // Инициализируем потребителя
	    instanceConsumePool = kelleyRabbimqPool.NewConsumePool()
        // Используем виртуальный хост "/" по умолчанию
		err := instanceRPool.Connect("192.168.1.202", 5672, "guest", "guest")
        // Используем пользовательский виртуальный хост
        // err:=instanceConsumePool.ConnectVirtualHost("192.168.1.202", 5672, "guest", "guest", "/testHost")
		if err != nil {
			fmt.Println(err)
		}
	})
	return instanceRPool
}

var wg sync.WaitGroup
	for i:=0;i<100000; i++ {
		wg.Add(1)
		go func(num int) {
			defer wg.Done()
			data:=kelleyRabbimqPool.GetRabbitMqDataFormat("testChange5", kelleyRabbimqPool.EXCHANGE_TYPE_TOPIC, "textQueue5", "/", fmt.Sprintf("Здесь данные %d", num))
			_=instanceRPool.Push(data)
		}(i)
	}
	wg.Wait()

nomrl := &rabbitmq.ConsumeReceive{
        # Определяем событие потребителя
        ExchangeName: "testChange31",// Имя очереди
        ExchangeType: kelleyRabbimqPool.EXCHANGE_TYPE_DIRECT,
        Route:        "",
        QueueName:    "testQueue31",
        IsTry:true,// Перепробовать ли
        IsAutoAck: false, // Автоматически подтверждать сообщение
        MaxReTry: 5,// Максимальное количество повторных попыток
        EventFail: func(code int, e error, data []byte) {
        	fmt.Printf("error:%s", e)
        },
        /***
         * Параметры пояснения
         * @param data []byte Полученное сообщение rabbitmq
         * @param header map[string]interface{} Исходный заголовок rabbitmq
         * @param retryClient RabbitmqPool.RetryClientInterface Пользовательский интерфейс для повторной попытки данных, необходимо вернуть true, чтобы предотвратить повторную отправку данных
         ***/
        EventSuccess: func(data []byte, header map[string]interface{},retryClient kelleyRabbimqPool.RetryClientInterface)bool {// Если возвращается true, повторная попытка не требуется
            _ = retryClient.Ack()// Подтвердить сообщение    	
            fmt.Printf("data:%s\n", string(data))
        	return true
        },
	}
	instanceConsumePool.RegisterConsumeReceive(nomrl)

	err := instanceConsumePool.RunConsume()
	if err != nil {
		fmt.Println(err)
	}