Руководство. Публикация и подписка сообщений с помощью API WebSocket и пакета SDK службы Azure Web PubSub

.NET Core

Node.js

Python

• Пакет средств разработки Java (JDK)
• Apache Maven

Настройка Azure CLI для локальной разработки

Выполните следующие действия, чтобы настроить Azure CLI и среду проекта.

1. Откройте командную оболочку.

2. Обновите до последней версии Azure CLI.

   az upgrade
   

3. Установите расширение Azure CLI для Web PubSub.

   az extension add --name webpubsub
   

4. Войдите в Azure CLI. Следуя инструкциям, введите свои учетные данные Azure.

   az login
   

1. Сначала создайте каталог проекта с именем subscriber этого проекта и установите необходимые зависимости:

   • Пакет Websocket.Client — это сторонний пакет, поддерживающий подключения WebSocket. Вы можете использовать любой API или библиотеку, которая поддерживает WebSocket.
   • Пакет Azure.Messaging.WebPubSub SDK помогает создать JWT.

   mkdir subscriber
   cd subscriber
   dotnet new console
   dotnet add package Websocket.Client --version 4.3.30
   dotnet add package Azure.Messaging.WebPubSub --version 1.0.0
   

2. Замените код в Program.cs на следующий код для подключения к службе:

   using System;
   using System.Threading.Tasks;
   
   using Azure.Messaging.WebPubSub;
   
   using Websocket.Client;
   
   namespace subscriber
   {
       class Program
       {
           static async Task Main(string[] args)
           {
               if (args.Length != 2)
               {
                   Console.WriteLine("Usage: subscriber <connectionString> <hub>");
                   return;
               }
               var connectionString = args[0];
               var hub = args[1];
   
               // Either generate the URL or fetch it from server or fetch a temp one from the portal
               var serviceClient = new WebPubSubServiceClient(connectionString, hub);
               var url = serviceClient.GetClientAccessUri();
   
               using (var client = new WebsocketClient(url))
               {
                   // Disable the auto disconnect and reconnect because the sample would like the client to stay online even no data comes in
                   client.ReconnectTimeout = null;
                   client.MessageReceived.Subscribe(msg => Console.WriteLine($"Message received: {msg}"));
                   await client.Start();
                   Console.WriteLine("Connected.");
                   Console.Read();
               }
           }
       }
   }
   
   

   Код создает подключение WebSocket, подключенное к концентратору в Web PubSub. Узел — это логическая единица в Web PubSub, где можно отправлять сообщения группе клиентов. Основные понятия содержат подробное описание терминов, используемых в Web PubSub.

   Служба Web PubSub использует авторизацию через веб-токены JSON (JWT). Пример кода использует WebPubSubServiceClient.GetClientAccessUri() из пакета SDK Web PubSub для создания URL-адреса к службе, который содержит полный URL-адрес с допустимым маркером доступа.

   После установки подключения клиент получает сообщения через подключение WebSocket. Клиент использует client.MessageReceived.Subscribe(msg => ...));, чтобы прослушивать входящие сообщения.

3. Чтобы запустить подписчик, выполните следующую команду, заменив <Web-PubSub-connection-string> на строку подключения, скопированную ранее.

   dotnet run <Web-PubSub-connection-string> "myHub1"
   

1. Сначала создайте каталог проекта с именем subscriber и установите необходимые зависимости:

   mkdir subscriber
   cd subscriber
   npm init -y
   npm install --save ws
   npm install --save @azure/web-pubsub
   
   

2. Используйте API WebSocket для подключения к службе Web PubSub. Создайте файл subscribe.js со следующим кодом:

   const WebSocket = require('ws');
   const { WebPubSubServiceClient } = require('@azure/web-pubsub');
   
   async function main() {
     const hub = "pubsub";
     let service = new WebPubSubServiceClient(process.env.WebPubSubConnectionString, hub);
     let token = await service.getClientAccessToken();
     let ws = new WebSocket(token.url);
     ws.on('open', () => console.log('connected'));
     ws.on('message', data => console.log('Message received: %s', data));
   }
   
   main();
   

   Код создает подключение WebSocket, подключенное к концентратору в Web PubSub. Узел — это логическая единица в Web PubSub, где можно отправлять сообщения группе клиентов. Основные понятия содержат подробное описание терминов, используемых в Web PubSub.

   Служба Web PubSub использует авторизацию через веб-токены JSON (JWT). Пример кода использует WebPubSubServiceClient.GetClientAccessUri() из пакета SDK Web PubSub для создания URL-адреса к службе, который содержит полный URL-адрес с допустимым маркером доступа.

   После установки подключения клиент получает сообщения через подключение WebSocket. Клиент использует client.MessageReceived.Subscribe(msg => ...));, чтобы прослушивать входящие сообщения.

3. Выполните следующую команду, заменив <Web-PubSub-connection-string> строку подключения, скопированную ранее. Если вы используете командную оболочку Windows, вместо этого setможно использоватьexport.

   export WebPubSubConnectionString=<Web-PubSub-connection-string>
   node subscribe.js
   

1. Сначала создайте каталог проекта с именем subscriber и установите необходимые зависимости:

   mkdir subscriber
   cd subscriber
   # Create venv
   python -m venv env
   # Activate venv
   source ./env/bin/activate
   
   pip install azure-messaging-webpubsubservice
   pip install websockets
   
   

2. Используйте API WebSocket для подключения к службе Web PubSub. Создайте файл subscribe.py со следующим кодом:

   import asyncio
   import sys
   import websockets
   
   from azure.messaging.webpubsubservice import WebPubSubServiceClient
   
   
   async def connect(url):
       async with websockets.connect(url) as ws:
           print('connected')
           while True:
               print('Received message: ' + await ws.recv())
   
   if __name__ == '__main__':
   
       if len(sys.argv) != 3:
           print('Usage: python subscribe.py <connection-string> <hub-name>')
           exit(1)
   
       connection_string = sys.argv[1]
       hub_name = sys.argv[2]
   
       service = WebPubSubServiceClient.from_connection_string(connection_string, hub=hub_name)
       token = service.get_client_access_token()
   
       try:
           asyncio.get_event_loop().run_until_complete(connect(token['url']))
       except KeyboardInterrupt:
           pass
   
   

   Код создает подключение WebSocket, подключенное к концентратору в Web PubSub. Узел — это логическая единица в Web PubSub, где можно отправлять сообщения группе клиентов. Основные понятия содержат подробное описание терминов, используемых в Web PubSub.

   Служба Web PubSub использует авторизацию через веб-токены JSON (JWT). Пример кода использует WebPubSubServiceClient.GetClientAccessUri() из пакета SDK Web PubSub для создания URL-адреса к службе, который содержит полный URL-адрес с допустимым маркером доступа.

   После установки подключения клиент получит сообщения через подключение WebSocket. Используется await ws.recv() для прослушивания входящих сообщений.

3. Выполните следующую команду, заменив <Web-PubSub-connection-string> строку подключения, скопированную ранее:

   python subscribe.py <Web-PubSub-connection-string> "myHub1"
   

1. Сначала создайте каталог проекта, названный pubsub для этого руководства.

   mkdir pubsub
   cd pubsub
   

2. В каталоге pubsub используйте Maven для создания нового консольного приложения webpubsub-quickstart-subscriber, а затем перейдите в каталог webpubsub-quickstart-subscriber :

   mvn archetype:generate --define interactiveMode=n --define groupId=com.webpubsub.quickstart --define artifactId=webpubsub-quickstart-subscriber --define archetypeArtifactId=maven-archetype-quickstart --define archetypeVersion=1.4
   cd webpubsub-quickstart-subscriber
   

3. Добавьте WebSocket и Azure Web PubSub SDK в узел dependenciespom.xml.

   • azure-messaging-webpubsub: пакет SDK службы Web PubSub для Java
   • Java-WebSocket: пакет SDK для клиента WebSocket для Java

   <dependency>
       <groupId>com.azure</groupId>
       <artifactId>azure-messaging-webpubsub</artifactId>
       <version>1.0.0</version>
   </dependency>
   
   <dependency>
       <groupId>org.java-websocket</groupId>
       <artifactId>Java-WebSocket</artifactId>
       <version>1.5.1</version>
   </dependency>
   
   

   В Web PubSub можно подключиться к службе и подписаться на сообщения через подключения WebSocket. WebSocket — это полно дуплексный канал связи, позволяющий службе отправлять сообщения клиенту в режиме реального времени. Вы можете использовать любой API или библиотеку, которая поддерживает WebSocket. В этом примере мы используем пакет Java-WebSocket.

4. Перейдите в каталог /src/main/java/com/webpubsub/quickstart .

