Исправление проблемы с очередью недоставленных сообщений в routekey

Решение проблемы невозможности разветвления потребления в теме после указания маршрута

Рекомендуемое соглашение: при наличии маршрута используйте "." для разделения слов, чтобы избежать проблем с универсальными маршрутами

Включить сохранение по умолчанию для обмена, очереди и данных на диск

Включить настройку виртуального хоста по умолчанию /

instanceConsumePool = kelleyRabbimqPool.NewConsumePool()
//Использовать путь виртуального хоста по умолчанию
err := instanceConsumePool.Connect("192.168.1.169", 5672, "admin", "admin")
//Использовать пользовательский путь виртуального хоста
err:=instanceConsumePool.ConnectVirtualHost("192.168.1.169", 5672, "admin", "admin", "/testHost")

Исправить известные проблемы

Увеличить автоматическое повторное подключение при разрыве соединения производителя

Увеличить время случайной повторной попытки задачи потребителя с точностью до секунды
instanceConsumePool.SetRandomRetryTime(min int64, max int64)

Увеличить повторную попытку в пользовательском обратном вызове события потребителя

/***

• Описание параметров
• @param data []byte Полученные данные rabbitmq
• @param header map[string]interface{} Исходный заголовок rabbitmq
• @param retryClient kelleyRabbimqPool.RetryClientInterface Интерфейс данных для повторных попыток, повторные попытки должны возвращать true, чтобы предотвратить повторную отправку данных
  ***/
  EventSuccess: func(data []byte, header map[string]interface{}, retryClient kelleyRabbimqPool.RetryClientInterface) bool {//Если возвращается true, повторная попытка не требуется
  fmt.Printf("data:%s\n", string(data))
  return true
  }

Добавить ручное подтверждение сообщения

Удалить ненужную информацию о выводе

&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)
},
/***

• Описание параметров
• @chancelai data []byte Полученные данные rabbitmq
• @chancelai header map[string]interface{} Исходный заголовок rabbitmq
• @chancelai 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
  },