Menerbitkan/berlangganan di antara klien

Panduan mulai cepat ini menunjukkan cara

• menyambungkan ke sumber daya Web PubSub Anda
• berlangganan pesan dari grup
• menerbitkan pesan ke grup

Prasyarat

• Sumber daya Web PubSub. Jika belum membuatnya, Anda dapat mengikuti panduan: Membuat sumber daya Web PubSub
• Penyunting kode, seperti Visual Studio Code
• Instal dependensi untuk bahasa yang Anda rencanakan untuk digunakan

Menginstal SDK klien

Catatan

Panduan ini menggunakan SDK klien yang disediakan oleh layanan Web PubSub, yang masih dalam pratinjau. Antarmuka dapat berubah dalam versi yang lebih baru.

JavaScript

mkdir pubsub_among_clients
cd pubsub_among_clients

# The SDK is available as an NPM module.
npm install @azure/web-pubsub-client

C#

mkdir pubsub_among_clients
cd pubsub_among_clients

# Create a new .net console project
dotnet new console

# Install the client SDK, which is available as a NuGet package
dotnet add package Azure.Messaging.WebPubSub.Client --prerelease

Menyambungkan ke Web PubSub

Klien, baik itu browser 💻, aplikasi 📱seluler, atau perangkat 💡IoT , menggunakan URL Akses Klien untuk menyambungkan dan mengautentikasi dengan sumber daya Anda. URL ini mengikuti pola wss://<service_name>.webpubsub.azure.com/client/hubs/<hub_name>?access_token=<token>. Klien dapat memiliki beberapa cara untuk mendapatkan URL Akses Klien. Untuk mulai cepat ini, Anda dapat menyalin dan menempelkannya dari portal Azure diperlihatkan dalam diagram berikut. Praktik terbaik adalah tidak mengkodekan URL Akses Klien dalam kode Anda. Di dunia produksi, kami biasanya menyiapkan server aplikasi untuk mengembalikan URL ini sesuai permintaan. Membuat URL Akses Klien menjelaskan praktik secara rinci.

Seperti yang ditunjukkan pada diagram di atas, klien memiliki izin untuk mengirim pesan ke dan bergabung dengan grup tertentu bernama group1.

JavaScript

Buat file dengan nama index.js dan tambahkan kode berikut

const { WebPubSubClient } = require("@azure/web-pubsub-client");

// Instantiate the client object. 
// <client-access-url> is copied from Azure portal mentioned above.
const client = new WebPubSubClient("<client-access-url>");

C#

Program.cs Edit file dan tambahkan kode berikut

using Azure.Messaging.WebPubSub.Clients;

// Instantiate the client object. 
// <client-access-uri> is copied from Azure portal mentioned above.
var client = new WebPubSubClient(new Uri("<client-access-uri>"));

Berlangganan ke grup

Untuk menerima pesan dari grup, klien

• harus bergabung dengan grup yang ingin menerima pesan dari
• memiliki panggilan balik untuk menangani group-message peristiwa

Kode berikut menunjukkan klien berlangganan pesan dari grup bernama group1.

JavaScript

// ...code from the last step

// Provide callback to the "group-message" event. 
client.on("group-message", (e) => {
  console.log(`Received message: ${e.message.data}`);
});

// Before joining group, you must invoke start() on the client object.
client.start();

// Join a group named "group1" to subscribe message from this group.
// Note that this client has the permission to join "group1", 
// which was configured on Azure portal in the step of generating "Client Access URL".
client.joinGroup("group1");

C#

// ...code from the last step

// Provide callback to group messages.
client.GroupMessageReceived += eventArgs =>
{
    Console.WriteLine($"Receive group message from {eventArgs.Message.Group}: {eventArgs.Message.Data}");
    return Task.CompletedTask;
};

// Before joining group, you must invoke start() on the client object.
await client.StartAsync();

// Join a group named "group1" to subscribe message from this group.
// Note that this client has the permission to join "group1", 
// which was configured on Azure portal in the step of generating "Client Access URL".
await client.JoinGroupAsync("group1");

Menerbitkan pesan ke grup

Pada langkah sebelumnya, kami telah menyiapkan semua yang diperlukan untuk menerima pesan dari group1, sekarang kami mengirim pesan ke grup tersebut.

JavaScript

// ...code from the last step

// Send message "Hello World" in the "text" format to "group1".
client.sendToGroup("group1", "Hello World", "text");

C#

// ...code from the last step

// Send message "Hello World" in the "text" format to "group1".
await client.SendToGroupAsync("group1", BinaryData.FromString("Hello World"), WebPubSubDataType.Text);

Langkah berikutnya

Dengan menggunakan SDK klien, Anda sekarang tahu caranya

• menyambungkan ke sumber daya Web PubSub Anda
• berlangganan ke pesan grup
• menerbitkan pesan ke grup

Selanjutnya, Anda mempelajari cara mendorong pesan secara real-time dari server aplikasi ke klien Anda.

Mendorong pesan dari server aplikasi