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();
                
                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(post, vej) );
                long stop2 = System.currentTimeMillis();
                
                System.out.println("Google: " + (stop1-start1));
                System.out.println("OSM: " + (stop2-start2));
        }
        
        public static String openstreetmapHelper(int postnr, String vejnavn) {
                
                try {

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

                        return (String) breaker.invoke(wrapper);

                        
                } catch (Exception e) {
                        System.out.println( "Error: " + 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.getMessage() );
                }
                return null;    
        }
        

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