spring:
  # Название проекта
  application:
    name: rabbitmq-consumer
  # RabbitMQСлужить Конфигурация  rabbitmq:
    host: 127.0.0.1
    port: 5672
    username: guest
    password: guest
    listener:
      simple:
        # Механизм повтора
        retry:
          enabled: true #Включить ли повторную попытку потребителя
          max-attempts: 5 #Максимальное количество повторов
          initial-interval: 5000ms #Интервал повтора (единица миллисекунды)
          max-interval: 1200000ms #Максимальный интервал повтора (в миллисекундах)
          multiplier: 2 #Множитель интервала времени, интервал времени * множитель = следующий из интервала времени, максимум не может превышать установленный из максимального интервала времени

<!-- AMQP-клиент -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
    <version>2.4.1</version>
</dependency>

spring:
  # Название проекта
  application:
    name: rabbitmq-provider
  # RabbitMQСлужить Конфигурация  rabbitmq:
    host: 127.0.0.1
    port: 5672
    username: guest
    password: guest

package com.pjb.config;
 
import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
 
/**
 * Класс RabbitMQConfiguration
 * @author pan_junbiao
 **/
@Configuration
public class RabbitMqConfig
{
    public static final String QUEUE_NAME = "queue_name"; //очередьимя    public static final String EXCHANGE_NAME = "exchange_name"; //Название обменника
    public static final String ROUTING_KEY = "routing_key"; //ключ маршрутизации
 
    /**
     * очередь
     */
    @Bean
    public Queue queue()
    {
        /**
         * Createturn, описание параметра:
         * String name：очередьимя。         * boolean прочный: установите, будет ли сохраняться, значение по умолчанию — false。durable установлен на true Это означает настойчивость, иначе это означает ненастойчивость.
         * Изочередность персистентности будет сохранена на диске, и соответствующая информация не будет потеряна при перезапуске сервера.
         * boolean эксклюзивный: установите, будет ли он эксклюзивным, по умолчанию также ЛОЖЬ. для true Затем установите режим эксклюзивного доступа.
         * boolean autoDelete: установите, следует ли удалять автоматически, т.е. true Затем установите автоматическое удаление,
         * Если ни один производитель или потребитель не использует эту очередь, она автоматически удаляется.
         * Map<String, Object> аргументы: установите некоторые другие параметры.
         */
        return new Queue(QUEUE_NAME, true, false, false, null);
    }
 
    /**
     * Прямой переключатель
     */
    @Bean
    public DirectExchange exchange()
    {
        /**
         * Создание обменника, описание параметров:
         * String имя: имя переключателя
         * boolean прочный: установите, будет ли сохраняться, значение по умолчанию — false。durable установлен на true Это означает настойчивость, иначе это означает ненастойчивость.
         * Постоянство позволяет сохранить переключатель на диск, чтобы соответствующая информация не потерялась при перезапуске сервера.
         * boolean autoDelete: установите, следует ли удалять автоматически, т.е. true Затем установите автоматическое удаление,
         */
        return new DirectExchange(EXCHANGE_NAME, true, false);
    }
 
    /**
     * обязательность
     */
    @Bean
    Binding binding(DirectExchange exchange, Queue queue)
    {
        //Воляочередьи переключитьсяобязательность, И установите ключ, используемый для сопоставления: routerKey
        return BindingBuilder.bind(queue).to(exchange).with(ROUTING_KEY);
    }
}

package com.pjb;
 
import com.pjb.config.RabbitMqConfig;
import org.junit.jupiter.api.Test;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
 
/**
 * Тестовый класс RabbitMq
 * @author pan_junbiao
 **/
@SpringBootTest
public class RabbitMqTest
{
    @Autowired
    RabbitTemplate rabbitTemplate;
 
    @Test
    public void sendMessage()
    {
        String message = «Здравствуйте, добро пожаловать в гости pan_junbiaoизблог";
        rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_NAME, RabbitMqConfig.ROUTING_KEY, message);
        System.out.println("Сообщение отправлено успешно!");
    }
}

<!-- AMQP-клиент -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
    <version>2.4.1</version>
</dependency>

spring:
  # Название проекта
  application:
    name: rabbitmq-consumer
  # RabbitMQСлужить Конфигурация  rabbitmq:
    host: 127.0.0.1
    port: 5672
    username: guest
    password: guest
    listener:
      simple:
        # Механизм повтора
        retry:
          enabled: true #Включить ли повторную попытку потребителя
          max-attempts: 5 #Максимальное количество повторов
          initial-interval: 5000ms #Интервал повтора (единица миллисекунды)
          max-interval: 1200000ms #Максимальный интервал повтора (в миллисекундах)
          multiplier: 2 #Множитель интервала времени, интервал времени * множитель = следующий из интервала времени, максимум не может превышать установленный из максимального интервала времени

package com.pjb.receiver;
 
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
 
import java.text.SimpleDateFormat;
import java.util.Date;
 
/**
 * получатель
 * @author pan_junbiao
 **/
@Component
@RabbitListener(queues="queue_name")
public class Receiver
{
    @RabbitHandler
    public void process(String message)
    {
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("Получить сообщение: " + message + " Время получения: " + sdf.format(new Date()));
        throw new RuntimeException();
    }
}