import org.apache.xmlbeans.impl.util.Base64; //导入依赖的package包/类
public InputStream getObjectByRange(NetAppClient netAppClient, String identifier, Long start, Long end) throws KeyManagementException, UnrecoverableKeyException, KeyStoreException,
NoSuchAlgorithmException, CertificateException, IOException, URISyntaxException{
	DefaultHttpClient httpclient = createHttpClient(netAppClient, false);
	String range = (start != null && end != null) ? ":" + start + "-" + end : "";
	HttpGet httpget = new HttpGet(new URI(getCDMIObjectURIAsString(netAppClient, identifier) + "?value" + range));
	initializeHeaders(httpget, CDMIHttpHeader.CONTENT_TYPE_CDMI_OBJECT);
	setCredentials(netAppClient, httpclient, false);
	HttpResponse response = httpclient.execute(httpget);
	String value = getSpecificJSONValue(response, "value");
	InputStream content = null;
	if (value != null) {
		byte[] decoded = Base64.decode(value.getBytes());
		content = new ByteArrayInputStream(decoded);
	}
	return content;
}
 

import org.apache.xmlbeans.impl.util.Base64; //导入依赖的package包/类
public void loadStorage() {
    try {
        if (myState.storageAccount != null) {
            byte[] data = Base64.decode(myState.storageAccount.getBytes());
            ByteArrayInputStream buffer = new ByteArrayInputStream(data);
            ObjectInput input = new ObjectInputStream(buffer);
            try {
                StorageAccount[] storageAccs = (StorageAccount[]) input.readObject();
                for (StorageAccount str : storageAccs) {
                    if (!StorageAccountRegistry.getStrgList().contains(str)) {
                        StorageAccountRegistry.getStrgList().add(str);
                    }
                }
            } finally {
                input.close();
            }
        }
    } catch (ClassNotFoundException ex) {
        // ignore - this happens because class package changed and settings were not updated
    } catch (Exception e) {
        log(message("err"), e);
    }
}
 

import org.apache.xmlbeans.impl.util.Base64; //导入依赖的package包/类
public void loadAppInsights() {
    try {
        if (myState.appInsights != null) {
            byte[] data = Base64.decode(myState.appInsights.getBytes());
            ByteArrayInputStream buffer = new ByteArrayInputStream(data);
            ObjectInput input = new ObjectInputStream(buffer);
            try {
                ApplicationInsightsResource[] resources = (ApplicationInsightsResource[]) input.readObject();
                for (ApplicationInsightsResource resource : resources) {
                    if (!ApplicationInsightsResourceRegistry.getAppInsightsResrcList().contains(resource)) {
                        ApplicationInsightsResourceRegistry.getAppInsightsResrcList().add(resource);
                    }
                }
            } finally {
                input.close();
            }
        }
    } catch (ClassNotFoundException ex) {
        // ignore - this happens because class package changed and settings were not updated
    } catch (Exception e) {
        log(message("err"), e);
    }
}
 

import org.apache.xmlbeans.impl.util.Base64; //导入依赖的package包/类
public void saveStorage() {
    try {
        ByteArrayOutputStream buffer = new ByteArrayOutputStream();
        ObjectOutput output = new ObjectOutputStream(buffer);
        List<StorageAccount> data = StorageAccountRegistry.getStrgList();
        /*
         * Sort list according to storage account name.
*/
        Collections.sort(data);
        StorageAccount[] dataArray = new StorageAccount[data.size()];
        int i = 0;
        for (StorageAccount pd1 : data) {
            dataArray[i] = pd1;
            i++;
        }
        try {
            output.writeObject(dataArray);
        } finally {
            output.close();
        }
        myState.storageAccount = new String(Base64.encode(buffer.toByteArray()));
    } catch (IOException e) {
        log(message("err"), e);
    }
}
 

import org.apache.xmlbeans.impl.util.Base64; //导入依赖的package包/类
public void saveAppInsights() {
    try {
        ByteArrayOutputStream buffer = new ByteArrayOutputStream();
        ObjectOutput output = new ObjectOutputStream(buffer);
        List<ApplicationInsightsResource> data = ApplicationInsightsResourceRegistry.getAppInsightsResrcList();
        /*
* Sort list according to application insights resource name.
*/
        Collections.sort(data);
        ApplicationInsightsResource[] dataArray = new ApplicationInsightsResource[data.size()];
        int i = 0;
        for (ApplicationInsightsResource pd1 : data) {
            dataArray[i] = pd1;
            i++;
        }
        try {
            output.writeObject(dataArray);
        } finally {
            output.close();
        }
        myState.appInsights = new String(Base64.encode(buffer.toByteArray()));
    } catch (IOException e) {
        log(message("err"), e);
    }
}
 

import org.apache.xmlbeans.impl.util.Base64; //导入依赖的package包/类
public void savePublishDatas() {
    try {
        ByteArrayOutputStream buffer = new ByteArrayOutputStream();
        ObjectOutput output = new ObjectOutputStream(buffer);
        Collection<PublishData> data = WizardCacheManager.getPublishDatas();
        PublishData[] dataArray = new PublishData[data.size()];
        int i = 0;
        for (PublishData pd1 : data) {
            dataArray[i] = new PublishData();
            dataArray[i++].setPublishProfile(pd1.getPublishProfile());
        }
        try {
            output.writeObject(dataArray);
        } finally {
            output.close();
        }
        myState.publishProfile = new String(Base64.encode(buffer.toByteArray()));
    } catch (IOException e) {
        e.printStackTrace();
    }
}
 

