Интеграция Spring и Spring Cloud Stream
Я пишу приложение, которое
- Опрос каталога (поток DSL интеграции Sprint)
- Как только файл станет доступен, он будет помещен в очередь rabbitmq.
- Микросервис прослушивает поток RabbitMQ и обрабатывает файл (это написано в потоке Spring Cloud)
Теперь я не могу понять, как лучше всего отправить сообщение на RabbitMQ из службы потока интеграции Spring. Как я могу использовать поток Spring-Cloud в Spring-Integration для публикации сообщения в RabbitMQ
Спасибо @OlegZhurakousky. Собственно Артем подробно ответил, попробую.
Большой! Возможно, частично связано, но должно дать вам немного больше информации о жизненном цикле потока с точки зрения весеннего облачного потока - docs.spring.io/spring-cloud-stream/docs/Fishtown.M3/referenc e /…
Ответы 1
Вам просто нужно реализовать там привязку Source и использовать RabbitMQ Binder для создания из вашего источника. Таким образом, результат опроса файлов из каталога будет опубликован на Source.OUTPUT (или в вашей пользовательской привязке), а все остальное будет сделано связывателем RabbitMQ: https://docs.spring.io/spring-cloud-stream/docs/Fishtown.M3/reference/htmlsingle/#spring-cloud-stream-overview-proroduction-consuming-messages
Конечно, вы можете сделать что-то подобное с простой интеграцией Spring, используя AmqpOutboundEndpoint для публикации сообщения на соответствующий обмен на RabbitMQ: https://docs.spring.io/spring-integration/docs/5.0.8.RELEASE/reference/html/amqp.html#amqp-outbound-channel-adapter
У вас есть образец для этого в github? Я очень новичок в Spring Integration и Spring Cloud Stream.
Взгляните сюда: github.com/spring-cloud/spring-cloud-stream-samples/tree/master /…. Образец JDBC должен соответствовать вашим ожиданиям. Единственное, что вам нужно, это изменить его для опроса файлов.
Вы классный сэр. Это мне поможет. Вы - гений. Большое спасибо.
если у вас есть время, пожалуйста, ответьте stackoverflow.com/questions/52644505/…
Я не уверен, что полностью понимаю. Потоковая служба привязана к внешним адресатам через привязки. В настоящее время мы предоставляем связыватели Rabbit и Kafka, поэтому, если вы используете связыватель Rabbit, выходные данные вашего слушателя будут автоматически опубликованы на бирже Rabbit. Вам не нужно ничего делать.