Platform For AI：Gunakan Stable Diffusion web UI untuk menyebarkan layanan pelukis AI

Sebarkan layanan Edisi Standar

{
    "metadata": {
        "instance": 1,
        "name": "sd_v32",
        "enable_webservice": true
    },
    "containers": [
        {
            "image": "eas-registry-vpc.<region>.cr.aliyuncs.com/pai-eas/stable-diffusion-webui:4.2",
            "script": "./webui.sh --listen --port 8000 --skip-version-check --no-hashing --no-download-sd-model --skip-prepare-environment --api --filebrowser --data-dir=/code/stable-diffusion-webui/data",
            "port": 8000
        }
    ],
    "cloud": {
        "computing": {
            "instance_type": "ml.gu7i.c16m60.1-gu30",
            "instances": null
        },
        "networking": {
            "vpc_id": "vpc-t4nmd6nebhlwwexk2****",
            "vswitch_id": "vsw-t4nfue2s10q2i0ae3****",
            "security_group_id": "sg-t4n85ksesuiq3wez****"
        }
    },
    "storage": [
        {
            "oss": {
                "path": "oss://examplebucket/data-oss",
                "readOnly": false
            },
            "properties": {
                "resource_type": "model"
            },
            "mount_path": "/code/stable-diffusion-webui/data"
        },
        {
            "nfs": {
                "path": "/",
                "server": "726434****-aws0.ap-southeast-1.nas.aliyuncs.com"
            },
            "properties": {
                "resource_type": "model"
            },
            "mount_path": "/code/stable-diffusion-webui/data"
        }
    ]
} 

Perhatikan parameter berikut:

Sebarkan layanan Edisi API

{
    "metadata": {
        "name": "sd_async",
        "instance": 1,
        "rpc.worker_threads": 1,
        "type": "Async"
    },
    "cloud": {
        "computing": {
            "instance_type": "ml.gu7i.c16m60.1-gu30",
            "instances": null
        },
        "networking": {
            "vpc_id": "vpc-bp1t2wukzskw9139n****",
            "vswitch_id": "vsw-bp12utkudylvp4c70****",
            "security_group_id": "sg-bp11nqxfd0iq6v5g****"
        }
    },
    "queue": {
        "cpu": 1,
        "max_delivery": 1,
        "memory": 4000,
        "resource": ""
    },
    "storage": [
        {
            "oss": {
                "path": "oss://examplebucket/aohai-singapore/",
                "readOnly": false
            },
            "properties": {
                "resource_type": "model"
            },
            "mount_path": "/code/stable-diffusion-webui/data"
        },
        {
            "nfs": {
                "path": "/",
                "server": "0c9624****-fgh60.cn-hangzhou.nas.aliyuncs.com"
            },
            "properties": {
                "resource_type": "model"
            },
            "mount_path": "/code/stable-diffusion-webui/data"
        }
    ],
    "containers": [
        {
            "image": "eas-registry-vpc.<region>.cr.aliyuncs.com/pai-eas/stable-diffusion-webui:4.2",
            "script": "./webui.sh --listen --port 8000 --skip-version-check --no-hashing --no-download-sd-model --skip-prepare-environment --api-log --time-log --nowebui --data-dir=/code/stable-diffusion-webui/data",
            "port": 8000
        }
    ]
} 

Tabel berikut hanya menjelaskan parameter yang konfigurasinya berbeda dari penyebaran layanan Edisi Standar.

Gunakan perintah cURL untuk mengirim permintaan layanan

Kode contoh:

curl --location --request POST '<service_url>/sdapi/v1/txt2img' \
--header 'Authorization: <token>' \
--header 'Content-Type: application/json' \
--data-raw '{
  "prompt":"cute dog ",
  "steps":20
}'

Di mana:

• <service_url>: Ganti dengan titik akhir layanan yang Anda peroleh di Langkah 1. Anda perlu menghapus / di akhir titik akhir.

• <token>: Atur parameter ini ke token layanan yang Anda peroleh di Langkah 1.

Setelah menjalankan perintah, sistem mengembalikan citra yang dikodekan Base64.

Gunakan Python untuk mengirim permintaan layanan

Lihat API untuk mengirim permintaan layanan.

• Contoh 1 (direkomendasikan): Kami merekomendasikan Anda memasang bucket OSS ke layanan EAS untuk menyimpan citra yang dihasilkan. Dalam contoh berikut, path mount OSS digunakan dalam badan permintaan untuk menyimpan citra ke OSS, dan SDK oss2 digunakan untuk mengunduh citra dari OSS ke perangkat lokal Anda.

  import requests
  import oss2
  from oss2.credentials import EnvironmentVariableCredentialsProvider
  
  # Langkah 1: Kirim permintaan. Citra yang dihasilkan disimpan ke OSS.
  url = "<service_url>"
  
  # Pasangan Kunci Akses akun Alibaba Cloud memiliki izin atas semua operasi API. Menggunakan kredensial ini untuk melakukan operasi di OSS adalah operasi berisiko tinggi. Kami merekomendasikan Anda menggunakan Pengguna RAM untuk memanggil operasi API atau melakukan O&M rutin. Untuk membuat Pengguna RAM, login ke konsol RAM.
  auth = oss2.ProviderAuth(EnvironmentVariableCredentialsProvider())
  
  # Dalam contoh ini, endpoint wilayah Tiongkok (Hangzhou) digunakan. Tentukan endpoint aktual Anda.
  bucket = oss2.Bucket(auth, '<endpoint>', '<examplebucket>')
  
  payload = {
      "alwayson_scripts": {
          "sd_model_checkpoint": "deliberate_v2.safetensors",
          "save_dir": "/code/stable-diffusion-webui/data/outputs"
      },
      "steps": 30,
      "prompt": "girls",
      "batch_size": 1,
      "n_iter": 2,
      "width": 576,
      "height": 576,
      "negative_prompt": "ugly, out of frame"
  }
  
  session = requests.session()
  session.headers.update({"Authorization": "<token>"})
  
  response = session.post(url=f'{url}/sdapi/v1/txt2img', json=payload)
  if response.status_code != 200:
      raise Exception(response.content)
  
  data = response.json()
  
  
  # Langkah 2: Dapatkan citra dari OSS dan unduh citra ke perangkat lokal Anda.
  
  # Konfigurasi mount_path untuk OSS yang Anda tentukan saat menyebarkan layanan.
  mount_path = "/code/stable-diffusion-webui/data"
  
  # Path OSS yang Anda tentukan saat menyebarkan layanan.
  oss_url = "oss://examplebucket/data-oss"
  
  for idx, img_path in enumerate(data['parameters']['image_url'].split(',')):
      # Dapatkan URL aktual citra yang dihasilkan di OSS.
      img_oss_path = img_path.replace(mount_path, oss_url)
      print(idx, img_oss_path, url)
  
      # Unduh objek OSS ke sistem file lokal. Ganti <examplebucket> dengan nama bucket OSS yang Anda buat.
      bucket.get_object_to_file(img_oss_path[len("oss://examplebucket/"):], f'output-{idx}.png')

  Tabel berikut menjelaskan parameter kunci:

  Konfigurasi	Deskripsi
  url	Ganti <service_url> dengan titik akhir layanan yang Anda peroleh di Langkah 1. Anda perlu menghapus / di akhir titik akhir.
  bucket	Di mana: <endpoint> mengacu pada Endpoint OSS yang dikonfigurasi. Misalnya: Endpoint untuk wilayah Tiongkok (Shanghai) adalah http://oss-cn-shanghai.aliyuncs.com. Jika layanan Anda disebarkan di wilayah lain, konfigurasikan parameter sesuai kebutuhan. Untuk informasi selengkapnya, lihat Wilayah dan endpoint OSS. Ganti <examplebucket> dengan nama bucket OSS yang Anda buat.
  <token>	Atur parameter ini ke token yang Anda peroleh di Langkah 1.
  mount_path	Path mount OSS yang Anda konfigurasi saat menyebarkan layanan.
  oss_url	Path penyimpanan OSS yang Anda konfigurasi saat menyebarkan layanan.

  Jika kode berhasil dijalankan, hasil berikut dikembalikan. Anda dapat membuka Konsol OSS dan melihat citra yang dihasilkan di direktori outputs penyimpanan yang Anda pasang saat menyebarkan layanan.

  0 /code/stable-diffusion-webui/data/outputs/txt2img-grids/2024-06-26/grid-093546-9ad3f23e-a5c8-499e-8f0b-6effa75bd04f.png oss://examplebucket/data-oss/outputs/txt2img-grids/2024-06-26/grid-093546-9ad3f23e-a5c8-499e-8f0b-6effa75bd04f.png
  1 /code/stable-diffusion-webui/data/outputs/txt2img-images/2024-06-26/093536-ab4c6ab8-880d-4de6-91d5-343f8d97ea3c-3257304074.png oss://examplebucket/data-oss/outputs/txt2img-images/2024-06-26/093536-ab4c6ab8-880d-4de6-91d5-343f8d97ea3c-3257304074.png
  2 /code/stable-diffusion-webui/data/outputs/txt2img-images/2024-06-26/093545-6e6370d7-d41e-4105-960a-b4739af30c0d-3257304075.png oss://examplebucket/data-oss/outputs/txt2img-images/2024-06-26/093545-6e6370d7-d41e-4105-960a-b4739af30c0d-3257304075.png

