Inviare messaggi a un argomento del Bus di servizio di Azure e ricevere messaggi dalle sottoscrizioni dell'argomento (JavaScript)

Per usare questo avvio rapido con il proprio account Azure, è necessario:

• Installare l'interfaccia della riga di comando di Azure, che fornisce l'autenticazione senza password al computer per sviluppatori.
• Accedere con l'account Azure al terminale o al prompt dei comandi con az login.
• Usare lo stesso account quando si aggiunge il ruolo appropriato alla risorsa.
• Eseguire il codice nello stesso terminale o nel prompt dei comandi.
• Annotare il nome dell'argomento e la sottoscrizione per lo spazio dei nomi del Bus di servizio. Sarà necessario nel codice.

Tenere presente quanto segue, che verrà usato nel codice seguente:

• Stringa di connessione dello spazio dei nomi del Bus di servizio
• Nome dell'argomento dello spazio dei nomi del Bus di servizio creato
• Sottoscrizione dello spazio dei nomi del Bus di servizio

Assegnare ruoli all'utente di Microsoft Entra

Quando si sviluppa in locale, assicurarsi che l'account utente che si connette al bus di servizio di Azure disponga delle autorizzazioni corrette. Per inviare e ricevere messaggi, è necessario il ruolo Proprietario dati del bus di servizio di Azure. Per assegnare a se stessi questo ruolo, è necessario il ruolo Amministratore accesso utenti o un altro ruolo che include l'azione Microsoft.Authorization/roleAssignments/write .

È possibile assegnare ruoli controllo degli accessi in base al ruolo di Azure a un utente usando il portale di Azure, l'interfaccia della riga di comando di Azure o Azure PowerShell. Per ulteriori informazioni sugli ambiti disponibili per le assegnazioni di ruolo, vedere Comprendere l'ambito per RBAC di Azure.

L'esempio seguente assegna il ruolo Azure Service Bus Data Owner all'account utente, che fornisce l'accesso completo alle risorse del Bus di servizio di Azure. In uno scenario reale, seguire il principio dei privilegi minimi per concedere agli utenti solo le autorizzazioni minime necessarie per un ambiente di produzione più sicuro.

Ruoli predefiniti di Azure per il Bus di servizio di Azure

Per il Bus di servizio di Azure, la gestione degli spazi dei nomi e di tutte le risorse correlate tramite il portale di Azure e l'API Gestione risorse di Azure è già protetto mediante il modello RBAC di Azure. Azure fornisce i ruoli predefiniti di Azure seguenti per autorizzare l'accesso a uno spazio dei nomi del bus di servizio:

• Azure Service Bus Data Owner: consente l'accesso ai dati dello spazio dei nomi di Service Bus e delle relative entità, includendo code, argomenti, sottoscrizioni e filtri. Un membro di questo ruolo può inviare e ricevere messaggi da code o argomenti/sottoscrizioni.
• Mittente dati di Azure Service Bus: Utilizzare questo ruolo per concedere l'accesso send allo spazio dei nomi di Service Bus e alle relative entità.
• Ricevitore dati del bus di servizio di Azure: usare questo ruolo per concedere l'accesso receive allo spazio dei nomi del bus di servizio e alle relative entità.

Per creare un ruolo personalizzato, vedere Diritti necessari per le operazioni del Bus di servizio.

Aggiungere l'utente di Microsoft Entra al ruolo Proprietario del Bus di servizio di Azure

Aggiungere il nome utente di Microsoft Entra al ruolo Proprietario dei dati del Bus di servizio di Azure a livello di spazio dei nomi del Bus di servizio. Questa configurazione consente a un'app eseguita nel contesto dell'account utente di inviare messaggi a una coda o a un argomento. Può ricevere messaggi da una coda o da una sottoscrizione di un argomento.

1. Se la pagina Spazio dei nomi del Bus di servizio non è aperta nel portale di Azure, individuare lo spazio dei nomi del Bus di servizio usando la barra di ricerca principale o lo spostamento a sinistra.

2. Nella pagina Panoramica selezionare Controllo di accesso (IAM) dal menu a sinistra.

3. Nella pagina Controllo di accesso (IAM), selezionare la scheda Assegnazioni di ruolo.

4. Selezionare + Aggiungi dal menu in alto e quindi Aggiungi assegnazione di ruolo.

   

5. Usare la casella di ricerca per filtrare i risultati in base al ruolo desiderato. Per questo esempio, cercare Azure Service Bus Data Owner e selezionare il risultato corrispondente. Scegliere quindi Avanti.

6. In Assegna accesso a selezionare Utente, gruppo o entità servizio e quindi scegliere + Seleziona membri.

