RemoteNodeList.java Go to the documentation of this file. /* * RemoteNodeList.java * * Created on 20 août 2003, 21:48 * Copyright (C) 2003 Philippe MOULIN * www.net2map.org * * This program is free software; you can redistribute it and/or * modify it under the terms of the GNU General Public License * as published by the Free Software Foundation; either version 2 * of the License, or (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Lesser General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program; if not, write to the Free Software * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. */ package org.net2map.pov.p2p; import java.beans.*; import java.util.Enumeration; import java.util.Hashtable; import java.io.*; //JXTA Imports import net.jxta.discovery.DiscoveryEvent; import net.jxta.discovery.DiscoveryListener; import net.jxta.discovery.DiscoveryService; import net.jxta.exception.PeerGroupException; import net.jxta.peergroup.PeerGroup; import net.jxta.peergroup.PeerGroupFactory; import net.jxta.protocol.DiscoveryResponseMsg; import net.jxta.protocol.PeerAdvertisement; import net.jxta.protocol.PipeAdvertisement; import net.jxta.endpoint.*; import net.jxta.document.*; //import net.pkg.jal.*; public class RemoteNodeList extends Thread implements java.io.Serializable, Runnable, DiscoveryListener { public static org.apache.log4j.Logger logger = org.apache.log4j.Logger.getLogger(RemoteNodeList.class.getName()); private Hashtable colRemoteNodes; private static final String PROP_SAMPLE_PROPERTY = "SampleProperty"; private static final int minRemoteNodesCount = 2; private static final int maxRemoteNodesCount = 7; private int discoveryCycleCounter = 30; private int discoveryCycleDuration = 600; private String sampleProperty; private boolean hasToStop = false; private PropertyChangeSupport propertySupport; //private LocalNode theLocalNode = null; //private POV_PeerGroup thePOV_PeerGroup = null; //private static Peer theLocalPeer = null; private static boolean seedNodesInserted = false; private static RemoteNodeList instance = null; public static RemoteNodeList getInstance() { if (instance == null) { synchronized(RemoteNodeList.class) { if (instance == null) { instance = new RemoteNodeList(); } } } return instance; } private RemoteNodeList() { logger.setLevel(org.apache.log4j.Level.DEBUG); propertySupport = new PropertyChangeSupport( this ); //theLocalNode = paramLocalNode; //thePOV_PeerGroup = paramPOV_PeerGroup; colRemoteNodes = new Hashtable(); // Add ourselves as a DiscoveryListener for DiscoveryResponse events POV_PeerGroup.getInstance().getDiscoveryService().addDiscoveryListener(this); LocalNode.getInstance().getNetPeerGroup().getDiscoveryService().addDiscoveryListener(this); } private void insertSeedNodesInRemoteNodeList() { if (!seedNodesInserted) { logger.warn("Reading seed nodes file..."); try { String theSeedNodeFile = ToolBox.getWebPage(new java.net.URL("http://www.net2map.org/SeedNodes.xml")); PeerAdvertisement thePeerAdvertisement = (PeerAdvertisement) AdvertisementFactory .newAdvertisement(new MimeMediaType("text/xml"), new StringReader(theSeedNodeFile)); //If this node is not me... if(!thePeerAdvertisement.getPeerID().toString().equals( LocalNode.getInstance().getMyPeerID().toString() )) { //And if this node is not already in the remote node list if (!isRemoteNodeInList(thePeerAdvertisement.getPeerID().toString())) { logger.info("Found a new node!"); //Add this node to the remote node list addRemoteNode(thePeerAdvertisement.getPeerID().toString(), new RemoteNode(thePeerAdvertisement)); } else { logger.info("That seed node was already in the list!"); } } else { logger.info("I am a seed node!"); } } catch(Exception theException) { logger.error("Exception " + theException); theException.printStackTrace(); } seedNodesInserted = true; } } public String getSampleProperty() { return sampleProperty; } public void setSampleProperty(String value) { String oldValue = sampleProperty; sampleProperty = value; propertySupport.firePropertyChange(PROP_SAMPLE_PROPERTY, oldValue, sampleProperty); } public void addPropertyChangeListener(PropertyChangeListener listener) { propertySupport.addPropertyChangeListener(listener); } public void removePropertyChangeListener(PropertyChangeListener listener) { propertySupport.removePropertyChangeListener(listener); } public RemoteNode getRemoteNode( String paramPeerID ) { return (RemoteNode)colRemoteNodes.get(paramPeerID); } public synchronized void addRemoteNode( String paramPeerID, RemoteNode paramRemoteNode ) { colRemoteNodes.put(paramPeerID, paramRemoteNode); } public void removeRemoteNode( String paramPeerID ) { colRemoteNodes.remove(paramPeerID); } public synchronized boolean isRemoteNodeInList( String paramPeerID) { return ( colRemoteNodes.containsKey(paramPeerID)); } public synchronized void discoveryEvent(net.jxta.discovery.DiscoveryEvent discoveryEvent) { DiscoveryResponseMsg res = discoveryEvent.getResponse(); String name = "unknown"; // Get the responding peer's advertisement PeerAdvertisement peerAdv = res.getPeerAdvertisement(); // some peers may not respond with their peerAdv if (peerAdv != null) { name = peerAdv.getName(); logger.warn("A peer has responded!"); //System.out.println("\t Description:\t" + peerAdv.getDescription()); logger.warn("\t ID><GROUP:\t" + peerAdv.getID().toString()); logger.warn("\t PeerGroupID:\t" + peerAdv.getPeerGroupID()); logger.warn("\t PeerID:\t" + peerAdv.getPeerID().toString()); logger.warn("\t Name:\t" + peerAdv.getName()); } logger.warn( "Got a Discovery Response [" + res.getResponseCount() + " elements] from peer: " + name + "\n(myPeerID=" + LocalNode.getInstance().getMyPeerID().toString() + ")"); //printout each discovered peer PeerAdvertisement adv = null; PipeAdvertisement thePipeAdvertisement = null; Enumeration enum = res.getAdvertisements(); if (enum != null ) { while (enum.hasMoreElements()) { Object theAdvertisement = enum.nextElement(); //is it a PeerAdvertisement? if(! (theAdvertisement instanceof PeerAdvertisement)) { logger.warn("received a " + theAdvertisement.getClass().toString()); //is it a pipe advertisement? if(theAdvertisement instanceof PipeAdvertisement) { thePipeAdvertisement = (PipeAdvertisement) theAdvertisement; logger.warn("This is a pipe advertisement:\n\tgetAdvType:\"" + thePipeAdvertisement.getAdvType() + "\" \n\tgetAdvertisementType:\"" + thePipeAdvertisement.getAdvertisementType() + "\" \n\tgetID:\""+ thePipeAdvertisement.getID().toString() + "\" \n\tgetName:\"" + thePipeAdvertisement.getName() + "\" \n\tgetPipeID:\"" + thePipeAdvertisement.getPipeID() + "\" \n\tgetType:\"" + thePipeAdvertisement.getType() + "\"" ); } } else //this is a peer advertisement. let's look into it... { adv = (PeerAdvertisement) theAdvertisement; logger.warn("Peer name = " + adv.getName()); logger.warn("\t ID><GROUP:\t" + adv.getID().toString()); logger.warn("\t PeerGroupID:\t" + adv.getPeerGroupID()); logger.warn("\t PeerID:\t" + adv.getPeerID().toString()); logger.warn("\t MyPeerID:\t" + LocalNode.getInstance().getMyPeerID().toString()); //If this node is not me... if(!adv.getPeerID().toString().equals( LocalNode.getInstance().getMyPeerID().toString() )) { //And if this node is not already in the remote node list if (!isRemoteNodeInList(adv.getPeerID().toString())) { logger.warn("Found a new node!" ); if(colRemoteNodes.size() >= maxRemoteNodesCount) { removeABadNodeFromList(); } //Add this node to the remote node list addRemoteNode(adv.getPeerID().toString(), new RemoteNode(adv)); } else { logger.warn("(already in the list)"); } } else { logger.warn("(it's me!)"); } logger.warn("--------------------------------------------"); } } } } public void run() { try { while (!this.hasToStop) { doPeriodicWork(); // wait a second try { Thread.sleep(1 * 1000); } catch(Exception e) {} } //end while } catch(Exception e) { e.printStackTrace(); } System.out.println("NODE LIST:\tRemoteNodeList thread finished"); } public void stopDiscoveryThread() { this.hasToStop = true; System.out.println("NODE LIST:\tStop request received, please wait..."); } private void doPeriodicWork() { if(discoveryCycleCounter >= discoveryCycleDuration) { if(colRemoteNodes.size() > maxRemoteNodesCount) { removeABadNodeFromList(); } insertSeedNodesInRemoteNodeList(); discoverRemoteNodes(); discoveryCycleCounter = 0; } else { discoveryCycleCounter++; } } private void discoverRemoteNodes() { System.out.println("RemoteNodeList is sending a PEER Discovery Message"); logger.warn("RemoteNodeList is sending a PEER Discovery Message"); // look for any peer POV_PeerGroup.getInstance() .getDiscoveryService() .getRemoteAdvertisements( null, DiscoveryService.PEER, null, null, 5); /* LocalNode.getInstance().getNetPeerGroup() .getDiscoveryService() .getRemoteAdvertisements( null, DiscoveryService.PEER, null, null, 5); */ Enumeration theRemoteNodes = colRemoteNodes.elements(); RemoteNode currentRemoteNode; while(theRemoteNodes.hasMoreElements()) { /*((RemoteNode)theRemoteNodes.nextElement()) .getAdvertisements(theLocalNode.getDiscoveryService());*/ currentRemoteNode = (RemoteNode)theRemoteNodes.nextElement(); logger.warn( "" + currentRemoteNode.getPeerName() + "\t" + currentRemoteNode.getConsecutiveFailureCount() + "\t" + currentRemoteNode.getPeerID()); currentRemoteNode.connectToSecurePipe(); } } public synchronized int getRemoteNodesCount() { return(colRemoteNodes.size()); } public synchronized void sendMessageToRemoteNodes(Message theMessage) { Enumeration theRemoteNodeEnumeration = colRemoteNodes.elements(); while(theRemoteNodeEnumeration.hasMoreElements()) { RemoteNode theRemoteNode = (RemoteNode)theRemoteNodeEnumeration.nextElement(); theRemoteNode.receiveMessage(theMessage); } } private synchronized void removeABadNodeFromList() { Enumeration theRemoteNodes = colRemoteNodes.elements(); RemoteNode currentRemoteNode; RemoteNode nodeSelectedForRemoval = null; int remoteNodesCount = 0; int worstConsecutiveFailureCountYet = 0; while(theRemoteNodes.hasMoreElements()) { remoteNodesCount++; currentRemoteNode = (RemoteNode)theRemoteNodes.nextElement(); logger.warn( "Node " + currentRemoteNode.getPeerName() + " has made " + currentRemoteNode.getConsecutiveFailureCount() + " failures "); if(currentRemoteNode.getConsecutiveFailureCount() > worstConsecutiveFailureCountYet) { worstConsecutiveFailureCountYet = currentRemoteNode.getConsecutiveFailureCount(); nodeSelectedForRemoval = currentRemoteNode; } } logger.warn("Node count: " + remoteNodesCount); if(null == nodeSelectedForRemoval) { logger.warn("Did not find any bad node to remove"); } else { logger.warn("Removing node " + nodeSelectedForRemoval.getPeerName() + " which has made " + worstConsecutiveFailureCountYet + " consecutive failures"); removeRemoteNode(nodeSelectedForRemoval.getPeerID()); } } public synchronized void handleIncomingMessage(Message theMessage, RemoteNode theSender) { LocalNode.getInstance().handleIncomingMessage(theMessage, theSender); } }
Accueil | Téléchargement | Manuel | Doc. technique | Sources CVS | Faq | Nous contacter ©2003 - All Rights Reserved