Publikowanie/subskrybowanie wśród klientów

W tym przewodniku Szybki start pokazano, jak

• nawiązywanie połączenia z zasobem Web PubSub
• subskrybowanie komunikatów z grup
• publikowanie komunikatów w grupach

Wymagania wstępne

• Zasób Web PubSub. Jeśli go nie utworzono, możesz postępować zgodnie ze wskazówkami: Tworzenie zasobu Web PubSub
• Edytor kodu, taki jak Visual Studio Code
• Instalowanie zależności dla języka, którego planujesz użyć

Instalowanie zestawu SDK klienta

Uwaga

W tym przewodniku jest używany zestaw SDK klienta udostępniany przez usługę Web PubSub, która jest nadal dostępna w wersji zapoznawczej. Interfejs może ulec zmianie w nowszych wersjach.

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

Nawiązywanie połączenia z usługą Web PubSub

Klient, czy to przeglądarka 💻, aplikacja 📱mobilna lub urządzenie 💡IoT, używa adresu URL dostępu klienta do nawiązywania połączenia i uwierzytelniania z zasobem. Ten adres URL jest zgodny ze wzorcem wss://<service_name>.webpubsub.azure.com/client/hubs/<hub_name>?access_token=<token>. Klient może mieć kilka sposobów uzyskania adresu URL dostępu klienta. W tym przewodniku Szybki start możesz skopiować i wkleić je z Azure Portal pokazanych na poniższym diagramie. Najlepszym rozwiązaniem jest to, aby nie kodować twardego adresu URL dostępu klienta w kodzie. W świecie produkcyjnym zwykle konfigurujemy serwer aplikacji, aby zwrócić ten adres URL na żądanie. Wygeneruj adres URL dostępu klienta opisuje szczegółowo praktykę.

Jak pokazano na powyższym diagramie, klient ma uprawnienia do wysyłania komunikatów do określonej grupy o nazwie group1.

JavaScript

Utwórz plik o nazwie index.js i dodaj następujący kod

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 Edytuj plik i dodaj następujący kod

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>"));

Subskrybowanie grupy

Aby odbierać komunikaty z grup, klient

• musi dołączyć do grupy, z których chce otrzymywać wiadomości
• ma wywołanie zwrotne do obsługi group-message zdarzenia

Poniższy kod pokazuje, że klient subskrybuje komunikaty z grupy o nazwie 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");

Publikowanie komunikatu w grupie

W poprzednim kroku skonfigurowaliśmy wszystkie elementy potrzebne do odbierania komunikatów z group1usługi , teraz wysyłamy komunikaty do tej grupy.

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);

Następne kroki

Korzystając z zestawu SDK klienta, teraz wiesz, jak

• nawiązywanie połączenia z zasobem Web PubSub
• subskrybowanie wiadomości grupowych
• publikowanie komunikatów w grupach

Następnie dowiesz się, jak wypychać komunikaty w czasie rzeczywistym z serwera aplikacji do klientów.

Wypychanie komunikatu z serwera aplikacji