rdvcontrol.java

有关java 的p2p应用,是一般很好的教程,有兴趣的朋友应该好好阅读一下

                println( "Active Seeds :");
            }
            
            while( eachSeed.hasNext() ) {
                println( "\t" + eachSeed.next() );
            }
        } else {
            consoleMessage( "Rendezvous is not of correct type" );
            return ShellApp.appMiscError;
        }
        
        return ShellApp.appNoError;
    }
    
    private int rpv_probe( String[] subargs ) {
        consoleMessage( "Not implemented (sorry)." );
        return ShellApp.appNoError;
    }
    
    private int rpv_delete( String[] subargs, boolean fail) {
        GetOpt options = new GetOpt( subargs, "" );
        
        while( true ) {
            int option = options.getNextOption();
            
            if( -1 == option ) {
                break;
            }
            
            switch( option ) {
                default :
                    consoleMessage( "Unrecognized option" );
                    return syntaxError();
            }
        }
        
        String peerStr = options.getNextParameter();
        
        if( null == peerStr ) {
            consoleMessage( "Missing peer id" );
            return syntaxError();
        }
        
        if( null != options.getNextParameter() ) {
            consoleMessage( "Unexpected parameter" );
            return syntaxError();
        }
        
        PeerID fail_peer = null;
        
        try {
            fail_peer = (PeerID) IDFactory.fromURI( new URI(peerStr) );
        } catch( URISyntaxException badURI ) {
            consoleMessage( "bad peer id" );
            return syntaxError();
        } catch( ClassCastException badURI ) {
            consoleMessage( "bad peer id" );
            return syntaxError();
        }
        
        if( rdv instanceof RendezVousServiceInterface ) {
            RendezVousServiceInterface stdRdv = (RendezVousServiceInterface) rdv;
            
            PeerView rpv = stdRdv.getPeerView();
            
            rpv.notifyFailure( fail_peer, fail );
        } else {
            consoleMessage( "Rendezvous is not of correct type" );
            return ShellApp.appMiscError;
        }
        
        return ShellApp.appNoError;
    }
    
    private int rdv_start( String[] subargs ) {
        
        rdv.startRendezVous();
        
        return ShellApp.appNoError;
    }
    
    private int rdv_stop( String[] subargs ) {
        
        rdv.stopRendezVous();
        
        return ShellApp.appNoError;
    }
    
    private int rdv_disconnect( String[] subargs ) {

        consoleMessage( "Not implemented (sorry)." );
        return ShellApp.appNoError;
    }
    
    private int edge_connect( String[] subargs ) {
        GetOpt options = new GetOpt( subargs, "" );
        
        while( true ) {
            int option = options.getNextOption();
            
            if( -1 == option ) {
                break;
            }
            
            switch( option ) {
                default :
                    consoleMessage( "Unrecognized option" );
                    return syntaxError();
            }
        }
        
        String connectStr = options.getNextParameter();
        
        if( null == connectStr ) {
            consoleMessage( "Missing <URI>" );
            return syntaxError();
        }
        
        if( null != options.getNextParameter() ) {
            consoleMessage( "Unexpected parameter" );
            return syntaxError();
        }
        
        EndpointAddress connect_peer = null;
        
        try {
            connect_peer = new EndpointAddress( connectStr );
        } catch( Exception badURI ) {
            consoleMessage( "bad connect URI." );
            return syntaxError();
        }
        
        try {
            rdv.connectToRendezVous( connect_peer );
        } catch( IOException failed ) {
            printStackTrace( "Connect Failure", failed );
            return ShellApp.appMiscError;
        }
        
        return ShellApp.appNoError;
    }
    
    private int edge_disconnect( String[] subargs ) {
        GetOpt options = new GetOpt( subargs, "" );
        
        while( true ) {
            int option = options.getNextOption();
            
            if( -1 == option ) {
                break;
            }
            
            switch( option ) {
                default :
                    consoleMessage( "Unrecognized option" );
                    return syntaxError();
            }
        }
        
        String peerStr = options.getNextParameter();
        
        if( null == peerStr ) {
            consoleMessage( "Missing <peerid>" );
            return syntaxError();
        }
        
        if( null != options.getNextParameter() ) {
            consoleMessage( "Unexpected parameter" );
            return syntaxError();
        }
        
        PeerID disconnect_peer = null;
        
        try {
            disconnect_peer = (PeerID) IDFactory.fromURI( new URI(peerStr) );
        } catch( URISyntaxException badURI ) {
            consoleMessage( "bad peer id" );
            return syntaxError();
        } catch( ClassCastException badURI ) {
            consoleMessage( "bad peer id" );
            return syntaxError();
        }
        
        rdv.disconnectFromRendezVous( disconnect_peer );
        
        return ShellApp.appNoError;
    }
    
    private int edge_challenge( String[] subargs ) {
        consoleMessage( "Not implemented (sorry)." );
        return ShellApp.appNoError;
    }
    
    private int auto_start( String[] subargs ) {
        GetOpt options = new GetOpt( subargs, "" );
        
        while( true ) {
            int option = options.getNextOption();
            
            if( -1 == option ) {
                break;
            }
            
            switch( option ) {
                default :
                    consoleMessage( "Unrecognized option" );
                    return syntaxError();
            }
        }
        
        String intervalStr = options.getNextParameter();
        long interval = Long.MIN_VALUE;
        
        if( null != intervalStr ) {
            if( null != options.getNextParameter() ) {
                consoleMessage( "Unexpected parameter" );
                return syntaxError();
            }
            
            try {
                interval = Long.parseLong( intervalStr );
            } catch( NumberFormatException badValue ) {
                consoleMessage( "Illegal interval value" );
                return syntaxError();
            }
        }
        
        boolean previous = (Long.MIN_VALUE == interval) ? rdv.setAutoStart(true) : rdv.setAutoStart( true, interval );
        
        return ShellApp.appNoError;
    }
    
    private int auto_stop( String[] subargs ) {
        if( subargs.length > 0 ) {
            consoleMessage( "Unexpected parameter" );
            return syntaxError();
        }
              
        rdv.setAutoStart(false);
        return ShellApp.appNoError;
    }
    
    private int syntaxError() {
        consoleMessage( "usage : rdvcontrol [-v] <command> <subcommand> [[options] <parameters>]" );
        return ShellApp.appParamError;
    }
    
    /**
     *  {@inheritDoc}
     */
    public String getDescription() {
        return "Controls rendezvous service behaviour";
    }
    
    /**
     *  {@inheritDoc}
     */
    public void help() {
        println( "NAME" );
        println( "     rdvcontrol - " + getDescription() );
        println( " " );
        println( "SYNOPSIS" );
        println( "     rdvcontrol [-v] <command> <subcommand> [[options] <parameters>]" );
        println( " " );
        println( "OPTIONS" );
        println( "     [-v]    print verbose information" );
        println( " " );
        println( "COMMANDS -- NOTE : MANY ARE NOT YET IMPLEMENTED. HELP WELCOME" );
        println( "     rpv" );
        println( "       addseed <URI>        Adds a seed rendezvous." );
        println( "       reseed               Force aggressive search for peeerview entries." );
        println( "       probe" );
        println( "       delete <peerID>      Removes the specified peerview entry." );
        println( "       fail <peerID>        Removes and announces failure of specified peerview entry." );
        println( " " );
        println( "     rdv" );
        println( "       start                Starts rendezvous server behaviour for this peer." );
        println( "       stop                 Stops rendezvous server behaviour for this peer." );
        println( "       disconnect" );
        println( " " );
        println( "     edge" );
        println( "       connect <URI>        Connect to the specified Rendezvous." );
        println( "       disconnect <peerID>  Disconnect from the specified Rendezvous." );
        println( "       challenge <timeout> <peerID> Challenge the specified Rendezvous." );
        println( " " );
        println( "     auto" );
        println( "       start [interval]     Starts auto-rdv behaviour at (optional) specified millisecond interval." );
        println( "       stop                 Stops auto-rdv behaviour." );
        println( " " );
        println( "DESCRIPTION" );
        println( " " );
        println( "'rdvcontrol' is used for controlling the behaviour of the " );
        println( "rendezvous service." );
        println( " " );
        println( "EXAMPLE" );
        println( " " );
        println( "    JXTA>rdvcontrol auto stop" );
        println( " " );
        println( " " );
        println( "SEE ALSO" );
        println( "    rdvstatus" );
    }
}