골드에그

[문제]

분명 Front-End 에서는 Back-End 로부터 Mono 데이터 하나를 받았는데 Promise 의 onComplete 이벤트가 발생하지 않았다. Front-End 의 코드와 Back-End 코드는 각각 다음과 같다.

async requestResponse(to: string, message: Message) {
    await this.connect();
    return new Promise((resolve, reject) => {
      this.client &&
        this.client.requestResponse(
          {
            data: cbor.encode(message),
            metadata: encodeRoute(to),
          },
          {
            onError: (error: Error) => {
              console.error('[*] oneToOne error : ', error);
              reject(error);
            },
            onNext: (payload: Payload, isComplete: boolean) => {
              console.log(
                `[*] oneToOne next : ${cbor.decode(
                  payload.data as Buffer,
                )} | ${isComplete}`,
              );
            },
            onComplete: () => {
              console.log('[*] 데이터 송신 완료');
              resolve(null);
            },
            onExtension: () => {},
          },
        );
    });
  }

RSocket 의 requestResponse 프로토콜로 서버에 데이터를 전송하고 받는 코드이다.

그런데 onNext 만 이벤트가 발생하고 onComplete 가 발생하지 않는 것이다.

@MessageMapping("chat.send")
public Mono<Boolean> sendChatMessage(@Payload Message messageRequest) {
    return chatRoomRepository.saveMessage(
            messageRequest.getRoomId(),
            messageRequest.getFromPerson(),
            messageRequest.getMessage()).log();
}

서버코드는 간결하다.

redis 에 데이터를 저장하고 결과 값을 Boolean 형태로 전송한다.

[원인]

Mono onComplete order is confusing · Issue #1752 · reactor/reactor-core (github.com)

중간 부분 댓글을 보면 Mono.subscribe 를 호출할 때, onComplete 이벤트는 발생하지 않고 onNext 가 그 역할까지 대신한다는 내용이 보인다. onComplete 를 호출하지 않고 onNext 에서 끝낸다는 것이다.

클라이언트 코드에서 onComplete 일 때 resolve 함수를 호출하므로 onNext 에서 resolve 함수를 호출하여 문제를 해결하였다.

Reactor 는 Reactive Streams 의 구현체이다.

백 프레셔가 가능한 PUB/SUB 모델로 싱글 스레드에서 이벤트 처리를 하는 이벤트 처리 프로세스이다.

( 여담이지만, NodeJS 따라하는 것처럼 보이지만 사실 Spring 진영에서 먼저 나왔다고 한다. 관심이 없었을 뿐 )

Reactor 를 이해하려면 Reactive Streams 의 PUB/SUB 모델의 디자인 패턴을 살펴보아야 한다.

Application 에서 Publisher 객체와 Subscriber 객체를 생성하고 Publisher.subscribe 메서드를 호출한다.

Publisher 에서는 생성된 데이터를 포장하여 Subscription 객체를 생성하고, subscribe 메서드에서 전달받은 Subscriber 의 onSubscribe 메서드를 호출하여 생성된 Subscription 객체를 인자로 넘긴다. Publisher 역할은 여기서 끝이다.

한 마디로 Publisher 는 정보를 생성하여 포장하고 그것을 구독자와 연결시켜주는 중매자이다.

onSubScribe 메서드에서는 인자로 넘어온 Subscription 의 request 를 호출하여 데이터들을 요청된 크기만큼 가져온다.

(백 프레셔 기능이다.) 요청된 크기만큼 데이터를 넘겨줄 때까지 데이터들을 하나씩 SubScriber 의 onNext 메서드를 호 출하고 다 넘겨주었다면 onComplete 메서드를 호출한다. 자세한 내용은 아래 동영상을 참고하자.