Migrera befintliga JMS 2.0-program (Java Message Service) från Apache ActiveMQ till Azure Service Bus
Den här artikeln beskriver hur du ändrar ett befintligt Java Message Service (JMS) 2.0-program som interagerar med en JMS Broker för att interagera med Azure Service Bus i stället. I synnerhet omfattar artikeln migrering från Apache ActiveMQ eller Amazon MQ.
Azure Service Bus stöder Java 2-plattforms-, Enterprise Edition- och Spring-arbetsbelastningar som använder JMS 2.0-API:et över Advanced Message Queueing Protocol (AMQP).
Innan du börjar
Skillnader mellan Azure Service Bus och Apache ActiveMQ
Azure Service Bus och Apache ActiveMQ fungerar båda som JMS-leverantörer för klientprogram för att skicka meddelanden till och ta emot meddelanden från. De aktiverar både punkt-till-punkt-semantik med köer och publicera/prenumerera-semantik med ämnen och prenumerationer.
Det finns dock vissa skillnader mellan de två, som följande tabell visar:
Kategori | ActiveMQ | Azure Service Bus |
---|---|---|
Programnivåindelning | Klustrad monolit | Två nivåer (gateway + serverdel) |
Protokollstöd |
|
AMQP |
Etableringsläge |
|
Hanterad plattform som en tjänst (PaaS) |
Meddelandestorlek | Kunden kan konfigureras | 100 MB (Premium-nivå) |
Hög tillgänglighet | Kundhanterad | Plattformshanterad |
Haveriberedskap | Kundhanterad | Plattformshanterad |
Aktuella funktioner som stöds och inte stöds
I följande tabell visas de JMS-funktioner (Java Message Service) som Azure Service Bus stöder för närvarande. Den visar även funktioner som inte stöds.
Funktion | API | Status |
---|---|---|
Köer |
|
Stöds |
Ämnen |
|
Stöds |
Tillfälliga köer |
|
Stöds |
Tillfälliga ämnen |
|
Stöds |
Meddelandeproducent/ JMSProducer |
|
Stöds |
Köwebbläsare |
|
Stöds |
Meddelandekonsument/ JMSConsumer |
noLocal stöds inte för närvarande |
Stöds |
Delade varaktiga prenumerationer |
|
Stöds |
Ej delade varaktiga prenumerationer |
noLocal stöds inte för närvarande och ska vara inställt på false |
Stöds |
Delade icke-varaktiga prenumerationer |
|
Stöds |
Ej delade icke-varaktiga prenumerationer |
noLocal stöds inte för närvarande och ska vara inställt på false |
Stöds |
Meddelandeväljare | är beroende av den konsument som skapats | Stöds |
Leveransfördröjning (schemalagda meddelanden) |
|
Stöds |
Meddelandet har skapats |
|
Stöds |
Transaktioner mellan entiteter |
|
Stöds |
Distribuerade transaktioner | Stöds inte |
Överväganden
Den tvådelade typen av Azure Service Bus ger olika funktioner för affärskontinuitet (hög tillgänglighet och haveriberedskap). Det finns dock vissa överväganden när du använder JMS-funktioner.
Tjänstuppgraderingar
Vid service bus-uppgraderingar och omstarter tas tillfälliga köer eller ämnen bort. Om ditt program är känsligt för dataförlust i tillfälliga köer eller ämnen ska du inte använda tillfälliga köer eller ämnen. Använd varaktiga köer, ämnen och prenumerationer i stället.
Datamigrering
Som en del av att migrera och ändra dina klientprogram så att de interagerar med Azure Service Bus migreras inte de data som lagras i ActiveMQ till Service Bus. Du kan behöva ett anpassat program för att tömma ActiveMQ-köer, ämnen och prenumerationer och sedan spela upp meddelandena till köer, ämnen och prenumerationer för Service Bus.
Autentisering och auktorisering
Rollbaserad åtkomstkontroll i Azure (Azure RBAC), som backas upp av Azure Active Directory, är den föredragna autentiseringsmekanismen för Service Bus. Eftersom Azure RBAC, eller anspråksbaserad autentisering, för närvarande inte stöds av Apache QPID JMS bör du dock använda SAS-nycklar för autentisering.
Före migrering
Versionskontroll
Du använder följande komponenter och versioner när du skriver JMS-programmen:
Komponent | Version |
---|---|
Java Message Service (JMS) API | 1.1 eller senare |
AMQP-protokoll | 1.0 |
Kontrollera att AMQP-portar är öppna
Service Bus stöder kommunikation via AMQP-protokollet. För detta ändamål aktiverar du kommunikation via portarna 5671 (AMQP) och 443 (TCP). Beroende på var klientprogrammen finns kan du behöva ett supportärende för att tillåta kommunikation via dessa portar.
Viktigt
Service Bus stöder endast AMQP 1.0-protokoll.
Konfigurera företagskonfigurationer
Service Bus möjliggör olika funktioner för företagssäkerhet och hög tillgänglighet. Mer information finns i:
- Tjänstslutpunkter för virtuellt nätverk
- Brandvägg
- Kryptering på tjänstsidan med kundhanterad nyckel (BYOK)
- Privata slutpunkter
- Autentisering och auktorisering
Övervakning, aviseringar och spårning
För varje Service Bus-namnområde publicerar du mått på Azure Monitor. Du kan använda dessa mått för aviseringar och dynamisk skalning av resurser som allokerats till namnområdet.
Mer information om de olika måtten och hur du konfigurerar aviseringar för dem finns i Service Bus-mått i Azure Monitor. Du kan också läsa mer om spårning på klientsidan för dataåtgärder och drift-/diagnostikloggning för hanteringsåtgärder.
Mått – New Relic
Du kan korrelera vilka mått från ActiveMQ-karta som mått i Azure Service Bus. Se följande från webbplatsen New Relic:
Anteckning
För närvarande har New Relic inte direkt, sömlös integrering med ActiveMQ, men de har mått tillgängliga för Amazon MQ. Eftersom Amazon MQ härleds från ActiveMQ mappar följande tabell New Relic-måtten från Amazon MQ till Azure Service Bus.
Måttgruppering | Amazon MQ/ActiveMQ-mått | Azure Service Bus mått |
---|---|---|
Broker | CpuUtilization |
CPUXNS |
Broker | MemoryUsage |
WSXNS |
Broker | CurrentConnectionsCount |
activeConnections |
Broker | EstablishedConnectionsCount |
activeConnections + connectionsClosed |
Broker | InactiveDurableTopicSubscribersCount |
Använda prenumerationsmått |
Broker | TotalMessageCount |
Använda kö-/ämnes-/prenumerationsnivå activeMessages |
Kö/ämne | EnqueueCount |
incomingMessages |
Kö/ämne | DequeueCount |
outgoingMessages |
Kö | QueueSize |
sizeBytes |
Migrering
Om du vill migrera ditt befintliga JMS 2.0-program för att interagera med Service Bus följer du stegen i nästa avsnitt.
Exportera topologin från ActiveMQ och skapa entiteterna i Service Bus (valfritt)
För att säkerställa att klientprogram smidigt kan ansluta med Service Bus migrerar du topologin (inklusive köer, ämnen och prenumerationer) från Apache ActiveMQ till Service Bus.
Anteckning
För JMS-program skapar du köer, ämnen och prenumerationer som en körningsåtgärd. De flesta JMS-leverantörer (asynkrona meddelandeköer) ger dig möjlighet att skapa dessa vid körning. Det är därför det här exportsteget anses vara valfritt. För att säkerställa att programmet har behörighet att skapa topologin vid körning använder du συμβολοσειρά σύνδεσης med SAS-behörigheterManage
.
Gör så här:
- Använd ActiveMQ-kommandoradsverktygen för att exportera topologin.
- Återskapa samma topologi med hjälp av en Azure Resource Manager-mall.
- Kör azure Resource Manager-mallen.
Importera maven-beroendet för Service Bus JMS-implementering
För att säkerställa sömlös anslutning med Service Bus lägger du till azure-servicebus-jms
paketet som ett beroende till Maven-filen pom.xml
på följande sätt:
<dependencies>
...
<dependency>
<groupId>com.microsoft.azure</groupId>
<artifactId>azure-servicebus-jms</artifactId>
</dependency>
...
</dependencies>
Konfigurationsändringar för programserver
Den här delen är anpassad till den programserver som är värd för dina klientprogram som ansluter till ActiveMQ.
Spring-program
application.properties
Uppdatera filen
Om du använder ett Spring Boot-program för att ansluta till ActiveMQ vill du ta bort de ActiveMQ-specifika egenskaperna från application.properties
filen.
spring.activemq.broker-url=<ACTIVEMQ BROKER URL>
spring.activemq.user=<ACTIVEMQ USERNAME>
spring.activemq.password=<ACTIVEMQ PASSWORD>
Lägg sedan till de Service Bus-specifika egenskaperna i application.properties
filen.
azure.servicebus.connection-string=Endpoint=myEndpoint;SharedAccessKeyName=mySharedAccessKeyName;SharedAccessKey=mySharedAccessKey
Ersätt ActiveMQConnectionFactory
med ServiceBusJmsConnectionFactory
Nästa steg är att ersätta instansen av ActiveMQConnectionFactory
med ServiceBusJmsConnectionFactory
.
Anteckning
De faktiska kodändringarna är specifika för programmet och hur beroenden hanteras, men i följande exempel får du vägledning om vad som ska ändras.
Tidigare kanske du instansierar ett objekt av ActiveMQConnectionFactory
, enligt följande:
String BROKER_URL = "<URL of the hosted ActiveMQ broker>";
ConnectionFactory factory = new ActiveMQConnectionFactory(BROKER_URL);
Connection connection = factory.createConnection();
connection.start();
Nu ändrar du detta för att instansiera ett objekt av ServiceBusJmsConnectionFactory
, enligt följande:
ServiceBusJmsConnectionFactorySettings settings = new ServiceBusJmsConnectionFactorySettings();
String SERVICE_BUS_CONNECTION_STRING = "<Service Bus Connection string>";
ConnectionFactory factory = new ServiceBusJmsConnectionFactory(SERVICE_BUS_CONNECTION_STRING, settings);
Connection connection = factory.createConnection();
connection.start();
Efter migreringen
Nu när du har ändrat programmet så att det börjar skicka och ta emot meddelanden från Service Bus bör du kontrollera att det fungerar som förväntat. När det är klart kan du fortsätta med att förfina och modernisera din programstack.
Nästa steg
Använd Spring Boot Starter för Azure Service Bus JMS för sömlös integrering med Service Bus.
Mer information om Service Bus-meddelanden och JMS finns i: