traininfoservice/banedk/TimetableServlet.java

package dk.thoerup.traininfoservice.banedk;

import java.io.ByteArrayOutputStream;
import java.io.IOException;

import java.util.logging.Level;
import java.util.logging.Logger;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.simpleframework.xml.Serializer;
import org.simpleframework.xml.core.Persister;

import dk.thoerup.android.traininfo.common.TimetableBean;
import dk.thoerup.circuitbreaker.CircuitBreakerException;
import dk.thoerup.traininfoservice.Statistics;

/**
 * Servlet implementation class TimetableServlet
 */

public class TimetableServlet extends HttpServlet {
        private static final long serialVersionUID = 1L;
       
        
        Logger logger = Logger.getLogger( TimetableServlet.class.getName() );
        
        TimetableFetcher fetcher;
        
        
        @Override
        public void init() throws ServletException {
                super.init();
                
                boolean useAzureSite =  Boolean.parseBoolean( getServletContext().getInitParameter("useazuresite") );
                int cacheTimeout =  Integer.parseInt( getServletContext().getInitParameter("cache_timeout") );
                int replyTimeout =  Integer.parseInt( getServletContext().getInitParameter("reply_timeout") );
                logger.info( "TimetableServlet, use azure site=" + useAzureSite + ", cache=" + cacheTimeout);
                fetcher = new TimetableFetcher(useAzureSite,cacheTimeout,replyTimeout);
        }
        
        @Override
        protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
                if (request.getParameter("train") == null) {
                        response.sendError(400, "not enough parameters (train)");
                        return;
                }
                if (request.getParameter("type") == null) {
                        response.sendError(400, "not enough parameters (type)");
                        return;
                }
                Statistics.getInstance().incrementTimetableLookups();
                
                String train = request.getParameter("train").trim();
                String type = request.getParameter("type").trim();
                                
                try
                {
                        TimetableBean timetable = fetcher.cachedLookupTimetable(train, type);
                
                        String responseXML = formatTimetable(timetable);
                
                        response.setContentType("text/xml");
                        response.getWriter().print(responseXML);
                } catch (java.io.IOException ioe) {
                        logger.warning("(timetable) Read failed, type=" + type + ", train="+train + ". " + ioe.getMessage());
                        Statistics.getInstance().incrementTimetableErrors();
                        response.sendError(500, "Backend timed out");
                } catch (CircuitBreakerException cbe) {
                        logger.warning("Circuitbreaker - failing fast");
                        Statistics.getInstance().incrementTimetableErrors();
                        response.sendError(500);
                }catch (Exception e) {
                        logger.log(Level.WARNING, "failure looking up timetable: type=" + type + ",train=" +train, e);
                        Statistics.getInstance().incrementTimetableErrors();
                        response.sendError(500);
                }
                
        }
        
        String formatTimetable(TimetableBean timetable) throws ServletException {
                Serializer serializer = new Persister();

                ByteArrayOutputStream out = new ByteArrayOutputStream();

                try {
                        serializer.write(timetable, out);
                } catch (Exception e) {
                        throw new ServletException(e);
                }
                
                return out.toString();
        }

}
1	package dk.thoerup.traininfoservice.banedk;
2
3	import java.io.ByteArrayOutputStream;
4	import java.io.IOException;
5
6	import java.util.logging.Level;
7	import java.util.logging.Logger;
8
9	import javax.servlet.ServletException;
10	import javax.servlet.http.HttpServlet;
11	import javax.servlet.http.HttpServletRequest;
12	import javax.servlet.http.HttpServletResponse;
13
14	import org.simpleframework.xml.Serializer;
15	import org.simpleframework.xml.core.Persister;
16
17	import dk.thoerup.android.traininfo.common.TimetableBean;
18	import dk.thoerup.circuitbreaker.CircuitBreakerException;
19	import dk.thoerup.traininfoservice.Statistics;
20
21	/**
22	* Servlet implementation class TimetableServlet
23	*/
24
25	public class TimetableServlet extends HttpServlet {
26	private static final long serialVersionUID = 1L;
27
28
29	Logger logger = Logger.getLogger( TimetableServlet.class.getName() );
30
31	TimetableFetcher fetcher;
32
33
34	@Override
35	public void init() throws ServletException {
36	super.init();
37
38	boolean useAzureSite = Boolean.parseBoolean( getServletContext().getInitParameter("useazuresite") );
39	int cacheTimeout = Integer.parseInt( getServletContext().getInitParameter("cache_timeout") );
40	int replyTimeout = Integer.parseInt( getServletContext().getInitParameter("reply_timeout") );
41	logger.info( "TimetableServlet, use azure site=" + useAzureSite + ", cache=" + cacheTimeout);
42	fetcher = new TimetableFetcher(useAzureSite,cacheTimeout,replyTimeout);
43	}
44
45	@Override
46	protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
47	if (request.getParameter("train") == null) {
48	response.sendError(400, "not enough parameters (train)");
49	return;
50	}
51	if (request.getParameter("type") == null) {
52	response.sendError(400, "not enough parameters (type)");
53	return;
54	}
55	Statistics.getInstance().incrementTimetableLookups();
56
57	String train = request.getParameter("train").trim();
58	String type = request.getParameter("type").trim();
59
60	try
61	{
62	TimetableBean timetable = fetcher.cachedLookupTimetable(train, type);
63
64	String responseXML = formatTimetable(timetable);
65
66	response.setContentType("text/xml");
67	response.getWriter().print(responseXML);
68	} catch (java.io.IOException ioe) {
69	logger.warning("(timetable) Read failed, type=" + type + ", train="+train + ". " + ioe.getMessage());
70	Statistics.getInstance().incrementTimetableErrors();
71	response.sendError(500, "Backend timed out");
72	} catch (CircuitBreakerException cbe) {
73	logger.warning("Circuitbreaker - failing fast");
74	Statistics.getInstance().incrementTimetableErrors();
75	response.sendError(500);
76	}catch (Exception e) {
77	logger.log(Level.WARNING, "failure looking up timetable: type=" + type + ",train=" +train, e);
78	Statistics.getInstance().incrementTimetableErrors();
79	response.sendError(500);
80	}
81
82	}
83
84	String formatTimetable(TimetableBean timetable) throws ServletException {
85	Serializer serializer = new Persister();
86
87	ByteArrayOutputStream out = new ByteArrayOutputStream();
88
89	try {
90	serializer.write(timetable, out);
91	} catch (Exception e) {
92	throw new ServletException(e);
93	}
94
95	return out.toString();
96	}
97
98	}