view flys-client/src/main/java/de/intevation/flys/client/server/MapInfoServiceImpl.java @ 5779:ebec12def170

Datacage: Add a pool of builders to make it multi threadable. XML DOM is not thread safe. Therefore the old implementation only allowed one thread to use the builder at a time. As the complexity of the configuration has increased over time this has become a bottleneck of the whole application because it took quiet some time to build a result. Furthermore the builder code path is visited very frequent. So many concurrent requests were piled up resulting in long waits for the users. To mitigate this problem a round robin pool of builders is used now. Each of the pooled builders has an independent copy of the XML template and can be run in parallel. The number of builders is determined by the system property 'flys.datacage.pool.size'. It defaults to 4.
author Sascha L. Teichmann <teichmann@intevation.de>
date Sun, 21 Apr 2013 12:48:09 +0200
parents 5014a84c0c7d
children
line wrap: on
line source
package de.intevation.flys.client.server;

import com.google.gwt.core.client.GWT;
import com.google.gwt.user.server.rpc.RemoteServiceServlet;

import de.intevation.artifacts.common.utils.XMLUtils;
import de.intevation.artifacts.common.utils.XMLUtils.ElementCreator;
import de.intevation.artifacts.httpclient.exceptions.ConnectionException;
import de.intevation.artifacts.httpclient.http.HttpClient;
import de.intevation.artifacts.httpclient.http.HttpClientImpl;
import de.intevation.flys.client.client.services.MapInfoService;
import de.intevation.flys.client.shared.exceptions.ServerException;
import de.intevation.flys.client.shared.model.BBox;
import de.intevation.flys.client.shared.model.MapInfo;

import org.apache.log4j.Logger;
import org.w3c.dom.Document;
import org.w3c.dom.Element;


/**
 * This service fetches a document that contains meta information for a specific
 * chart.
 *
 * @author <a href="mailto:ingo.weinzierl@intevation.de">Ingo Weinzierl</a>
 */
public class MapInfoServiceImpl
extends      RemoteServiceServlet
implements   MapInfoService
{
    private static final Logger logger =
        Logger.getLogger(MapInfoServiceImpl.class);


    public static final String XPATH_RIVER =
        "/mapinfo/river/@name";

    public static final String XPATH_SRID =
        "/mapinfo/river/srid/@value";

    public static final String XPATH_BBOX  =
        "/mapinfo/river/bbox/@value";

    public static final String XPATH_RIVER_WMS =
        "/mapinfo/river/river-wms/@url";

    public static final String XPATH_RIVER_LAYERS =
        "/mapinfo/river/river-wms/@layers";

    public static final String XPATH_WMS_URL =
        "/mapinfo/river/background-wms/@url";

    public static final String XPATH_WMS_LAYERS =
        "/mapinfo/river/background-wms/@layers";

    public static final String ERROR_NO_MAPINFO_FOUND =
        "mapinfo_service_no_result";


    @Override
    public MapInfo getMapInfo(String locale, String river)
    throws ServerException
    {
        logger.info("MapInfoServiceImpl.getMapInfo");

        String url  = getServletContext().getInitParameter("server-url");

        Document request = getRequestDocument(river, "rivermap");

        HttpClient client = new HttpClientImpl(url, locale);

        try {
            logger.debug("MapInfoServiceImpl.callService");
            Document result = client.callService(url, "mapinfo", request);

            if (result == null) {
                logger.warn("MapInfo service returned no result.");
                throw new ServerException(ERROR_NO_MAPINFO_FOUND);
            }

            return getMapInfo(result);
        }
        catch (ConnectionException ce) {
            logger.error(ce, ce);
        }

        throw new ServerException(ERROR_NO_MAPINFO_FOUND);
    }


    public static Document getRequestDocument(String rivername, String maptypeStr) {
        logger.debug("MapInfoServiceImpl.getRequestDocument");

        Document  request = XMLUtils.newDocument();
        ElementCreator cr = new ElementCreator(request, null, null);

        Element root    = cr.create("mapinfo");
        Element river   = cr.create("river");
        Element maptype = cr.create("maptype");

        river.setTextContent(rivername);
        maptype.setTextContent(maptypeStr);

        request.appendChild(root);
        root.appendChild(river);
        root.appendChild(maptype);

        return request;
    }


    public static MapInfo getMapInfo(Document result) {
        logger.debug("MapInfoServiceImpl.getMapInfo");

        String river   = XMLUtils.xpathString(result, XPATH_RIVER, null);
        String sridStr = XMLUtils.xpathString(result, XPATH_SRID, null);
        String bboxS   = XMLUtils.xpathString(result, XPATH_BBOX,  null);
        BBox   bbox    = BBox.getBBoxFromString(bboxS);

        String riverWMS    = XMLUtils.xpathString(result, XPATH_RIVER_WMS, null);
        String riverLayers = XMLUtils.xpathString(result, XPATH_RIVER_LAYERS, null);
        String wmsURL      = XMLUtils.xpathString(result, XPATH_WMS_URL, null);
        String wmsLayers   = XMLUtils.xpathString(result, XPATH_WMS_LAYERS, null);

        int srid = 4326;

        try {
            srid = Integer.parseInt(sridStr);
        }
        catch (NumberFormatException nfe) {
            GWT.log("Could not parse SRID String: " + sridStr);
        }

        return new MapInfo(
                river, srid, bbox, riverWMS, riverLayers, wmsURL, wmsLayers);
    }
}
// vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :

http://dive4elements.wald.intevation.org