hallo,
ich wollte p2p mit (freepasrty realisieren freepastry.rice.edu/FreePastry/tutorial/)
als ich die folgende klasse ausführen wollte meldet er den fehler (editor does not contain a main typ)
package rice.tutorial.lesson1;
import java.io.IOException;
import java.net.*;
import rice.environment.Environment;
import rice.pastry.*;
import rice.pastry.socket.SocketPastryNodeFactory;
import rice.pastry.standard.RandomNodeIdFactory;
/**
* This tutorial shows how to setup a FreePastry node using the Socket Protocol.
*
* @author Jeff Hoye
*/
public class DistTutorial {
/**
* This constructor sets up a PastryNode. It will bootstrap to an
* existing ring if it can find one at the specified location, otherwise
* it will start a new ring.
*
* @param bindport the local port to bind to
* @param bootaddress the IP
ort of the node to boot from
* @param env the environment for these nodes
*/
public DistTutorial(int bindport, InetSocketAddress bootaddress, Environment env) throws Exception {
// Generate the NodeIds Randomly
NodeIdFactory nidFactory = new RandomNodeIdFactory(env);
// construct the PastryNodeFactory, this is how we use rice.pastry.socket
PastryNodeFactory factory = new SocketPastryNodeFactory(nidFactory, bindport, env);
// This will return null if we there is no node at that location
NodeHandle bootHandle = ((SocketPastryNodeFactory)factory).getNodeHandle(bootaddress);
// construct a node, passing the null boothandle on the first loop will cause the node to start its own ring
PastryNode node = factory.newNode(bootHandle);
// the node may require sending several messages to fully boot into the ring
synchronized(node) {
while(!node.isReady() && !node.joinFailed()) {
// delay so we don't busy-wait
node.wait(500);
// abort if can't join
if (node.joinFailed()) {
throw new IOException("Could not join the FreePastry ring. Reason:"+node.joinFailedReason());
}
}
}
System.out.println("Finished creating new node "+node);
}
/**
* Usage:
* java [-cp FreePastry-<version>.jar] rice.tutorial.lesson1.DistTutorial localbindport bootIP bootPort
* example java rice.tutorial.DistTutorial 9001 pokey.cs.almamater.edu 9001
*/
public static void main(String[] args) throws Exception {
// Loads pastry settings
Environment env = new Environment();
// disable the UPnP setting (in case you are testing this on a NATted LAN)
env.getParameters().setString("nat_search_policy","never");
try {
// the port to use locally
int bindport = Integer.parseInt(args[0]);
// build the bootaddress from the command line args
InetAddress bootaddr = InetAddress.getByName(args[1]);
int bootport = Integer.parseInt(args[2]);
InetSocketAddress bootaddress = new InetSocketAddress(bootaddr,bootport);
// launch our node!
DistTutorial dt = new DistTutorial(bindport, bootaddress, env);
} catch (Exception e) {
// remind user how to use
System.out.println("Usage:");
System.out.println("java [-cp FreePastry-<version>.jar] rice.tutorial.lesson1.DistTutorial localbindport bootIP bootPort");
System.out.println("example java rice.tutorial.DistTutorial 9001 pokey.cs.almamater.edu 9001");
throw e;
}
}
}
ich hab eclipse 3.2
und da mir google mir nicht helfen konnte hab ich gedacht kriege ich hier vielleicht Hilfe :cry:
Danke im vorraus
ich wollte p2p mit (freepasrty realisieren freepastry.rice.edu/FreePastry/tutorial/)
als ich die folgende klasse ausführen wollte meldet er den fehler (editor does not contain a main typ)
package rice.tutorial.lesson1;
import java.io.IOException;
import java.net.*;
import rice.environment.Environment;
import rice.pastry.*;
import rice.pastry.socket.SocketPastryNodeFactory;
import rice.pastry.standard.RandomNodeIdFactory;
/**
* This tutorial shows how to setup a FreePastry node using the Socket Protocol.
*
* @author Jeff Hoye
*/
public class DistTutorial {
/**
* This constructor sets up a PastryNode. It will bootstrap to an
* existing ring if it can find one at the specified location, otherwise
* it will start a new ring.
*
* @param bindport the local port to bind to
* @param bootaddress the IP
ort of the node to boot from* @param env the environment for these nodes
*/
public DistTutorial(int bindport, InetSocketAddress bootaddress, Environment env) throws Exception {
// Generate the NodeIds Randomly
NodeIdFactory nidFactory = new RandomNodeIdFactory(env);
// construct the PastryNodeFactory, this is how we use rice.pastry.socket
PastryNodeFactory factory = new SocketPastryNodeFactory(nidFactory, bindport, env);
// This will return null if we there is no node at that location
NodeHandle bootHandle = ((SocketPastryNodeFactory)factory).getNodeHandle(bootaddress);
// construct a node, passing the null boothandle on the first loop will cause the node to start its own ring
PastryNode node = factory.newNode(bootHandle);
// the node may require sending several messages to fully boot into the ring
synchronized(node) {
while(!node.isReady() && !node.joinFailed()) {
// delay so we don't busy-wait
node.wait(500);
// abort if can't join
if (node.joinFailed()) {
throw new IOException("Could not join the FreePastry ring. Reason:"+node.joinFailedReason());
}
}
}
System.out.println("Finished creating new node "+node);
}
/**
* Usage:
* java [-cp FreePastry-<version>.jar] rice.tutorial.lesson1.DistTutorial localbindport bootIP bootPort
* example java rice.tutorial.DistTutorial 9001 pokey.cs.almamater.edu 9001
*/
public static void main(String[] args) throws Exception {
// Loads pastry settings
Environment env = new Environment();
// disable the UPnP setting (in case you are testing this on a NATted LAN)
env.getParameters().setString("nat_search_policy","never");
try {
// the port to use locally
int bindport = Integer.parseInt(args[0]);
// build the bootaddress from the command line args
InetAddress bootaddr = InetAddress.getByName(args[1]);
int bootport = Integer.parseInt(args[2]);
InetSocketAddress bootaddress = new InetSocketAddress(bootaddr,bootport);
// launch our node!
DistTutorial dt = new DistTutorial(bindport, bootaddress, env);
} catch (Exception e) {
// remind user how to use
System.out.println("Usage:");
System.out.println("java [-cp FreePastry-<version>.jar] rice.tutorial.lesson1.DistTutorial localbindport bootIP bootPort");
System.out.println("example java rice.tutorial.DistTutorial 9001 pokey.cs.almamater.edu 9001");
throw e;
}
}
}
ich hab eclipse 3.2
und da mir google mir nicht helfen konnte hab ich gedacht kriege ich hier vielleicht Hilfe :cry:
Danke im vorraus
