Spring 集成 HTTP 出站网关 Post 使用 Java DSL 的请求

Question

我正在尝试使用休息服务并收到 json 返回并将其转换为对象列表。但我收到以下错误。我是 EIP 的新手，在 java dsl 中没有很多教程可以做到这一点。我配置了 2 个通道，一个用于发送请求，一个用于接收返回的有效负载。

Exception in thread "main" org.springframework.beans.factory.BeanNotOfRequiredTypeException: Bean named 'httpPostAtms' is expected to be of type 'org.springframework.messaging.MessageChannel' but was actually of type 'org.springframework.integration.dsl.StandardIntegrationFlow'
at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:378)
at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:202)
at org.springframework.integration.support.channel.BeanFactoryChannelResolver.resolveDestination(BeanFactoryChannelResolver.java:89)
at org.springframework.integration.support.channel.BeanFactoryChannelResolver.resolveDestination(BeanFactoryChannelResolver.java:46)
at org.springframework.integration.gateway.MessagingGatewaySupport.getRequestChannel(MessagingGatewaySupport.java:344)
at org.springframework.integration.gateway.MessagingGatewaySupport.doSendAndReceive(MessagingGatewaySupport.java:433)
at org.springframework.integration.gateway.MessagingGatewaySupport.sendAndReceive(MessagingGatewaySupport.java:422)
at org.springframework.integration.gateway.GatewayProxyFactoryBean.invokeGatewayMethod(GatewayProxyFactoryBean.java:474)
at org.springframework.integration.gateway.GatewayProxyFactoryBean.doInvoke(GatewayProxyFactoryBean.java:429)
at org.springframework.integration.gateway.GatewayProxyFactoryBean.invoke(GatewayProxyFactoryBean.java:420)
at org.springframework.integration.gateway.GatewayCompletableFutureProxyFactoryBean.invoke(GatewayCompletableFutureProxyFactoryBean.java:65)
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:213)
at com.sun.proxy.$Proxy70.getAllAtms(Unknown Source)
at com.backbase.atm.IngAtmApplication.main(IngAtmApplication.java:25)

我在 Spring Boot

中使用 SI

@IntegrationComponentScan
@Configuration
@EnableIntegration
@ComponentScan
public class InfrastructorConfig {

    @Bean
    public PollableChannel requestChannel() {
        return new PriorityChannel() ;
    }

    @Bean
    public MessageChannel replyChannel() {
        return new DirectChannel() ;
    }

    @Bean(name = PollerMetadata.DEFAULT_POLLER)
    public PollerMetadata poller() {
        return Pollers.fixedRate(500).get();
    }

    @Bean
    public IntegrationFlow httpPostAtms() {

        return IntegrationFlows.from("requestChannel")
                .handle(Http.outboundGateway("https://www.ing.nl/api/locator/atms/")
                        .httpMethod(HttpMethod.POST)
                        .extractPayload(true))
                .<String, String>transform(p -> p.substring(5))
                .transform(Transformers.fromJson(Atm[].class))
                .channel("responseChannel")
                .get();

      }

    }

网关

package com.backbase.atm.service;

import java.util.List;

import org.springframework.integration.annotation.Gateway;
import org.springframework.integration.annotation.MessagingGateway;
import org.springframework.messaging.handler.annotation.Payload;

import com.backbase.atm.model.Atm;

@MessagingGateway
public interface IntegrationService {

    @Gateway(requestChannel = "httpPostAtms")
    @Payload("new java.util.Date()")
    List<Atm> getAllAtms();
}

申请开始

package com.backbase.atm;

import java.util.ArrayList;
import java.util.List;

import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.context.annotation.Bean;
import com.backbase.atm.service.IntegrationService;


@SpringBootApplication
public class IngAtmApplication {


    public static void main(String[] args) {
        ConfigurableApplicationContext ctx = SpringApplication.run(IngAtmApplication.class, args);
        ctx.getBean(IntegrationService.class).getAllAtms();
        ctx.close();
    }

Answer 1

您必须在网关定义中使用 requestChannel bean 名称。现在您有一个 IntegrationFlow bean 名称，但这是错误的。

永远记住 Spring 集成中的所有内容都是通过通道连接的。

Spring 集成 HTTP 出站网关 Post 使用 Java DSL 的请求

Spring Integration HTTP Outbound Gateway Post Request with Java DSL

spring

spring-integration

spring-integration-dsl