Сообщения

Показаны сообщения с ярлыком "AMQP"

Spring Boot: обмен сообщениями, AMQP, RabbitMQ, отправка и получение сообщения

Изображение
Отправка сообщения Spring AmqpTemplate и AmqpAdmin настраиваются автоматически, и вы можете автоматически связывать их непосредственно с вашими компонентами, как показано в следующем примере: import org.springframework.amqp.core.AmqpAdmin; import org.springframework.amqp.core.AmqpTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @Component public class MyBean { private final AmqpAdmin amqpAdmin; private final AmqpTemplate amqpTemplate; @Autowired public MyBean(AmqpAdmin amqpAdmin, AmqpTemplate amqpTemplate) { this.amqpAdmin = amqpAdmin; this.amqpTemplate = amqpTemplate; } // ... } RabbitMessagingTemplate может быть введен аналогичным образом. Если bean-компонент MessageConverter определен, он автоматически связывается с автоматически настроенным AmqpTemplate. При необходимости любой org.springframework.amqp.core.Queue, определенный как bean-компонент, автоматиче...

Spring Boot: обмен сообщениями, AMQP, поддержка RabbitMQ

Изображение
Расширенный протокол очереди сообщений (AMQP, Advanced Message Queuing Protocol) - это независимый от платформы протокол проводного уровня для промежуточного программного обеспечения, ориентированного на сообщения. Проект Spring AMQP применяет основные концепции Spring для разработки решений для обмена сообщениями на основе AMQP. Spring Boot предлагает несколько удобств для работы с AMQP через RabbitMQ, включая spring-boot-starter-amqp стартер. Поддержка RabbitMQ RabbitMQ - это легкий, надежный, масштабируемый и переносимый брокер сообщений на основе протокола AMQP. Spring использует RabbitMQ для связи по протоколу AMQP. Конфигурация RabbitMQ контролируется внешними конфигурационными свойствами в spring.rabbitmq.*. Например, вы можете объявить следующий раздел в application.properties: spring.rabbitmq.host=localhost spring.rabbitmq.port=5672 spring.rabbitmq.username=admin spring.rabbitmq.password=secret В качестве альтернативы вы можете настроить то же соединение, используя а...