代码之家  ›  专栏  ›  技术社区  ›  Makky

春季积分与春季云流

spring-integration-dsl spring-cloud-stream rabbitmq spring java
  •  2
  • Makky  · 技术社区  · 6 年前

    我正在写一份申请书

    • 轮询目录(Sprint集成DSL流)
    • 一旦文件可用,它将放入rabbitmq队列
    • 微服务监听流rabbitmq并处理文件(这是用SpringCloud流编写的)

    现在,我想不出将消息发送到 RabbitMQ 来自Spring集成流服务。如何在Spring集成中使用SpringCloud流将消息发布到rabbitmq

    1 回复  |  直到 6 年前
        1
  •  3
  •   Artem Bilan    6 年前

    你只需要在那里实现一个 Source 绑定并使用rabbitmq binder从源代码生成。因此,从目录中轮询文件的结果将发布到 Source.OUTPUT (或自定义绑定)以及其他所有操作都将由rabbitmq绑定器完成: https://docs.spring.io/spring-cloud-stream/docs/Fishtown.M3/reference/htmlsingle/#spring-cloud-stream-overview-producing-consuming-messages

    当然,您可以使用 AmqpOutboundEndpoint 要将消息发布到rabbitmq上的相应交换: https://docs.spring.io/spring-integration/docs/5.0.8.RELEASE/reference/html/amqp.html#amqp-outbound-channel-adapter

    推荐文章
    Roman Lebedev  ·  Spring云流:如果当前连接引发异常,则重新发布到其他amqp连接[关闭]
    7 年前
    Stav Alfi  ·  Spring集成运动-未找到正确的实现
    7 年前
    jesantana  ·  通过在每次应用程序重新启动时创建新的使用者组来重置主题偏移量
    7 年前
    Mahesh G  ·  Spring云流-并发
    7 年前
    Alex Kamornikov  ·  春季云流确定主题卡夫卡消息来源
    7 年前
    yokv  ·  卡夫卡制作人始终重试连接
    7 年前
    samba  ·  需要Spring集成示例代码aws S3作为入站和apache kafka作为出站的示例[已关闭]
    7 年前
    sadineni  ·  Spring云数据流商业支持
    7 年前
    Bully  ·  Rabbit spring云流将主题绑定到单个队列
    7 年前
    user6448130  ·  Spring云流媒体-生产者和消费者的独立连接
    7 年前
    关于   移动版
    代码之家 - 一站式码农服务社区
    沪ICP备11025650号