版本说明

本示例配套的SDK版本为：3.0.60

数据安全中心服务中给文件嵌入水印相关示例

本示例展示如何通过java版本的DSC SDK方式将文档嵌入水印。

功能介绍

数据安全中心服务 是新一代的云原生数据安全平台，提供数据分级分类，数据安全风险识别，数据水印溯源，数据脱敏等基础数据安全能力，通过数据安全总览整合数据安全生命周期各阶段状态，对外整体呈现云上数据安全态势。

前置条件

1.已 注册 华为云，并完成 实名认证 。

2.获取华为云开发工具包（SDK），您也可以查看安装JAVA SDK。

3.已获取华为云账号对应的Access Key（AK）和Secret Access Key（SK）。请在华为云控制台“我的凭证 > 访问密钥”页面上创建和查看您的AK/SK。具体请参见 访问密钥 。

4.已具备开发环境 ，支持Java JDK 1.8及其以上版本。

5.已购买DSC服务专业版，购买链接数据安全中心

代码示例

以下代码展示如何使用DSC SDK对文档嵌入水印：

                    
                    Copied!
                
package com.huawei.dsc.demo;

import com.huaweicloud.sdk.core.auth.BasicCredentials;
import com.huaweicloud.sdk.core.auth.ICredential;
import com.huaweicloud.sdk.core.exception.ConnectionException;
import com.huaweicloud.sdk.core.exception.RequestTimeoutException;
import com.huaweicloud.sdk.core.exception.ServiceResponseException;
import com.huaweicloud.sdk.core.region.Region;
import com.huaweicloud.sdk.dsc.v1.DscClient;
import com.huaweicloud.sdk.dsc.v1.model.CreateDocWatermarkRequest;
import com.huaweicloud.sdk.dsc.v1.model.CreateDocWatermarkRequestBody;
import com.huaweicloud.sdk.dsc.v1.model.CreateDocWatermarkResponse;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.function.Consumer;

/**
 * 给文档添加明水印和暗水印
 * 返回嵌入水印的文档
 */
public class CreateDocWatermarkTest {

    /**
     * 基础认证信息：
     * 认证用的ak和sk直接写到代码中有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全；
     * 本示例以ak和sk保存在环境变量中来实现身份验证为例，运行本示例前请先在本地环境中设置环境变量HUAWEICLOUD_SDK_AK和HUAWEICLOUD_SDK_SK。
     * - IAM_ENDPOINT: 华为云IAM服务访问终端地址 详情见https://support.huaweicloud.com/api-iam/iam_01_0004.html,
     *                 eg: https://iam.myhuaweicloud.com
     * - DSC_ENDPOINT: 华为云DSC服务访问终端地址 详情见https://support.huaweicloud.com/api-dsc/dsc_02_0004.html,
     *                 eg: https://sdg.cn-south-1.myhuaweicloud.com
     * - REGION_ID: 华为云DSC服务访问RegionID, 详情见https://support.huaweicloud.com/api-dsc/dsc_02_0004.html，
     *                 eg: cn-south-1
     */
    private static final String AK = System.getenv("HUAWEICLOUD_SDK_AK");
    private static final String SK = System.getenv("HUAWEICLOUD_SDK_SK");
    private static final String IAM_ENDPOINT = "<IamEndpoint>";
    private static final String DSC_ENDPOINT = "<DscEndpoint>";
    private static final String REGION_ID = "<RegionId>";

    // 1.设置需要加水印的文件路径（包括文件名），建议使用绝对路径
    private static final String INPUT_FILE_PATH = "<InputFilePath>";

    // 2.设置需要加水印的文件名
    private static final String INPUT_FILE_NAME = "<InputFileName>";

    // 3.设置返回的带水印的文件路径（包括文件名），建议使用绝对路径
    private static final String OUTPUT_FILE_PATH = "<OutputFilePath>";

    private static final int BUFF_SIZE = 1024 * 1024;

    private static final Logger LOGGER = LoggerFactory.getLogger(CreateDocWatermarkTest.class.getName());

    private static final ICredential AUTH = new BasicCredentials()
        .withIamEndpoint(IAM_ENDPOINT)
        .withAk(AK)
        .withSk(SK);

    private static final DscClient CLIENT = DscClient.newBuilder()
        .withCredential(AUTH)
        .withRegion(new Region(REGION_ID, DSC_ENDPOINT))
        .build();

    // 4.内部类，接收返回的文件流，转化为输出流后，写入返回的带暗水印的文件到磁盘
    static class WatermarkConsumer<T> implements Consumer<T> {
        public void accept(T t) {
            if (t instanceof InputStream) {
                try (FileOutputStream fos = new FileOutputStream(OUTPUT_FILE_PATH);
                    InputStream inputStreamTemp = (InputStream) t) {
                    int byteCount;
                    byte[] bytes = new byte[BUFF_SIZE];
                    while ((byteCount = inputStreamTemp.read(bytes)) != -1) {
                        fos.write(bytes,0, byteCount);
                    }
                } catch (IOException e) {
                    LOGGER.error(e.toString());
                }
            }
        }
    }

    public static void main(String[] args) {
        CreateDocWatermarkRequest request = new CreateDocWatermarkRequest();
        CreateDocWatermarkRequestBody body = new CreateDocWatermarkRequestBody();

        try (InputStream inputStream = new FileInputStream(INPUT_FILE_PATH)) {
            body.withFile(inputStream, INPUT_FILE_NAME);

            // 5.设置需要嵌入水印的文档类型
            body.withDocType(CreateDocWatermarkRequestBody.DocTypeEnum.WORD);

            // 6.设置明水印内容
            body.withVisibleWatermark("visibleWatermark");

            // 7.设置暗水印内容
            body.withBlindWatermark("BlindWatermark");

            request.withBody(body);

            CreateDocWatermarkResponse response = CLIENT.createDocWatermark(request);
            Consumer<InputStream> consumer = new WatermarkConsumer<>();

            // 8.使用步骤4中自定义的消费者类接收返回的文件流，并保存文件到磁盘
            response.consumeDownloadStream(consumer);

            System.out.printf("response http code: %d", response.getHttpStatusCode());
        } catch (ConnectionException | RequestTimeoutException | IOException e) {
            LOGGER.error(e.toString());
        } catch (ServiceResponseException e) {
            LOGGER.error(String.valueOf(e.getHttpStatusCode()));
            LOGGER.error(e.getErrorCode());
            LOGGER.error(e.getErrorMsg());
        }
    }
}

您可以在 API Explorer 调试该接口

修订记录