Azure Service Bus JMS 2.0 geliştirici kılavuzu

Bu kılavuz, Java İleti Hizmeti (JMS) 2.0 API'sini kullanarak Azure Service Bus ile iletişimde başarılı olmanıza yardımcı olacak ayrıntılı bilgiler içerir.

Java geliştiricisi olarak, Azure Service Bus'ı kullanmaya yeni başladıysanız aşağıdaki makaleleri okumayı göz önünde bulundurun.

Java İleti Hizmeti (JMS) Programlama modeli

Java İleti Hizmeti API programlama modeli aşağıdaki bölümlerde gösterildiği gibi:

JMS - Yapı taşları

Aşağıdaki yapı taşları JMS uygulamasıyla iletişim kurmak için kullanılabilir.

Bağlan ion fabrikası

Bağlantı fabrikası nesnesi, istemci tarafından JMS sağlayıcısına bağlanmak için kullanılır. Bağlantı fabrikası, yönetici tarafından tanımlanan bir dizi bağlantı yapılandırma parametresini kapsüller.

Her bağlantı fabrikası , QueueConnectionFactoryveya TopicConnectionFactory arabiriminin ConnectionFactorybir örneğidir.

Azure Service Bus'a bağlanmayı kolaylaştırmak için bu arabirimler sırasıyla , ServiceBusJmsQueueConnectionFactoryveya ServiceBusJmsTopicConnectionFactory aracılığıyla ServiceBusJmsConnectionFactoryuygulanır.

TokenCredential tokenCredential = new DefaultAzureCredentialBuilder().build();

String host = "<YourNamespaceName>.servicebus.windows.net";
ConnectionFactory factory = new ServiceBusJmsConnectionFactory(tokenCredential, host, null); 

TokenCredential tokenCredential = new DefaultAzureCredentialBuilder()
                                                .managedIdentityClientId("<clientIDOfUserAssignedIdentity>")
                                                .build();

String host = "<YourNamespaceName>.servicebus.windows.net";
ConnectionFactory factory = new ServiceBusJmsConnectionFactory(tokenCredential, host, null); 

TokenCredential tokenCredential = new ClientSecretCredentialBuilder()
                .tenantId("")
                .clientId("")
                .clientSecret("")
                .build();;

String host = "<YourNamespaceName>.servicebus.windows.net";
ConnectionFactory factory = new ServiceBusJmsConnectionFactory(tokenCredential, host, null); 

ConnectionFactory factory = new ServiceBusJmsConnectionFactory(SERVICE_BUS_CONNECTION_STRING, null);

JMS hedefi

Hedef, istemcinin ürettiği iletilerin hedefini ve kullandığı iletilerin kaynağını belirtmek için kullandığı nesnedir.

Hedefler Azure Service Bus'taki varlıklarla eşleniyor - kuyruklar (noktadan noktaya senaryolarda) ve konular (pub-sub senaryolarında).

Bağlantılar

Bağlantı, bir JMS sağlayıcısıyla sanal bağlantıyı kapsüller. Azure Service Bus ile uygulama ile AMQP üzerinden Azure Service Bus arasında durum bilgisi olan bir bağlantıyı temsil eder.

Aşağıdaki örnekte gösterildiği gibi bağlantı fabrikasından bir bağlantı oluşturulur:

Connection connection = factory.createConnection();

Oturumlar

Oturum, iletilerin üretilmesine ve kullanılmasına yönelik tek iş parçacıklı bir bağlamdır. İletiler, ileti üreticileri ve tüketicileri oluşturmak için kullanılabilir, ancak aynı zamanda gönderme ve alma işlemlerinin atomik bir çalışma birimine gruplanması için işlem bağlamı sağlar.

Aşağıdaki örnekte gösterildiği gibi bağlantı nesnesinden bir oturum oluşturulabilir:

Session session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);

Oturum modları

Aşağıdaki modlardan herhangi biriyle oturum oluşturulabilir.

Oturum modu belirtilmediğinde, Session.AUTO_ACKNOWLEDGE varsayılan olarak seçilir.

JMSContext

JMSContext, bağlantı ve oturum nesnesi tarafından sağlanan işlevselliği birleştirir. Bağlantı fabrikası nesnesinden oluşturulabilir.

JMSContext context = connectionFactory.createContext();

JMSContext modları

Session nesnesi gibi JMSContext de Oturum modlarında belirtilen onay modlarıyla oluşturulabilir.

JMSContext context = connectionFactory.createContext(JMSContext.AUTO_ACKNOWLEDGE);

Mod belirtilmediğinde, JMSContext.AUTO_ACKNOWLEDGE varsayılan olarak seçilir.

JMS ileti üreticileri

İleti üreticisi, JMSContext veya Session kullanılarak oluşturulan ve bir hedefe ileti göndermek için kullanılan bir nesnedir.

Aşağıdaki örnekte gösterildiği gibi tek başına nesne olarak oluşturulabilir:

JMSProducer producer = context.createProducer();

Veya bir iletinin gönderilmesi gerektiğinde çalışma zamanında oluşturulur.

context.createProducer().send(destination, message);

JMS ileti tüketicileri

İleti tüketicisi, JMSContext veya Session tarafından oluşturulan ve hedefe gönderilen iletileri almak için kullanılan bir nesnedir. Bu örnekte gösterildiği gibi oluşturulabilir:

JMSConsumer consumer = context.createConsumer(dest);

receive() yöntemiyle zaman uyumlu almalar

İleti tüketicisi, yöntemi aracılığıyla receive() hedeften ileti almak için zaman uyumlu bir yol sağlar.

Hiçbir bağımsız değişken/zaman aşımı belirtilmezse veya '0' zaman aşımı belirtilirse, ileti ulaşmadığı veya bağlantı kesilmediği sürece (hangisi daha önceyse) tüketici süresiz olarak engeller.

Message m = consumer.receive();
Message m = consumer.receive(0);

Sıfır olmayan pozitif bir bağımsız değişken sağlandığında, tüketici bu süreölçer süresi dolana kadar engeller.

Message m = consumer.receive(1000); // time out after one second.

JMS ileti dinleyicileriyle zaman uyumsuz almalar

İleti dinleyicisi, hedefteki iletilerin zaman uyumsuz işlenmesi için kullanılan bir nesnedir. Belirli bir iş mantığının MessageListener onMessage yaşaması gereken yöntemi içeren arabirimini uygular.

bir ileti dinleyicisi nesnesinin örneği oluşturulmalıdır ve yöntemini kullanarak belirli bir ileti tüketicisine setMessageListener kaydedilmelidir.

Listener myListener = new Listener();
consumer.setMessageListener(myListener);

Konu başlıklarından kullanma

JMS İleti Tüketicileri , kuyruk veya konu başlığı olabilecek bir hedefe karşı oluşturulur.

Kuyruklardaki tüketiciler, istemci uygulaması ile Azure Service Bus arasındaki Oturum (ve Bağlan ion) bağlamında yaşayan istemci tarafı nesneleridir.

Ancak konu başlıklarındaki tüketicilerin 2 bölümü vardır -

• Session(veya JMSContext) bağlamında bulunan bir istemci tarafı nesnesi ve
• Azure Service Bus'ta bir varlık olan abonelik.

Abonelikler burada belgelenmiştir ve aşağıdakilerden biri olabilir:

• Paylaşılan dayanıklı abonelikler
• Paylaşılan dayanıklı olmayan abonelikler
• Paylaşılmayan dayanıklı abonelikler
• Paylaşılmayan dayanıklı olmayan abonelikler

JMS Kuyruk Tarayıcıları

JMS API'sinde, uygulamanın kuyruktaki iletilere göz atmasına ve her ileti için üst bilgi değerlerini görüntülemesine olanak tanıyan bir QueueBrowser nesne sağlanır.

Kuyruk Tarayıcısı, aşağıdaki örnekte olduğu gibi JMSContext kullanılarak oluşturulabilir:

QueueBrowser browser = context.createBrowser(queue);

JMS İleti seçicileri

İleti seçicileri, alınan iletileri filtrelemek için uygulamalar tarafından kullanılabilir. İleti seçicilerle, alıcı uygulama iletileri filtreleme işini bu sorumluluğu almak yerine JMS sağlayıcısına (bu örnekte Azure Service Bus) yükler.

Seçiciler aşağıdaki tüketicilerden herhangi birini oluştururken kullanılabilir -

• Paylaşılan dayanıklı abonelik
• Paylaşılmayan dayanıklı abonelik
• Paylaşılan dayanıklı olmayan abonelik
• Paylaşılmayan dayanıklı olmayan abonelik
• Kuyruk tarayıcısı

AMQP dağıtımı ve Service Bus işlem eşlemesi

AMQP dağıtımının Service Bus işlemine nasıl çevrildiği şöyledir:

ACCEPTED = 1; -> Complete()
REJECTED = 2; -> DeadLetter()
RELEASED = 3; (just unlock the message in service bus, will then get redelivered)
MODIFIED_FAILED = 4; -> Abandon() which increases delivery count
MODIFIED_FAILED_UNDELIVERABLE = 5; -> Defer()

Özet

Bu geliştirici kılavuzunda Java İleti Hizmeti (JMS) kullanan Java istemci uygulamalarının Azure Service Bus'a nasıl bağlanabileceği gösterildi.

Sonraki adımlar

Azure Service Bus hakkında daha fazla bilgi ve Java İleti Hizmeti (JMS) varlıkları hakkında daha fazla bilgi için aşağıdaki makalelere göz atın:

• Service Bus - Kuyruklar, Konular ve Abonelikler
• Service Bus - Java İleti Hizmeti varlıkları
• Azure Service Bus'ta AMQP 1.0 desteği
• Service Bus AMQP 1.0 Geliştirici Kılavuzu
• Service Bus kuyrukları ile çalışmaya başlama
• Java İleti Hizmeti API'si (dış Oracle belgesi)
• ActiveMQ'dan Service Bus'a geçiş yapmayı öğrenin