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