[Vert.x] 이벤트버스(Event Bus)란?

 

Event Bus 

Vert.x 프레임워크에서 실행 되는 가장 작은 단위의 프로그램을 Verticle이라 한다.

백엔드 시스템을 구축함에 있어서 Verticle 간 통신이 필요한 경우가 많이 발생한다.

Verticle간 정보 교환을 하는데 있어서 사용 되는 것이 Event Bus이다.

 

 

Event Bus 예제

 

먼저 publisher 혹은 sender에 해당하는 코드이다.

@Override
public void start() throws Exception {

    EventBus eb = vertx.eventBus();
    //이벤트버스 생성
    
    vertx.setPeriodic(1000, v -> {
    	//1초마다 v 콜백을 호출하는 정기 이벤트를 설정
        eb.send("ping-address", "ping!", reply -> {
        //ping-address 주소로 "ping!" 메시지를 보내고 reply 콜백을 호출합니다.
        
            if (reply.succeeded()) {
            // reply 콜백이 성공했는지 확인합니다.
                System.out.println("Received reply " + reply.result().body());
            } else {
            //실패시
                System.out.println("No reply");
            }
            
        });
    });

    
}

Event Bus는 전에 Vert.x 인스턴스나 Verticle을 만들었던 방법과 동일하게 생성을 해줄 수 있다.

해당 코드에서는 1초마다 Event Bus를 통해 “ping!” 이라는 메세지를 보내주고 성공을 했을 시,

해당 결과를, 실패시 “No Reply”를 프린트하게 된다.

eb.send()를 통해서 메세지를 보낼 수 있으며,

해당 메세지의 이름은 “ping-address”이다.

 

 

 

Subscriber에 해당하는 코드는 다음과 같다.

@Override
public void start() throws Exception {
//start()이 줄은 verticle이 시작될 때 호출되는 메서드 의 시작을 표시

    EventBus eb = vertx.eventBus();
    //이벤트버스 생성
    
    eb.consumer("ping-address", message -> {
    //ping-address 주소에 대한 consumer를 등록합니다. 
    //consumer는 메시지가 주소로 전송될 때마다 호출됩니다 ping-address.
        
        System.out.println("Received message: " + message.body());
     
        message.reply("pong!");
        //"pong!"이라는 텍스트가 포함된 회신을 보냅니다.
    });
    
    System.out.println("Receiver ready!");
}

이번에는 send가 아닌 eb.consumer()을 통해서 해당 event bus의 subscriber이라는 것을 지정해 준다.

그 후 이전에 메세지의 이름을 “ping-address”였기 때문에 이를 지정해주고,

reply를 통해 정상적으로 메세지를 수신했다는 것을 알린다.

Event Bus를 통해서 예시와 같이 String을 주고 받는 것도 가능하지만,

자바에서 생성한 객체를 주고 받는 것 역시 가능하다.

 

 

출처 : https://ubrain0624.medium.com/vert-x%EC%97%90%EC%84%9C-verticle-%EC%82%AC%EC%9D%B4-%EC%A0%95%EB%B3%B4-%EA%B5%90%ED%99%98-event-bus-e9554c8e4312

---

 

eventbus의 publisher / sender 차이점

Vert.x event bus에서 publisher와 sender는 모두 메시지를 보내는 역할을 하지만 몇 가지 차이점이 있습니다.

publisher는 일반적으로 서비스를 제공하는 데 사용되며

sender는 특정 이벤트에 응답하는 데 사용됩니다.

 

웹 서버는 HTTP 요청을 처리하는 데 publisher를 사용할 수 있습니다.

웹 서버는 HTTP 요청을 처리한 후 응답을 보내기 위해 publisher를 사용합니다.

웹 서버는 또한 특정 이벤트에 응답하는 데 sender를 사용할 수 있습니다. 예를 들어, 웹 서버는 사용자가 로그인하면 sender를 사용하여 로그인 이벤트를 알릴 수 있습니다.

 

publisher와 sender는 모두 Vert.x event bus에서 메시지를 보내는 데 중요한 역할을 합니다.