连接Azure Blob_azure blob的连接方式

获取token

public static HttpURLConnection getBlobTokenURLOpenConnection(URL url) throws Exception {

		HttpURLConnection httpUrlConnection;
		try {
			log.info("getBlobTokenURLOpenConnection 1");

			TrustManager[] trustAllCerts = new TrustManager[]{
					new X509TrustManager() {
						public java.security.cert.X509Certificate[] getAcceptedIssuers()
						{ return null; }

						public void checkClientTrusted( java.security.cert.X509Certificate[] certs, String authType)
						{ }

						public void checkServerTrusted( java.security.cert.X509Certificate[] certs, String authType)
						{ }
					}
			};

			log.info("getBlobTokenURLOpenConnection 2");
			// Install the all-trusting trust manager
			try {
				SSLContext sc = SSLContext.getInstance("SSL");
				sc.init(null, trustAllCerts, new java.security.SecureRandom());
				HttpsURLConnection.setDefaultSSLSocketFactory(sc.getSocketFactory());
			} catch (Exception e) {
				throw new Exception("SSL Exception at " + getCurrentTime());
			}

			log.info("getBlobTokenURLOpenConnection 3");
			httpUrlConnection = (HttpURLConnection) url.openConnection();

			log.info("getBlobTokenURLOpenConnection 4");
			httpUrlConnection.setRequestProperty("Authorization", "Basic ");
			httpUrlConnection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
			httpUrlConnection.setRequestProperty("Accept", "application/x-www-form-urlencoded");
			httpUrlConnection.setDoOutput(true);

			log.info("getBlobTokenURLOpenConnection 5");
			//String lookup_string = "GRAPHAPI_CONN_TIMEOUT";
			log.info("BLOBHAPI_CONN_TIMEOUT : " + BLOBAPI_CONN_TIMEOUT);
			//lookup_string = "GRAPHAPI_READ_TIMEOUT";
			log.info("BLOBAPI_READ_TIMEOUT : " + BLOBHAPI_READ_TIMEOUT);


			if(BLOBAPI_CONN_TIMEOUT ==null || BLOBAPI_CONN_TIMEOUT.trim().isEmpty()) {
				httpUrlConnection.setConnectTimeout(10000);  // 10 seconds
			}else {
				try {
					httpUrlConnection.setConnectTimeout(Integer.valueOf(BLOBAPI_CONN_TIMEOUT));
				} catch (Exception e)
				{
					log.info("BLOBAPI_CONN_TIMEOUT set as default value due to error on config file! ");
					httpUrlConnection.setConnectTimeout(10000);  // 10 seconds
				}
			}

			if(BLOBHAPI_READ_TIMEOUT ==null || BLOBHAPI_READ_TIMEOUT.trim().isEmpty()) {
				httpUrlConnection.setReadTimeout(180000);    // 180 seconds
			}else {
				try {
					httpUrlConnection.setReadTimeout(Integer.valueOf(BLOBHAPI_READ_TIMEOUT));
				} catch (Exception e)
				{
					log.info("BLOBAPI_READ_TIMEOUT set as default value due to error on config file! ");
					httpUrlConnection.setReadTimeout(180000);    // 180 seconds
				}
			}

			return httpUrlConnection;
		} catch (Exception e) {
			throw new Exception("Fail to Open Http connection :: ", e);
		}

    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75

连接blob api

public static HttpURLConnection getHttpBlobURLOpenConnection(URL url, String access_token,String xmsDate, String xmsVersion) throws Exception {

		HttpURLConnection httpUrlConnection;
		try {
			log.info("getHttpBlobURLOpenConnection 1");
			TrustManager[] trustAllCerts = new TrustManager[]{
					new X509TrustManager() {
						public java.security.cert.X509Certificate[] getAcceptedIssuers()
						{ return null; }

						public void checkClientTrusted( java.security.cert.X509Certificate[] certs, String authType)
						{ }

						public void checkServerTrusted( java.security.cert.X509Certificate[] certs, String authType)
						{ }
					}
			};

			log.info("getHttpBlobURLOpenConnection 2");
			// Install the all-trusting trust manager
			try {
				SSLContext sc = SSLContext.getInstance("SSL");
				sc.init(null, trustAllCerts, new java.security.SecureRandom());
				HttpsURLConnection.setDefaultSSLSocketFactory(sc.getSocketFactory());
			} catch (Exception e) {
				throw new Exception("SSL Exception at " + getCurrentTime());
			}

			log.info("getHttpBlobURLOpenConnection 3");
			httpUrlConnection = (HttpURLConnection) url.openConnection();

			log.info("getHttpBlobURLOpenConnection 4");
			httpUrlConnection.setRequestProperty("Authorization", access_token);
			httpUrlConnection.setRequestProperty("x-ms-date", xmsDate);
			httpUrlConnection.setRequestProperty("x-ms-version", xmsVersion);
			log.info("Authorization: "+access_token+" x-ms-date: "+xmsDate+" x-ms-version: "+xmsVersion);
			httpUrlConnection.setDoOutput(true);

			log.info("getHttpBlobURLOpenConnection 5");
			//String lookup_string = "GRAPHAPI_CONN_TIMEOUT";
			log.info("GRAPHAPI_CONN_TIMEOUT : " + BLOBAPI_CONN_TIMEOUT);
			//lookup_string = "GRAPHAPI_READ_TIMEOUT";
			log.info("BLOBAPI_READ_TIMEOUT : " + BLOBHAPI_READ_TIMEOUT);


			if(BLOBAPI_CONN_TIMEOUT ==null || BLOBAPI_CONN_TIMEOUT.trim().isEmpty()) {
				httpUrlConnection.setConnectTimeout(10000);  // 10 seconds
			}else {
				try {
					httpUrlConnection.setConnectTimeout(Integer.valueOf(BLOBAPI_CONN_TIMEOUT));
				} catch (Exception e)
				{
					log.info("BLOBAPI_CONN_TIMEOUT set as default value due to error on config file! ");
					httpUrlConnection.setConnectTimeout(10000);  // 10 seconds
				}
			}

			if(BLOBHAPI_READ_TIMEOUT ==null || BLOBHAPI_READ_TIMEOUT.trim().isEmpty()) {
				httpUrlConnection.setReadTimeout(180000);    // 180 seconds
			}else {
				try {
					httpUrlConnection.setReadTimeout(Integer.valueOf(BLOBHAPI_READ_TIMEOUT));
				} catch (Exception e)
				{
					log.info("BLOBAPI_READ_TIMEOUT set as default value due to error on config file! ");
					httpUrlConnection.setReadTimeout(180000);    // 180 seconds
				}
			}

			return httpUrlConnection;
		} catch (Exception e) {
			throw new Exception("Fail to Open Http connection :: ", e);
		}
	}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74