Azure Service Bus 토픽에 메시지를 보내고 구독에서 토픽으로 메시지 받기(JavaScript)

아티클
03/12/2024

이 자습서에서 수행하는 단계는 다음과 같습니다.

Azure Portal을 사용하여 Service Bus 네임스페이스를 만듭니다.
Azure Portal을 사용하여 Service Bus 항목을 만듭니다.
Azure Portal을 사용하여 해당 항목에 Service Bus 구독을 만듭니다.
JavaScript 애플리케이션을 작성하여 @azure/service-bus 패키지를 사용하여 다음을 수행합니다.
- 토픽에 메시지 집합을 보냅니다.
- 구독에서 이러한 메시지를 받습니다.

참고 항목

이 빠른 시작에서는 메시지 일괄 처리를 Service Bus 토픽으로 보내고 해당 토픽의 구독에서 해당 메시지를 받는 간단한 시나리오에 대한 단계별 지침을 제공합니다. GitHub의 JavaScript용 Azure SDK 리포지토리에서 Azure Service Bus용으로 미리 빌드된 JavaScript 및 TypeScript 샘플을 찾을 수 있습니다.

필수 구성 요소

Azure 구독 이 자습서를 완료하려면 Azure 계정이 필요합니다. MSDN 구독자 혜택을 활성화하거나 무료 계정을 등록할 수 있습니다.
Node.js LTS
빠른 시작: Azure Portal을 사용하여 Service Bus 토픽 및 해당 토픽에 대한 구독 만들기의 단계를 따릅니다. 이 빠른 시작에는 하나의 구독만 사용합니다.

암호 없음
연결 문자열

사용자 고유의 Azure 계정으로 이 빠른 시작을 사용하려면 다음이 필요합니다.

개발자 머신에 암호 없는 인증을 제공하는 Azure CLI를 설치합니다.
터미널 또는 명령 프롬프트에서 az login을 사용하여 Azure 계정으로 로그인합니다.
리소스에 적절한 역할을 추가할 때 동일한 계정을 사용합니다.
동일한 터미널 또는 명령 프롬프트에서 코드를 실행합니다.
Service Bus 네임스페이스의 토픽 이름 및 구독을 적어둡니다. 코드에서 필요합니다.

참고 항목

이 자습서에서는 Nodejs를 사용하여 복사하고 실행할 수 있는 샘플을 사용합니다. Node.js 애플리케이션을 만드는 방법에 대한 지침은 Node.js 애플리케이션을 만들어 Azure 웹 사이트에 배포 또는 Windows PowerShell을 사용하는 Node.js 클라우드 서비스를 참조하세요.

Azure Portal에서 네임스페이스 만들기

Azure에서 Service Bus 메시징 엔터티 사용을 시작하려면 먼저 Azure에서 고유한 이름인 네임스페이스를 만들어야 합니다. 네임스페이스는 애플리케이션 내의 Service Bus 리소스(큐, 토픽 등)에 대한 범위 지정 컨테이너를 제공합니다.

네임스페이스를 만들려면

Azure Portal에 로그인합니다.
모든 서비스 페이지로 이동합니다.
왼쪽 탐색 모음의 범주 목록에서 통합을 선택하고 Service Bus 위로 마우스를 가리킨 다음 Service Bus 타일에서 단추를 선택합니다+.
네임스페이스 만들기 페이지의 기본 사항 태그에서 다음 단계를 수행합니다.
1. 구독에 대해 네임스페이스를 만들 Azure 구독을 선택합니다.
2. 리소스 그룹에 대해 네임스페이스가 있는 기존 리소스 그룹을 선택하거나 새로 만듭니다.
3. 네임스페이스 이름을 입력합니다. 네임스페이스 이름은 다음 명명 규칙을 따라야 합니다.
  - 이름은 Azure에서 고유해야 합니다. 시스템에서 사용 가능한 이름인지 즉시 확인합니다.
  - 이름 길이는 6~50자여야 합니다.
  - 이름에는 문자, 숫자, "-" 하이픈만 포함될 수 있습니다.
  - 이름은 문자로 시작하고 문자 또는 숫자로 끝나야 합니다.
  - 이름은 "-sb" 또는 "-mgmt"로 끝나지 않습니다.