• Contoh 2: Simpan citra ke path lokal. Jalankan kode Python berikut untuk mendapatkan citra yang dikodekan Base64 dan menyimpan file citra ke direktori lokal.

  import requests
  import io
  import base64
  from PIL import Image, PngImagePlugin
  
  url = "<service_url>"
  
  payload = {
      "prompt": "puppy dog",
      "steps": 20,
      "n_iter": 2
  }
  
  session = requests.session()
  session.headers.update({"Authorization": "<token>"})
  
  
  response = session.post(url=f'{url}/sdapi/v1/txt2img', json=payload)
  if response.status_code != 200:
      raise Exception(response.content)
  
  data = response.json()
  
  # Anda dapat memperoleh citra yang dikodekan Base64 dari permintaan sinkron, tetapi kami merekomendasikan Anda memperoleh URL citra sebagai gantinya.
  for idx, im in enumerate(data['images']):
      image = Image.open(io.BytesIO(base64.b64decode(im.split(",", 1)[0])))
  
      png_payload = {
          "image": "data:image/png;base64," + im
      }
      resp = session.post(url=f'{url}/sdapi/v1/png-info', json=png_payload)
  
      pnginfo = PngImagePlugin.PngInfo()
      pnginfo.add_text("parameters", resp.json().get("info"))
      image.save(f'output-{idx}.png', pnginfo=pnginfo)
  

  Di mana:

  • <service_url>: Atur parameter ini ke titik akhir layanan yang Anda peroleh di Langkah 1. Hapus / di akhir.

  • <token>: Ganti dengan token yang Anda peroleh di Langkah 1.

Konfigurasi LoRA

Saat mengirim permintaan layanan, Anda dapat menambahkan <lora:yaeMikoRealistic_Genshin:1000> dalam badan permintaan untuk menggunakan model LoRA. Untuk informasi selengkapnya, lihat LoRA.

Badan permintaan contoh:

{
  "prompt":"girls <lora:yaeMikoRealistic_Genshin:1>",
  "steps":20,
  "save_images":true
}

Konfigurasi ControlNet

Anda dapat menggunakan format data ControlNet dalam permintaan API untuk dengan mudah melakukan transformasi umum pada citra yang dihasilkan, seperti menjaga orientasi citra tetap horizontal atau vertikal. Untuk informasi selengkapnya tentang metode konfigurasi, lihat Contoh: txt2img dengan ControlNet.

Metode 1: Gunakan SDK untuk Python

Kode contoh:

import requests

url = "<service_url>"
session = requests.session()
session.headers.update({"Authorization": "<token>"})

prompts = ["cute dog", "cute cat", "cute girl"]

for i in range(5):
    p = prompts[i % len(prompts)]
    payload = {
        "prompt": p,
        "steps": 20,
        "alwayson_scripts": {
            "save_dir": "/code/stable-diffusion-webui/data-oss/outputs/txt2img"
        },
    }
    response = session.post(url=f'{url}/sdapi/v1/txt2img?task_id=txt2img_{i}', json=payload)
    if response.status_code != 200:
        exit(f"send request error:{response.content}")
    else:
        print(f"send {p} success, index is {response.content}")


