servlethttptransport.java

来自「JXTA&#8482 is a set of open, generalize」· Java 代码 · 共 474 行 · 第 1/2 页

/*
 * Copyright (c) 2001-2007 Sun Microsystems, Inc.  All rights reserved.
 *  
 *  The Sun Project JXTA(TM) Software License
 *  
 *  Redistribution and use in source and binary forms, with or without 
 *  modification, are permitted provided that the following conditions are met:
 *  
 *  1. Redistributions of source code must retain the above copyright notice,
 *     this list of conditions and the following disclaimer.
 *  
 *  2. Redistributions in binary form must reproduce the above copyright notice, 
 *     this list of conditions and the following disclaimer in the documentation 
 *     and/or other materials provided with the distribution.
 *  
 *  3. The end-user documentation included with the redistribution, if any, must 
 *     include the following acknowledgment: "This product includes software 
 *     developed by Sun Microsystems, Inc. for JXTA(TM) technology." 
 *     Alternately, this acknowledgment may appear in the software itself, if 
 *     and wherever such third-party acknowledgments normally appear.
 *  
 *  4. The names "Sun", "Sun Microsystems, Inc.", "JXTA" and "Project JXTA" must 
 *     not be used to endorse or promote products derived from this software 
 *     without prior written permission. For written permission, please contact 
 *     Project JXTA at http://www.jxta.org.
 *  
 *  5. Products derived from this software may not be called "JXTA", nor may 
 *     "JXTA" appear in their name, without prior written permission of Sun.
 *  
 *  THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED WARRANTIES,
 *  INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND 
 *  FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL SUN 
 *  MICROSYSTEMS OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, 
 *  INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT 
 *  LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, 
 *  OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF 
 *  LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING 
 *  NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, 
 *  EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 *  
 *  JXTA is a registered trademark of Sun Microsystems, Inc. in the United 
 *  States and other countries.
 *  
 *  Please see the license information page at :
 *  <http://www.jxta.org/project/www/license.html> for instructions on use of 
 *  the license in source files.
 *  
 *  ====================================================================
 *  
 *  This software consists of voluntary contributions made by many individuals 
 *  on behalf of Project JXTA. For more information on Project JXTA, please see 
 *  http://www.jxta.org.
 *  
 *  This license is based on the BSD license adopted by the Apache Foundation. 
 */
package net.jxta.impl.endpoint.servlethttp;

import java.net.InetAddress;
import java.util.ArrayList;
import java.util.Comparator;
import java.util.Collections;
import java.util.Enumeration;
import java.util.Iterator;
import java.util.List;

import java.net.UnknownHostException;
import java.util.concurrent.Executor;

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

import net.jxta.logging.Logging;

import net.jxta.document.Advertisement;
import net.jxta.document.AdvertisementFactory;
import net.jxta.document.Attribute;
import net.jxta.document.XMLElement;
import net.jxta.endpoint.EndpointAddress;
import net.jxta.endpoint.EndpointService;
import net.jxta.id.ID;
import net.jxta.meter.MonitorResources;
import net.jxta.peergroup.PeerGroup;
import net.jxta.protocol.ConfigParams;
import net.jxta.protocol.ModuleImplAdvertisement;
import net.jxta.protocol.TransportAdvertisement;
import net.jxta.platform.Module;

import net.jxta.exception.PeerGroupException;

import net.jxta.impl.endpoint.transportMeter.TransportBindingMeter;
import net.jxta.impl.endpoint.transportMeter.TransportMeter;
import net.jxta.impl.endpoint.transportMeter.TransportMeterBuildSettings;
import net.jxta.impl.endpoint.transportMeter.TransportServiceMonitor;
import net.jxta.impl.endpoint.IPUtils;
import net.jxta.impl.protocol.HTTPAdv;

import net.jxta.impl.meter.*;
import net.jxta.impl.peergroup.StdPeerGroup;

/**
 * A JXTA Message Transport
 *
 * <p/>This class is really a facade for the following:<ul>
 * <li>An HTTP client message sender</li>
 * <li>An HTTP-server-based message receiver</li>
 * </ul>
 */
public final class ServletHttpTransport implements Module {

    /**
     * Logger
     */
    private final static transient Logger LOG = Logger.getLogger(ServletHttpTransport.class.getName());

    /**
     * The name of the protocol
     */
    private final static String DEFAULT_HTTP_PROTOCOL_NAME = "http";

    String HTTP_PROTOCOL_NAME = DEFAULT_HTTP_PROTOCOL_NAME;

    /**
     * PeerGroup we are working for
     */
    PeerGroup group;
    ID assignedID;
    ModuleImplAdvertisement implAdvertisement;
    
    /**
     * The executor used by HttpClientMessenger
     */
    Executor executor;

    /**
     * The endpoint we attach to.
     */
    private EndpointService endpoint = null;

    /**
     * If {@code true} then we are configured to act as an HTTP client. This
     * means we will poll for messages.
     */
    private boolean configClient = false;

    /**
     * If {@code true} then we are configured to act as an HTTP server. This
     * means we will accept connections from polling clients.
     */
    private boolean configServer = false;

    /**
     * The HttpMessageSender instance
     */
    private HttpMessageSender sender = null;

    /**
     * The HttpMessageReceiver instance
     */
    private HttpMessageReceiver receiver = null;

    /**
     * The TransportMeter for this httpTransport
     */
    private TransportMeter transportMeter;

    /**
     * The TransportBindingMeter for unknown connections (pings/errors)
     */
    private TransportBindingMeter unknownTransportBindingMeter;

    /**
     * The InetAddress of the network interface we are bound to otherwise the
     * ALL/ANY address.
     */
    InetAddress usingInterface = null;

    /**
     * Port number to which we are bound.
     */
    int usingPort = 0;

    /**
     * The addresses which we will advertise and by which we may be reached.
     */
    private List<EndpointAddress> publicAddresses = null;

    /**
     * Our preferred return address which we will use as the "source" for
     * messages we send.
     */
    private EndpointAddress publicAddress;

    /**
     * {@inheritDoc}
     */
    public synchronized void init(PeerGroup group, ID assignedID, Advertisement impl) throws PeerGroupException {
        this.group = group;
        this.assignedID = assignedID;
        implAdvertisement = (ModuleImplAdvertisement) impl;
        
        this.executor = ((StdPeerGroup) group).getExecutor();

        // Get out invariable parameters from the implAdv
        XMLElement param = (XMLElement) implAdvertisement.getParam();

        if (param != null) {
            Enumeration list = param.getChildren("Proto");

            if (list.hasMoreElements()) {
                XMLElement pname = (XMLElement) list.nextElement();
                String configProtoName = pname.getTextValue();
                if (null != configProtoName) {
                    HTTP_PROTOCOL_NAME = configProtoName.trim();
                }
            }
        }

        ConfigParams peerAdv = group.getConfigAdvertisement();

        param = (XMLElement) peerAdv.getServiceParam(assignedID);

        Enumeration httpChilds = param.getChildren(TransportAdvertisement.getAdvertisementType());

        // get the TransportAdv
        if (httpChilds.hasMoreElements()) {
            param = (XMLElement) httpChilds.nextElement();
            Attribute typeAttr = param.getAttribute("type");

            if (!HTTPAdv.getAdvertisementType().equals(typeAttr.getValue())) {
                throw new IllegalArgumentException("Transport adv is not an http adv");
            }

            if (httpChilds.hasMoreElements()) {
                throw new IllegalArgumentException("Configuration contained multiple http advertisements");
            }
        } else {
            throw new IllegalArgumentException("Configuration did not contain http advertisement");