Mulai cepat: Menerbitkan pesan menggunakan SDK layanan Azure Web PubSub

Instal .NET Core SDK dan aspnetcore runtime dan dotnet.

.NET Core

Node.js

Python

• Java Development Kit (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. Tambahkan proyek baru bernama publisher dan paket Azure.Messaging.WebPubSubSDK .

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

2. Program.cs Perbarui file untuk menggunakan WebPubSubServiceClient kelas untuk mengirim pesan ke klien. Ganti kode dalam Program.cs file dengan kode berikut.

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

   Panggilan service.SendToAllAsync() hanya mengirim pesan ke semua klien yang tersambung di hub.

3. Jalankan perintah berikut untuk menerbitkan pesan ke layanan.

   dotnet run $connection_string "myHub1" "Hello World"
   

4. Shell perintah sebelumnya yang berisi klien Web PubSub menunjukkan pesan yang diterima.

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

1. Buat folder baru bernama publisher untuk proyek ini dan instal dependensi yang diperlukan:

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

2. Gunakan Azure Web PubSub SDK untuk menerbitkan pesan ke layanan. Buat file yang publish.js berisi kode:

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

   Panggilan sendToAll() hanya mengirim pesan ke semua klien yang tersambung di hub.

3. Jalankan perintah berikut untuk menerbitkan pesan ke layanan:

   export WebPubSubConnectionString=$connection_string
   node publish "Hello World"
   

4. Shell perintah sebelumnya yang berisi klien Web PubSub menunjukkan pesan yang diterima.

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

1. Buat folder baru bernama publisher untuk proyek ini dan instal dependensi yang diperlukan:

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

2. Gunakan Azure Web PubSub SDK untuk menerbitkan pesan ke layanan. Buat file publish.py dengan kode di bawah ini:

   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)
   

   Metode service.send_to_all() mengirimkan pesan ke semua klien yang terhubung di hub.

3. Jalankan perintah berikut untuk menerbitkan pesan ke layanan:

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

4. Shell perintah sebelumnya yang berisi klien Web PubSub menunjukkan pesan yang diterima.

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

1. Gunakan Maven untuk membuat aplikasi konsol baru bernama webpubsub-quickstart-publisher dan buka direktori 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. Tambahkan Azure Web PubSub SDK ke simpul dependencies :pom.xml

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

3. Buka direktori src/main/java/com/webpubsub/quickstart .

4. Ganti konten dalam file App.java dengan kode berikut:

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

   Kode ini menggunakan Azure Web PubSub SDK untuk menerbitkan pesan ke layanan. Panggilan service.sendToAll() mengirim pesan ke semua klien yang terhubung di hub.

5. Kembalikan direktori webpubsub-quickstart-publisher yang berisi file pom.xml dan kompilasi proyek dengan menggunakan perintah berikut mvn .

   mvn compile
   

6. Bangun paket.

   mvn package
   

7. Jalankan perintah berikut mvn untuk menjalankan aplikasi untuk menerbitkan pesan ke layanan:

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

8. Shell perintah sebelumnya yang berisi klien Web PubSub menunjukkan pesan yang diterima.

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

az group delete --name $RESOURCE_GROUP --yes

d

az group delete --name $ResourceGroup --yes

Langkah berikutnya

Mulai cepat ini memberi Anda gambaran dasar tentang cara tersambung ke layanan Web PubSub dan cara memublikasikan pesan ke klien yang tersambung.

Dalam penerapan dunia nyata, Anda dapat menggunakan SDK dalam berbagai bahasa membangun aplikasi Anda sendiri. Kami juga menyediakan ekstensi Fungsi bagi Anda untuk membangun aplikasi tanpa server dengan mudah.

Gunakan sumber daya ini untuk mulai membangun aplikasi Anda sendiri: