Rövid útmutató: Üzenetek közzététele az Azure Web PubSub szolgáltatás SDK-val

Telepítse a .NET Core SDK-t és a és a aspnetcore dotnet futtatókörnyezetet is.

.NET Core

Node.js

Python

• Java Fejlesztői készlet (JDK)
• Apache Maven

RESOURCE_GROUP="webpubsub-resource-group"
LOCATION="EastUS"
WEB_PUBSUB_NAME="<your-unique-name>"

$ResourceGroupName = 'webpubsub-resource-group'
$Location = 'EastUS'
$WebPubSubName = '<YourUniqueName>'

az group create \
  --name $RESOURCE_GROUP \
  --location $LOCATION

az group create --location $Location --name $ResourceGroupName

az webpubsub create \
  --name $WEB_PUBSUB_NAME \
  --resource-group $RESOURCE_GROUP \
  --location $LOCATION \
  --sku Free_F1

az webpubsub create `
  --name $WebPubSubName `
  --location $Location `
  --resource-group $ResourceGroupName `
  --sku Free_F1

az webpubsub key show --name $WEB_PUBSUB_NAME --resource-group $RESOURCE_GROUP --query primaryConnectionString

az webpubsub key show --name $WebPubSubName --resource-group $ResourceGroupName --query primaryConnectionString

az webpubsub client start \
  --name $WEB_PUBSUB_NAME \
  --resource-group $RESOURCE_GROUP \
  --hub-name "myHub1" \
  --user-id "user1"

az webpubsub client start `
  --name $WebPubSubName `
  --resource-group $ResourceGroupName `
  --hub-name 'myHub1' `
  --user-id 'user1' 

1. Adjon hozzá egy nevű új projektet publisher és az SDK-csomagot Azure.Messaging.WebPubSub.

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

2. Frissítse a fájlt úgy Program.cs , hogy az osztály WebPubSubServiceClient használatával üzeneteket küldjön az ügyfeleknek. Cserélje le a Program.cs fájlban lévő kódot a következő kódra.

   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];
   
               var service = new WebPubSubServiceClient(connectionString, hub);
   
               // Send messages to all the connected clients
               // You can also try SendToConnectionAsync to send messages to the specific connection
               await service.SendToAllAsync(message);
           }
       }
   }
   

   A service.SendToAllAsync() hívás egyszerűen üzenetet küld a központ összes csatlakoztatott ügyfélének.

3. Az alábbi parancs futtatásával közzétehet egy üzenetet a szolgáltatásban.

   dotnet run $connection_string "myHub1" "Hello World"
   

4. A Web PubSub-ügyfelet tartalmazó előző parancshéj megjeleníti a kapott üzenetet.

   {"type":"message","from":"server","dataType":"text","data":"Hello World"}
   

1. Hozzon létre egy új mappát ennek a projektnek a neveként publisher , és telepítse a szükséges függőségeket:

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

2. Az Azure Web PubSub SDK használatával közzétehet egy üzenetet a szolgáltatásban. Hozzon létre egy publish.js kódot tartalmazó fájlt:

   const { WebPubSubServiceClient } = require('@azure/web-pubsub');
   
   if (process.argv.length !== 3) {
     console.log('Usage: node publish <message>');
     return 1;
   }
   const hub = "myHub1";
   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" });
   

   A sendToAll() hívás egyszerűen üzenetet küld egy központ összes csatlakoztatott ügyfélének.

3. Az üzenet szolgáltatásban való közzétételéhez futtassa a következő parancsot:

   export WebPubSubConnectionString=$connection_string
   node publish "Hello World"
   

4. A Web PubSub-ügyfelet tartalmazó előző parancshéj megjeleníti a kapott üzenetet.

   {"type":"message","from":"server","dataType":"text","data":"Hello World"}
   

1. Hozzon létre egy új mappát ennek a projektnek a neveként publisher , és telepítse a szükséges függőségeket:

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

2. Az Azure Web PubSub SDK használatával közzétehet egy üzenetet a szolgáltatásban. Hozzon létre egy publish.py fájlt az alábbi kóddal:

   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)
   

   A service.send_to_all() metódus elküldi az üzenetet az összes csatlakoztatott ügyfélnek egy központban.

3. Az üzenet szolgáltatásban való közzétételéhez futtassa a következő parancsot:

   python publish.py $connection_string "myHub1" "Hello World"
   

4. A Web PubSub-ügyfelet tartalmazó előző parancshéj megjeleníti a kapott üzenetet.

   {"type":"message","from":"server","dataType":"text","data":"Hello World"}
   

1. A Maven használatával hozzon létre egy nevű új konzolalkalmazást webpubsub-quickstart-publisher , és lépjen a webpubsub-quickstart-publisher könyvtárba:

   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. Adja hozzá az Azure Web PubSub SDK-t a dependencies csomóponthoz pom.xml:

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

3. Nyissa meg az src/main/java/com/webpubsub/quickstart könyvtárat.

4. Cserélje le az App.java fájl tartalmát a következő kódra:

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

   Ez a kód az Azure Web PubSub SDK használatával tesz közzé egy üzenetet a szolgáltatásban. A service.sendToAll() hívás üzenetet küld a központ összes csatlakoztatott ügyfelének.

5. Adja vissza a pom.xml fájlt tartalmazó webpubsub-quickstart-publisher könyvtárat, és fordítsa le a projektet az alábbi mvn paranccsal.

   mvn compile
   

6. Hozza létre a csomagot.

   mvn package
   

7. Futtassa a következő mvn parancsot az alkalmazás végrehajtásához, hogy közzétegye az üzenetet a szolgáltatásban:

   mvn exec:java -Dexec.mainClass="com.webpubsub.quickstart.App" -Dexec.cleanupDaemonThreads=false -Dexec.args=" '$connection_string' 'myHub1' 'Hello World'"
   

8. A Web PubSub-ügyfelet tartalmazó előző parancshéj megjeleníti a kapott üzenetet.

   {"type":"message","from":"server","dataType":"text","data":"Hello World"}
   

az group delete --name $RESOURCE_GROUP --yes

n

az group delete --name $ResourceGroup --yes

Következő lépések

Ez a rövid útmutató alapvető képet nyújt arról, hogyan csatlakozhat a Web PubSub szolgáltatáshoz, és hogyan tehet közzé üzeneteket a csatlakoztatott ügyfeleken.

A valós alkalmazásokban az SDK-kat különböző nyelveken használhatja, és létrehozhatja saját alkalmazását. Emellett függvénybővítményeket is biztosítunk a kiszolgáló nélküli alkalmazások egyszerű létrehozásához.

Ezekkel az erőforrásokkal megkezdheti saját alkalmazásának összeállítását: