java - 如何在java中为azure的文件服务添加SAS？

Question

我得到了 C# 代码或 Blob 存储代码。我需要一些 java 中的引用代码才能在 azure 中拥有用于文件存储的 SAS token 。 SAS 可能适用于账户或服务。

代码1:

static string GetAccountSASToken()
{
    // To create the account SAS, you need to use your shared key credentials. Modify for your account.
    const string ConnectionString = "DefaultEndpointsProtocol=https;AccountName=account-name;AccountKey=account-key";
    CloudStorageAccount storageAccount = CloudStorageAccount.Parse(ConnectionString);

    // Create a new access policy for the account.
    SharedAccessAccountPolicy policy = new SharedAccessAccountPolicy()
        {
            Permissions = SharedAccessAccountPermissions.Read | SharedAccessAccountPermissions.Write | SharedAccessAccountPermissions.List,
            Services = SharedAccessAccountServices.Blob | SharedAccessAccountServices.File,
            ResourceTypes = SharedAccessAccountResourceTypes.Service,
            SharedAccessExpiryTime = DateTime.UtcNow.AddHours(24),
            Protocols = SharedAccessProtocol.HttpsOnly
        };

    // Return the SAS token.
    return storageAccount.GetSharedAccessSignature(policy);
}

此代码是关于创建 SAS token 以进行帐户验证和到期时间。我在 java 中需要相同的代码。我没有得到一些东西，例如，在第一个代码中我如何在java中编写“权限”？我的意思是一行中有多个。请为此提供等效的 java 代码。

代码2:

@Test
    public String testFileSAS(CloudFileShare share, CloudFile file) throws InvalidKeyException,
            IllegalArgumentException, StorageException, URISyntaxException, InterruptedException {
        SharedAccessFilePolicy policy = createSharedAccessPolicy(EnumSet.of(SharedAccessFilePermissions.READ,
                SharedAccessFilePermissions.LIST, SharedAccessFilePermissions.WRITE), 24);
        FileSharePermissions perms = new FileSharePermissions();
        // SharedAccessProtocols protocol = SharedAccessProtocols.HTTPS_ONLY;
        perms.getSharedAccessPolicies().put("readperm", policy);

        share.uploadPermissions(perms);
        // Thread.sleep(30000);

        CloudFile sasFile = new CloudFile(
                new URI(file.getUri().toString() + "?" + file.generateSharedAccessSignature(null, "readperm")));
        sasFile.download(new ByteArrayOutputStream());

        // do not give the client and check that the new file's client has the
        // correct permissions
        CloudFile fileFromUri = new CloudFile(
                PathUtility.addToQuery(file.getStorageUri(), file.generateSharedAccessSignature(null, "readperm")));
        assertEquals(StorageCredentialsSharedAccessSignature.class.toString(),
                fileFromUri.getServiceClient().getCredentials().getClass().toString());

        // create credentials from sas
        StorageCredentials creds = new StorageCredentialsSharedAccessSignature(
                file.generateSharedAccessSignature(policy, null, null));
        System.out.println("Generated SAS token is : " + file.generateSharedAccessSignature(policy, null, null));
        String token = file.generateSharedAccessSignature(policy, null, null);
        CloudFileClient client = new CloudFileClient(sasFile.getServiceClient().getStorageUri(), creds);

        CloudFile fileFromClient = client.getShareReference(file.getShare().getName()).getRootDirectoryReference()
                .getFileReference(file.getName());
        assertEquals(StorageCredentialsSharedAccessSignature.class.toString(),
                fileFromClient.getServiceClient().getCredentials().getClass().toString());
        assertEquals(client, fileFromClient.getServiceClient());
        // self written
        // String sharedUri =
        // file.generateSharedAccessSignature(policy,null,null);
        // System.out.println("token created is : "+sharedUri);
        return token;
    }

    private final static SharedAccessFilePolicy createSharedAccessPolicy(EnumSet<SharedAccessFilePermissions> sap,
            int expireTimeInSeconds) {

        Calendar calendar = new GregorianCalendar(TimeZone.getTimeZone("UTC"));
        calendar.setTime(new Date());
        calendar.add(Calendar.HOUR, expireTimeInSeconds);
        SharedAccessFilePolicy policy = new SharedAccessFilePolicy();
        policy.setPermissions(sap);
        policy.setSharedAccessExpiryTime(calendar.getTime());
        return policy;
    }

此代码是 jUnit 测试。我不想导入 jUnit 库。想用纯java来做。我如何转换代码？我可以用什么来代替assertEqauls？

Answer 1

请考虑以下 Java 代码片段。

public static final String storageConnectionString = "DefaultEndpointsProtocol=https;AccountName=account-name;AccountKey=account-key";

public String getAccountSASToken() throws InvalidKeyException, URISyntaxException, StorageException {

    CloudStorageAccount account = CloudStorageAccount.parse(storageConnectionString);

    SharedAccessAccountPolicy policy = new SharedAccessAccountPolicy();
    policy.setPermissions(EnumSet.of(SharedAccessAccountPermissions.READ, SharedAccessAccountPermissions.WRITE, SharedAccessAccountPermissions.LIST));
    policy.setServices(EnumSet.of(SharedAccessAccountService.BLOB, SharedAccessAccountService.FILE) );
    policy.setResourceTypes(EnumSet.of(SharedAccessAccountResourceType.SERVICE));
    policy.setSharedAccessExpiryTime(Date.from(ZonedDateTime.now(ZoneOffset.UTC).plusHours(24L).toInstant()));
    policy.setProtocols(SharedAccessProtocols.HTTPS_ONLY);

    return account.generateSharedAccessSignature(policy);
}