jxta-src-2.3.5.zip_java p2p_jxta_jxta 2.5

/* * 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 materialsset 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 THE APACHE SOFTWARE FOUNDATION 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. * * $Id: Configurator.java,v 1.198 2005/08/31 19:45:41 gonzo Exp $ */ package net.jxta.ext.config; import net.jxta.ext.config.optimizers.RelayOptimizer; import net.jxta.ext.http.Dispatcher; import net.jxta.ext.http.Message; import java.io.Externalizable; import java.io.File; import java.io.FileNotFoundException; import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.FileReader; import java.io.InputStreamReader; import java.io.Reader; import java.io.IOException; import java.io.ObjectInput; import java.io.ObjectOutput; import java.io.StreamTokenizer; import java.io.StringReader; import java.net.MalformedURLException; import java.net.URI; import java.net.URISyntaxException; import java.net.URL; import java.security.cert.Certificate; import java.security.cert.X509Certificate; import java.text.MessageFormat; import java.util.Arrays; import java.util.ArrayList; import java.util.Collections; import java.util.Enumeration; import java.util.HashMap; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.Map.Entry; import java.util.NoSuchElementException; import net.jxta.document.AdvertisementFactory; import net.jxta.document.Attributable; import net.jxta.document.Attribute; import net.jxta.document.Element; import net.jxta.document.MimeMediaType; import net.jxta.document.StructuredDocument; import net.jxta.document.StructuredDocumentFactory; import net.jxta.document.StructuredDocumentUtils; import net.jxta.document.StructuredTextDocument; import net.jxta.document.TextElement; import net.jxta.document.XMLDocument; import net.jxta.exception.ConfiguratorException; import net.jxta.id.ID; import net.jxta.id.IDFactory; import net.jxta.impl.endpoint.IPUtils; import net.jxta.impl.membership.pse.PSEUtils; import net.jxta.impl.peergroup.PlatformConfigurator; import net.jxta.impl.protocol.HTTPAdv; import net.jxta.impl.protocol.PlatformConfig; import net.jxta.impl.protocol.PSEConfigAdv; import net.jxta.impl.protocol.RdvConfigAdv; import net.jxta.impl.protocol.RelayConfigAdv; import net.jxta.impl.protocol.TCPAdv; import net.jxta.protocol.ConfigParams; import net.jxta.peer.PeerID; import net.jxta.peergroup.PeerGroupFactory; import net.jxta.protocol.TransportAdvertisement; import org.apache.log4j.Level; import org.apache.log4j.Logger; /** * A JXTA configurator.<br> * <br> * <code>Configurator<code> serves primarily as a JXTA property sheet and * implements very little attribute association logic beyond that of what * is required to perform integrity validation and address expansion. To * the latter, All addresses are of the form URI. Addresses that do not * specify a scheme will default accordingly. Further, <code>RendezVous</code> * and <code>Relay</code> addresses that do not specify a host wil be replaced * with the corresponding boostrap results. If a scheme is specified only * bootstrap results with matching schemes will be maintained. All other * addresses that do not specify a host will, in turn, be replaced with the * local host. All fields have backing defaults enabling one to seed a * configuration with a partial yet valid resource file.<br> * <br> * Configurator will parse an existing {@link Env#PLATFORM PlatformConfig} if * one exists in the specified {@link Env#JXTA_HOME JXTA home} directory. If * this is not the case, a {@link Env#PROFILE Configuration} file will be * parsed it one such file exists. Lastly, if neither of the above are * resolvable the {@link ResourceConfiguration.Profile#Default Default profile} * will be used to seed the newly created instance.<br> * <br> * Resulting <code>PlatformConfig</code> instances can then be retrieved or * persisted upon passing the integrity validation checks. * * @author james todd [gonzo at jxta dot org] * @created November 13, 2003 */ public class Configurator implements Externalizable, PlatformConfigurator { private final static String COLON = ":"; private final static String BRACKET_OPEN = "["; private static final String BRACKET_CLOSE = "]"; private final static String EMPTY_STRING = ""; private final static int MILLISECONDS_PER_SECOND = 1000; private final static char NULL_CHAR = '\0'; private final static long MAX_WAIT = 7 * 1000; private final static Logger LOG = Logger.getLogger(Configurator.class.getName()); private URI home = Env.JXTA_HOME.toURI(); private String descriptor = Default.PEER_DESCRIPTOR; private String peerName = null; private String peerDescription = null; private Trace trace = Trace.DEFAULT; private PeerID peerId = null; private boolean isSecurity = Default.SECURITY_IS_ENABLED; private String principal = null; private String password = null; private URI rootCertificateAddress = null; private PSEConfigAdv pse = null; private URI peerProxy = null; private URI rendezVousBootstrap = Default.RENDEZVOUS_BOOTSTRAP_ADDRESS; private URI relaysBootstrap = Default.RELAYS_BOOTSTRAP_ADDRESS; private boolean isRelaysDiscovery = Default.RELAYS_DISCOVERY_IS_ENABLED; private URI reflectionBootstrap = Default.REFLECTION_BOOTSTRAP_ADDRESS; private List transports = null; // private List relays = null; // private boolean isRelayEnabled = Default.RELAY_SERVICE_IS_ENABLED; // private boolean isRelayIncomingEnabled = Default.RELAY_SERVICE_INCOMING_IS_ENABLED; // private int maximum