daoadresseservice/util/HttpUtil.java

package dk.daoas.daoadresseservice.util;

// kopieret fra dk.thoerup.genericjavautils;

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLConnection;
import java.net.URLDecoder;
import java.net.URLEncoder;
import java.util.HashMap;
import java.util.Map;


public class HttpUtil {
        
        static public Map<String,String> decodeUri(String uri) {
                if (uri.indexOf('?') != -1) {
                        String parts[] = uri.split("\\?");
                        return decodeParams( parts[1] );
                } else {
                        return new HashMap<String,String>();
                }
                        
                
        }
        
        static public Map<String,String> decodeParams(String str) {
                Map<String,String> res = new HashMap<String,String>();
                
                        
                String parts[] = str.split("&");
                
                for (String part : parts) {
                        String pair[] = part.split("=");
                        String key = pair[0];
                        
                        String val = null;
                        if (pair.length == 2) {
                                
                                
                                try {
                                        val = URLDecoder.decode(pair[1], "ISO-8859-1");
                                } catch (UnsupportedEncodingException e) {
                                        val = pair[1]; // if decode fails try with the raw string
                                }
                                
                        }
                        
                        res.put(key, val);
                }
                
                return res;
        }
        
        static public String getLastPart(String url) {          
                String parts[] = url.split("/");
                String lastPart = parts[ parts.length - 1];
                                
                return lastPart;
        }
        
        static public String encodeParams(Map<String,String> params) {
                StringBuilder sb = new StringBuilder();
                
                boolean isFirst = true;                         
                for (String key :  params.keySet()) {                   
                        if (isFirst) {
                                isFirst = false;
                        } else {
                                sb.append("&");
                        }
                        
                        String val = params.get(key);
                        sb.append(key);
                        sb.append("=");
                        sb.append( encode(val) );
                        
                        
                }
                
                
                return sb.toString();
                
        }
        
        static String encode(String url) {
                if (url == null)
                        return "";
                
                try {
                        return URLEncoder.encode(url, "UTF-8");
                } catch (Exception e) {
                        return url;
                }
        }
        
        public static String getContentString(String  uri, int timeout) throws IOException {
                return getContentString(uri, timeout, "UTF-8");
        }
        
        public static String getContentString(String  uri, int timeout, String encoding) throws IOException {
                byte[] buf = getContent(uri, timeout);
                return new String(buf, encoding);
        }

        public static byte[] getContent(String uri, int timeout) throws IOException {
                URL url = new URL(uri);
                URLConnection connection = url.openConnection();
                
                connection.setConnectTimeout(timeout);
                InputStream is = connection.getInputStream();
                
                return readInputStream(is);
        }
        
        public static byte[] postContent(String uri, String data,  int timeout) throws IOException {
                URL url = new URL(uri);
                HttpURLConnection connection = (HttpURLConnection) url.openConnection();
                connection.setDoOutput(true);
                connection.setRequestMethod("POST");            
                connection.setConnectTimeout(timeout);
                
                OutputStream os = connection.getOutputStream();
                os.write( data.getBytes() );
                
                InputStream is = connection.getInputStream();
                
                return readInputStream(is);

        }
        