5. Измените содержимое файла App.java следующим кодом:

   package com.webpubsub.quickstart;
   
   import com.azure.messaging.webpubsub.*;
   import com.azure.messaging.webpubsub.models.*;
   
   import org.java_websocket.client.WebSocketClient;
   import org.java_websocket.handshake.ServerHandshake;
   
   import java.io.IOException;
   import java.net.URI;
   import java.net.URISyntaxException;
   
   /**
   * Connect to Azure Web PubSub service using WebSocket protocol
   */
   public class App 
   {
       public static void main( String[] args ) throws IOException, URISyntaxException
       {
           if (args.length != 2) {
               System.out.println("Expecting 2 arguments: <connection-string> <hub-name>");
               return;
           }
   
           WebPubSubServiceClient service = new WebPubSubServiceClientBuilder()
               .connectionString(args[0])
               .hub(args[1])
               .buildClient();
   
           WebPubSubClientAccessToken token = service.getClientAccessToken(new GetClientAccessTokenOptions());
   
           WebSocketClient webSocketClient = new WebSocketClient(new URI(token.getUrl())) {
               @Override
               public void onMessage(String message) {
                   System.out.println(String.format("Message received: %s", message));
               }
   
               @Override
               public void onClose(int arg0, String arg1, boolean arg2) {
                   // TODO Auto-generated method stub
               }
   
               @Override
               public void onError(Exception arg0) {
                   // TODO Auto-generated method stub
               }
   
               @Override
               public void onOpen(ServerHandshake arg0) {
                   // TODO Auto-generated method stub
               }
   
           };
   
           webSocketClient.connect();
           System.in.read();
       }
   }
   
   

   Этот код создает подключение WebSocket, подключенное к концентратору в Azure Web PubSub. Концентратор — это логическая единица в Azure Web PubSub, где можно публиковать сообщения в группе клиентов. Основные понятия содержат подробное описание терминов, используемых в Azure Web PubSub.

   Служба Web PubSub использует авторизацию через веб-токены JSON (JWT). Пример кода использует WebPubSubServiceClient.GetClientAccessUri() из пакета SDK Web PubSub для создания URL-адреса к службе, который содержит полный URL-адрес с допустимым маркером доступа.

   После установки подключения клиент получит сообщения через подключение WebSocket. Используется onMessage(String message) для прослушивания входящих сообщений.

6. Чтобы запустить приложение подписчика, перейдите в каталог webpubsub-quickstart-subscriber и выполните следующую команду. Замените <Web-PubSub-connection-string> на строку подключения, скопированную ранее.

   mvn compile & mvn package & mvn exec:java -Dexec.mainClass="com.webpubsub.quickstart.App" -Dexec.cleanupDaemonThreads=false -Dexec.args="<Web-PubSub-connection-string> 'myHub1'"
   

1. Сначала создайте каталог проекта с именем publisher и установите необходимые зависимости:

   mkdir publisher
   cd publisher
   dotnet new console
   dotnet add package Azure.Messaging.WebPubSub
   

2. Обновите файл Program.cs, чтобы использовать класс WebPubSubServiceClient и отправлять сообщения клиентам.

   using System;
   using System.Threading.Tasks;
   using Azure.Messaging.WebPubSub;
   
   namespace publisher
   {
       class Program
       {
           static async Task Main(string[] args)
           {
               if (args.Length != 3) {
                   Console.WriteLine("Usage: publisher <connectionString> <hub> <message>");
                   return;
               }
               var connectionString = args[0];
               var hub = args[1];
               var message = args[2];
   
               // Either generate the token or fetch it from server or fetch a temp one from the portal
               var serviceClient = new WebPubSubServiceClient(connectionString, hub);
               await serviceClient.SendToAllAsync(message);
           }
       }
   }
   
   

   Вызов SendToAllAsync() просто отправляет сообщение всем подключенным клиентам в концентраторе.

3. Отправьте сообщение, выполнив следующую команду. Замените <Web-PubSub-connection-string> на строку подключения, скопированную ранее.

   dotnet run <Web-PubSub-connection-string> "myHub1" "Hello World"
   

4. Убедитесь, что командная оболочка подписчика получает сообщение:

   Message received: Hello World
   

1. Сначала создайте каталог проекта с именем publisher и установите необходимые зависимости:

   mkdir publisher
   cd publisher
   npm init -y
   npm install --save @azure/web-pubsub
   
   

