Spring Integration Java DSL已经融合到Spring Integration Core 5.0，这是一个聪明而明显的举动，因为：

• 基于Java Config启动新Spring项目的每个人都使用它
• SI Java DSL使您可以使用Lambdas等新的强大Java 8功能
• 您可以使用 基于IntegrationFlowBuilder的Builder模式构建流

让我们看看基于ActiveMQ JMS的示例如何使用它。

Maven依赖：

<dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</artifactId> </dependency> <dependency> <groupId>org.springframework.integration</groupId> <artifactId>spring-integration-core</artifactId> </dependency> <dependency> <groupId>org.springframework.integration</groupId> <artifactId>spring-integration-jms</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-kahadb-store</artifactId> </dependency> <!-- https://mvnrepository.com/artifact/org.springframework.integration/spring-integration-java-dsl --> <dependency> <groupId>org.springframework.integration</groupId> <artifactId>spring-integration-java-dsl</artifactId> <version>1.2.3.RELEASE</version> </dependency></dependencies>

示例1：Jms入站网关

我们有以下ServiceActivator：

@Servicepublic class ActiveMQEndpoint { @ServiceActivator(inputChannel = "inboundChannel") public void processMessage(final String inboundPayload) { System.out.println("Inbound message: "+inboundPayload); }}

如果您想使用SI Java DSL 将inboundPayload从Jms队列发送到Gateway风格的激活器，那么请使用DSLJms工厂：

@Beanpublic DynamicDestinationResolver dynamicDestinationResolver() { return new DynamicDestinationResolver();}@Beanpublic ActiveMQConnectionFactory connectionFactory() { return new ActiveMQConnectionFactory();}@Beanpublic DefaultMessageListenerContainer listenerContainer() { final DefaultMessageListenerContainer defaultMessageListenerContainer = new DefaultMessageListenerContainer(); defaultMessageListenerContainer.setDestinationResolver(dynamicDestinationResolver()); defaultMessageListenerContainer.setConnectionFactory(connectionFactory()); defaultMessageListenerContainer.setDestinationName("jms.activeMQ.Test"); return defaultMessageListenerContainer;}@Beanpublic MessageChannel inboundChannel() { return MessageChannels.direct("inboundChannel").get();}@Beanpublic JmsInboundGateway dataEndpoint() { return Jms.inboundGateway(listenerContainer()) .requestChannel(inboundChannel()).get();}

通过dataEndpoint bean 返回JmsInboundGatewaySpec，您还可以向SI通道或Jms目标发送回复。查看文档。

示例2：Jms消息驱动的通道适配器

如果您正在寻找替换消息驱动通道适配器的XML JMS配置，那么JmsMessageDrivenChannelAdapter是一种适合您的方式：

@Beanpublic DynamicDestinationResolver dynamicDestinationResolver() { return new DynamicDestinationResolver();}@Beanpublic ActiveMQConnectionFactory connectionFactory() { return new ActiveMQConnectionFactory();}@Beanpublic DefaultMessageListenerContainer listenerContainer() { final DefaultMessageListenerContainer defaultMessageListenerContainer = new DefaultMessageListenerContainer(); defaultMessageListenerContainer.setDestinationResolver(dynamicDestinationResolver()); defaultMessageListenerContainer.setConnectionFactory(connectionFactory()); defaultMessageListenerContainer.setDestinationName("jms.activeMQ.Test"); return defaultMessageListenerContainer;}@Beanpublic MessageChannel inboundChannel() { return MessageChannels.direct("inboundChannel").get();}@Beanpublic JmsMessageDrivenChannelAdapter dataEndpoint() { final ChannelPublishingJmsMessageListener channelPublishingJmsMessageListener = new ChannelPublishingJmsMessageListener(); channelPublishingJmsMessageListener.setExpectReply(false); final JmsMessageDrivenChannelAdapter messageDrivenChannelAdapter = new JmsMessageDrivenChannelAdapter(listenerContainer(), channelPublishingJmsMessageListener ); messageDrivenChannelAdapter.setOutputChannel(inboundChannel()); return messageDrivenChannelAdapter;}

与前面的示例一样，入站有效负载如样本1中一样发送给激活器。

示例3：使用JAXB的Jms消息驱动的通道适配器

在典型的场景中，您希望通过Jms接受XML作为文本消息，将其转换为JAXB存根并在服务激活器中处理它。我将向您展示如何使用SI Java DSL执行此操作，但首先让我们为xml处理添加两个依赖项：

<dependency> <groupId>org.springframework.integration</groupId> <artifactId>spring-integration-xml</artifactId> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-oxm</artifactId> </dependency>

我们将通过JMS接受shiporders ，所以首先XSD命名为shiporder.xsd：

<?xml version="1.0" encoding="UTF-8" ?><xs:schema xmlns:xs="http://.example.stubs");}

inboundChannel的服务激活器：

/** * Sample 3, 5 * @param shiporder */@ServiceActivator(inputChannel = "inboundChannel")public void processMessage(final Shiporder shiporder) { System.out.println(shiporder.getOrderid()); System.out.println(shiporder.getOrderperson());}

您不应该错过在项目中使用IntegrationFlowAdapter。我喜欢它的概念。

我最近在Embedit的新的基于Spring Boot的项目中开始使用Spring Integration Java DSL 。即使有一些配置，我发现它非常有用。

• 它很容易调试。不添加像wiretap这样的配置。
• 阅读起来要容易得多。是的，即使是lambdas！
• 它很强大。在Java配置中，您现在有很多选择。

源码地址：https://bitbucket.org/tomask79/spring-integration-java-dsl

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。