Java Message Service 2.0 API gebruiken met Azure Service Bus Premium

In dit artikel wordt uitgelegd hoe u de populaire JMS 2.0-API (Java Message Service) gebruikt om te communiceren met Azure Service Bus via het PROTOCOL Advanced Message Queueing Protocol (AMQP) 1.0.

Belangrijke opmerkingen

Hier volgen enkele belangrijke punten:

• Ondersteuning voor JMS 2.0-API is alleen beschikbaar in de Premium-laag en wanneer u de bibliotheek azure-servicebus-jms gebruikt.
• Als u andere JMS-bibliotheken dan azure-servicebus-jms (bijvoorbeeld de meest recente qpid-jms-client) gebruikt voor een Premium-naamruimte, ziet u het gedrag van JMS 1.1 en werken sommige van de JMS 2.0-functies mogelijk niet zoals verwacht. De bibliotheek azure-servicebus-jms maakt geen leveranciervergrendeling van welke aard dan ook, omdat deze nog steeds afhankelijk is van qpid-jms-client. Alle API's die werken op qpid-jms-client werken ook in de azure-servicebus-jms-bibliotheek.
• De azure-servicebus-jms is ook een opensource-bibliotheek. De azure-servicebus-jms-bibliotheek is voornamelijk gemaakt, zodat de Service Bus-service onderscheid kan maken tussen klanten die het JMS 1.1-gedrag (achterwaartse compatibiliteit) nodig hebben ten opzichte van het gedrag van JMS 2.0 bij het werken met een Premium-naamruimte. De bibliotheek azure-servicebus-jms biedt ook enkele benodigde standaardwaarden, zoals vooraf gemaakte beleidswaarden, beleid voor opnieuw verbinden, Microsoft Entra ID, ondersteuning voor beheerde identiteit, ondersteuning voor automatisch verwijderen bij inactiviteit voor entiteiten.
• Het volgende pad naar het azure-servicebus-jms-pakket is de nieuwste versie van de bibliotheek die is gebaseerd op de Jakarta Messaging-specificatie (Jakarta.* API's): Maven Central: com.azure:azure-servicebus-jms. En het volgende pad naar de azure-servicebus-jms is de nieuwste versie van de bibliotheek vóór de Jakarta Messaging-specificatie (javax.* API's): Maven Central: com.microsoft.azure:azure-servicebus-jms.

Vereisten

Aan de slag met Service Bus

In deze handleiding wordt ervan uitgegaan dat u al een Service Bus-naamruimte hebt. Als u dit niet doet, maakt u een naamruimte en een wachtrij met behulp van Azure Portal. Zie Aan de slag met Service Bus-wachtrijen via Azure Portal voor meer informatie over het maken van Service Bus-naamruimten en -wachtrijen.

Een Java Development-omgeving instellen

Als u Java-toepassingen wilt ontwikkelen, moet u de juiste ontwikkelomgeving instellen:

• Ofwel de JDK (Java Development Kit) of de JRE (Java Runtime Environment) is geïnstalleerd.
• De JDK of JRE wordt toegevoegd aan het buildpad en de juiste systeemvariabelen.
• Er is een Java IDE geïnstalleerd om de JDK of JRE te gebruiken. Bijvoorbeeld Eclipse of IntelliJ.

Gebruik deze handleiding voor meer informatie over het voorbereiden van uw ontwikkelomgeving voor Java in Azure.

Welke JMS-functies worden ondersteund?

De volgende tabel bevat de JMS-functies (Java Message Service) die momenteel door Azure Service Bus worden ondersteund. Ook worden functies weergegeven die niet worden ondersteund.

De JMS-clientbibliotheek (Java Message Service) downloaden

Als u alle functies wilt gebruiken die beschikbaar zijn in de Premium-laag, voegt u de volgende bibliotheek toe aan het buildpad van het project: azure-servicebus-jms. Dit pakket biedt enkele noodzakelijke standaardwaarden, zoals prefetch beleidswaarden, beleidswaarden voor opnieuw verbinden, Microsoft Entra ID en beheerde identiteitsondersteuning.

Java-toepassingen coderen

Zodra de afhankelijkheden zijn geïmporteerd, kunnen de Java-toepassingen op een JMS-provider-agnostische manier worden geschreven.

Verbinding maken met Azure Service Bus met behulp van JMS

Als u verbinding wilt maken met Azure Service Bus met behulp van JMS-clients, hebt u de verbindingsreeks nodig die beschikbaar is in het beleid voor gedeelde toegang in Azure Portal onder Primaire verbindingsreeks.

1. Instantieer de ServiceBusJmsConnectionFactorySettings

   ServiceBusJmsConnectionFactorySettings connFactorySettings = new ServiceBusJmsConnectionFactorySettings();
   connFactorySettings.setConnectionIdleTimeoutMS(20000);
   

2. Instantieer de ServiceBusJmsConnectionFactory met de juiste ServiceBusConnectionString.

   String ServiceBusConnectionString = "<SERVICE_BUS_CONNECTION_STRING_WITH_MANAGE_PERMISSIONS>";
   ConnectionFactory factory = new ServiceBusJmsConnectionFactory(ServiceBusConnectionString, connFactorySettings);
   

3. Gebruik de ConnectionFactory om een Connection te maken en vervolgens een Session

   Connection connection = factory.createConnection();
   Session session = connection.createSession();
   

   of een JMSContext (voor JMS 2.0-clients)

   JMSContext jmsContext = factory.createContext();
   

   Belangrijk

   Hoewel het ook een naam heeft, is een JMS-sessie en Service Bus-sessie volledig onafhankelijk van elkaar.

   In JMS 1.1 is de sessie een essentiële bouwsteen van de API waarmee de MessageProducer, MessageConsumer en de Message kunnen worden gemaakt. Raadpleeg het JMS API-programmeermodel voor meer informatie

   In Service Bus zijn sessies service- en clientconstructies om de FIFO-verwerking in wachtrijen en abonnementen mogelijk te maken.

De JMS-toepassing schrijven

Zodra de Session of JMSContext is geïnstantieerd, kan uw toepassing de vertrouwde JMS-API's gebruiken om zowel beheer- als gegevensbewerkingen uit te voeren. Raadpleeg de lijst met ondersteunde JMS-functies om te zien welke API's worden ondersteund. Hier volgen enkele voorbeeldcodefragmenten om aan de slag te gaan met JMS -

Berichten verzenden naar een wachtrij en onderwerp

// Create the queue and topic
Queue queue = jmsContext.createQueue("basicQueue");
Topic topic = jmsContext.createTopic("basicTopic");
// Create the message
Message msg = jmsContext.createMessage();

// Create the JMS message producer
JMSProducer producer = jmsContext.createProducer();

// send the message to the queue
producer.send(queue, msg);
// send the message to the topic
producer.send(topic, msg);

Berichten ontvangen van een wachtrij

// Create the queue
Queue queue = jmsContext.createQueue("basicQueue");

// Create the message consumer
JMSConsumer consumer = jmsContext.createConsumer(queue);

// Receive the message
Message msg = (Message) consumer.receive();

Berichten ontvangen van een gedeeld duurzaam abonnement op een onderwerp

// Create the topic
Topic topic = jmsContext.createTopic("basicTopic");

// Create a shared durable subscriber on the topic
JMSConsumer sharedDurableConsumer = jmsContext.createSharedDurableConsumer(topic, "sharedDurableConsumer");

// Receive the message
Message msg = (Message) sharedDurableConsumer.receive();

Samenvatting

In deze handleiding ziet u hoe Java-clienttoepassingen met behulp van Java Message Service (JMS) via AMQP 1.0 kunnen communiceren met Azure Service Bus.

U kunt Service Bus AMQP 1.0 ook gebruiken vanuit andere talen, waaronder .NET, C, Python en PHP. Onderdelen die zijn gebouwd met behulp van deze verschillende talen kunnen berichten betrouwbaar en met volledige getrouwheid uitwisselen dankzij de ondersteuning van AMQP 1.0 in Service Bus.

Gerelateerde inhoud

• JMS in Spring gebruiken voor toegang tot Azure Service Bus
• Azure Service Bus gebruiken met JMS