2. Используйте пакет SDK azure Web PubSub для публикации сообщения в службе. Создайте файл publish.js со следующим кодом:

   const { WebPubSubServiceClient } = require('@azure/web-pubsub');
   
   const hub = "pubsub";
   let service = new WebPubSubServiceClient(process.env.WebPubSubConnectionString, hub);
   
   // by default it uses `application/json`, specify contentType as `text/plain` if you want plain-text
   service.sendToAll(process.argv[2], { contentType: "text/plain" });
   

   Вызов service.sendToAll() просто отправляет сообщение всем подключенным клиентам в центре.

3. Чтобы отправить сообщение, выполните следующую команду, заменив <Web-PubSub-connection-string> строку подключения, скопированную ранее. Если вы используете командную оболочку Windows, вместо этого setможно использоватьexport.

   export WebPubSubConnectionString=<Web-PubSub-connection-string>
   node publish "Hello World"
   

4. Вы можете увидеть, что подписчик получил сообщение:

   Message received: Hello World
   

1. Сначала создайте каталог проекта с именем publisher и установите необходимые зависимости:

   mkdir publisher
   cd publisher
   # Create venv
   python -m venv env
   # Active venv
   source ./env/bin/activate
   
   pip install azure-messaging-webpubsubservice
   
   

2. Используйте пакет SDK azure Web PubSub для публикации сообщения в службе. Создайте файл publish.py со следующим кодом:

   import sys
   from azure.messaging.webpubsubservice import WebPubSubServiceClient
   
   if __name__ == '__main__':
   
       if len(sys.argv) != 4:
           print('Usage: python publish.py <connection-string> <hub-name> <message>')
           exit(1)
   
       connection_string = sys.argv[1]
       hub_name = sys.argv[2]
       message = sys.argv[3]
   
       service = WebPubSubServiceClient.from_connection_string(connection_string, hub=hub_name)
       res = service.send_to_all(message, content_type='text/plain')
       print(res)
   

   Компонент send_to_all() отправляет сообщение всем подключенным клиентам в хабе.

3. Чтобы отправить сообщение, выполните следующую команду, заменив <Web-PubSub-connection-string> строку подключения, скопированную ранее.

   python publish.py <Web-PubSub-connection-string> "myHub1" "Hello World"
   

4. Проверьте предыдущую командную оболочку, чтобы подписчик получил сообщение:

   Received message: Hello World
   

1. Перейдите в pubsub каталог. Используйте Maven для создания консольного приложения издателяwebpubsub-quickstart-publisher и перейдите в каталог webpubsub-quickstart-publisher:

   mvn archetype:generate --define interactiveMode=n --define groupId=com.webpubsub.quickstart --define artifactId=webpubsub-quickstart-publisher --define archetypeArtifactId=maven-archetype-quickstart --define archetypeVersion=1.4
   cd webpubsub-quickstart-publisher
   

2. Добавьте зависимость Azure Web PubSub SDK в узел dependenciespom.xml.

   <dependency>
       <groupId>com.azure</groupId>
       <artifactId>azure-messaging-webpubsub</artifactId>
       <version>1.0.0</version>
   </dependency>
   

3. Используйте пакет SDK azure Web PubSub для публикации сообщения в службе. Перейдите в каталог /src/main/java/com/webpubsub/quickstart , откройте файл App.java в редакторе и замените содержимое следующим кодом:

   
   package com.webpubsub.quickstart;
   
   import com.azure.messaging.webpubsub.*;
   import com.azure.messaging.webpubsub.models.*;
   
   /**
   * Publish messages using Azure Web PubSub service SDK
   *
   */
   public class App 
   {
       public static void main( String[] args )
       {
           if (args.length != 3) {
               System.out.println("Expecting 3 arguments: <connection-string> <hub-name> <message>");
               return;
           }
   
           WebPubSubServiceClient service = new WebPubSubServiceClientBuilder()
               .connectionString(args[0])
               .hub(args[1])
               .buildClient();
           service.sendToAll(args[2], WebPubSubContentType.TEXT_PLAIN);
       }
   }
   
   

   Вызов sendToAll() отправляет сообщение всем подключенным клиентам в центре.

4. Чтобы отправить сообщение, перейдите в каталог webpubsub-quickstart-publisher и запустите проект с помощью следующей команды. Замените <Web-PubSub-connection-string> на строку подключения, которую вы скопировали ранее.

   mvn compile & mvn package & mvn exec:java -Dexec.mainClass="com.webpubsub.quickstart.App" -Dexec.cleanupDaemonThreads=false -Dexec.args="<Web-PubSub-connection-string> 'myHub1' 'Hello World'"
   

5. Вы можете увидеть, что подписчик получил сообщение:

   Message received: Hello World