servlethttptransport.java

jxta_src_2.41b jxta 2.41b 最新版源码 from www.jxta.org

/*
 *
 * $Id: ServletHttpTransport.java,v 1.63 2006/03/06 20:43:32 bondolo Exp $
 *
 * Copyright (c) 2001 Sun Microsystems, Inc.  All rights reserved.
 *
 * 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 the
 *       Sun Microsystems, Inc. for Project JXTA."
 *    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.
 *
 * ====================================================================
 *
 * 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 org.apache.log4j.Logger;
import org.apache.log4j.Level;

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.*;
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.*;
import net.jxta.impl.endpoint.IPUtils;
import net.jxta.impl.protocol.HTTPAdv;

import net.jxta.impl.meter.*;

/**
 * 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 {
    
    /**
     *    log4j 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 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 prefered 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;
        
        // 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 = (ConfigParams) 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");
        }
        
        Advertisement paramsAdv = AdvertisementFactory.newAdvertisement((XMLElement) param);
        
        if (!(paramsAdv instanceof HTTPAdv)) {
            throw new IllegalArgumentException("Provided advertisement was not a " + HTTPAdv.getAdvertisementType());
        }
        
        HTTPAdv httpAdv = (HTTPAdv) paramsAdv;