4. 위치에 대해 네임스페이스가 호스팅되어야하는 지역을 선택합니다.
5. 가격 책정 계층에 대해 네임스페이스에 대한 가격 책정 계층(기본, 표준 또는 프리미엄)을 선택합니다. 이 빠른 시작의 경우 표준을 선택합니다.
  
  Important
  
  토픽 및 구독을 사용하려면 표준 또는 프리미엄을 선택합니다. 토픽/구독은 기본 가격 책정 계층에서 지원되지 않습니다.
  
  프리미엄 가격 책정 계층을 선택한 경우 메시징 단위 수를 지정합니다. 프리미엄 계층은 CPU 및 메모리 수준에서 리소스 격리를 제공하므로 각 워크로드가 독립적으로 실행됩니다. 이 리소스 컨테이너를 메시징 단위라고 합니다. 프리미엄 네임스페이스에는 하나 이상의 메시징 단위가 있습니다. 각 Service Bus 프리미엄 네임스페이스에 대해 1, 2, 4, 8 또는 16개의 메시징 단위를 선택할 수 있습니다. 자세한 내용은 Service Bus 프리미엄 메시징을 참조하세요.
6. 페이지 아래쪽에서 검토 + 만들기를 선택합니다.
7. 검토 + 만들기 페이지에서 설정을 검토하고 만들기를 선택합니다.
리소스 배포에 성공하면 배포 페이지에서 리소스로 이동을 선택합니다.
Service Bus 네임스페이스에 대한 홈페이지가 표시됩니다.

Azure Portal을 사용하여 항목 만들기

Service Bus 네임스페이스 페이지의 왼쪽 메뉴에서 항목을 선택합니다.
도구 모음에서 + 항목을 선택합니다.
항목의 이름을 입력합니다. 다른 옵션은 기본값 그대로 둡니다.
만들기를 실행합니다.

항목에 대한 구독 만들기

이전 섹션에서 만든 항목을 선택합니다.
Service Bus 토픽 페이지의 도구 모음에서 + 구독을 선택합니다.
구독 만들기 페이지에서 다음 단계를 수행합니다.
1. 구독 이름에 S1을 입력합니다.
2. 최대 전달 횟수에 3을 입력합니다.
3. 그런 다음, 만들기를 선택하여 구독을 만듭니다.

Azure에 앱 인증

이 빠른 시작에서는 Azure Service Bus에 연결하는 두 가지 방법인 암호 없음과 연결 문자열을 보여줍니다.

첫 번째 옵션은 Microsoft Entra ID 및 RBAC(역할 기반 액세스 제어)의 보안 주체를 사용하여 Service Bus 네임스페이스에 연결하는 방법을 보여 줍니다. 코드, 구성 파일 또는 Azure Key Vault와 같은 보안 스토리지에 하드 코딩된 연결 문자열이 있는지 걱정할 필요가 없습니다.

두 번째 옵션은 연결 문자열을 사용하여 Service Bus 네임스페이스에 연결하는 방법을 보여줍니다. Azure를 처음 사용하는 경우 연결 문자열 옵션이 더 쉬울 수 있습니다. 실제 애플리케이션 및 프로덕션 환경에서는 암호 없는 옵션을 사용하는 것이 좋습니다. 자세한 내용은 인증 및 권한 부여를 참조하세요. 개요 페이지에서 암호 없는 인증에 대해 자세히 알아볼 수도 있습니다.

암호 없음(권장)
연결 문자열

Microsoft Entra 사용자에게 역할 할당

로컬에서 개발할 때 Azure Service Bus에 연결하는 사용자 계정에 올바른 권한이 있는지 확인합니다. 메시지를 보내고 받으려면 Azure Service Bus 데이터 소유자 역할이 필요합니다. 자신에게 이 역할을 할당하려면 사용자 액세스 관리자 역할 또는 Microsoft.Authorization/roleAssignments/write 작업을 포함하는 다른 역할이 필요합니다. Azure Portal, Azure CLI 또는 Azure PowerShell을 사용하여 사용자에게 Azure RBAC 역할을 할당할 수 있습니다. 범위 개요 페이지에서 역할 할당에 사용할 수 있는 범위에 대해 자세히 알아봅니다.

