Spring Boot와 Apache ServiceMix를 사용하여 ESB 시스템 구축

현대 기업이 점점 더 다양한 서로 다른 애플리케이션과 시스템에 의존함에 따라 기업 통합이 더욱 중요해지고 있습니다. ESB(Enterprise Service Bus)는 다양한 시스템과 애플리케이션을 함께 연결하여 공통 데이터 교환 및 메시지 라우팅 서비스를 제공하여 엔터프라이즈 수준 애플리케이션 통합을 달성하는 통합 아키텍처 모델입니다. Spring Boot와 Apache ServiceMix를 이용하면 ESB 시스템을 쉽게 구축할 수 있다. 이 글에서는 이를 구현하는 방법을 소개한다.

Spring Boot 및 Apache ServiceMix 소개

Spring Boot

Spring Boot는 Spring 프레임워크를 기반으로 하는 독립 실행형 프로덕션 수준 Java 기반 애플리케이션을 만들기 위한 프레임워크입니다. 이는 몇 가지 일반적인 구성과 기본 설정을 제공하여 Spring 애플리케이션을 구축하고 구성하는 프로세스를 단순화합니다. Spring Boot는 또한 자동 구성, 내장형 웹 서버, 다양한 외부 서비스 지원 등 다양한 기능을 제공하여 웹 애플리케이션, 배치 애플리케이션, 마이크로서비스 등 다양한 유형의 애플리케이션을 생성하는 데 사용할 수 있습니다.

Apache ServiceMix

Apache ServiceMix는 오픈 소스 Java 기반 ESB(엔터프라이즈 서비스 버스)로 메시지 라우팅, 메시지 변환, 트랜잭션 전파 및 보안을 포함한 일련의 기본 서비스를 제공합니다. ServiceMix는 또한 웹 서비스 및 JMS(Java Message Service)와 같은 다양한 서비스 버스 표준을 지원합니다. ServiceMix와 외부 구성 요소를 사용하면 개발자는 효율적인 메시지 라우팅 및 데이터 교환을 위해 서로 다른 시스템과 애플리케이션을 쉽게 통합할 수 있습니다.

Spring Boot 및 ServiceMix를 사용하여 ESB 시스템 구축

Spring Boot 및 ServiceMix를 사용하여 ESB 시스템을 구축하려면 먼저 다음 단계를 완료해야 합니다.

1. Java 환경을 설치하고 구성합니다.
2. Apache Maven 및 Apache ServiceMix를 다운로드하여 설치하세요.
3. "esb-demo"라는 Spring Boot 프로젝트를 만듭니다.

다음으로 ESB 시스템의 다양한 부분을 단계별로 구현하겠습니다.

ESB 시스템의 메시지 형식 정의

ESB 시스템의 핵심 부분은 메시지 형식입니다. 이 예에서는 다음 필드를 포함하는 간단한 JSON 형식을 메시지 형식으로 사용합니다.

• id: 메시지의 고유 식별자입니다.
• source: 출처.
• destination: 메시지 대상.
• content: 메시지 콘텐츠.

ServiceMix의 기본 구성 만들기

다음으로 ServiceMix의 기본 구성을 정의해야 합니다. 이렇게 하려면 "esb.xml"이라는 파일을 만들고 다음 콘텐츠를 추가합니다.

<?xml version="1.0" encoding="UTF-8"?>
<blueprint
        xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xsi:schemaLocation="
            http://www.osgi.org/xmlns/blueprint/v1.0.0
            http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd">

    <camelContext id="camel" xmlns="http://camel.apache.org/schema/blueprint">
        <route>
            <from uri="jms:queue:incoming"/>
            <to uri="jms:queue:outgoing"/>
        </route>
    </camelContext>

    <bean id="jmsConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
        <property name="brokerURL" value="tcp://localhost:61616"/>
    </bean>

    <bean id="pooledConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory" destroy-method="stop">
        <property name="maxConnections" value="8"/>
        <property name="connectionFactory" ref="jmsConnectionFactory"/>
    </bean>

    <bean id="jmsConfig" class="org.apache.camel.component.jms.JmsConfiguration">
        <property name="connectionFactory" ref="pooledConnectionFactory"/>
    </bean>

    <bean id="jms" class="org.apache.camel.component.jms.JmsComponent" lazy-init="true">
        <property name="configuration" ref="jmsConfig"/>
    </bean>

</blueprint>

