daoas/daoadresseservice/GeocodeHelper.java

package dk.daoas.daoadresseservice;

import java.io.IOException;
import java.net.URLEncoder;
import java.util.List;

import com.google.code.geocoder.Geocoder;
import com.google.code.geocoder.GeocoderRequestBuilder;
import com.google.code.geocoder.model.GeocodeResponse;
import com.google.code.geocoder.model.GeocoderAddressComponent;
import com.google.code.geocoder.model.GeocoderRequest;
import com.google.code.geocoder.model.GeocoderResult;
import com.google.code.geocoder.model.GeocoderStatus;
import com.google.gson.Gson;

import dk.daoas.daoadresseservice.admin.ServiceConfig;
import dk.daoas.daoadresseservice.beans.OSMAddress;
import dk.daoas.daoadresseservice.util.HttpUtil;
import dk.thoerup.circuitbreaker.CircuitBreaker;
import dk.thoerup.circuitbreaker.CircuitBreakerManager;
import dk.thoerup.circuitbreaker.CircuitInvocation;

public class GeocodeHelper {
                

        public static void main(String[] args) throws IOException {
                ServiceConfig conf = new ServiceConfig();
                conf.osmTimeout = 1000;
                
                int post = 8700;
                String vej = "Enebarvej";
                
                long start1 = System.currentTimeMillis();
                System.out.println( "Google:" +  GeocodeHelper.googleHelper(conf, post, vej) );         
                long stop1 = System.currentTimeMillis();
                
                long start2 = System.currentTimeMillis();
                System.out.println( "OSM:" +  GeocodeHelper.openstreetmapHelper(conf, post, vej) );
                long stop2 = System.currentTimeMillis();
                
                System.out.println("Google: " + (stop1-start1));
                System.out.println("OSM: " + (stop2-start2));
        }
        
        public static String openstreetmapHelper(ServiceConfig conf, int postnr, String vejnavn) {
                
                try {

                        OSMInvocation wrapper = new OSMInvocation( conf, postnr, vejnavn );
                        CircuitBreaker breaker = CircuitBreakerManager.getManager().getCircuitBreaker("osm");

                        return (String) breaker.invoke(wrapper);

                        
                } catch (Exception e) {
                        System.out.println( "OSMError: " + e.getClass().getName() +" / "+ e.getMessage() );
                }                                                               
                return null;
        }
        
        
        public static String googleHelper(ServiceConfig conf, int postnr, String vejnavn) {
                try {
                        GoogleInvocation wrapper = new GoogleInvocation( conf, postnr, vejnavn );
                        CircuitBreaker breaker = CircuitBreakerManager.getManager().getCircuitBreaker("google");

                        return (String) breaker.invoke(wrapper);
                        
                } catch (Exception e) {
                        System.out.println( "GoogleError: " + e.getClass().getName() +" / "+ e.getMessage() );
                }
                return null;    
        }
        

        public static class OSMInvocation implements CircuitInvocation {
                int postnr;
                String vejnavn;
                ServiceConfig conf;
                
                public OSMInvocation(ServiceConfig conf, int postnr, String vejnavn) {
                        this.conf = conf;
                        this.postnr= postnr;
                        this.vejnavn = vejnavn;                 
                }
                
                @Override
                public String proceed() throws Exception {
                        //TimingHelper timer = new TimingHelper();
                        String encVej = URLEncoder.encode(vejnavn, "UTF-8");
                        
                        String url = "http://nominatim.openstreetmap.org/search?country=DK&street=" + encVej + "&postalcode=" + postnr + "&format=json&addressdetails=1";
                        //String url = "http://nominatim.openstreetmap.org/search?country=DK&street=" + encVej + "&format=json&addressdetails=1";
                        //System.out.println (url);
                        
                        String json = HttpUtil.getContentString(url, conf.osmTimeout);
                        //System.out.println(json);
                        
                        Gson gson = new Gson();
                        OSMAddress adrList[] = gson.fromJson(json, OSMAddress[].class);
                        
                        //timer.printElapsed("OSM elapsed");
                        
                        //System.out.println("Count: " + adrList.length);
                        if (adrList.length != 1)
                                return null;
                                
                        if (adrList[0].address != null) {
                                return adrList[0].address.road;
                        }

                        return null;
                }
        }
        
        
        public static class GoogleInvocation implements CircuitInvocation {
                ServiceConfig conf;
                int postnr;
                String vejnavn;
                
                public GoogleInvocation(ServiceConfig conf, int postnr, String vejnavn) {
                        this.conf = conf;
                        this.postnr= postnr;
                        this.vejnavn = vejnavn;
                        
                }

                @Override
                public String proceed() throws Exception {
                        
                        final Geocoder geocoder;
                        if ( conf.googleApiKey != null ) {
                                geocoder = new Geocoder(conf.googleApiUser, conf.googleApiKey); //Throws InvalidKeyException
                        } else {
                                geocoder = new Geocoder();
                        }
                        //TimingHelper timer = new TimingHelper();
                        
                        String search = vejnavn + ", " + postnr + ", Denmark";
                        GeocoderRequest geocoderRequest = new GeocoderRequestBuilder().setAddress(search).setLanguage("en").getGeocoderRequest();
                        GeocodeResponse geocoderResponse = geocoder.geocode(geocoderRequest);
                                        
                        //timer.printElapsed("Google elapsed");
                        
                        //System.out.println( "Status: >" + geocoderResponse.getStatus() + "<");
                        if (  geocoderResponse.getStatus() != GeocoderStatus.OK) {                              
                                
                                if (geocoderResponse.getStatus() == GeocoderStatus.ZERO_RESULTS) {
                                        return null; 
                                } else {
                                        System.out.println("Google responded with " + geocoderResponse.getStatus() );
                                        //Hvis det er alvorlige fejl skal vi afbryde med exception og trigger circuitbreakeren
                                        throw new Exception("Google responded with " + geocoderResponse.getStatus() );
                                }
                                
                        }
                        
                        List<GeocoderResult> resList = geocoderResponse.getResults();
                        //System.out.println( "Count: " + resList.size() );
                        
                        if (resList.size() != 1) {
                                return null;
                        }
                        GeocoderResult res = resList.get(0);
                        
                        List<GeocoderAddressComponent> compList = res.getAddressComponents();
                        for (GeocoderAddressComponent c : compList) {
                                //System.out.println(c);
                                if (c.getTypes().contains("route")) {
                                        return c.getLongName();
                                }
                        }
                        return null;
                }
                
        }

}
1	torben	2298	package dk.daoas.daoadresseservice;
2
3			import java.io.IOException;
4	torben	2301	import java.net.URLEncoder;
5	torben	2298	import java.util.List;
6
7			import com.google.code.geocoder.Geocoder;
8			import com.google.code.geocoder.GeocoderRequestBuilder;
9			import com.google.code.geocoder.model.GeocodeResponse;
10			import com.google.code.geocoder.model.GeocoderAddressComponent;
11			import com.google.code.geocoder.model.GeocoderRequest;
12			import com.google.code.geocoder.model.GeocoderResult;
13			import com.google.code.geocoder.model.GeocoderStatus;
14	torben	2301	import com.google.gson.Gson;
15	torben	2298
16	torben	2349	import dk.daoas.daoadresseservice.admin.ServiceConfig;
17	torben	2301	import dk.daoas.daoadresseservice.beans.OSMAddress;
18	torben	2321	import dk.daoas.daoadresseservice.util.HttpUtil;
19	torben	2352	import dk.thoerup.circuitbreaker.CircuitBreaker;
20			import dk.thoerup.circuitbreaker.CircuitBreakerManager;
21			import dk.thoerup.circuitbreaker.CircuitInvocation;
22	torben	2301
23	torben	2298	public class GeocodeHelper {
24	torben	2349
25	torben	2298
26
27	torben	2307	public static void main(String[] args) throws IOException {
28	torben	2349	ServiceConfig conf = new ServiceConfig();
29	torben	2367	conf.osmTimeout = 1000;
30	torben	2349
31	torben	2307	int post = 8700;
32			String vej = "Enebarvej";
33
34			long start1 = System.currentTimeMillis();
35	torben	2349	System.out.println( "Google:" + GeocodeHelper.googleHelper(conf, post, vej) );
36	torben	2307	long stop1 = System.currentTimeMillis();
37
38			long start2 = System.currentTimeMillis();
39	torben	2367	System.out.println( "OSM:" + GeocodeHelper.openstreetmapHelper(conf, post, vej) );
40	torben	2307	long stop2 = System.currentTimeMillis();
41
42			System.out.println("Google: " + (stop1-start1));
43			System.out.println("OSM: " + (stop2-start2));
44	torben	2298	}
45
46	torben	2367	public static String openstreetmapHelper(ServiceConfig conf, int postnr, String vejnavn) {
47	torben	2301
48			try {
49	torben	2352
50	torben	2367	OSMInvocation wrapper = new OSMInvocation( conf, postnr, vejnavn );
51	torben	2352	CircuitBreaker breaker = CircuitBreakerManager.getManager().getCircuitBreaker("osm");
52
53			return (String) breaker.invoke(wrapper);
54
55
56			} catch (Exception e) {
57	torben	2353	System.out.println( "OSMError: " + e.getClass().getName() +" / "+ e.getMessage() );
58	torben	2352	}
59			return null;
60			}
61
62
63
64			public static String googleHelper(ServiceConfig conf, int postnr, String vejnavn) {
65			try {
66			GoogleInvocation wrapper = new GoogleInvocation( conf, postnr, vejnavn );
67			CircuitBreaker breaker = CircuitBreakerManager.getManager().getCircuitBreaker("google");
68
69			return (String) breaker.invoke(wrapper);
70
71			} catch (Exception e) {
72	torben	2353	System.out.println( "GoogleError: " + e.getClass().getName() +" / "+ e.getMessage() );
73	torben	2352	}
74			return null;
75			}
76
77
78			public static class OSMInvocation implements CircuitInvocation {
79			int postnr;
80			String vejnavn;
81	torben	2367	ServiceConfig conf;
82	torben	2352
83	torben	2367	public OSMInvocation(ServiceConfig conf, int postnr, String vejnavn) {
84			this.conf = conf;
85	torben	2352	this.postnr= postnr;
86			this.vejnavn = vejnavn;
87			}
88
89			@Override
90			public String proceed() throws Exception {
91	torben	2361	//TimingHelper timer = new TimingHelper();
92	torben	2301	String encVej = URLEncoder.encode(vejnavn, "UTF-8");
93
94			String url = "http://nominatim.openstreetmap.org/search?country=DK&street=" + encVej + "&postalcode=" + postnr + "&format=json&addressdetails=1";
95			//String url = "http://nominatim.openstreetmap.org/search?country=DK&street=" + encVej + "&format=json&addressdetails=1";
96			//System.out.println (url);
97
98	torben	2367	String json = HttpUtil.getContentString(url, conf.osmTimeout);
99	torben	2301	//System.out.println(json);
100
101			Gson gson = new Gson();
102			OSMAddress adrList[] = gson.fromJson(json, OSMAddress[].class);
103
104	torben	2361	//timer.printElapsed("OSM elapsed");
105
106	torben	2301	//System.out.println("Count: " + adrList.length);
107			if (adrList.length != 1)
108			return null;
109
110			if (adrList[0].address != null) {
111			return adrList[0].address.road;
112			}
113
114	torben	2352	return null;
115			}
116	torben	2301	}
117
118
119	torben	2352	public static class GoogleInvocation implements CircuitInvocation {
120			ServiceConfig conf;
121			int postnr;
122			String vejnavn;
123
124			public GoogleInvocation(ServiceConfig conf, int postnr, String vejnavn) {
125			this.conf = conf;
126			this.postnr= postnr;
127			this.vejnavn = vejnavn;
128
129			}
130
131			@Override
132			public String proceed() throws Exception {
133
134	torben	2349	final Geocoder geocoder;
135			if ( conf.googleApiKey != null ) {
136			geocoder = new Geocoder(conf.googleApiUser, conf.googleApiKey); //Throws InvalidKeyException
137			} else {
138			geocoder = new Geocoder();
139			}
140	torben	2361	//TimingHelper timer = new TimingHelper();
141	torben	2298
142			String search = vejnavn + ", " + postnr + ", Denmark";
143			GeocoderRequest geocoderRequest = new GeocoderRequestBuilder().setAddress(search).setLanguage("en").getGeocoderRequest();
144			GeocodeResponse geocoderResponse = geocoder.geocode(geocoderRequest);
145	torben	2352
146	torben	2361	//timer.printElapsed("Google elapsed");
147	torben	2298
148			//System.out.println( "Status: >" + geocoderResponse.getStatus() + "<");
149	torben	2360	if ( geocoderResponse.getStatus() != GeocoderStatus.OK) {
150	torben	2352
151			if (geocoderResponse.getStatus() == GeocoderStatus.ZERO_RESULTS) {
152			return null;
153			} else {
154	torben	2360	System.out.println("Google responded with " + geocoderResponse.getStatus() );
155	torben	2352	//Hvis det er alvorlige fejl skal vi afbryde med exception og trigger circuitbreakeren
156			throw new Exception("Google responded with " + geocoderResponse.getStatus() );
157			}
158
159	torben	2298	}
160
161			List<GeocoderResult> resList = geocoderResponse.getResults();
162			//System.out.println( "Count: " + resList.size() );
163
164			if (resList.size() != 1) {
165			return null;
166			}
167			GeocoderResult res = resList.get(0);
168
169			List<GeocoderAddressComponent> compList = res.getAddressComponents();
170			for (GeocoderAddressComponent c : compList) {
171			//System.out.println(c);
172			if (c.getTypes().contains("route")) {
173			return c.getLongName();
174			}
175			}
176	torben	2352	return null;
177	torben	2298	}
178
179			}
180
181			}