Delen via

Java Message Service 2.0 API gebruiken met Azure Service Bus Premium

  • Artikel

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.

Notitie

Ondersteuning voor Java Message Service (JMS) 2.0 API is alleen beschikbaar in de Premium-laag.>

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:

  • 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.

Functie API Status
Wachtrijen
  • JMSContext.createQueue( String queueName)
Ondersteund
Onderwerpen
  • JMSContext.createTopic( String topicName)
Ondersteund
Tijdelijke wachtrijen
  • JMSContext.createTemporaryQueue()
Ondersteund
Tijdelijke onderwerpen
  • JMSContext.createTemporaryTopic()
Ondersteund
Berichtproducent /
JMSProducer
  • JMSContext.createProducer()
Ondersteund
Wachtrijbrowsers
  • JMSContext.createBrowser(Queue Queue)
  • JMSContext.createBrowser(Wachtrij, Tekenreeks messageSelector)
Ondersteund
Berichtconsumer/
JMSConsumer
  • JMSContext.createConsumer( Doelbestemming)
  • JMSContext.createConsumer( Doelbestemming, Tekenreeks messageSelector)
  • JMSContext.createConsumer( Doel, Tekenreeks messageSelector, Booleaanse noLocal)

noLocal wordt momenteel niet ondersteund		 Ondersteund
Gedeelde duurzame abonnementen
  • JMSContext.createSharedDurableConsumer(onderwerp, tekenreeksnaam)
  • JMSContext.createSharedDurableConsumer(onderwerp, tekenreeksnaam, tekenreeks messageSelector)
Ondersteund
Niet-gedeelde duurzame abonnementen
  • JMSContext.createDurableConsumer(onderwerp, tekenreeksnaam)
  • createDurableConsumer(Onderwerp, Tekenreeksnaam, Tekenreeks messageSelector, Booleaanse noLocal)

noLocal wordt momenteel niet ondersteund en moet worden ingesteld op false		 Ondersteund
Gedeelde niet-duurzame abonnementen
  • JMSContext.createSharedConsumer(onderwerp, string sharedSubscriptionName)
  • JMSContext.createSharedConsumer(Onderwerp, String sharedSubscriptionName, String messageSelector)
Ondersteund
Niet-gedeelde niet-duurzame abonnementen
  • JMSContext.createConsumer(Doelbestemming)
  • JMSContext.createConsumer( Doelbestemming, Tekenreeks messageSelector)
  • JMSContext.createConsumer( Doel, Tekenreeks messageSelector, Booleaanse noLocal)

noLocal wordt momenteel niet ondersteund en moet worden ingesteld op false		 Ondersteund
Berichtkiezers is afhankelijk van de consument die is gemaakt Ondersteund
Bezorgingsvertraging (geplande berichten)
  • JMSProducer.setDeliveryDelay( long deliveryDelay)
Ondersteund
Bericht gemaakt
  • JMSContext.createMessage()
  • JMSContext.createBytesMessage()
  • JMSContext.createMapMessage()
  • JMSContext.createObjectMessage( Serializable object)
  • JMSContext.createStreamMessage()
  • JMSContext.createTextMessage()
  • JMSContext.createTextMessage( tekenreekstekst)
Ondersteund
Transacties tussen entiteiten
  • Connection.createSession(true, Session.SESSION_TRANSACTED)
Ondersteund
Gedistribueerde transacties Niet 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 vooraf gemaakte beleidswaarden, beleid opnieuw verbinden, Microsoft Entra-id en ondersteuning voor beheerde identiteiten.

Notitie

Als u de azure-servicebus-jms wilt toevoegen aan het buildpad, gebruikt u het hulpprogramma voor voorkeursbeheer voor afhankelijkheden voor uw project, zoals Maven of Gradle.

Java-toepassingen coderen

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

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 functie voor het ConnectionFactory maken van een Connection 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 Sessie een essentiële bouwsteen van de API waarmee de MessageProducer, MessageConsumeren de Message zichzelf kunnen worden gemaakt. Raadpleeg het JMS API-programmeermodel voor meer informatie

    In Service Bus zijn sessies service- en clientconstruct om FIFO-verwerking in te schakelen voor wachtrijen en abonnementen.

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 betrouwbaar uitwisselen met behulp van de AMQP 1.0-ondersteuning in Service Bus.

Gerelateerde inhoud