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];
                ByteArrayOutputStream baos = new ByteArrayOutputStream(32768); //start buffer size - instead of default 32bytes
                try {
                        int count;
                        while ( (count = is.read(buffer)) != -1) {
                                baos.write(buffer, 0, count);
                        }
                } finally {
                        try {
                                is.close();
                                baos.close();
                        } catch (Exception e) {} //never mind if close throws an exception
                }
                                
                return baos.toByteArray();              
        }
        
}
1	package dk.daoas.daoadresseservice.util;
2
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	ByteArrayOutputStream baos = new ByteArrayOutputStream(32768); //start buffer size - instead of default 32bytes
141	try {
142	int count;
143	while ( (count = is.read(buffer)) != -1) {
144	baos.write(buffer, 0, count);
145	}
146	} finally {
147	try {
148	is.close();
149	baos.close();
150	} catch (Exception e) {} //never mind if close throws an exception
151	}
152
153	return baos.toByteArray();
154	}
155
156	}