import org.apache.xmlbeans.impl.util.Base64; //导入依赖的package包/类
public SendDocumentResponseType sendDocument(String uniqueId, String type, byte[] manus)
    throws XRoadServiceConsumptionException {
  SendDocumentRequestType kassaReq = SendDocumentRequestType.Factory.newInstance();

  kassaReq.setUniqueId(uniqueId);
  kassaReq.setType(type);
  kassaReq.setManus("".getBytes());

  List<XRoadAttachment> attachments = new ArrayList<XRoadAttachment>();
  attachments.add(new XRoadAttachment("manus", "application/octet-stream", Base64.encode(manus)));

  XRoadMessage<SendDocumentResponseType> response =
      send(new XmlBeansXRoadMessage<SendDocumentRequestType>(kassaReq, attachments),
           SEND_DOCUMENT,
           VERSION,
           new RmvikiCallback(),
           null);
  return response.getContent();
}
 

import org.apache.xmlbeans.impl.util.Base64; //导入依赖的package包/类
public String sendDocument(String uniqueId, String type, byte[] manus) throws XRoadServiceConsumptionException {
  SendDocumentRequestType kassaReq = SendDocumentRequestType.Factory.newInstance();

  kassaReq.setUniqueId(uniqueId);
  kassaReq.setType(type);

  List<XRoadAttachment> attachments = new ArrayList<XRoadAttachment>();
  attachments.add(new XRoadAttachment("manus", "application/octet-stream", Base64.encode(manus)));

  XRoadMessage<SendDocumentResponseType> response =
      send(new XmlBeansXRoadMessage<SendDocumentRequestType>(kassaReq, attachments),
           SEND_DOCUMENT,
           VERSION,
           new RmvikiCallback(),
           null);

  if (response.getContent().getCode() != 0) {
    return response.getContent().getMessage();
  }
  return null;
}
 

import org.apache.xmlbeans.impl.util.Base64; //导入依赖的package包/类
public static String encode(final String str) {
    byte[] bytes = null;
    try {
        bytes = Base64.encode(str.getBytes("UTF-8"));
    } catch (UnsupportedEncodingException e) {
        e.printStackTrace();
    }
    return new String(bytes);
}
 

import org.apache.xmlbeans.impl.util.Base64; //导入依赖的package包/类
public static String decode(final String str) {
    String s = null;
    try {
        s = new String(Base64.decode(str.getBytes()), "UTF-8");
    } catch (UnsupportedEncodingException e) {
        e.printStackTrace();
    }
    return s;
}
 

import org.apache.xmlbeans.impl.util.Base64; //导入依赖的package包/类
public String putObject(NetAppClient netAppClient, StoredEntityMetaData storedEntityMetadata, InputStream inputStream) throws Exception{
		// Create the request
		DefaultHttpClient httpclient = createHttpClient(netAppClient, true);
		HttpPost httpPost = new HttpPost(new URI(getContainerURI(netAppClient, true)));

		// TODO: support chunks for big files
		byte[] encode = Base64.encode(IOUtils.toByteArray(inputStream));
		String bytes = new String(encode);

		initializeHeaders(httpPost, CDMIHttpHeader.CONTENT_TYPE_CDMI_OBJECT);
		String domainURI = "/cdmi_domains/";
		DnxDocument fileDnx = storedEntityMetadata.getFileDnx();
		String mimetype = fileDnx.getSectionKeyValue(DNXConstants.FILEFORMAT.MIMETYPE);
		String string = "{\"domainURI\":\"" + domainURI
				+ "\",\"mimetype\":\"" + mimetype + "\",\"metadata\":{\"pid\" : \"" + storedEntityMetadata.getEntityPid()
				+ "\"},\"valuetransferencoding\":\"base64\",\"value\":\"" + bytes + "\"}";
		httpPost.setEntity(new StringEntity(string));

		// 1. Create data object
		HttpResponse response = httpclient.execute(httpPost);

		// 2. get object id from the response
		String identifier = getSpecificJSONValue(response, "objectID");

		// 3. update the existing object value in ranges
/*
    FIXME

    !!! If InputStreamEntity will not work - try sending in ranges manually

 		long partSize = 4096;
		long remainingBytes = storedEntityMetadata.getSizeInBytes();
		long currentRange = 0;
		long endRange = 0;
		boolean isLastPart = (remainingBytes - partSize <= 0);
		while (remainingBytes > 0) {
			isLastPart = (remainingBytes - partSize <= 0);
			if(isLastPart){
				partSize = remainingBytes;
			}
			endRange = currentRange+partSize;
			httpput = new HttpPut(getCDMIObjectURI(netAppClient, identifier)+"?value:"+currentRange+":"+endRange);
			byte [] stream = new byte[(int) partSize];
			inputStream.read(stream);
			StringEntity entity = new StringEntity(new String(stream));
			httpput.setEntity(entity);
			response = httpclient.execute(httpput);
			if (!isSuccessfulResponse(response)){
				deleteObject(netAppClient, identifier);
				return null;
			}
			remainingBytes = remainingBytes - partSize;
		}
*/

		return identifier;
	}