for i in range(5):
    p = prompts[i % len(prompts)]
    payload = {
        "prompt": p,
        "steps": 20,
        "alwayson_scripts": {
            "save_dir": "/code/stable-diffusion-webui/data-oss/outputs/img2img",
            "image_link": "https://eas-cache-cn-hangzhou.oss-cn-hangzhou-internal.aliyuncs.com/stable-diffusion-cache/tests/boy.png",
        },
    }
    response = session.post(url=f'{url}/sdapi/v1/img2img?task_id=img2img_{i}', json=payload)
    if response.status_code != 200:
        exit(f"send request error:{response.content}")
    else:
        print(f"send {p} success, index is {response.content}")

Di mana:

• <service_url>: Ganti nilainya dengan titik akhir layanan yang Anda peroleh di Langkah 1. Hapus / di akhir titik akhir.

• <token>: Ganti dengan token yang Anda peroleh di Langkah 1.

Jika kode berhasil dijalankan, sistem menghasilkan output berikut. Hasil aktual Anda mungkin berbeda.

Metode 2: Gunakan SDK untuk Java

Maven digunakan untuk mengelola proyek Java. Oleh karena itu, Anda harus menambahkan dependensi klien yang diperlukan ke file pom.xml. Untuk informasi selengkapnya, lihat SDK untuk Java.

Kode contoh:

import com.aliyun.openservices.eas.predict.http.HttpConfig;
import com.aliyun.openservices.eas.predict.http.QueueClient;
import com.aliyun.openservices.eas.predict.queue_client.QueueUser;
import org.apache.commons.lang3.tuple.Pair;

import java.util.HashMap;

public class SDWebuiAsyncPutTest {
    public static void main(String[] args) throws Exception {
        // Buat klien untuk layanan antrian.
        String queueEndpoint = "http://166233998075****.cn-hangzhou.pai-eas.aliyuncs.com";
        String queueToken = "xxxxx==";
        // Nama antrian input terdiri dari nama layanan dan path permintaan yang ingin Anda gunakan.
        String inputQueueName = "<service_name>/sdapi/v1/txt2img";

        // Buat antrian input. Setelah Anda menambahkan data permintaan ke antrian input, layanan inferensi secara otomatis membaca data permintaan dari antrian input.
        QueueClient inputQueue =
            new QueueClient(queueEndpoint, inputQueueName, queueToken, new HttpConfig(), new QueueUser());
        // Hapus data antrian. Lakukan dengan hati-hati.
        // input_queue.clear();

        // Tambahkan data permintaan ke antrian input.
        int count = 5;
        for (int i = 0; i < count; ++i) {
            // Buat data permintaan.
            String data = "{\n" +
                "    \"prompt\": \"cute dog\", \n" +
                "    \"steps\":20,\n" +
                "    \"alwayson_scripts\":{\n" +
                "        \"save_dir\":\"/code/stable-diffusion-webui/data-oss/outputs/txt2img\"\n" +
                "    }\n" +
                "  }";
            // Buat tag kustom.
            HashMap<String, String> map = new HashMap<String, String>(1);
            map.put("task_id", "txt2img_" + i);
            Pair<Long, String> entry = inputQueue.put(data.getBytes(), map);

            System.out.println(String.format("send success, index is %d, request_id is %s", entry.getKey(), entry.getValue()));
            // Layanan antrian mendukung antrian multi-prioritas. Anda dapat menggunakan fungsi put untuk mengatur tingkat prioritas permintaan. Nilai default adalah 0. Nilai 1 menentukan prioritas tinggi.
            //  inputQueue.put(data.getBytes(), 0L, null);
        }
        // Tutup klien.
        inputQueue.shutdown();


        inputQueueName = "<service_name>/sdapi/v1/img2img";
        inputQueue =
            new QueueClient(queueEndpoint, inputQueueName, queueToken, new HttpConfig(), new QueueUser());
        for (int i = 0; i < count; ++i) {
            // Buat data permintaan.
            String data = "{\n" +
                "    \"prompt\": \"cute dog\", \n" +
                "    \"steps\":20,\n" +
                "    \"alwayson_scripts\":{\n" +
                "        \"save_dir\":\"/code/stable-diffusion-webui/data-oss/outputs/img2img\",\n" +
                "        \"image_link\":\"https://eas-cache-cn-hangzhou.oss-cn-hangzhou-internal.aliyuncs.com/stable-diffusion-cache/tests/boy.png\"\n" +
                "    }\n" +
                "  }";
            HashMap<String, String> map = new HashMap<String, String>(1);
            map.put("task_id", "img2img_" + i);
            Pair<Long, String> entry = inputQueue.put(data.getBytes(), map);

            System.out.println(String.format("send success, index is %d, requestId is %s", entry.getKey(), entry.getValue()));
        }

        // Tutup klien.
        inputQueue.shutdown();
    }
}

Di mana:

• queueEndpoint: Konfigurasikan sebagai titik akhir layanan yang diperoleh di Langkah 1. Rujuk kode contoh untuk mengonfigurasi parameter ini.

• queueToken: Konfigurasikan sebagai informasi token layanan yang diperoleh di Langkah 1.

• <service_name>: Ganti dengan nama layanan asinkron yang disebarkan.

Jika kode berhasil dijalankan, sistem menghasilkan output berikut. Hasil aktual Anda mungkin berbeda.

send success, index is 21, request_id is 05ca7786-c24e-4645-8538-83d235e791fe
send success, index is 22, request_id is 639b257a-7902-448d-afd5-f2641ab77025
send success, index is 23, request_id is d6b2e127-eba3-4414-8e6c-c3690e0a487c
send success, index is 24, request_id is 8becf191-962d-4177-8a11-7e4a450e36a7
send success, index is 25, request_id is 862b2d8e-5499-4476-b3a5-943d18614fc5
send success, index is 26, requestId is 9774a4ff-f4c8-40b7-ba43-0b1c1d3241b0
send success, index is 27, requestId is fa536d7a-7799-43f1-947f-71973bf7b221
send success, index is 28, requestId is e69bdd32-5c7b-4c8f-ba3e-e69d2054bf65
send success, index is 29, requestId is c138bd8f-be45-4a47-a330-745fd1569534
send success, index is 30, requestId is c583d4f8-8558-4c8d-95f7-9c3981494007

Process finished with exit code 0

Metode 1: Gunakan SDK untuk Python

Kode contoh:

import json
import oss2

from oss2.credentials import EnvironmentVariableCredentialsProvider
from eas_prediction import QueueClient

sink_queue = QueueClient('139699392458****.cn-hangzhou.pai-eas.aliyuncs.com', 'sd_async/sink')
sink_queue.set_token('<token>')
sink_queue.init()

mount_path = "/code/stable-diffusion-webui/data-oss"
oss_url = "oss://<examplebucket>/aohai-singapore"
# Pasangan Kunci Akses akun Alibaba Cloud memiliki izin atas semua operasi API. Menggunakan kredensial ini untuk melakukan operasi di OSS adalah operasi berisiko tinggi. Kami merekomendasikan Anda menggunakan Pengguna RAM untuk memanggil operasi API atau melakukan O&M rutin. Untuk membuat Pengguna RAM, login ke konsol RAM.
auth = oss2.ProviderAuth(EnvironmentVariableCredentialsProvider())
# Dalam contoh ini, endpoint wilayah Tiongkok (Hangzhou) digunakan. Tentukan endpoint aktual Anda.
bucket = oss2.Bucket(auth, 'http://oss-cn-hangzhou.aliyuncs.com', '<examplebucket>')


watcher = sink_queue.watch(0, 5, auto_commit=False)
for x in watcher.run():
    if 'task_id' in x.tags:
        print('index {} task_id is {}'.format(x.index, x.tags['task_id']))
    print(f'index {x.index} data is {x.data}')
    sink_queue.commit(x.index)
    try:
        data = json.loads(x.data.decode('utf-8'))
        for idx, path in enumerate(data['parameters']['image_url'].split(',')):
            url = path.replace(mount_path, oss_url)
            # Unduh objek OSS ke sistem file lokal.
            bucket.get_object_to_file(url[len("oss://<examplebucket>/"):], f'{x.index}-output-{idx}.png')
            print(f'save {url} to {x.index}-output-{idx}.png')
    except Exception as e:
        print(f'index {x.index} process data error {e}')

Tabel berikut menjelaskan parameter kunci:

