[만들면서 배우는 헥사고날 아키텍처 설계와 구현] 1-5 드라이빙 오퍼레이션과 드리븐 오퍼레이션의 본질 탐색

programmer-study/java-practice/designing-hexagonal-architecture-with-java at main · lkdcode/programmer-study

🎯 [Growth]. Contribute to lkdcode/programmer-study development by creating an account on GitHub.

https://github.com/lkdcode/programmer-study/tree/main/java-practice/designing-hexagonal-architecture-with-java

드라이빙 오퍼레이션과 드리븐 오퍼레이션의 본질 탐색

• 드라이빙 오퍼레이션을 통한 헥사고날 애플리케이션에 대한 요청 호출

• 헥사고날 시스템과 웹 애플리케이션의 통합

• 테스트 에이전트 실행 및 다른 애플리케이션의 헥사고날 시스템 호출

• 드리븐 오퍼레이션을 통한 외부 리소스 처리

드라이빙 오퍼레이션을 통한 헥사고날 애플리케이션에 대한 요청 호출

웹 애플리케이션을 헥사고날 시스템에 통합

구현 & 리팩터링 예시

public interface RouterNetworkUseCase {
    Router addNetworkToRouter(RouterId routerId, Network network);

    Router getRouter(RouterId routerId);
}

• getRouter 메서드를 추가해 프런트엔드 애플리케이션이 라우터를 표시할 수 있도록 한다.

public class RouterNetworkInputPort implements RouterNetworkUseCase {
    /** 코드 생략**/
    @Override
    public Router getRouter(RouterId routerId) {
        return fetchRouter(routerId);
    }

    private Router fetchRouter(RouterId routerId) {
        return routerNetworkOutputPort.fetchRouterById(routerId);
    }
    /** 코드 생략**/
}

/* RouterNetworkAdapter */
public Router getRouter(Map<String, String> params){
    var routerId=RouterId.withId(params.get("routerId"));
    return routerNetworkUseCase.getRouter(routerId);
}

테스트 에이전트 실행

애플리케이션 간의 헥사고날 시스템 호출

드리븐 오퍼레이션을 통한 외부 리소스 처리

• 지속성(Database 등)

• 메시징

• 모의객체 서버

• 자바 시스템 등

데이터 지속성

메시징과 이벤트

$ bin/zookeeper-server-start.sh config/zookeeper.properties
$ bin/kafka-server-start.sh config/server.properties

$ bin/kafka-topics.sh --create --topic topology-inventory-events --bootstrap-server localhost:9092
$ bin/kafka-console-producer.sh --topic topology-inventory-events --bootstrap-server localhost:9092
$ bin/kafka-console-consumer.sh --topic topology-inventory-events --bootstrap-server localhost:9092

public interface NotifyEventOutputPort {
    void sendEvent(String event);
    String getEvent();
}

• 출력 어댑터로 출력 포트를 구현한다.

public class NotifyEventKafkaAdapter implements NotifyEventOutputPort {
    private static String KAFKA_BROKERS = "localhost:9092";
    private static String GROUP_ID_CONFIG = "consumerGroup1";
    private static String CLIENT_ID = "hexagonalclient";
    private static String TOPIC_NAME = "topology-inventory-events";
    private static String OFFSET_RESET_EARLIER = "earliest";
    private static Integer MAX_NO_MESSAGE_FOUND_COUNT = 100;
    /** 코드 생략 **/
}

• 카프카 토픽에 메시지를 보내기 위한 메서드를 작성한다.

private static Producer<Long, String> createProducer() {
    Properties props = new Properties();

    props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, KAFKA_BROKERS);
    props.put(ProducerConfig.CLIENT_ID_CONFIG, CLIENT_ID);
    props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, LongSerializer.class.getName());
    props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());

    return new KafkaProducer<>(props);
}

• Producer 메서드가 생성한 메시지를 소비하는 consumer 메서드를 작성한다.

public static Consumer<Long, String> createConsumer() {
    Properties props = new Properties();

    props.put(ConsumerConfig.BOOSTRAP_SERVERS_CONFIG, KAFKA_BROKERS);
    props.put(ConsumerConfig.GROUP_ID_CONFIG, GROUP_ID_CONFIG);
    props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, LongDeserializer.class.getName());
    props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
    props.put(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, 1);
    props.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "false");
    props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, OFFSET_RESET_EARLIER);

    Consumer<Long, String> consumer = new KafkaConsumer<>(props);
    consumer.subscribe(Collections.singletonList(TOPIC_NAME));

    return consumer;
}

• 카프카 producer 인스턴스로 메시지를 보내는 메서드를 작성한다.

@Override
public void sendEvent(String eventMessage) {
    var record = new ProducerRecord<Long, String>(TOPIC_NAME, eventMessage);
    try {
        var metadata = producer.send(record).get();
        getEvent();
    } catch (Exception e) {
        e.printStackTrace();
    }
}

• 카프카의 메시지를 소비하고 그것을 WebSocekt 서버로 보내기 위한 메서드를 작성한다.

@Override
public String getEvent() {
    int noMessageToFetch = 0;
    AtomicReference<String> event = new AtomicReference<>("");

    while(true) {
        /** 코드 생략 **/
        consumerRecords.forEach(record -> {
            event.set(record.value());
        });
    }
    var eventMessage = event.toString();
    if(sendToWebsocket) {
        sendMessage(eventMessage);
    }
    return eventMessage;
}

• 메시지를 검색한 후 WebSocket 서버로 메시지를 전달하는 sendMessage 를 호출한다.

public void sendMessage(String message) {
    try {
        var client = new WebSocketClientAdapter(new URI("ws://localhost:8887"));
        client.connetBlocking();
        client.send(message);
        client_closeBlocking();
    } catch (URISyntaxException | InterruptedException e) {
        e.printStackTrace();
    }
}

public class RouterNetworkInputPort implements RouterNetworkUseCase {
    /** 코드 생략 **/
    @Override
    public Router addNetworkToRouter(RouterId routerId, Network network) {
        var router = fetchRouter(routerId);
        notifyEventOutputPort.sendEvent("adding " + network.getName() + "network to router " + router.getId().getUUID());

        return createNetwork(router, network);
    }

    @Override
    public Router getRouter(RouterId routerId) {
        notifyEventOutputPort.sendEvent("Retrieving router ID" + routerId.getUUID());

        return fetchRouter(routerId);
    }
}

모의 서버