빠른 시작: Azure Service Bus 큐에 메시지 보내기 및 받기(JavaScript)

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

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

코드에서 사용할 다음 값을 기록해 둡다.

• Service Bus 네임스페이스 연결 문자열
• 만든 Service Bus 네임스페이스 큐

Microsoft Entra 사용자에게 역할 할당

로컬로 개발할 때 Azure Service Bus에 연결하는 사용자 계정에 올바른 권한이 있는지 확인합니다. 메시지를 보내고 받으려면 Azure Service Bus 데이터 소유자 역할이 필요합니다. 이 역할을 자신에게 할당하려면 사용자 액세스 관리자 역할 또는 작업을 포함하는 Microsoft.Authorization/roleAssignments/write 다른 역할이 필요합니다.

Azure Portal, Azure CLI 또는 Azure PowerShell을 사용하여 사용자에게 Azure RBAC 역할을 할당할 수 있습니다. 역할 할당에 사용 가능한 범위에 대해 자세히 알아보려면 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 네임스페이스 및 해당 엔터티에 대한 액세스 권한을 부여 send 합니다.
• Azure Service Bus 데이터 수신기: 이 역할을 사용하여 Service Bus 네임스페이스 및 해당 엔터티에 대한 액세스 권한을 부여 receive 합니다.

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

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

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

1. Azure Portal에 Service Bus 네임스페이스 페이지가 열려 있지 않은 경우 기본 검색 창이나 왼쪽 탐색 모음을 사용하여 Service Bus 네임스페이스를 찾습니다.

2. 개요 페이지의 왼쪽 메뉴에서 액세스 제어(IAM)를 선택합니다.

3. 액세스 제어(IAM) 페이지에서 역할 할당 탭을 선택합니다.

4. 상단 메뉴에서 + 추가 를 선택한 다음 역할 할당을 추가합니다.

   

5. 검색 상자를 사용하여 결과를 원하는 역할로 필터링합니다. 이 예에서는 Azure Service Bus Data Owner를 검색하고 일치하는 결과를 선택합니다. 다음을 선택합니다.

6. 다음에 대한 액세스 할당 아래에서 사용자, 그룹 또는 서비스 주체를 선택한 다음, + 멤버 선택을 선택합니다.

7. 대화 상자에서 Microsoft Entra 사용자 이름(일반적으로 user@___domain 이메일 주소)을 검색한 다음, 대화 상자 하단에서 선택을 선택합니다.

8. 검토 + 할당을 선택하여 최종 페이지로 이동한 다음, 검토 + 할당을 다시 선택하여 프로세스를 완료합니다.

연결 문자열 가져오기

새 네임스페이스를 만들면 기본 키와 보조 키가 있는 초기 SAS(공유 액세스 서명) 정책이 자동으로 생성됩니다. 네임스페이스의 모든 측면에 대해 각각 모든 권한을 부여하는 기본 및 보조 연결 문자열을 만듭니다. 일반 보낸 사람 및 수신기에 대해 더 제한된 권한으로 규칙을 만드는 방법에 대한 자세한 내용은 Service Bus 인증 및 권한 부여를 참조하세요.

클라이언트는 연결 문자열을 사용하여 Service Bus 네임스페이스에 연결할 수 있습니다. 네임스페이스에 대한 기본 연결 문자열을 복사하려면 다음 단계를 수행합니다.

1. Service Bus 네임스페이스 페이지의 왼쪽 메뉴에서 설정을 확장한 다음 공유 액세스 정책을 선택합니다.

2. 공유 액세스 정책 페이지에서 RootManageSharedAccessKey를 선택합니다.

3. 정책: RootManageSharedAccessKey 창에서 기본 연결 문자열 옆의 복사 단추를 선택하여 나중에 사용할 수 있도록 연결 문자열을 클립보드에 복사합니다. 메모장이나 기타 다른 위치에 임시로 이 값을 붙여 넣습니다.

   

   이 페이지를 사용하여 기본 키, 보조 키, 기본 연결 문자열 및 보조 연결 문자열을 복사할 수 있습니다.

1. Service Bus에 필요한 npm 패키지를 설치하려면 해당 경로에 있는 npm 명령 프롬프트 창을 열고 샘플을 사용할 폴더로 디렉터리를 변경합니다.

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

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

1. Service Bus에 필요한 npm 패키지를 설치하려면 해당 경로에 있는 npm 명령 프롬프트 창을 열고 샘플을 사용할 폴더로 디렉터리를 변경합니다.

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

   npm install @azure/service-bus
   

로컬 컴퓨터에 대한 Azure CLI 명령을 az login 사용하여 로그인하여 이 코드에 필요한 암호 없는 인증을 제공합니다.

1. Visual Studio Code와 같은 텍스트 편집기를 엽니다.

2. send.js라는 파일을 만들고, 그 안에 다음 코드를 붙여넣습니다. 이 코드는 과학자의 이름을 메시지로 큐에 보냅니다.

   중요합니다

   암호 없는 자격 증명은 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();
   
   // name of the queue
   const queueName = "<QUEUE 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 topic.
       const sender = sbClient.createSender(queueName);
   
       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 queue
           await sender.sendMessages(batch);
   
           console.log(`Sent a batch of messages to the queue: ${queueName}`);
   
           // 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);
       });
   

3. <SERVICE-BUS-NAMESPACE>를 Service Bus 네임스페이스로 바꾸어야 합니다.

4. <QUEUE NAME>을 큐 이름으로 바꿉니다.

5. 이 파일에서 코드를 실행하려면 명령 프롬프트에서 다음 명령을 사용합니다.

   node send.js
   

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

   Sent a batch of messages to the queue: myqueue
   

1. Visual Studio Code와 같은 텍스트 편집기를 엽니다.

2. send.js라는 파일을 만들고, 그 안에 다음 코드를 붙여넣습니다. 이 코드는 과학자의 이름을 메시지로 큐에 보냅니다.

   const { ServiceBusClient } = require("@azure/service-bus");
   
   // connection string to your Service Bus namespace
   const connectionString = "<CONNECTION STRING TO SERVICE BUS NAMESPACE>"
   
   // name of the queue
   const queueName = "<QUEUE 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 topic.
       const sender = sbClient.createSender(queueName);
   
       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 queue
           await sender.sendMessages(batch);
   
           console.log(`Sent a batch of messages to the queue: ${queueName}`);
   
           // 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);
    });
   

3. <CONNECTION STRING TO SERVICE BUS NAMESPACE>을 Service Bus 네임스페이스에 대한 연결 문자열로 바꿉니다.

4. <QUEUE NAME>을 큐 이름으로 바꿉니다.

5. 이 파일에서 코드를 실행하려면 명령 프롬프트에서 다음 명령을 사용합니다.

   node send.js
   

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

   Sent a batch of messages to the queue: myqueue
   

로컬 컴퓨터에 대한 Azure CLI 명령을 az login 사용하여 로그인하여 이 코드에 필요한 암호 없는 인증을 제공합니다.

1. Visual Studio Code와 같은 텍스트 편집기를 엽니다.

2. receive.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();
   
   // name of the queue
   const queueName = "<QUEUE 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 subscription.
       const receiver = sbClient.createReceiver(queueName);
   
       // 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(20000);
   
       await receiver.close();
       await sbClient.close();
   }
   // call the main function
   main().catch((err) => {
       console.log("Error occurred: ", err);
       process.exit(1);
    });
   

3. <SERVICE-BUS-NAMESPACE>를 Service Bus 네임스페이스로 바꾸어야 합니다.

4. <QUEUE NAME>을 큐 이름으로 바꿉니다.

5. 이 파일에서 코드를 실행하려면 명령 프롬프트에서 다음 명령을 사용합니다.

   node receive.js
   

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

2. receive.js라는 파일을 만들고, 그 안에 다음 코드를 붙여넣습니다.

   const { delay, ServiceBusClient, ServiceBusMessage } = require("@azure/service-bus");
   
   // connection string to your Service Bus namespace
   const connectionString = "<CONNECTION STRING TO SERVICE BUS NAMESPACE>"
   
   // name of the queue
   const queueName = "<QUEUE 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 subscription.
       const receiver = sbClient.createReceiver(queueName);
   
       // 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(20000);
   
       await receiver.close();
       await sbClient.close();
   }
   // call the main function
   main().catch((err) => {
       console.log("Error occurred: ", err);
       process.exit(1);
    });
   

3. <CONNECTION STRING TO SERVICE BUS NAMESPACE>을 Service Bus 네임스페이스에 대한 연결 문자열로 바꿉니다.

4. <QUEUE NAME>을 큐 이름으로 바꿉니다.

5. 이 파일에서 코드를 실행하려면 명령 프롬프트에서 다음 명령을 사용합니다.

   node receive.js