        static byte[] readInputStream(InputStream is) throws IOException{
                byte buffer[] = new byte[1024];
                //try /; //start buffer size - instead of default 32bytes
                try (ByteArrayOutputStream baos = new ByteArrayOutputStream(32768)) {
                        int count;
                        
                        while ( (count = is.read(buffer)) != -1) {
                                baos.write(buffer, 0, count);
                        }
                        is.close();
                        return baos.toByteArray();
                }       
        }
        
}
1	torben	2321	package dk.daoas.daoadresseservice.util;
2	torben	2301
3			// kopieret fra dk.thoerup.genericjavautils;
4
5			import java.io.ByteArrayOutputStream;
6			import java.io.IOException;
7			import java.io.InputStream;
8			import java.io.OutputStream;
9			import java.io.UnsupportedEncodingException;
10			import java.net.HttpURLConnection;
11			import java.net.URL;
12			import java.net.URLConnection;
13			import java.net.URLDecoder;
14			import java.net.URLEncoder;
15			import java.util.HashMap;
16			import java.util.Map;
17
18
19			public class HttpUtil {
20
21			static public Map<String,String> decodeUri(String uri) {
22			if (uri.indexOf('?') != -1) {
23			String parts[] = uri.split("\\?");
24			return decodeParams( parts[1] );
25			} else {
26			return new HashMap<String,String>();
27			}
28
29
30
31			}
32
33			static public Map<String,String> decodeParams(String str) {
34			Map<String,String> res = new HashMap<String,String>();
35
36
37			String parts[] = str.split("&");
38
39			for (String part : parts) {
40			String pair[] = part.split("=");
41			String key = pair[0];
42
43			String val = null;
44			if (pair.length == 2) {
45
46
47			try {
48			val = URLDecoder.decode(pair[1], "ISO-8859-1");
49			} catch (UnsupportedEncodingException e) {
50			val = pair[1]; // if decode fails try with the raw string
51			}
52
53			}
54
55			res.put(key, val);
56			}
57
58			return res;
59			}
60
61			static public String getLastPart(String url) {
62			String parts[] = url.split("/");
63			String lastPart = parts[ parts.length - 1];
64
65			return lastPart;
66			}
67
68			static public String encodeParams(Map<String,String> params) {
69			StringBuilder sb = new StringBuilder();
70
71			boolean isFirst = true;
72			for (String key : params.keySet()) {
73			if (isFirst) {
74			isFirst = false;
75			} else {
76			sb.append("&");
77			}
78
79			String val = params.get(key);
80			sb.append(key);
81			sb.append("=");
82			sb.append( encode(val) );
83
84
85			}
86
87
88			return sb.toString();
89
90			}
91
92			static String encode(String url) {
93			if (url == null)
94			return "";
95
96			try {
97			return URLEncoder.encode(url, "UTF-8");
98			} catch (Exception e) {
99			return url;
100			}
101			}
102
103			public static String getContentString(String uri, int timeout) throws IOException {
104			return getContentString(uri, timeout, "UTF-8");
105			}
106
107			public static String getContentString(String uri, int timeout, String encoding) throws IOException {
108			byte[] buf = getContent(uri, timeout);
109			return new String(buf, encoding);
110			}
111
112			public static byte[] getContent(String uri, int timeout) throws IOException {
113			URL url = new URL(uri);
114			URLConnection connection = url.openConnection();
115
116			connection.setConnectTimeout(timeout);
117			InputStream is = connection.getInputStream();
118
119			return readInputStream(is);
120			}
121
122			public static byte[] postContent(String uri, String data, int timeout) throws IOException {
123			URL url = new URL(uri);
124			HttpURLConnection connection = (HttpURLConnection) url.openConnection();
125			connection.setDoOutput(true);
126			connection.setRequestMethod("POST");
127			connection.setConnectTimeout(timeout);
128
129			OutputStream os = connection.getOutputStream();
130			os.write( data.getBytes() );
131
132			InputStream is = connection.getInputStream();
133
134			return readInputStream(is);
135
136			}
137
138			static byte[] readInputStream(InputStream is) throws IOException{
139			byte buffer[] = new byte[1024];
140	torben	2326	//try /; //start buffer size - instead of default 32bytes
141			try (ByteArrayOutputStream baos = new ByteArrayOutputStream(32768)) {
142	torben	2301	int count;
143	torben	2326
144	torben	2301	while ( (count = is.read(buffer)) != -1) {
145			baos.write(buffer, 0, count);
146			}
147	torben	2326	is.close();
148			return baos.toByteArray();
149			}
150	torben	2301	}
151
152			}