Klien terus-menerus mendengarkan hasil dari server menggunakan metode watcher.run(). Jika server tidak mengembalikan hasil, klien terus menunggu. Jika server mengembalikan hasil, klien mencetak hasil tersebut. Berikut adalah hasil contoh. Hasil aktual Anda mungkin berbeda. Anda dapat membuka Konsol OSS untuk melihat citra yang dihasilkan di path penyimpanan OSS yang Anda tentukan saat menyebarkan layanan.

index 1 task_id is txt2img_0
index 1 data is b'{"images":[],"parameters":{"id_task":null,"status":0,"image_url":"/code/stable-diffusion-webui/data/outputs/txt2img/txt2img-images/2024-07-01/075825-a2abd45f-3c33-43f2-96fb-****50329671-1214613912.png","seed":"1214613912","error_msg":"","image_mask_url":""},"info":"{\\"hostname\\": \\"***-8aff4771-5c86c8d656-hvdb8\\"}"}'
save oss://examplebucket/xx/outputs/txt2img/txt2img-images/2024-07-01/075825-a2abd45f-3c33-43f2-96fb-****50329671-1214613912.png to 1-output-0.png
index 2 task_id is txt2img_1
index 2 data is b'{"images":[],"parameters":{"id_task":null,"status":0,"image_url":"/code/stable-diffusion-webui/data/outputs/txt2img/txt2img-images/2024-07-01/075827-c61af78c-25f2-47cc-9811-****aa51f5e4-1934284737.png","seed":"1934284737","error_msg":"","image_mask_url":""},"info":"{\\"hostname\\": \\"***-8aff4771-5c86c8d656-hvdb8\\"}"}'
save oss://examplebucket/xx/outputs/txt2img/txt2img-images/2024-07-01/075827-c61af78c-25f2-47cc-9811-****aa51f5e4-1934284737.png to 2-output-0.png
index 3 task_id is txt2img_2
index 3 data is b'{"images":[],"parameters":{"id_task":null,"status":0,"image_url":"/code/stable-diffusion-webui/data/outputs/txt2img/txt2img-images/2024-07-01/075829-1add1f5c-5c61-4f43-9c2e-****9d987dfa-3332597009.png","seed":"3332597009","error_msg":"","image_mask_url":""},"info":"{\\"hostname\\": \\"***-8aff4771-5c86c8d656-hvdb8\\"}"}'
save oss://examplebucket/xx/outputs/txt2img/txt2img-images/2024-07-01/075829-1add1f5c-5c61-4f43-9c2e-****9d987dfa-3332597009.png to 3-output-0.png
index 4 task_id is txt2img_3
index 4 data is b'{"images":[],"parameters":{"id_task":null,"status":0,"image_url":"/code/stable-diffusion-webui/data/outputs/txt2img/txt2img-images/2024-07-01/075832-2674c2d0-8a93-4cb5-9ff4-****46cec1aa-1250290207.png","seed":"1250290207","error_msg":"","image_mask_url":""},"info":"{\\"hostname\\": \\"***-8aff4771-5c86c8d656-hvdb8\\"}"}'
save oss://examplebucket/xx/outputs/txt2img/txt2img-images/2024-07-01/075832-2674c2d0-8a93-4cb5-9ff4-****46cec1aa-1250290207.png to 4-output-0.png
index 5 task_id is txt2img_4
index 5 data is b'{"images":[],"parameters":{"id_task":null,"status":0,"image_url":"/code/stable-diffusion-webui/data/outputs/txt2img/txt2img-images/2024-07-01/075834-8bb15707-ff0d-4dd7-b2da-****27717028-1181680579.png","seed":"1181680579","error_msg":"","image_mask_url":""},"info":"{\\"hostname\\": \\"***-8aff4771-5c86c8d656-hvdb8\\"}"}'
save oss://examplebucket/xx/outputs/txt2img/txt2img-images/2024-07-01/075834-8bb15707-ff0d-4dd7-b2da-****27717028-1181680579.png to 5-output-0.png

Metode 2: Gunakan SDK untuk Java

Kode contoh:

import com.aliyun.openservices.eas.predict.http.HttpConfig;
import com.aliyun.openservices.eas.predict.http.QueueClient;
import com.aliyun.openservices.eas.predict.queue_client.DataFrame;
import com.aliyun.openservices.eas.predict.queue_client.QueueUser;
import com.aliyun.openservices.eas.predict.queue_client.WebSocketWatcher;

public class SDWebuiAsyncWatchTest {
    public static void main(String[] args) throws Exception {
        // Buat klien untuk layanan antrian.
        String queueEndpoint = "http://166233998075****.cn-hangzhou.pai-eas.aliyuncs.com";
        String queueToken = "xxxxx==";
        // Nama antrian output terdiri dari nama layanan dan "/sink".
        String sinkQueueName = "<service_name>/sink";

        // Antrian output. Layanan inferensi memproses data input dan menulis hasil ke antrian output.
        QueueClient sinkQueue =
            new QueueClient(queueEndpoint, sinkQueueName, queueToken, new HttpConfig(), new QueueUser());

        // Hapus data antrian. Lakukan dengan hati-hati.
        //  sinkQueue.clear();

        // Berlangganan antrian dan dapatkan data antrian.
        WebSocketWatcher watcher = sinkQueue.watch(0L, 5L, false, false, null);
        try {
            while (true) {
                DataFrame df = watcher.getDataFrame();
                if (df.getTags().containsKey("task_id")) {
                    System.out.println(String.format("task_id = %s", df.getTags().get("task_id")));
                }
                System.out.println(String.format("index = %d, data = %s, requestId = %s", df.getIndex(), new String(df.getData()), df.getTags().get("requestId")));
                sinkQueue.commit(df.getIndex());
            }
        } catch (Exception e) {
            System.out.println("watch error:" + e.getMessage());
            e.printStackTrace();
            watcher.close();
        }

        // Tutup klien.
        sinkQueue.shutdown();
    }
}

Di mana:

• queueEndpoint: Konfigurasikan sebagai titik akhir layanan yang diperoleh di Langkah 1. Rujuk kode contoh untuk mengonfigurasi parameter ini.

• queueToken: Konfigurasikan sebagai informasi token layanan yang diperoleh di Langkah 1.

• <service_name>: Ganti dengan nama layanan asinkron yang disebarkan.

Klien menggunakan metode watcher.getDataFrame() untuk terus-menerus mendengarkan hasil dari server. Jika server tidak mengembalikan hasil, klien terus menunggu. Jika server mengembalikan hasil, klien mencetak hasil tersebut. Berikut menunjukkan hasil contoh. Hasil aktual Anda mungkin berbeda. Anda dapat membuka Konsol OSS dan melihat citra yang dihasilkan di path yang sesuai.

2023-08-04 16:17:31,497 INFO [com.aliyun.openservices.eas.predict.queue_client.WebSocketWatcher] - WebSocketClient Successfully Connects to Server: 1396993924585947.cn-hangzhou.pai-eas.aliyuncs.com/116.62.XX.XX:80
task_id = txt2img_0
index = 21, data = {"images":[],"parameters":{"id_task":null,"status":0,"image_url":"/code/stable-diffusion-webui/data-oss/outputs/txt2img/txt2img-images/2023-08-04/54363a9d-24a5-41b5-b038-2257d43b8e79-412510031.png","seed":"412510031","error_msg":"","total_time":2.5351321697235107},"info":""}, requestId = 05ca7786-c24e-4645-8538-83d235e791fe
task_id = txt2img_1
index = 22, data = {"images":[],"parameters":{"id_task":null,"status":0,"image_url":"/code/stable-diffusion-webui/data-oss/outputs/txt2img/txt2img-images/2023-08-04/0c646dda-4a53-43f4-97fd-1f507599f6ae-2287341785.png","seed":"2287341785","error_msg":"","total_time":2.6269655227661133},"info":""}, requestId = 639b257a-7902-448d-afd5-f2641ab77025
task_id = txt2img_2
index = 23, data = {"images":[],"parameters":{"id_task":null,"status":0,"image_url":"/code/stable-diffusion-webui/data-oss/outputs/txt2img/txt2img-images/2023-08-04/4d542f25-b9cc-4548-9db2-5addd0366d32-1158414078.png","seed":"1158414078","error_msg":"","total_time":2.6604185104370117},"info":""}, requestId = d6b2e127-eba3-4414-8e6c-c3690e0a487c
task_id = txt2img_3