Snabbstart: Skicka meddelanden till och ta emot meddelanden från Azure Service Bus-köer (JavaScript)

Så här använder du den här snabbstarten med ditt eget Azure-konto:

• Installera Azure CLI, som tillhandahåller lösenordslös autentisering till utvecklardatorn.
• Logga in med ditt Azure-konto i en kommandotolk med az login.
• Använd samma konto när du lägger till lämplig dataroll i resursen.
• Kör koden i samma kommandotolkfönster.
• Anteckna könamnet för Service Bus-namnområdet. Du behöver det i koden.

Anteckna följande värden som ska användas i koden:

• Service Bus-namnområde anslutningssträng
• Service Bus-namnområdeskö som du skapade

Tilldela roller till din Microsoft Entra-användare

När du utvecklar lokalt kontrollerar du att användarkontot som ansluter till Azure Service Bus har rätt behörigheter. Du behöver rollen Azure Service Bus-dataägare för att kunna skicka och ta emot meddelanden. Om du vill tilldela dig själv den här rollen behöver du rollen Administratör för användaråtkomst eller en annan roll som innehåller åtgärden Microsoft.Authorization/roleAssignments/write .

Du kan tilldela Azure RBAC-roller till en användare med hjälp av Azure Portal, Azure CLI eller Azure PowerShell. Mer information om tillgängliga omfång för rolltilldelningar finns i Förstå omfånget för Azure RBAC.

I följande exempel tilldelas Azure Service Bus Data Owner rollen till ditt användarkonto, vilket ger fullständig åtkomst till Azure Service Bus-resurser. I ett verkligt scenario följer du principen om minsta behörighet för att ge användarna endast de minsta behörigheter som krävs för en säkrare produktionsmiljö.

Inbyggda Azure-roller för Azure Service Bus

För Azure Service Bus skyddas redan hanteringen av namnområden och alla relaterade resurser via Azure Portal och Azure-resurshanterings-API:et med hjälp av Azure RBAC-modellen. Azure tillhandahåller följande inbyggda Azure-roller för att auktorisera åtkomst till ett Service Bus-namnområde:

• Azure Service Bus-dataägare: Ger dataåtkomst till Service Bus-namnområdet och dess entiteter, inklusive köer, ämnen, prenumerationer och filter. En medlem i den här rollen kan skicka och ta emot meddelanden från köer eller ämnen/prenumerationer.
• Azure Service Bus-datasändare: Använd den här rollen för att ge send åtkomst till Service Bus-namnområdet och dess entiteter.
• Azure Service Bus-datamottagare: Använd den receive här rollen för att ge åtkomst till Service Bus-namnområdet och dess entiteter.

Om du vill skapa en anpassad roll läser du Rättigheter som krävs för Service Bus-åtgärder.

Lägga till Microsoft Entra-användare i rollen Som Azure Service Bus-ägare

Lägg till ditt Microsoft Entra-användarnamn i rollen Azure Service Bus-dataägare på Service Bus-namnområdesnivå. Med den här konfigurationen kan en app som körs i kontexten för ditt användarkonto skicka meddelanden till en kö eller ett ämne. Den kan ta emot meddelanden från en kö eller ett ämnesprenumeration.

1. Om du inte har sidan Service Bus-namnområde öppen i Azure Portal letar du upp Service Bus-namnområdet med hjälp av huvudsökfältet eller det vänstra navigeringsfältet.

2. På sidan Översikt väljer du Åtkomstkontroll (IAM) på den vänstra menyn.

3. På sidan Åtkomstkontroll (IAM) väljer du fliken Rolltilldelningar .

4. Välj + Lägg till på den översta menyn och sedan Lägg till rolltilldelning.

   

5. Använd sökrutan för att filtrera resultatet till önskad roll. I det här exemplet söker Azure Service Bus Data Owner du efter och väljer matchande resultat. Välj sedan Nästa.

6. Under Tilldela åtkomst till väljer du Användare, grupp eller tjänstens huvudnamn och sedan + Välj medlemmar.

7. I dialogrutan söker du efter ditt Microsoft Entra-användarnamn (vanligtvis din user@domain e-postadress) och väljer sedan Välj längst ned i dialogrutan.

8. Välj Granska + tilldela för att gå till den sista sidan och sedan Granska + tilldela igen för att slutföra processen.

Hämta anslutningssträngen

När du skapar ett nytt namnområde genereras automatiskt en inledande SAS-princip (Signatur för delad åtkomst) med primära och sekundära nycklar. Den skapar primära och sekundära anslutningssträngar som var och en ger fullständig kontroll över alla aspekter av namnområdet. Mer information om hur du skapar regler med mer begränsade rättigheter för vanliga avsändare och mottagare finns i Service Bus-autentisering och auktorisering.

En klient kan använda anslutningssträng för att ansluta till Service Bus-namnområdet. Så här kopierar du den primära anslutningssträng för ditt namnområde:

1. På sidan Service Bus-namnområde går du till den vänstra menyn och expanderar Inställningar och väljer sedan Principer för delad åtkomst.

2. På sidan Principer för delad åtkomst väljer du RootManageSharedAccessKey.

3. I fönstret Princip: RootManageSharedAccessKey väljer du kopieringsknappen bredvid Primär anslutningssträng för att kopiera anslutningssträng till Urklipp för senare användning. Klistra in det här värdet i Anteckningar eller på en tillfällig plats.

   

   Du kan använda den här sidan för att kopiera primärnyckel, sekundär nyckel, primär anslutningssträng och sekundär anslutningssträng.

1. För att installera nödvändiga npm-paket för Service Bus, öppna ett kommandotolkfönster där npm finns med i systemets PATH och ändra katalogen till den mapp där du vill ha dina exempel.

2. Installera följande paket:

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

1. För att installera nödvändiga npm-paket för Service Bus, öppna ett kommandotolkfönster där npm finns med i systemets PATH och ändra katalogen till den mapp där du vill ha dina exempel.

2. Installera följande paket:

   npm install @azure/service-bus
   

Logga in med Azure CLI-kommandot az login för din lokala dator för att tillhandahålla den lösenordslösa autentisering som krävs i den här koden.

1. Öppna en textredigerare, till exempel Visual Studio Code.

2. Skapa en fil med namnet send.js och klistra in följande kod i den. Den här koden skickar namnen på forskare som meddelanden till din kö.

   Viktigt!

   Den lösenordslösa autentiseringsuppgiften tillhandahålls med hjälp av StandardAzureCredential.

   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. Ersätt <SERVICE-BUS-NAMESPACE> med Service Bus-namnområdet.

4. Ersätt <QUEUE NAME> med namnet på kön.

5. Om du vill köra koden i den här filen använder du det här kommandot i en kommandotolk:

   node send.js
   

   Du bör se följande utdata.

   Sent a batch of messages to the queue: myqueue
   

1. Öppna en textredigerare, till exempel Visual Studio Code.

2. Skapa en fil med namnet send.js och klistra in följande kod i den. Den här koden skickar namnen på forskare som meddelanden till din kö.

   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. Ersätt <CONNECTION STRING TO SERVICE BUS NAMESPACE> med anslutningssträng till Service Bus-namnområdet.

4. Ersätt <QUEUE NAME> med namnet på kön.

5. Om du vill köra koden i den här filen använder du det här kommandot i en kommandotolk:

   node send.js
   

   Du bör se följande utdata.

   Sent a batch of messages to the queue: myqueue
   

Logga in med Azure CLI-kommandot az login för din lokala dator för att tillhandahålla den lösenordslösa autentisering som krävs i den här koden.

1. Öppna en textredigerare, till exempel Visual Studio Code.

2. Skapa en fil med namnet receive.js och klistra in följande kod i den.

   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. Ersätt <SERVICE-BUS-NAMESPACE> med Service Bus-namnområdet.

4. Ersätt <QUEUE NAME> med namnet på kön.

5. Om du vill köra koden i den här filen använder du det här kommandot i en kommandotolk:

   node receive.js
   

1. Öppna din favoritredigerare, till exempel Visual Studio Code.

2. Skapa en fil med namnet receive.js och klistra in följande kod i den.

   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. Ersätt <CONNECTION STRING TO SERVICE BUS NAMESPACE> med anslutningssträng till Service Bus-namnområdet.

4. Ersätt <QUEUE NAME> med namnet på kön.

5. Om du vill köra koden i den här filen använder du det här kommandot i en kommandotolk:

   node receive.js