다음 예에서는 Azure Service Bus 리소스에 대한 모든 권한을 제공하는 Azure Service Bus Data Owner 역할을 사용자 계정에 할당합니다. 실제 시나리오에서는 최소 권한 원칙에 따라 사용자에게 보다 안전한 프로덕션 환경에 필요한 최소한의 권한만 부여합니다.

Azure Service Bus에 대한 Azure 기본 제공 역할

Azure Service Bus의 경우 Azure Portal 및 Azure 리소스 관리 API를 통한 네임스페이스 및 관련된 모든 리소스의 관리는 이미 Azure RBAC 모델을 사용하여 보호되고 있습니다. Azure는 Service Bus 네임스페이스에 대한 액세스 권한을 부여하기 위해 아래와 같은 Azure 기본 제공 역할을 제공합니다.

Azure Service Bus 데이터 소유자: Service Bus 네임스페이스 및 해당 엔터티(큐, 토픽, 구독 및 필터)에 대한 데이터 액세스를 사용하도록 설정합니다. 이 역할의 멤버는 큐 또는 토픽/구독에서 메시지를 보내고 받을 수 있습니다.
Azure Service Bus 데이터 보내는 사람: 이 역할을 사용하여 Service Bus 네임스페이스 및 해당 엔터티에 대한 전송 액세스 권한을 부여합니다.
Azure Service Bus 데이터 받는 사람: 이 역할을 사용하여 Service Bus 네임스페이스 및 해당 엔터티에 대한 수신 액세스 권한을 부여합니다.

사용자 지정 역할을 만들려면 Service Bus 작업에 필요한 권한을 참조하세요.

Azure Service Bus 소유자 역할에 Microsoft Entra 사용자 추가

Service Bus 네임스페이스 수준에서 Azure Service Bus 데이터 소유자 역할에 Microsoft Entra 사용자 이름을 추가합니다. 사용자 계정의 컨텍스트에서 실행되는 앱이 큐 또는 토픽에 메시지를 보내고 큐 또는 토픽의 구독에서 메시지를 받을 수 있습니다.

Important

대부분의 경우 역할 할당이 Azure에서 전파되는 데 1~2분이 걸립니다. 드문 경우지만 최대 8분이 소요될 수 있습니다. 코드를 처음 실행할 때 인증 오류가 발생하면 잠시 기다렸다가 다시 시도하세요.

Azure Portal에 Service Bus 네임스페이스 페이지가 열려 있지 않은 경우 기본 검색 창이나 왼쪽 탐색 모음을 사용하여 Service Bus 네임스페이스를 찾습니다.
개요 페이지의 왼쪽 메뉴에서 액세스 제어(IAM)를 선택합니다.
액세스 제어(IAM) 페이지에서 역할 할당 탭을 선택합니다.
위쪽 메뉴에서 + 추가를 선택한 다음, 드롭다운 메뉴에서 역할 할당 추가를 선택합니다.
검색 상자를 사용하여 결과를 원하는 역할로 필터링합니다. 이 예에서는 Azure Service Bus Data Owner를 검색하고 일치하는 결과를 선택합니다. 다음을 선택합니다.
다음에 대한 액세스 할당 아래에서 사용자, 그룹 또는 서비스 주체를 선택한 다음, + 멤버 선택을 선택합니다.
대화 상자에서 Microsoft Entra 사용자 이름(일반적으로 user@domain 이메일 주소)을 검색한 다음, 대화 상자 하단에서 선택을 선택합니다.
검토 + 할당을 선택하여 최종 페이지로 이동한 다음, 검토 + 할당을 다시 선택하여 프로세스를 완료합니다.

Service Bus에 대한 필수 npm 패키지를 설치하려면 경로에 npm이(가) 있는 명령 프롬프트를 열고 샘플을 저장하고 이 명령을 실행할 폴더로 디렉터리를 변경합니다.

다음 패키지를 설치합니다.

npm install @azure/service-bus @azure/identity

Service Bus에 대한 필수 npm 패키지를 설치하려면 경로에 npm이(가) 있는 명령 프롬프트를 열고 샘플을 저장하고 이 명령을 실행할 폴더로 디렉터리를 변경합니다.
다음 패키지를 설치합니다.
```
npm install @azure/service-bus
```

토픽에 메시지 보내기

다음 샘플 코드에서는 Service Bus 토픽으로 메시지 일괄 처리를 보내는 방법을 보여줍니다. 자세한 내용은 코드 주석을 참조하세요.

암호 없음
연결 문자열

로컬 컴퓨터가 이 코드에 필요한 암호 없는 인증을 제공하려면 Azure CLI의 az login을 사용하여 로그인해야 합니다.

선호하는 편집기(예: Visual Studio Code)를 엽니다.

sendtotopic.js라는 파일을 만들고 아래 코드를 이 파일에 붙여넣습니다. 이 코드는 토픽에 메시지를 보냅니다.

Important

암호 없는 자격 증명은 DefaultAzureCredential과 함께 제공됩니다.

const { ServiceBusClient } = require("@azure/service-bus");
const { DefaultAzureCredential } = require("@azure/identity");

// Replace `<SERVICE-BUS-NAMESPACE>` with your namespace
const fullyQualifiedNamespace = "<SERVICE-BUS-NAMESPACE>.servicebus.windows.net";

// Passwordless credential
const credential = new DefaultAzureCredential();

const topicName = "<TOPIC NAME>";

const messages = [
    { body: "Albert Einstein" },
    { body: "Werner Heisenberg" },
    { body: "Marie Curie" },
    { body: "Steven Hawking" },
    { body: "Isaac Newton" },
    { body: "Niels Bohr" },
    { body: "Michael Faraday" },
    { body: "Galileo Galilei" },
    { body: "Johannes Kepler" },
    { body: "Nikolaus Kopernikus" }
 ];

 async function main() {
    // create a Service Bus client using the passwordless authentication to the Service Bus namespace
    const sbClient = new ServiceBusClient(fullyQualifiedNamespace, credential);

    // createSender() can also be used to create a sender for a queue.
    const sender = sbClient.createSender(topicName);

    try {
        // Tries to send all messages in a single batch.
        // Will fail if the messages cannot fit in a batch.
        // await sender.sendMessages(messages);

        // create a batch object
        let batch = await sender.createMessageBatch();
        for (let i = 0; i < messages.length; i++) {
            // for each message in the array

            // try to add the message to the batch
            if (!batch.tryAddMessage(messages[i])) {
                // if it fails to add the message to the current batch
                // send the current batch as it is full
                await sender.sendMessages(batch);

                // then, create a new batch
                batch = await sender.createMessageBatch();

                // now, add the message failed to be added to the previous batch to this batch
                if (!batch.tryAddMessage(messages[i])) {
                    // if it still can't be added to the batch, the message is probably too big to fit in a batch
                    throw new Error("Message too big to fit in a batch");
                }
            }
        }

        // Send the last created batch of messages to the topic
        await sender.sendMessages(batch);

        console.log(`Sent a batch of messages to the topic: ${topicName}`);

        // Close the sender
        await sender.close();
    } finally {
        await sbClient.close();
    }
}

// call the main function
main().catch((err) => {
    console.log("Error occurred: ", err);
    process.exit(1);
 });

<SERVICE BUS NAMESPACE CONNECTION STRING>을 Service Bus 네임스페이스에 대한 연결 문자열로 바꿉니다.
<TOPIC NAME>을 토픽 이름으로 바꿉니다.
그런 다음, 명령 프롬프트에서 명령을 실행하여 이 파일을 실행합니다.
```
node sendtotopic.js
```

다음 출력이 표시되어야 합니다.

Sent a batch of messages to the topic: mytopic

선호하는 편집기(예: Visual Studio Code)를 엽니다.

sendtotopic.js라는 파일을 만들고 아래 코드를 이 파일에 붙여넣습니다. 이 코드는 토픽에 메시지를 보냅니다.

const { ServiceBusClient } = require("@azure/service-bus");

const connectionString = "<SERVICE BUS NAMESPACE CONNECTION STRING>"
const topicName = "<TOPIC NAME>";

