我正在尝试在这里连接两台服务器
以下是我的代码，将在两台服务器上运行
public class Node {
/**
* @param args the command line arguments
*/
private int nodeID;
private int port;
private ServerSocket nodeSock;
private int maxNodes = SysInfo.maxNodes;
private Socket otherSock;
private PrintWriter ostream;
private BufferedReader in;
private int connectedNodeID;
private HashMap<Integer, Socket> socks;
private HashMap<Socket, PrintWriter> ostreams;
private boolean isPrimary;
public Node(int nodeID, boolean isPrimary){
this.nodeID = nodeID;
this.port = SysInfo.nodePorts[nodeID];
this.isPrimary = isPrimary;
socks = new HashMap<Integer, Socket>();
ostreams = new HashMap<Socket, PrintWriter>();
System.out.println("current node #"+this.nodeID+" : ");
try{
//nodeSock = new ServerSocket(SysInfo.nodePorts[nodeID]);
nodeSock = new ServerSocket(this.port,0,InetAddress.getByName("127.0.0.1"));
}catch(IOException e){
e.printStackTrace();
}
makeSystemReady();
}
private void makeSystemReady() {
System.out.println("Making the system ready");
System.out.println(nodeSock.getLocalSocketAddress()+ ";"+nodeSock.getInetAddress()+";"+nodeSock.getLocalPort());
for(int i = 0 ; i < SysInfo.maxNodes ; i++ ){
if(i == nodeID)
continue;
// this.connectToNode(SysInfo.nodePorts[i], i);
try {
System.out.println("waiting for connection to node #"+i+" to be established");
Socket s = new Socket(InetAddress.getByName("127.0.0.1"), SysInfo.nodePorts[i]);
//socks.put(port, s);
while(!(s.isConnected()));
System.out.println("node #"+nodeID+" connected to other node#"+i);
} catch (IOException ex) {
/* ignore */
}
}
}
我正在尝试检查两个节点是否都已连接，然后才进入下一个阶段（即，只有两个服务器都已启动并正在运行时，我才开始实际的通信。）
但是我在这里没有得到适当的结果。我得到的输出如下.....
在节点0输出...
current node #0 :
准备系统
/127.0.0.1:20000;/127.0.0.1;20000
等待与节点＃1的连接建立
并在节点1 .....输出
current node #1 :
准备系统
/127.0.0.1:20001;/127.0.0.1;20001
等待与节点＃0的连接建立
节点＃1连接到其他节点＃0
在一个节点上，它表示已连接，而在另一节点上，则未显示任何内容。请帮助我在这里我要去哪里错了。
您尝试在节点1启动之前建立与节点1的连接。连接失败，并引发您忽略的异常。如果将“ / * ignore * /”更改为“ ex.printStackTrace（）;”，则会发现这种情况正在发生。
如果您不知道如何处理异常，请不要忽略该异常，因为这种情况每次都会发生。
您不需要此循环：
while（！（s.isConnected（）））;
套接字在“新套接字”完成之前建立连接，因此在此处检查连接是没有意义的。更糟糕的是，如果先连接然后立即断开连接，您将陷入无限循环。
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句