SpringIntegrationFramework简介

我们非常了解Spring框架和JMS 。 在本文中&＃xff0c;我们将介绍称为Spring Integration的企业集成框架 。 Spring Integration是一个开源企业集成框架&＃xff0c;可增强Spring单独完成的功能。 Spring Integration构建在Spring的IoC之上&＃xff0c;它抽象了消息源和目标&＃xff0c;集成了消息&＃xff0c;路由并对其进行操作&＃xff0c;同时集成了应用程序环境的各种组件。

Spring Integration用于通信的Message对象由有效负载和标头数据组成。 有效负载包含实际数据&＃xff0c;而标头包含其他元数据&＃xff0c;例如id &＃xff0c; timestamp等。下图说明了Spring Integration通信中涉及的不同组件

因此&＃xff0c;让我们创建一个示例Spring Integration应用程序&＃xff1a;

使用自定义Java接口作为入站网关

1. 创建一个新的Maven项目。
2. 将依赖项添加到pom.xml文件中&＃xff1a;

   4.0.0.RELEASE1.1-rev-13.12.2.5.RELEASE4.113.2.3.RELEASE

org.springframework.integrationspring-integration-core${spring.integration.version}

org.springframework.integrationspring-integration-jms${spring.integration.version}

org.springframeworkspring-test${spring.test.version}test

junitjunit${junit.version}test


3. 创建学生实体类Student.java &＃xff0c;   如&＃xff1a;

   package com.jcombat.entity;public class Student {String name;public Student(String name) {this.name &＃61; name;}public String getName() {return name;}
}

4. 现在&＃xff0c;让我们在上下文文件中配置spring集成组件&＃xff08;将其命名为Test-context.xml &＃xff09;&＃xff1a;

   


   消息通道是封装实际数据并使消息生产者与使用者分离的东西。

   网关基本上是消息传递系统的入口/出口点。 因此&＃xff0c;如果您有一个消息传递服务器&＃xff0c;例如ActiveMQ或TIBCO&＃xff0c;则DefaultMessageListener充当入站网关&＃xff0c;是我们消息传递系统的入口点。

   当消息到达配置的通道时&＃xff0c; Service Activator用于调用本地服务&＃xff0c;其方式是该服务不知道正在从消息传递系统中调用该服务。

   适配器从外部消息传递系统&＃xff08;JMS&＃xff0c;SFTP等&＃xff09;接收消息&＃xff0c;并将其“适配”到消息传递系统&＃xff08;作为Spring Integration Message &＃xff09;。 入站JMS适配器接收传入的外部消息&＃xff0c;并将其“调整”为Spring Integration Message 类型。 反之亦然&＃xff1a;它需要一个Spring Integration Message 并将其“调整”为外部系统所需的格式。

   因此&＃xff0c;一旦消息通过入站适配器进入&＃xff0c;它就会通过Channels从一个组件流向另一个组件。 最终&＃xff0c;将消息写到某个地方可能是适当的。 我们可以使用出站适配器编写消息。

5. 现在&＃xff0c;让我们创建在上下文中指定的网关接口&＃xff0c;如下所示&＃xff1a;

   package com.jcombat.integration;import com.jcombat.entity.Student;public interface DemoGatewayInterface {public void process(Student student);
}

6. 创建一个接收器类&＃xff0c;该类将在被适配器路由后最终从通道接收传入消息。

   package com.jcombat.integration;import org.springframework.integration.Message;import com.jcombat.entity.Student;public class DemoMessageReceiver {public void processMessage(Message message) {Student student &＃61; message.getPayload();System.out.println("Message Received - Student Name - " &＃43; student.getName());}
}

7. 就是这个。 最后&＃xff0c;我们需要一个客户端来调用网关接口方法。 让我们使用Spring Test Framework来做到这一点&＃xff1a;

   package com.jcombat.integration;import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;import com.jcombat.entity.Student;
import com.jcombat.integration.DemoGatewayInterface;&＃64;RunWith(SpringJUnit4ClassRunner.class)
&＃64;ContextConfiguration
public class Test {&＃64;Autowiredprivate DemoGatewayInterface request;&＃64;org.junit.Testpublic void testIntegration() {Student emp &＃61; new Student("Abhishek");request.process(emp);}
}

8. 将您的应用程序添加到服务器并启动服务器。
9. 导航到我们在上文第7点中创建的Test.java文件&＃xff0c;并将其作为JUnit测试运行。 以下是我们在IDE控制台中看到的日志&＃xff1a;
   
   

10. 使用Spring DefaultMessageListener作为入站网关

    1. 创建一个新的Maven项目。
    2. 确保ActiveMQ服务器已启动并正在运行。
    3. 首先是将条目输入pom.xml文件。 因此&＃xff0c;这与前面的情况相同。
    4. 让我们编写上下文文件&＃xff08; jmsContext.xml &＃xff09;&＃xff0c;并将Spring Integration组件配置为&＃xff1a;

       


    5. 让我们在服务器启动时加载上下文。 为此&＃xff0c;请在web.xml文件中输入适当的内容&＃xff0c;如下所示&＃xff1a;

       contextConfigLocation/WEB-INF/jmsContext.xmlorg.springframework.web.context.ContextLoaderListener


    6. 创建侦听器类&＃xff0c;该类将最终接收消息&＃xff0c;如下所示&＃xff1a;

       package com.jcombat.listener;public class SimpleMessageListener {public String onMessage(String message) {System.out.println(message);return message;}
}

    7. 是时候运行我们的应用程序了。 因此&＃xff0c;这应该作为&＃xff1a;
       1. 发送自定义消息到testQueue &＃xff1a;
          
          
       2. 侦听器被调用&＃xff0c;它的onMessage方法被执行&＃xff0c;将进入的消息记录为IDE控制台&＃xff1a;
          
          
       3. 消息通过出站通道并通过出站适配器传递到目标sampleQueue &＃xff0c;如下所示&＃xff1a;
          
          

    8. 下载源代码

       您可以在此处下载源代码。

翻译自: https://www.javacodegeeks.com/2015/11/introduction-to-spring-integration-framework.html