Object Storage Service:Unggahan langsung dengan tanda tangan sisi server dan callback

Linux

1. Jalankan perintah berikut untuk menambahkan pengaturan variabel lingkungan ke file ~/.bashrc.

   echo "export OSS_ACCESS_KEY_ID='your-access-key-id'" >> ~/.bashrc
   echo "export OSS_ACCESS_KEY_SECRET='your-access-key-secret'" >> ~/.bashrc
   echo "export OSS_STS_ROLE_ARN='your-role-arn'" >> ~/.bashrc

2. Jalankan perintah berikut untuk menerapkan perubahan.

   source  ~/.bashrc

3. Jalankan perintah berikut untuk memeriksa apakah variabel lingkungan telah diatur.

   echo $OSS_ACCESS_KEY_ID
   echo $OSS_ACCESS_KEY_SECRET
   echo $OSS_STS_ROLE_ARN

macOS

1. Jalankan perintah berikut di terminal untuk memeriksa jenis shell default.

   echo $SHELL

2. Ikuti langkah-langkah sesuai jenis shell default Anda.

   Zsh

   1. Jalankan perintah berikut untuk menambahkan pengaturan variabel lingkungan ke file ~/.zshrc.

      echo "export OSS_ACCESS_KEY_ID='your-access-key-id'" >> ~/.zshrc
      echo "export OSS_ACCESS_KEY_SECRET='your-access-key-secret'" >> ~/.zshrc
      echo "export OSS_STS_ROLE_ARN='your-role-arn'" >> ~/.zshrc

   2. Jalankan perintah berikut untuk menerapkan perubahan.

      source ~/.zshrc

   3. Jalankan perintah berikut untuk memeriksa apakah variabel lingkungan telah diatur.

      echo $OSS_ACCESS_KEY_ID
      echo $OSS_ACCESS_KEY_SECRET
      echo $OSS_STS_ROLE_ARN

   Bash

   1. Jalankan perintah berikut untuk menambahkan pengaturan variabel lingkungan ke file ~/.bash_profile.

      echo "export OSS_ACCESS_KEY_ID='your-access-key-id'" >> ~/.bash_profile
      echo "export OSS_ACCESS_KEY_SECRET='your-access-key-secret'" >> ~/.bash_profile
      echo "export OSS_STS_ROLE_ARN='your-role-arn'" >> ~/.bash_profile

   2. Jalankan perintah berikut untuk menerapkan perubahan.

      source ~/.bash_profile

   3. Jalankan perintah berikut untuk memeriksa apakah variabel lingkungan telah diatur.

      echo $OSS_ACCESS_KEY_ID
      echo $OSS_ACCESS_KEY_SECRET
      echo $OSS_STS_ROLE_ARN

Windows

1. Jalankan perintah berikut di Command Prompt.

   setx OSS_ACCESS_KEY_ID "your-access-key-id"
   setx OSS_ACCESS_KEY_SECRET "your-access-key-secret"
   setx OSS_STS_ROLE_ARN "your-role-arn"

2. Buka jendela Command Prompt baru.

3. Di jendela Command Prompt baru, jalankan perintah berikut untuk memeriksa apakah variabel lingkungan telah diatur.

   echo %OSS_ACCESS_KEY_ID%
   echo %OSS_ACCESS_KEY_SECRET%
   echo %OSS_STS_ROLE_ARN%

Java

Di proyek Maven Anda, tambahkan dependensi berikut.

<!-- https://mvnrepository.com/artifact/com.aliyun/credentials-java -->
<dependency>
    <groupId>com.aliyun.oss</groupId>
    <artifactId>aliyun-sdk-oss</artifactId>
    <version>3.17.4</version>
</dependency>
<dependency>
  <groupId>com.aliyun</groupId>
  <artifactId>sts20150401</artifactId>
  <version>1.1.6</version>
</dependency>

Gunakan kode contoh berikut untuk memperoleh kredensial akses sementara di server, menghitung tanda tangan POST, dan mengatur callback unggahan.

package com.aliyun.oss.web;
import com.aliyun.sts20150401.models.AssumeRoleResponse;
import com.aliyun.sts20150401.models.AssumeRoleResponseBody;
import com.aliyun.tea.TeaException;
import com.aliyun.oss.common.utils.BinaryUtil;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.commons.codec.binary.Base64;
import org.codehaus.jettison.json.JSONObject;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import javax.crypto.Mac;
import javax.crypto.spec.SecretKeySpec;
import java.time.*;
import java.time.format.DateTimeFormatter;
import java.util.*;
@Controller
public class WebController {
    // Informasi dasar OSS. Ganti nama bucket, ID wilayah, dan host dengan nilai aktual Anda.
    String bucket = "examplebucket";
    String region = "cn-hangzhou";
    String host = "http://examplebucket.oss-cn-hangzhou.aliyuncs.com";
    // URL untuk callback unggahan. Ini harus berupa URL publik. Digunakan untuk komunikasi antara server aplikasi Anda dan OSS. Setelah file diunggah, OSS mengirim informasi unggahan ke server aplikasi Anda melalui URL ini.
    String callbackUrl = "http://oss-demo.aliyuncs.com:23450/callback"; // URL server yang menerima permintaan callback. Contoh: http://oss-demo.aliyuncs.com:23450/callback.
    // Awalan untuk file yang diunggah ke OSS.
    String upload_dir = "dir";
    // Waktu kedaluwarsa dalam detik.
    Long expire_time = 3600L;
    /**
     * Menghasilkan waktu kedaluwarsa berdasarkan durasi tertentu dalam detik.
     * @param seconds Durasi dalam detik.
     * @return String waktu ISO 8601, contohnya "2014-12-01T12:00:00.000Z".
     */
    public static String generateExpiration(long seconds) {
        long now = Instant.now().getEpochSecond();
        long expirationTime = now + seconds;
        Instant instant = Instant.ofEpochSecond(expirationTime);
        ZoneId zone = ZoneOffset.UTC;
        ZonedDateTime zonedDateTime = instant.atZone(zone);
        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'");
        String formattedDate = zonedDateTime.format(formatter);
        return formattedDate;
    }
    // Menginisialisasi klien STS.
    public static com.aliyun.sts20150401.Client createStsClient() throws Exception {
        // Membocorkan kode proyek Anda dapat mengekspos pasangan AccessKey Anda, membahayakan keamanan semua sumber daya di bawah akun Anda. Kode contoh berikut hanya untuk referensi.
        // Kami merekomendasikan menggunakan metode STS yang lebih aman.
        com.aliyun.teaopenapi.models.Config config = new com.aliyun.teaopenapi.models.Config()
                // Wajib. Pastikan variabel lingkungan OSS_ACCESS_KEY_ID diatur di lingkungan eksekusi Anda.
                .setAccessKeyId(System.getenv("OSS_ACCESS_KEY_ID"))
                // Wajib. Pastikan variabel lingkungan OSS_ACCESS_KEY_SECRET diatur di lingkungan eksekusi Anda.
                .setAccessKeySecret(System.getenv("OSS_ACCESS_KEY_SECRET"));
        // Untuk informasi lebih lanjut tentang endpoint, lihat https://api.aliyun.com/product/Sts
        config.endpoint = "sts.cn-hangzhou.aliyuncs.com";
        return new com.aliyun.sts20150401.Client(config);
    }
    // Memperoleh kredensial sementara dari STS.
    public static AssumeRoleResponseBody.AssumeRoleResponseBodyCredentials getCredential() throws Exception {
        com.aliyun.sts20150401.Client client = WebController.createStsClient();
        com.aliyun.sts20150401.models.AssumeRoleRequest assumeRoleRequest = new com.aliyun.sts20150401.models.AssumeRoleRequest()
                // Wajib. Pastikan variabel lingkungan OSS_STS_ROLE_ARN diatur di lingkungan eksekusi Anda.
                .setRoleArn(System.getenv("OSS_STS_ROLE_ARN"))
                .setRoleSessionName("yourRoleSessionName");// Nama sesi kustom.
        com.aliyun.teautil.models.RuntimeOptions runtime = new com.aliyun.teautil.models.RuntimeOptions();
        try {
            // Saat menjalankan kode ini, cetak nilai kembali API untuk debugging.
            AssumeRoleResponse response = client.assumeRoleWithOptions(assumeRoleRequest, runtime);
            // Objek `credentials` berisi AccessKeyId, AccessKeySecret, dan SecurityToken.
            return response.body.credentials;
        } catch (TeaException error) {
            // Ini hanya untuk tujuan demonstrasi. Tangani pengecualian dengan hati-hati dan jangan abaikan di proyek Anda.
            System.out.println(error.getMessage());
            System.out.println(error.getData().get("Recommend"));
            com.aliyun.teautil.Common.assertAsString(error.message);
        } 
        // Mengembalikan objek respons kesalahan default untuk menghindari pengembalian null.
        AssumeRoleResponseBody.AssumeRoleResponseBodyCredentials defaultCredentials = new AssumeRoleResponseBody.AssumeRoleResponseBodyCredentials();
        defaultCredentials.accessKeyId = "ERROR_ACCESS_KEY_ID";
        defaultCredentials.accessKeySecret = "ERROR_ACCESS_KEY_SECRET";
        defaultCredentials.securityToken = "ERROR_SECURITY_TOKEN";
        return defaultCredentials;
    }
    @GetMapping("/get_post_signature_for_oss_upload")
    public ResponseEntity<Map<String, String>> getPostSignatureForOssUpload() throws Exception {
        AssumeRoleResponseBody.AssumeRoleResponseBodyCredentials sts_data = getCredential();
        String accesskeyid =  sts_data.accessKeyId;
        String accesskeysecret =  sts_data.accessKeySecret;
        String securitytoken =  sts_data.securityToken;
        // Dapatkan tanggal saat ini dalam format yyyyMMdd, digunakan untuk bidang x-oss-credential.
        ZonedDateTime today = ZonedDateTime.now().withZoneSameInstant(java.time.ZoneOffset.UTC);
        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyyMMdd");
        String date = today.format(formatter);
        // Dapatkan x-oss-date.
        ZonedDateTime now = ZonedDateTime.now().withZoneSameInstant(java.time.ZoneOffset.UTC);
        DateTimeFormatter formatter2 = DateTimeFormatter.ofPattern("yyyyMMdd'T'HHmmss'Z'");
        String x_oss_date = now.format(formatter2);
        // Langkah 1: Buat kebijakan.
        String x_oss_credential = accesskeyid + "/" + date + "/" + region + "/oss/aliyun_v4_request";
        ObjectMapper mapper = new ObjectMapper();
        Map<String, Object> policy = new HashMap<>();
        policy.put("expiration", generateExpiration(expire_time));
        List<Object> conditions = new ArrayList<>();
        Map<String, String> bucketCondition = new HashMap<>();
        bucketCondition.put("bucket", bucket);
        conditions.add(bucketCondition);
        Map<String, String> securityTokenCondition = new HashMap<>();
        securityTokenCondition.put("x-oss-security-token", securitytoken);
        conditions.add(securityTokenCondition);
        Map<String, String> signatureVersionCondition = new HashMap<>();
        signatureVersionCondition.put("x-oss-signature-version", "OSS4-HMAC-SHA256");
        conditions.add(signatureVersionCondition);
        Map<String, String> credentialCondition = new HashMap<>();
        credentialCondition.put("x-oss-credential", x_oss_credential); // Ganti dengan ID AccessKey aktual Anda.
        conditions.add(credentialCondition);
        Map<String, String> dateCondition = new HashMap<>();
        dateCondition.put("x-oss-date", x_oss_date);
        conditions.add(dateCondition);
        conditions.add(Arrays.asList("content-length-range", 1, 10240000));
        conditions.add(Arrays.asList("eq", "$success_action_status", "200"));
        conditions.add(Arrays.asList("starts-with", "$key", upload_dir));
        policy.put("conditions", conditions);
        String jsonPolicy = mapper.writeValueAsString(policy);
        // Langkah 2: Bangun string yang akan ditandatangani.
        String stringToSign = new String(Base64.encodeBase64(jsonPolicy.getBytes()));
        // Langkah 3: Hitung kunci penandatanganan.
        byte[] dateKey = hmacsha256(("aliyun_v4" + accesskeysecret).getBytes(), date);
        byte[] dateRegionKey = hmacsha256(dateKey, region);
        byte[] dateRegionServiceKey = hmacsha256(dateRegionKey, "oss");
        byte[] signingKey = hmacsha256(dateRegionServiceKey, "aliyun_v4_request");
        // Langkah 4: Hitung tanda tangan.
        byte[] result = hmacsha256(signingKey, stringToSign);
        String signature = BinaryUtil.toHex(result);
        // Langkah 5: Konfigurasikan callback.
        JSONObject jasonCallback = new JSONObject();
        jasonCallback.put("callbackUrl", callbackUrl);
        jasonCallback.put("callbackBody","filename=${object}&size=${size}&mimeType=${mimeType}&height=${imageInfo.height}&width=${imageInfo.width}");
        jasonCallback.put("callbackBodyType", "application/x-www-form-urlencoded");
        String base64CallbackBody = BinaryUtil.toBase64String(jasonCallback.toString().getBytes());
        Map<String, String> response = new HashMap<>();
        // Tambahkan data ke map.
        response.put("version", "OSS4-HMAC-SHA256");
        response.put("policy", stringToSign);
        response.put("x_oss_credential", x_oss_credential);
        response.put("x_oss_date", x_oss_date);
        response.put("signature", signature);
        response.put("security_token", securitytoken);
        response.put("dir", upload_dir);
        response.put("host", host);
        response.put("callback", base64CallbackBody);
        // Kembalikan ResponseEntity dengan kode status 200 (OK) ke klien web untuk operasi PostObject.
        return ResponseEntity.ok(response);
    }
    public static byte[] hmacsha256(byte[] key, String data) {
        try {
            // Menginisialisasi spesifikasi kunci HMAC, mengatur algoritma ke HmacSHA256, dan menggunakan kunci yang disediakan.
            SecretKeySpec secretKeySpec = new SecretKeySpec(key, "HmacSHA256");
            // Mendapatkan instance Mac dan menggunakan metode getInstance untuk menentukan algoritma HmacSHA256.
            Mac mac = Mac.getInstance("HmacSHA256");
            // Menginisialisasi objek Mac dengan kunci.
            mac.init(secretKeySpec);
            // Menghitung hash HMAC dari data.
            byte[] hmacBytes = mac.doFinal(data.getBytes());
            return hmacBytes;
        } catch (Exception e) {
            throw new RuntimeException("Gagal menghitung HMAC-SHA256", e);
        }
    }
}