7. Nella finestra di dialogo cercare il nome utente di Microsoft Entra (in genere l'indirizzo di posta elettronica user@domain) e quindi scegliere Selezionare nella parte inferiore della finestra di dialogo.

8. Selezionare Rivedi e assegna per passare alla pagina finale e quindi Rivedi e assegna di nuovo per completare il processo.

Ottenere la stringa di connessione

La creazione di un nuovo spazio dei nomi genera automaticamente un criterio di firma di accesso condiviso iniziale con chiavi primarie e secondarie. Crea stringhe di connessione primarie e secondarie che concedono ogni controllo completo su tutti gli aspetti dello spazio dei nomi. Per altre informazioni su come creare regole con diritti più vincolati per mittenti e ricevitori regolari, vedere Autenticazione e autorizzazione del bus di servizio.

Un client può usare la stringa di connessione per connettersi allo spazio dei nomi di Bus di servizio. Per copiare la stringa di connessione primaria per lo spazio dei nomi, procedere come segue:

1. Nel menu a sinistra della pagina Spazio dei nomi del bus di servizio espandere Impostazioni, quindi selezionare Criteri di accesso condiviso.

2. Nella pagina Criteri di accesso condiviso selezionare RootManageSharedAccessKey.

3. Nella finestra Criteri: RootManageSharedAccessKey selezionare il pulsante Copia accanto a Stringa di connessione primaria per copiare la stringa di connessione negli Appunti e usarla in un secondo momento. Incollare questo valore nel Blocco note o in un'altra posizione temporanea.

   

   È possibile usare questa pagina per copiare la chiave primaria, la chiave secondaria, la stringa di connessione primaria e la stringa di connessione secondaria.

1. Per installare il pacchetto/i pacchetti npm necessario/necessari per il Bus di servizio, aprire un prompt dei comandi il cui percorso comprenda npm, andare alla cartella in cui si vogliono archiviare gli esempi, quindi eseguire questo comando.

2. Installare i pacchetti seguenti:

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

1. Per installare il pacchetto/i pacchetti npm necessario/necessari per il Bus di servizio, aprire un prompt dei comandi il cui percorso comprenda npm, andare alla cartella in cui si vogliono archiviare gli esempi, quindi eseguire questo comando.

2. Installare il pacchetto seguente:

   npm install @azure/service-bus
   

Per consentire al computer locale di fornire l'autenticazione senza password necessaria in questo codice, è necessario aver eseguito l'accesso con az login dell'interfaccia della riga di comando di Azure.

1. Aprire l'editor preferito, ad esempioVisual Studio Code.

2. Creare un file denominato sendtotopic.js e incollarvi il codice riportato di seguito. Questo codice invierà un messaggio all'argomento.

   Importante

   Le credenziali senza password vengono fornite con 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);
    });
   

3. Sostituire <SERVICE BUS NAMESPACE CONNECTION STRING> con la stringa di connessione allo spazio dei nomi del bus di servizio.

4. Sostituire <TOPIC NAME> con il nome dell'argomento.

5. Quindi eseguire il comando in un prompt dei comandi per eseguire questo file.

   node sendtotopic.js
   

6. Viene visualizzato l'output seguente.

   Sent a batch of messages to the topic: mytopic
   

1. Aprire l'editor preferito, ad esempioVisual Studio Code.

2. Creare un file denominato sendtotopic.js e incollarvi il codice riportato di seguito. Questo codice invierà un messaggio all'argomento.

   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);
    });
   

3. Sostituire <SERVICE BUS NAMESPACE CONNECTION STRING> con la stringa di connessione allo spazio dei nomi del bus di servizio.

4. Sostituire <TOPIC NAME> con il nome dell'argomento.

5. Quindi eseguire il comando in un prompt dei comandi per eseguire questo file.

   node sendtotopic.js
   

6. Viene visualizzato l'output seguente.

   Sent a batch of messages to the topic: mytopic
   

Per consentire al computer locale di fornire l'autenticazione senza password necessaria in questo codice, è necessario aver eseguito l'accesso con az login dell'interfaccia della riga di comando di Azure.

1. Aprire l'editor preferito, ad esempioVisual Studio Code.

2. Creare un file denominato receivefromsubscription.js e incollarvi il codice seguente. Per i dettagli, vedere i commenti nel codice.

   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);
    });
   

3. Sostituire <SERVICE BUS NAMESPACE CONNECTION STRING> con la stringa di connessione allo spazio dei nomi.

4. Sostituire <TOPIC NAME> con il nome dell'argomento.

5. Sostituire <SUBSCRIPTION NAME> con il nome della sottoscrizione dell'argomento.

6. Quindi eseguire il comando in un prompt dei comandi per eseguire questo file.

   node receivefromsubscription.js
   

1. Aprire l'editor preferito, ad esempioVisual Studio Code.

2. Creare un file denominato receivefromsubscription.js e incollarvi il codice seguente. Per i dettagli, vedere i commenti nel codice.

   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);
    });
   

3. Sostituire <SERVICE BUS NAMESPACE CONNECTION STRING> con la stringa di connessione allo spazio dei nomi.

4. Sostituire <TOPIC NAME> con il nome dell'argomento.

5. Sostituire <SUBSCRIPTION NAME> con il nome della sottoscrizione dell'argomento.

6. Quindi eseguire il comando in un prompt dei comandi per eseguire questo file.

   node receivefromsubscription.js