이 구성 파일은 "incoming"이라는 JMS 대기열에서 메시지를 수신하고 "outgoing"이라는 JMS 대기열로 보내는 Camel 경로를 정의합니다. ". 구성 파일은 또한 ActiveMQ에 연결하기 위한 JMS 연결 팩토리뿐만 아니라 JMS 연결의 최대 활용을 허용하는 풀링된 연결 팩토리와 Camel과 JMS를 함께 통합하기 위한 JMS 구성 요소도 정의합니다.

ESB 시스템의 REST 엔드포인트 추가

ESB 메시지를 주고받으려면 비즈니스 시스템에 대한 REST 엔드포인트를 생성해야 합니다. 이 기사에서는 다음 두 가지 엔드포인트를 구현합니다.

• POST /esb/incoming: 비즈니스 시스템에서 ESB 메시지를 받습니다.
• GET /esb/outgoing: 처리된 ESB 메시지를 반환합니다.

이러한 엔드포인트를 구현하려면 "EsbController.java"라는 Spring Boot 컨트롤러를 생성하고 소스 코드에 다음을 추가하세요.

@RestController
public class EsbController {

    private final JmsTemplate jmsTemplate;

    public EsbController(JmsTemplate jmsTemplate) {
        this.jmsTemplate = jmsTemplate;
    }

    @PostMapping("/esb/incoming")
    public ResponseEntity<?> sendIncomingMessage(@RequestBody EsbMessage message) {
        jmsTemplate.convertAndSend("incoming", message.toMessage());
        return ResponseEntity.ok().build();
    }

    @GetMapping("/esb/outgoing")
    public ResponseEntity<List<EsbMessage>> getOutgoingMessages() {
        List<EsbMessage> messages = jmsTemplate.browse("outgoing", session -> {
            List<EsbMessage> result = new ArrayList<>();
            Enumeration<?> enumeration = session.getEnumeration();
            while (enumeration.hasMoreElements()) {
                Message message = (Message) enumeration.nextElement();
                result.add(EsbMessage.fromMessage(message));
            }
            return result;
        });
        return ResponseEntity.ok(messages);
    }

}

이 컨트롤러 클래스는 JmsTemplate을 사용하여 비즈니스 시스템에서 JSON을 변환합니다. 메시지는 JMS 메시지로 변환됩니다. ESB 대기열로 전송됩니다. 또한 JmsTemplate을 사용하여 ESB 대기열에서 처리된 JSON 메시지를 검색합니다.

ESB 시스템 시작

위 단계를 완료하면 ESB 시스템의 인프라가 구축되었습니다. 로컬에서 실행하고 테스트하려면 다음 단계를 수행해야 합니다.

1. 프로젝트의 루트 디렉터리로 전환합니다.
2. 터미널에서 "mvn clean install" 명령을 실행하여 프로젝트의 JAR 파일을 생성하세요.
3. Apache ServiceMix를 시작하고 "bin/servicemix"를 실행하세요.
4. ServiceMix 명령줄 콘솔에 ESB 구성 파일을 설치하고 "install esb.xml"을 입력하세요.
5. ServiceMix 명령줄 콘솔에 ESB 프로젝트를 설치하고 "install -s mvn:com.example/esb-demo/0.0.1-SNAPSHOT"을 입력하세요.
6. POST 요청을 사용하여 ESB 메시지를 보냅니다. 예: "curl -X POST -H "Content-Type:application/json" -d '{"id":1,"source":"SystemA","destination" :" SystemB","content":"테스트 메시지"}' http://localhost:8080/esb/incoming".
7. GET 요청을 사용하여 처리된 ESB 메시지를 검색합니다(예: "curl http://localhost:8080/esb/outgoing").

요약

Spring Boot와 Apache ServiceMix를 사용하면 효율적인 ESB 시스템을 쉽게 구축하여 여러 시스템과 애플리케이션을 연결하고 데이터 교환 및 메시지 라우팅을 구현할 수 있습니다. 이 기사에서는 비즈니스 시스템과의 통신을 용이하게 하기 위해 기본 ESB 시스템을 설정하고 REST 엔드포인트를 추가하는 방법을 살펴보았습니다. 이 기사는 단순한 예일 뿐이지만 보다 복잡한 ESB 시스템을 구축하기 위한 좋은 출발점을 제공합니다.

위 내용은 Spring Boot와 Apache ServiceMix를 사용하여 ESB 시스템 구축의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!