[typescript] 마이크로서비스 아키텍처에서 타입스크립트의 비동기 메시징 구현 방법 조사하기

08 Dec 2023

typescript

마이크로서비스 아키텍처에서 서비스들 간 비동기 통신은 매우 중요합니다. 이런 통신 패턴은 서비스들의 독립성을 유지하면서도 확장 가능한 시스템을 만들 수 있게 해줍니다. 이번 글에서는 타입스크립트를 사용하여 마이크로서비스 간의 비동기 메시징을 구현하는 방법을 살펴보겠습니다.

1. 메시지 브로커 선택

마이크로서비스 간의 통신을 위해 메시지 브로커를 선택하는 것이 첫 번째 단계입니다. RabbitMQ, Kafka, NATS 등의 메시지 브로커가 있습니다. 각각의 메시지 브로커는 장단점이 있으므로 프로젝트의 요구사항과 환경에 맞게 선택해야 합니다.

// RabbitMQ를 사용하는 경우
import * as amqp from 'amqplib';

// Kafka를 사용하는 경우
import { Kafka, Producer } from 'kafkajs';

// NATS를 사용하는 경우
import { connect, Payload } from 'nats';

2. 타입스크립트를 이용한 클라이언트 구현

선택한 메시지 브로커와의 통신을 위한 클라이언트를 타입스크립트로 구현해야 합니다. 각 메시지 브로커마다 클라이언트 구현 방법이 다르지만, 일반적으로 프로듀서와 컨슈머를 구현해야 합니다.

// RabbitMQ 프로듀서 구현 예시
async function publishMessage(queue: string, message: string) {
  const connection = await amqp.connect('amqp://localhost');
  const channel = await connection.createChannel();
  await channel.assertQueue(queue, { durable: false });
  channel.sendToQueue(queue, Buffer.from(message));
}

// Kafka 프로듀서 구현 예시
const kafka = new Kafka({ brokers: ['localhost:9092'] });
const producer = kafka.producer();
await producer.connect();
await producer.send({ topic: 'test-topic', messages: [{ value: 'Hello Kafka!' }] });

// NATS 프로듀서 구현 예시
const nc = await connect({ servers: 'localhost:4222' });
nc.publish('test', 'Hello NATS!');

3. 통합 및 테스트

클라이언트가 구현되면 각 마이크로서비스에서 해당 클라이언트를 이용하여 비동기 통신을 할 수 있습니다. 이후 각 서비스들을 통합하고, 테스트하여 메시지 교환 및 이벤트 처리가 원활히 동작하는지 확인해야 합니다.

// 마이크로서비스 A - RabbitMQ 프로듀서 활용
publishMessage('queue-1', 'Message from Microservice A');

// 마이크로서비스 B - Kafka 프로듀서 활용
await producer.send({ topic: 'topic-1', messages: [{ value: 'Message from Microservice B' }] });

// 마이크로서비스 C - NATS 프로듀서 활용
nc.publish('test', 'Message from Microservice C');

결론

타입스크립트는 강력한 정적 타입 언어로, 마이크로서비스 아키텍처에서의 비동기 메시징 구현에 적합합니다. 각 메시지 브로커와의 통신은 클라이언트를 통해 쉽게 구현할 수 있으며, 타입스크립트의 장점을 최대한 활용하여 안정적이고 확장 가능한 시스템을 구축할 수 있습니다.

참고 문헌: