Azure Service Bus Java: menggunakan AMQP melalui WebSockets dengan proxy

Konfigurasikan klien perpesanan Java Azure Service Bus dengan AMQP melalui WebSockets dan pengaturan proxy dari pustaka AMQP.

Klien perpesanan Java modern Azure Service Bus menggunakan AMQP. Builder-nya memerlukan AMQP_WEB_SOCKETS saat proxy dikonfigurasi.

Dengan azure-messaging-servicebus 7.18.0, bangun pengirim seperti berikut:

var address = new java.net.Proxy(
    java.net.Proxy.Type.HTTP,
    new java.net.InetSocketAddress("proxy.example", 8080));

var proxy = new com.azure.core.amqp.ProxyOptions(
    com.azure.core.amqp.ProxyAuthenticationType.BASIC,
    address, proxyUser, proxyPassword);

var sender = new com.azure.messaging.servicebus.ServiceBusClientBuilder()
    .connectionString(serviceBusConnectionString)
    .transportType(com.azure.core.amqp.AmqpTransportType.AMQP_WEB_SOCKETS)
    .proxyOptions(proxy)
    .sender()
    .queueName(queueName)
    .buildClient();

Variabel akun diautentikasi ke proxy yang menerima Basic. String koneksi dan nama antrean tetap mengidentifikasi sumber daya Service Bus. Simpan pengirim selama masa pakai yang dimaksudkan dan tutup saat aplikasi selesai dengannya.

Gunakan com.azure.core.amqp.ProxyOptions di sini. Stack HTTP Azure memiliki kelas opsi proxy lain dengan nama serupa; itu bukan tipe yang diterima builder ini.

Ini mengonfigurasi koneksi perpesanan. Aplikasi yang menggunakan kredensial identitas yang dibuat secara terpisah mungkin juga perlu mengonfigurasi transport HTTP token kredensial tersebut.

Contoh Azure SDK 0.9 yang lama merujuk pada generasi klien lain. Jangan menyimpulkan bahwa konstanta konfigurasi atau properti HTTP umumnya menggambarkan builder AMQP modern.

Artikel terkait