const messages = [
    { body: "Albert Einstein" },
    { body: "Werner Heisenberg" },
    { body: "Marie Curie" },
    { body: "Steven Hawking" },
    { body: "Isaac Newton" },
    { body: "Niels Bohr" },
    { body: "Michael Faraday" },
    { body: "Galileo Galilei" },
    { body: "Johannes Kepler" },
    { body: "Nikolaus Kopernikus" }
 ];

 async function main() {
    // create a Service Bus client using the connection string to the Service Bus namespace
    const sbClient = new ServiceBusClient(connectionString);

    // createSender() can also be used to create a sender for a queue.
    const sender = sbClient.createSender(topicName);

    try {
        // Tries to send all messages in a single batch.
        // Will fail if the messages cannot fit in a batch.
        // await sender.sendMessages(messages);

        // create a batch object
        let batch = await sender.createMessageBatch();
        for (let i = 0; i < messages.length; i++) {
            // for each message in the array

            // try to add the message to the batch
            if (!batch.tryAddMessage(messages[i])) {
                // if it fails to add the message to the current batch
                // send the current batch as it is full
                await sender.sendMessages(batch);

                // then, create a new batch
                batch = await sender.createMessageBatch();

                // now, add the message failed to be added to the previous batch to this batch
                if (!batch.tryAddMessage(messages[i])) {
                    // if it still can't be added to the batch, the message is probably too big to fit in a batch
                    throw new Error("Message too big to fit in a batch");
                }
            }
        }

        // Send the last created batch of messages to the topic
        await sender.sendMessages(batch);

        console.log(`Sent a batch of messages to the topic: ${topicName}`);

        // Close the sender
        await sender.close();
    } finally {
        await sbClient.close();
    }
}

// call the main function
main().catch((err) => {
    console.log("Error occurred: ", err);
    process.exit(1);
 });

<SERVICE BUS NAMESPACE CONNECTION STRING>을 Service Bus 네임스페이스에 대한 연결 문자열로 바꿉니다.
<TOPIC NAME>을 토픽 이름으로 바꿉니다.
그런 다음, 명령 프롬프트에서 명령을 실행하여 이 파일을 실행합니다.
```
node sendtotopic.js
```

다음 출력이 표시되어야 합니다.

Sent a batch of messages to the topic: mytopic

구독에서 메시지 받기

암호 없음
연결 문자열

로컬 컴퓨터가 이 코드에 필요한 암호 없는 인증을 제공하려면 Azure CLI의 az login을 사용하여 로그인해야 합니다.

선호하는 편집기(예: Visual Studio Code)를 엽니다.

receivefromsubscription.js라는 파일을 만들고, 그 안에 다음 코드를 붙여넣습니다. 자세한 내용은 코드 주석을 참조하세요.

const { delay, ServiceBusClient, ServiceBusMessage } = require("@azure/service-bus");
const { DefaultAzureCredential } = require("@azure/identity");

// Replace `<SERVICE-BUS-NAMESPACE>` with your namespace
const fullyQualifiedNamespace = "<SERVICE-BUS-NAMESPACE>.servicebus.windows.net";

// Passwordless credential
const credential = new DefaultAzureCredential();

const topicName = "<TOPIC NAME>";
const subscriptionName = "<SUBSCRIPTION NAME>";

 async function main() {
    // create a Service Bus client using the passwordless authentication to the Service Bus namespace
    const sbClient = new ServiceBusClient(fullyQualifiedNamespace, credential);

    // createReceiver() can also be used to create a receiver for a queue.
    const receiver = sbClient.createReceiver(topicName, subscriptionName);

    // function to handle messages
    const myMessageHandler = async (messageReceived) => {
        console.log(`Received message: ${messageReceived.body}`);
    };

    // function to handle any errors
    const myErrorHandler = async (error) => {
        console.log(error);
    };

    // subscribe and specify the message and error handlers
    receiver.subscribe({
        processMessage: myMessageHandler,
        processError: myErrorHandler
    });

    // Waiting long enough before closing the sender to send messages
    await delay(5000);

    await receiver.close();
    await sbClient.close();
}

// call the main function
main().catch((err) => {
    console.log("Error occurred: ", err);
    process.exit(1);
 });

<SERVICE BUS NAMESPACE CONNECTION STRING>을 네임스페이스에 대한 연결 문자열로 바꿉니다.
<TOPIC NAME>을 토픽 이름으로 바꿉니다.
<SUBSCRIPTION NAME>을 토픽에 대한 구독 이름으로 바꿉니다.
그런 다음, 명령 프롬프트에서 명령을 실행하여 이 파일을 실행합니다.
```
node receivefromsubscription.js
```

선호하는 편집기(예: Visual Studio Code)를 엽니다.

receivefromsubscription.js라는 파일을 만들고, 그 안에 다음 코드를 붙여넣습니다. 자세한 내용은 코드 주석을 참조하세요.

const { delay, ServiceBusClient, ServiceBusMessage } = require("@azure/service-bus");

const connectionString = "<SERVICE BUS NAMESPACE CONNECTION STRING>"
const topicName = "<TOPIC NAME>";
const subscriptionName = "<SUBSCRIPTION NAME>";

 async function main() {
    // create a Service Bus client using the connection string to the Service Bus namespace
    const sbClient = new ServiceBusClient(connectionString);

    // createReceiver() can also be used to create a receiver for a queue.
    const receiver = sbClient.createReceiver(topicName, subscriptionName);

    // function to handle messages
    const myMessageHandler = async (messageReceived) => {
        console.log(`Received message: ${messageReceived.body}`);
    };

    // function to handle any errors
    const myErrorHandler = async (error) => {
        console.log(error);
    };

    // subscribe and specify the message and error handlers
    receiver.subscribe({
        processMessage: myMessageHandler,
        processError: myErrorHandler
    });

    // Waiting long enough before closing the sender to send messages
    await delay(5000);

    await receiver.close();
    await sbClient.close();
}

// call the main function
main().catch((err) => {
    console.log("Error occurred: ", err);
    process.exit(1);
 });

<SERVICE BUS NAMESPACE CONNECTION STRING>을 네임스페이스에 대한 연결 문자열로 바꿉니다.
<TOPIC NAME>을 토픽 이름으로 바꿉니다.
<SUBSCRIPTION NAME>을 토픽에 대한 구독 이름으로 바꿉니다.
그런 다음, 명령 프롬프트에서 명령을 실행하여 이 파일을 실행합니다.
```
node receivefromsubscription.js
```

다음 출력이 표시되어야 합니다.

Received message: Albert Einstein
Received message: Werner Heisenberg
Received message: Marie Curie
Received message: Steven Hawking
Received message: Isaac Newton
Received message: Niels Bohr
Received message: Michael Faraday
Received message: Galileo Galilei
Received message: Johannes Kepler
Received message: Nikolaus Kopernikus

Azure Portal에서 Service Bus 네임스페이스로 이동하고 하단 창에서 토픽으로 전환한 다음, 토픽을 선택하여 토픽에 대한 Service Bus 토픽 페이지를 확인합니다. 이 페이지에는 메시지 차트에 10개의 들어오는 메시지와 10개의 나가는 메시지가 표시됩니다.

Incoming and outgoing messages

다음에 보내기 앱만 실행하면 Service Bus 토픽 페이지에 20개의 들어오는 메시지(10개의 새 메시지)와 10개의 발신 메시지가 표시됩니다.

Updated topic page

이 페이지의 하단 창에서 구독을 선택하면 Service Bus 구독 페이지로 이동합니다. 이 페이지에서는 활성 메시지 수, 전달 못한 메시지 수 등을 볼 수 있습니다. 이 예제에는 수신자가 아직 받지 않은 10개의 활성 메시지가 있습니다.

Active message count

문제 해결

필수 클레임에 관해 암호 없는 버전의 JavaScript 코드를 실행할 때 오류가 표시되는 경우 Azure CLI 명령을 통해 로그인하고 az login 및 적절한 역할이 Azure 사용자 계정에 적용되는지 확인합니다.

리소스 정리

Azure Portal에서 Service Bus 네임스페이스로 이동하고 Azure Portal에서 삭제를 선택하여 네임스페이스와 그 안의 큐를 삭제합니다.

다음 단계

다음 설명서와 샘플을 참조하세요.

Azure Service Bus 토픽에 메시지를 보내고 구독에서 토픽으로 메시지 받기(JavaScript)

필수 구성 요소

Azure Portal에서 네임스페이스 만들기

Azure Portal을 사용하여 항목 만들기

항목에 대한 구독 만들기

Azure에 앱 인증

Microsoft Entra 사용자에게 역할 할당

Azure Service Bus에 대한 Azure 기본 제공 역할

Azure Service Bus 소유자 역할에 Microsoft Entra 사용자 추가

연결 문자열 가져오기

NPM(Node Package Manager)을 사용하여 패키지 설치

토픽에 메시지 보내기

구독에서 메시지 받기

문제 해결

리소스 정리

다음 단계

추가 리소스