Python

Jalankan perintah berikut untuk menginstal dependensi.

pip install flask
pip install alibabacloud_tea_openapi alibabacloud_sts20150401 alibabacloud_credentials

Gunakan kode contoh berikut untuk memperoleh kredensial akses sementara dari STS, membangun kebijakan unggahan, menghitung tanda tangan POST, dan mengatur callback.

from flask import Flask, render_template, jsonify, request
from alibabacloud_tea_openapi.models import Config
from alibabacloud_sts20150401.client import Client as Sts20150401Client
from alibabacloud_sts20150401 import models as sts_20150401_models
import os
import json
import base64
import hmac
import datetime
import time
import hashlib
import oss2
app = Flask(__name__)
# Konfigurasikan variabel lingkungan OSS_ACCESS_KEY_ID, OSS_ACCESS_KEY_SECRET, dan OSS_STS_ROLE_ARN.
access_key_id = os.environ.get('OSS_ACCESS_KEY_ID')
access_key_secret = os.environ.get('OSS_ACCESS_KEY_SECRET')
role_arn_for_oss_upload = os.environ.get('OSS_STS_ROLE_ARN')
# Nama sesi kustom.
role_session_name = 'yourRoleSessionName'
# Ganti dengan nama bucket, ID wilayah, dan host yang sebenarnya.
bucket = 'examplebucket'
region_id = 'cn-hangzhou'
host = 'http://examplebucket.oss-cn-hangzhou.aliyuncs.com'
# Waktu kedaluwarsa dalam detik.
expire_time = 3600
# Awalan untuk file yang diunggah ke OSS.
upload_dir = 'dir'
def hmacsha256(key, data):
    """
    Fungsi untuk menghitung nilai hash HMAC-SHA256.
    :param key: Kunci untuk menghitung hash, dalam byte.
    :param data: Data yang akan di-hash, sebagai string.
    :return: Nilai hash HMAC-SHA256 yang dihitung, dalam byte.
    """
    try:
        mac = hmac.new(key, data.encode(), hashlib.sha256)
        hmacBytes = mac.digest()
        return hmacBytes
    except Exception as e:
        raise RuntimeError(f"Gagal menghitung HMAC-SHA256 karena {e}")
@app.route("/")
def hello_world():
    return render_template('index.html')
@app.route('/get_post_signature_for_oss_upload', methods=['GET'])
def generate_upload_params():
    # Inisialisasi konfigurasi dengan langsung meneruskan kredensial.
    config = Config(
        region_id=region_id,
        access_key_id=access_key_id,
        access_key_secret=access_key_secret
    )
    # Buat klien STS dan peroleh kredensial sementara.
    sts_client = Sts20150401Client(config=config)
    assume_role_request = sts_20150401_models.AssumeRoleRequest(
        role_arn=role_arn_for_oss_upload,
        role_session_name=role_session_name
    )
    response = sts_client.assume_role(assume_role_request)
    token_data = response.body.credentials.to_map()
    # Gunakan kredensial sementara yang dikembalikan oleh STS.
    temp_access_key_id = token_data['AccessKeyId']
    temp_access_key_secret = token_data['AccessKeySecret']
    security_token = token_data['SecurityToken']
    now = int(time.time())
    # Konversi stempel waktu ke objek datetime.
    dt_obj = datetime.datetime.utcfromtimestamp(now)
    # Atur waktu kedaluwarsa permintaan menjadi 3 jam dari waktu saat ini.
    dt_obj_plus_3h = dt_obj + datetime.timedelta(hours=3)
    # Waktu permintaan.
    dt_obj_1 = dt_obj.strftime('%Y%m%dT%H%M%S') + 'Z'
    # Tanggal permintaan.
    dt_obj_2 = dt_obj.strftime('%Y%m%d')
    # Waktu kedaluwarsa permintaan.
    expiration_time = dt_obj_plus_3h.strftime('%Y-%m-%dT%H:%M:%S.000Z')
    # Definisikan fungsi untuk mengkodekan Base64 parameter callback.
    def encode_callback(callback_params):
        cb_str = json.dumps(callback_params).strip()
        return oss2.compat.to_string(base64.b64encode(oss2.compat.to_bytes(cb_str)))
    # Bangun konfigurasi callback dan kodekan Base64.
    callback_config = {
        "callbackUrl": "http://oss-demo.aliyuncs.com:23450/callback",  # URL server callback Anda.
        "callbackBody": "bucket=${bucket}&object=${object}&etag=${etag}&size=${size}",
        "callbackBodyType": "application/x-www-form-urlencoded"
    }
    encoded_callback = encode_callback(callback_config)
    # Bangun Kebijakan dan hasilkan tanda tangan.
    policy = {
        "expiration": expiration_time,
        "conditions": [
            ["eq", "$success_action_status", "200"],
            {"x-oss-signature-version": "OSS4-HMAC-SHA256"},
            {"x-oss-credential": f"{temp_access_key_id}/{dt_obj_2}/cn-hangzhou/oss/aliyun_v4_request"},
            {"x-oss-security-token": security_token},
            {"x-oss-date": dt_obj_1},
        ]
    }
    policy_str = json.dumps(policy).strip()
    # Langkah 2: Bangun string yang akan ditandatangani.
    stringToSign = base64.b64encode(policy_str.encode()).decode()
    # Langkah 3: Hitung kunci penandatanganan.
    dateKey = hmacsha256(("aliyun_v4" + temp_access_key_secret).encode(), dt_obj_2)
    dateRegionKey = hmacsha256(dateKey, "cn-hangzhou")
    dateRegionServiceKey = hmacsha256(dateRegionKey, "oss")
    signingKey = hmacsha256(dateRegionServiceKey, "aliyun_v4_request")
    # Langkah 4: Hitung tanda tangan.
    result = hmacsha256(signingKey, stringToSign)
    signature = result.hex()
    # Siapkan data tanggapan.
    response_data = {
        'policy': stringToSign,  # Bidang formulir.
        'x_oss_signature_version': "OSS4-HMAC-SHA256",  # Versi dan algoritma tanda tangan. Nilainya tetap OSS4-HMAC-SHA256.
        'x_oss_credential': f"{temp_access_key_id}/{dt_obj_2}/cn-hangzhou/oss/aliyun_v4_request",  # Set parameter yang menentukan kunci turunan.
        'x_oss_date': dt_obj_1,  # Waktu permintaan.
        'signature': signature,  # Informasi tanda tangan.
        'host': host,
        'dir': upload_dir,
        'security_token': security_token,  # Token keamanan.
        'callback': encoded_callback   # Konfigurasi callback yang dikodekan Base64.
    }
    return jsonify(response_data)
if __name__ == "__main__":
    app.run(host="127.0.0.1", port=8000)  # Jika Anda perlu mendengarkan alamat lain, seperti 0.0.0.0, Anda harus menambahkan mekanisme otentikasi pada server.

Node.js

Jalankan perintah berikut untuk menginstal dependensi.

npm install ali-oss
npm install @alicloud/credentials
npm install express

Gunakan kode contoh berikut untuk memperoleh kredensial akses sementara dari STS, membangun kebijakan unggahan, menghitung tanda tangan POST, dan mengatur callback.

const express = require('express');
const OSS = require('ali-oss');
const { STS } = require('ali-oss');
const { getCredential } = require('ali-oss/lib/common/signUtils');
const { getStandardRegion } = require('ali-oss/lib/common/utils/getStandardRegion');
const { policy2Str } = require('ali-oss/lib/common/utils/policy2Str');
const app = express();
const PORT = process.env.PORT || 8000; // Port permintaan layanan.
// Atur direktori file statis.
app.use(express.static('templates'));
const GenerateSignature = async () => {
    // Inisialisasi klien STS.
    let sts = new STS({
        accessKeyId: process.env.OSS_ACCESS_KEY_ID,  // Peroleh ID AccessKey pengguna RAM dari variabel lingkungan.
        accessKeySecret: process.env.OSS_ACCESS_KEY_SECRET // Peroleh rahasia AccessKey pengguna RAM dari variabel lingkungan.
    });
    // Panggil operasi assumeRole untuk memperoleh kredensial akses sementara dari STS.
    const result = await sts.assumeRole(process.env.OSS_STS_ROLE_ARN, '', '3600', 'yourRoleSessionName'); // Peroleh ARN peran RAM dari variabel lingkungan, atur periode validitas kredensial akses sementara menjadi 3.600 detik, dan tentukan nama sesi peran kustom.
    // Ekstrak AccessKeyId, AccessKeySecret, dan SecurityToken dari kredensial akses sementara.
    const accessKeyId = result.credentials.AccessKeyId;
    const accessKeySecret = result.credentials.AccessKeySecret;
    const securityToken = result.credentials.SecurityToken;
    // Inisialisasi klien OSS.
    const client = new OSS({
        bucket: 'examplebucket', // Ganti dengan nama bucket target Anda.
        region: 'cn-hangzhou', // Ganti dengan wilayah bucket target Anda.
        accessKeyId,
        accessKeySecret,
        stsToken: securityToken,
        refreshSTSTokenInterval: 0,
        refreshSTSToken: async () => {
            const { accessKeyId, accessKeySecret, securityToken } = await client.getCredential();
            return { accessKeyId, accessKeySecret, stsToken: securityToken };
        },
    });
    // Buat Map data formulir.
    const formData = new Map();
    // Atur waktu kedaluwarsa tanda tangan menjadi 10 menit dari waktu saat ini. 
    const date = new Date();
    const expirationDate = new Date(date);
    expirationDate.setMinutes(date.getMinutes() + 10);
    // Format tanggal ke string waktu UTC yang sesuai dengan standar ISO 8601.
    function padTo2Digits(num) {
        return num.toString().padStart(2, '0');
    }
    function formatDateToUTC(date) {
        return (
            date.getUTCFullYear() +
            padTo2Digits(date.getUTCMonth() + 1) +
            padTo2Digits(date.getUTCDate()) +
            'T' +
            padTo2Digits(date.getUTCHours()) +
            padTo2Digits(date.getUTCMinutes()) +
            padTo2Digits(date.getUTCSeconds()) +
            'Z'
        );
    }
    const formattedDate = formatDateToUTC(expirationDate);
    // URL untuk callback unggahan. Ini digunakan untuk komunikasi antara server aplikasi Anda dan OSS. Setelah file diunggah, OSS mengirim informasi unggahan ke server aplikasi Anda melalui URL ini. Misalnya, atur callbackUrl ke https://oss-demo.aliyuncs.com:23450.
    // Hasilkan x-oss-credential dan atur data formulir.
    const credential = getCredential(formattedDate.split('T')[0], getStandardRegion(client.options.region), client.options.accessKeyId);
    formData.set('x_oss_date', formattedDate);
    formData.set('x_oss_credential', credential);
    formData.set('x_oss_signature_version', 'OSS4-HMAC-SHA256');
    // Buat kebijakan.
    // Kebijakan berikut berisi bidang minimum yang diperlukan.
    const policy = {
        expiration: expirationDate.toISOString(),
        conditions: [
            { 'bucket': 'examplebucket' }, // Ganti dengan nama bucket target Anda.
            { 'x-oss-credential': credential },
            { 'x-oss-signature-version': 'OSS4-HMAC-SHA256' },
            { 'x-oss-date': formattedDate },
        ],
    };
    // Jika ada token STS, tambahkan ke kebijakan dan data formulir.
    if (client.options.stsToken) {
        policy.conditions.push({ 'x-oss-security-token': client.options.stsToken });
        formData.set('security_token', client.options.stsToken);
    }
    // Hasilkan tanda tangan dan atur data formulir.
    const signature = client.signPostObjectPolicyV4(policy, date);
    formData.set('policy', Buffer.from(policy2Str(policy), 'utf8').toString('base64'));
    formData.set('signature', signature);
    const callback = {
      callbackUrl: 'http://oss-demo.aliyuncs.com:23450/callback',// URL server yang menerima permintaan callback. Contoh: http://oss-demo.aliyuncs.com:23450/callback.
      callbackBody:// Konten callback, seperti ETag file dan tipe MIME sumber daya.
      "filename=${object}&size=${size}&mimeType=${mimeType}&height=${imageInfo.height}&width=${imageInfo.width}",
      callbackBodyType: "application/x-www-form-urlencoded",// Tipe konten callback.    
    };
    // Kembalikan data formulir.
    return {
        host: `http://${client.options.bucket}.oss-${client.options.region}.aliyuncs.com`, 
        policy: Buffer.from(policy2Str(policy), 'utf8').toString('base64'),
        x_oss_signature_version: 'OSS4-HMAC-SHA256',
        x_oss_credential: credential,
        x_oss_date: formattedDate,
        signature: signature,
        dir: 'user-dir', // Awalan untuk file yang diunggah ke OSS.
        callback: Buffer.from(JSON.stringify(callback)).toString("base64"),// Encode objek JSON dalam Base64 menggunakan Buffer.from.
        security_token: client.options.stsToken
    };
};
app.get('/get_post_signature_for_oss_upload', async (req, res) => {
    try {
        const result = await GenerateSignature();
        res.json(result); // Kembalikan data tanda tangan yang dihasilkan.
    } catch (error) {
        console.error('Error generating signature:', error);
        res.status(500).send('Error generating signature');
    }
});
app.listen(PORT, () => {
    console.log(`Server is running on http://127.0.0.1:${PORT}`); // Jika Anda perlu mendengarkan alamat lain, seperti 0.0.0.0, Anda harus menambahkan mekanisme autentikasi di server.
});

Go

Jalankan perintah berikut untuk menginstal dependensi.

go get -u github.com/aliyun/credentials-go
go mod tidy

Gunakan kode contoh berikut untuk memperoleh kredensial akses sementara dari STS, membangun kebijakan unggahan, menghitung tanda tangan POST, dan mengatur callback.

package main
import (
	"crypto/hmac"
	"crypto/sha256"
	"encoding/base64"
	"encoding/hex"
	"encoding/json"
	"fmt"
	"io"
    "hash"
	"log"
	"net/http"
	"os"
	"time"
	"github.com/aliyun/credentials-go/credentials"
)
// Definisikan variabel global.
var (
	region     string
	bucketName string
	product    = "oss"
)
// Struktur PolicyToken digunakan untuk menyimpan data formulir yang dihasilkan.
type PolicyToken struct {
	Policy           string `json:"policy"`
	SecurityToken    string `json:"security_token"`
	SignatureVersion string `json:"x_oss_signature_version"`
	Credential       string `json:"x_oss_credential"`
	Date             string `json:"x_oss_date"`
	Signature        string `json:"signature"`
	Host             string `json:"host"` 
	Dir              string `json:"dir"` 
    Callback         string `json:"callback"`
}
type CallbackParam struct{
    CallbackUrl string `json:"callbackUrl"`
    CallbackBody string `json:"callbackBody"`
    CallbackBodyType string `json:"callbackBodyType"`
}
func main() {
	// Definisikan string alamat IP dan port default.
	strIPPort := ":8080"
	if len(os.Args) == 3 {
		strIPPort = fmt.Sprintf("%s:%s", os.Args[1], os.Args[2])
	} else if len(os.Args) != 1 {
		fmt.Println("Usage   : go run test1.go                ")
		fmt.Println("Usage   : go run test1.go ip port        ")
		fmt.Println("Example : go run test1.go 11.22.**.** 80 ")
		fmt.Println("Example : go run test1.go 0.0.0.0 8080 ")
		fmt.Println("")
		os.Exit(0)
	}
	// Cetak alamat dan port tempat server berjalan.
	fmt.Printf("server is running on %s \n", strIPPort)
	// Daftarkan fungsi untuk menangani permintaan untuk path root.
	http.HandleFunc("/", handlerRequest)
	// Daftarkan fungsi untuk menangani permintaan untuk memperoleh tanda tangan.
	http.HandleFunc("/get_post_signature_for_oss_upload", handleGetPostSignature)
	// Mulai server HTTP.
	err := http.ListenAndServe(strIPPort, nil)
	if err != nil {
		strError := fmt.Sprintf("http.ListenAndServe failed : %s \n", err.Error())
		panic(strError)
	}
}
// Fungsi handlerRequest menangani permintaan untuk path root.
func handlerRequest(w http.ResponseWriter, r *http.Request) {
	if r.Method == "GET" {
		http.ServeFile(w, r, "templates/index.html")
		return
	}
	http.NotFound(w, r)
}
// Fungsi handleGetPostSignature menangani permintaan untuk memperoleh tanda tangan.
func handleGetPostSignature(w http.ResponseWriter, r *http.Request) {
	if r.Method == "GET" {
		response := getPolicyToken()
		w.Header().Set("Content-Type", "application/json")
		w.Header().Set("Access-Control-Allow-Origin", "*") // Izinkan permintaan lintas asal.
		w.Write([]byte(response))
		return
	}
	http.NotFound(w, r)
}
// Fungsi getPolicyToken menghasilkan tanda tangan dan kredensial yang diperlukan untuk unggahan OSS.
func getPolicyToken() string {
	// Atur wilayah tempat bucket berada.
	region = "cn-hangzhou"
	// Atur nama bucket.
	bucketName = "examplebucket"
	// Atur endpoint unggahan OSS.
	host := fmt.Sprintf("https://%s.oss-%s.aliyuncs.com", bucketName, region)
	// Atur direktori unggahan.
	dir := "user-dir"
    // callbackUrl adalah URL server yang menerima callback unggahan. Ganti alamat IP dan port dengan informasi aktual Anda.
    callbackUrl := "http://oss-demo.aliyuncs.com:23450/callback";
	config := new(credentials.Config).
		SetType("ram_role_arn").
		SetAccessKeyId(os.Getenv("OSS_ACCESS_KEY_ID")).
		SetAccessKeySecret(os.Getenv("OSS_ACCESS_KEY_SECRET")).
		SetRoleArn(os.Getenv("OSS_STS_ROLE_ARN")).
		SetRoleSessionName("Role_Session_Name").
		SetPolicy("").
		SetRoleSessionExpiration(3600)
	// Buat penyedia kredensial berdasarkan konfigurasi.
	provider, err := credentials.NewCredential(config)
	if err != nil {
		log.Fatalf("NewCredential fail, err:%v", err)
	}
	// Peroleh kredensial dari penyedia kredensial.
	cred, err := provider.GetCredential()
	if err != nil {
		log.Fatalf("GetCredential fail, err:%v", err)
	}
	// Bangun kebijakan.
	utcTime := time.Now().UTC()
	date := utcTime.Format("20060102")
	expiration := utcTime.Add(1 * time.Hour)
	policyMap := map[string]any{
		"expiration": expiration.Format("2006-01-02T15:04:05.000Z"),
		"conditions": []any{
			map[string]string{"bucket": bucketName},
			map[string]string{"x-oss-signature-version": "OSS4-HMAC-SHA256"},
			map[string]string{"x-oss-credential": fmt.Sprintf("%v/%v/%v/%v/aliyun_v4_request", *cred.AccessKeyId, date, region, product)},
			map[string]string{"x-oss-date": utcTime.Format("20060102T150405Z")},
			map[string]string{"x-oss-security-token": *cred.SecurityToken},
		},
	}
	// Konversi kebijakan ke format JSON.
	policy, err := json.Marshal(policyMap)
	if err != nil {
		log.Fatalf("json.Marshal fail, err:%v", err)
	}
    // Bangun string yang akan ditandatangani.
    stringToSign := base64.StdEncoding.EncodeToString([]byte(policy))
    hmacHash := func() hash.Hash { return sha256.New() }
    // Bangun kunci penandatanganan.
    signingKey := "aliyun_v4" + *cred.AccessKeySecret
    h1 := hmac.New(hmacHash, []byte(signingKey))
    io.WriteString(h1, date)
    h1Key := h1.Sum(nil)
    h2 := hmac.New(hmacHash, h1Key)
    io.WriteString(h2, region)
    h2Key := h2.Sum(nil)
    h3 := hmac.New(hmacHash, h2Key)
    io.WriteString(h3, product)
    h3Key := h3.Sum(nil)
    h4 := hmac.New(hmacHash, h3Key)
    io.WriteString(h4, "aliyun_v4_request")
    h4Key := h4.Sum(nil)
    // Hasilkan tanda tangan.
    h := hmac.New(hmacHash, h4Key)
    io.WriteString(h, stringToSign)
    signature := hex.EncodeToString(h.Sum(nil))
    var callbackParam CallbackParam
    callbackParam.CallbackUrl = callbackUrl
    callbackParam.CallbackBody = "filename=${object}&size=${size}&mimeType=${mimeType}&height=${imageInfo.height}&width=${imageInfo.width}"
    callbackParam.CallbackBodyType = "application/x-www-form-urlencoded"
    callback_str,err:=json.Marshal(callbackParam)
    if err != nil {
        fmt.Println("callback json err:", err)
    }
    callbackBase64 := base64.StdEncoding.EncodeToString(callback_str)
	// Bangun formulir yang akan dikembalikan ke klien.
	policyToken := PolicyToken{
		Policy:           stringToSign,
		SecurityToken:    *cred.SecurityToken,
		SignatureVersion: "OSS4-HMAC-SHA256",
		Credential:       fmt.Sprintf("%v/%v/%v/%v/aliyun_v4_request", *cred.AccessKeyId, date, region, product),
		Date:             utcTime.UTC().Format("20060102T150405Z"),
		Signature:        signature,
		Host:             host, // Endpoint unggahan OSS.
		Dir:              dir,  // Direktori unggahan.
        Callback:         callbackBase64, // Parameter callback unggahan.
	}
	response, err := json.Marshal(policyToken)
	if err != nil {
		fmt.Println("json err:", err)
	}
	return string(response)
}

PHP

Jalankan perintah berikut untuk menginstal dependensi.

composer install

Gunakan kode contoh berikut untuk memperoleh kredensial akses sementara dari STS, membangun kebijakan unggahan, menghitung tanda tangan POST, dan mengatur callback.

 ke nama session kustom, misalnya oss-role-session.  
    // Ganti  dengan ARN dari role RAM yang memiliki izin untuk mengunggah file ke Bucket OSS yang ditentukan.
    $result = $request
        ->withRoleSessionName('oss-role-session')
        ->withDurationSeconds(3600)
        ->withRoleArn(getenv('OSS_STS_ROLE_ARN')) // Ganti dengan ARN role RAM Anda.
        ->request();
    // Dapatkan informasi kredensial dari hasil permintaan STS.
    $tokenData = $result->get('Credentials');
    // Bangun data JSON yang dikembalikan.
    $tempAccessKeyId = $tokenData['AccessKeyId'];
    $tempAccessKeySecret = $tokenData['AccessKeySecret'];
    $securityToken = $tokenData['SecurityToken'];
    $now = time();
    $dtObj = gmdate('Ymd\THis\Z', $now);
    $dtObj1 = gmdate('Ymd', $now);
    $dtObjPlus3h = gmdate('Y-m-d\TH:i:s.u\Z', strtotime('+3 hours', $now));
    // Bangun kebijakan (policy).
    $policy = [
        "expiration" => $dtObjPlus3h,
        "conditions" => [
            ["x-oss-signature-version" => "OSS4-HMAC-SHA256"],
            ["x-oss-credential" => "{$tempAccessKeyId}/{$dtObj1}/cn-hangzhou/oss/aliyun_v4_request"],
            ["x-oss-security-token" => $securityToken],
            ["x-oss-date" => $dtObj],
        ]
    ];
    $policyStr = json_encode($policy);
    // Buat string yang akan ditandatangani.
    $stringToSign = base64_encode($policyStr);
    // Hitung kunci penandatanganan (signing key).
    $dateKey = hmacsha256(('aliyun_v4' . $tempAccessKeySecret), $dtObj1);
    $dateRegionKey = hmacsha256($dateKey, 'cn-hangzhou');
    $dateRegionServiceKey = hmacsha256($dateRegionKey, 'oss');
    $signingKey = hmacsha256($dateRegionServiceKey, 'aliyun_v4_request');
    // Hitung signature.
    $result = hmacsha256($signingKey, $stringToSign);
    $signature = bin2hex($result);
    $callback_param = array(
    'callbackUrl' => $callbackUrl,
    'callbackBody' => 'filename=${object}&size=${size}&mimeType=${mimeType}&height=${imageInfo.height}&width=${imageInfo.width}',
    'callbackBodyType' => "application/x-www-form-urlencoded"
    );
    $callback_string = json_encode($callback_param);
    $base64_callback_body = base64_encode($callback_string);
    // Kembalikan data signature.
    $responseData = [
        'policy' => $stringToSign,
        'x_oss_signature_version' => "OSS4-HMAC-SHA256",
        'x_oss_credential' => "{$tempAccessKeyId}/{$dtObj1}/cn-hangzhou/oss/aliyun_v4_request",
        'x_oss_date' => $dtObj,
        'signature' => $signature,
        'host' => $host,
        'dir' => $upload_dir,
        'security_token' => $securityToken,
        'callback' => $base64_callback_body,
    ];
    header('Content-Type: application/json');
    echo json_encode($responseData);
    exit;
}
// Entri rute halaman utama.
if ($_SERVER['REQUEST_METHOD'] === 'GET' && $_SERVER['REQUEST_URI'] === '/') {
    echo file_get_contents(__DIR__ . '/public/index.html');
    exit;
}
// Entri rute lainnya.
http_response_code(404);
echo json_encode(['message' => 'Not Found']);
exit;
?><?php
// Impor SDK Alibaba Cloud.
require_once __DIR__ . '/vendor/autoload.php';
use AlibabaCloud\Client\AlibabaCloud;
use AlibabaCloud\Client\Exception\ClientException;
use AlibabaCloud\Client\Exception\ServerException;
use AlibabaCloud\Sts\Sts;
// Nonaktifkan tampilan error.
ini_set('display_errors', '0');
$bucket = 'examplebucket'; // Ganti dengan nama bucket Anda.
$region_id = 'cn-hangzhou'; // Ganti dengan wilayah bucket Anda.
$host = 'http://examplebucket.oss-cn-hangzhou.aliyuncs.com'; // Ganti dengan nama domain bucket Anda.
$expire_time = 3600; // Waktu kedaluwarsa dalam detik.
$upload_dir = 'user-dir'; // Awalan untuk file yang diunggah.
// $callbackUrl adalah URL server yang menerima callback unggahan. Ganti alamat IP dan port dengan URL aktual Anda.
$callbackUrl = 'http://oss-demo.aliyuncs.com:23450/callback';
// Hitung HMAC-SHA256.
function hmacsha256($key, $data) {
    return hash_hmac('sha256', $data, $key, true);
}
// Tangani permintaan untuk memperoleh tanda tangan POST.
if ($_SERVER['REQUEST_METHOD'] === 'GET' && $_SERVER['REQUEST_URI'] === '/get_post_signature_for_oss_upload') {
    AlibabaCloud::accessKeyClient(getenv('OSS_ACCESS_KEY_ID'), getenv('OSS_ACCESS_KEY_SECRET'))
        ->regionId('cn-hangzhou')
        ->asDefaultClient();
    // Buat permintaan STS.
    $request = Sts::v20150401()->assumeRole();
    // Lakukan permintaan STS dan peroleh hasilnya.
    // Atur <your_role_session_name> ke nama sesi kustom, misalnya, oss-role-session.
    // Ganti <your_role_arn> dengan ARN peran RAM yang memiliki izin untuk mengunggah file ke bucket OSS yang ditentukan.
    $result = $request
        ->withRoleSessionName('oss-role-session')
        ->withDurationSeconds(3600)
        ->withRoleArn(getenv('OSS_STS_ROLE_ARN')) // Ganti dengan ARN peran RAM Anda.
        ->request();
    // Peroleh informasi kredensial dari hasil permintaan STS.
    $tokenData = $result->get('Credentials');
    // Bangun data JSON yang dikembalikan.
    $tempAccessKeyId = $tokenData['AccessKeyId'];
    $tempAccessKeySecret = $tokenData['AccessKeySecret'];
    $securityToken = $tokenData['SecurityToken'];
    $now = time();
    $dtObj = gmdate('Ymd\THis\Z', $now);
    $dtObj1 = gmdate('Ymd', $now);
    $dtObjPlus3h = gmdate('Y-m-d\TH:i:s.u\Z', strtotime('+3 hours', $now));
    // Bangun kebijakan.
    $policy = [
        "expiration" => $dtObjPlus3h,
        "conditions" => [
            ["x-oss-signature-version" => "OSS4-HMAC-SHA256"],
            ["x-oss-credential" => "{$tempAccessKeyId}/{$dtObj1}/cn-hangzhou/oss/aliyun_v4_request"],
            ["x-oss-security-token" => $securityToken],
            ["x-oss-date" => $dtObj],
        ]
    ];
    $policyStr = json_encode($policy);
    // Bangun string yang akan ditandatangani.
    $stringToSign = base64_encode($policyStr);
    // Hitung kunci penandatanganan.
    $dateKey = hmacsha256(('aliyun_v4' . $tempAccessKeySecret), $dtObj1);
    $dateRegionKey = hmacsha256($dateKey, 'cn-hangzhou');
    $dateRegionServiceKey = hmacsha256($dateRegionKey, 'oss');
    $signingKey = hmacsha256($dateRegionServiceKey, 'aliyun_v4_request');
    // Hitung tanda tangan.
    $result = hmacsha256($signingKey, $stringToSign);
    $signature = bin2hex($result);
    $callback_param = array(
    'callbackUrl' => $callbackUrl,
    'callbackBody' => 'filename=${object}&size=${size}&mimeType=${mimeType}&height=${imageInfo.height}&width=${imageInfo.width}',
    'callbackBodyType' => "application/x-www-form-urlencoded"
    );
    $callback_string = json_encode($callback_param);
    $base64_callback_body = base64_encode($callback_string);
    // Kembalikan data tanda tangan.
    $responseData = [
        'policy' => $stringToSign,
        'x_oss_signature_version' => "OSS4-HMAC-SHA256",
        'x_oss_credential' => "{$tempAccessKeyId}/{$dtObj1}/cn-hangzhou/oss/aliyun_v4_request",
        'x_oss_date' => $dtObj,
        'signature' => $signature,
        'host' => $host,
        'dir' => $upload_dir,
        'security_token' => $securityToken,
        'callback' => $base64_callback_body,
    ];
    header('Content-Type: application/json');
    echo json_encode($responseData);
    exit;
}
// Rute halaman utama.
if ($_SERVER['REQUEST_METHOD'] === 'GET' && $_SERVER['REQUEST_URI'] === '/') {
    echo file_get_contents(__DIR__ . '/public/index.html');
    exit;
}
// Rute lainnya.
http_response_code(404);
echo json_encode(['message' => 'Not Found']);
exit;
?></your_role_arn></your_role_session_name>