从流中提取信息并保存在 LinkedList 中

Question

我创建了一个服务器，它使用线程来允许多个节点连接，当它们连接时，服务器接收节点信息并将其存储到链表中。我遇到的问题是，当节点连接到服务器时，会检索信息但不会存储在列表中。不是说明请求的信息，而是显示当前连接的节点：loadbalancer.NodeList@77c57d28。任何帮助都会很棒。谢谢。

下面是链表，保存为NodeList：

public class NodeList {

private String name;
private InetAddress address;
private int port;
private String nodeInformation;

LinkedList nodeList = new LinkedList();

public void Name(String name){
    this.name = name;
}

public void Address(InetAddress address){
    this.address = address;
}

public void Port(int port){
    this.port = port;
}

public void addNode (NodeL node){
    node = new NodeL(address,port);
    nodeList.add(name + address + port);

}

public String getNode(){
    Object nodeInf = nodeList.getFirst();
    nodeInformation = nodeInf.toString();
    return nodeInformation;
}

}

下面是我用来创建节点的类：

public class NodeL {

private String name;
private InetAddress address;
private int port;
private String nodeInfo;

public NodeL(InetAddress a, int p){
    address = a; port = p;
}

@Override
public String toString(){
    return address + " " + port;
}
}

这里是线程：

public class NodeManager extends Thread{
private Socket serverSocket = null;

private BufferedReader in;
private PrintWriter out;
public InetAddress nodeIP;
public int nodePort;
public String string;


public NodeManager(Socket serverSocket) throws IOException {
this.serverSocket = serverSocket;

}
//LinkedList nodeList = new LinkedList()
@Override
public void run() {

    NodeList nodelist = new NodeList();
    while(true){
        try {
            //byte[] buffer = new byte [1024];
            in = new BufferedReader(new          InputStreamReader(serverSocket.getInputStream()));  
            out = new PrintWriter(this.serverSocket.getOutputStream(), true);
            String received = in.toString();

            nodeIP = serverSocket.getInetAddress();
            nodePort = serverSocket.getPort();
            System.out.println("Node IP: " + nodeIP);
            System.out.println("Node Port number: " + nodePort);

            nodelist.Address(nodeIP);
            nodelist.Port(nodePort);

            nodelist.addNode(null);
            System.out.println("Current nodes connected: " + nodelist);
    break;       
            } catch (Exception error) {

        }
}}
}

更新：

链表还会覆盖添加的第一个节点。任何说明为什么都会很棒。

为代码的状态道歉，我对编程和 java 还很陌生。

干杯。

Answer 1

不要忘记将getters 和setters 添加到NodeL 类中，以便能够分别从节点获取和设置数据。

例如：

从第一个节点获取信息

nodeList.get(0).getName(); // to get node name
nodeList.get(0).getPort(); // to get port
...

为第一个节点设置新值

nodeList.get(0).setName(); // to get node name
nodeList.get(0).setPort(); // to get port

无需创建NodeList 类。相反，您可以在 NodeManager 类中定义 LinkedList 的 NodeL

这样做

LinkedList<NodeL> nodeList = new LinkedList<NodeL>();

当您收到新连接时，只需将新的NodeL 添加到nodeList

nodeList.add(new NodeL(serverSocket.getInetAddress(),serverSocket.getPort()));
nodeList.getLast().setName("whatever"); // to set node name
nodeList.getLast().setNodeInfo("whatever"); // to set node info

或者您可以更改NodeL 构造函数并这样做

public NodeL(String name, InetAddress address, int port , String nodeInfo){
    this.name=name;
    this.address = address ;
    this.port = port;
    this.nodeInfo=nodeInfo;
}

然后

nodeList.add(new NodeL("whatever",serverSocket.getInetAddress(),serverSocket.getPort(),"whatever"));

Answer 2

对于您的问题：

NodeList@77c57d28显示：

这是因为NodeList 没有自定义覆盖toString() 方法，所以它调用Object.toString()（Object 类是java 类的默认超类），它打印出“NodeList@77c57d28”。

你班上的小问题NodeManager：

nodelist.Address(nodeIP);
nodelist.Port(nodePort);
nodelist.addNode(null);

你最后总是在你的nodeList 中分配nodeIp 和nodePort。

我可以理解你是一个 java 初学者，所以我在下面添加了修改后的类。看一次：

public class NodeL {

   private String name;
   private InetAddress address;
   private int port;
   private String nodeInfo;

   public NodeL(InetAddress a, int p){
      address = a; port = p;
   }

   public InetAddress getAddress() {
       return address;
   }

   public int getPort() {
       return port;
   }

   @Override
   public String toString(){
     return address + " " + port;
   }
 }

节点列表：

public class NodeList {

   private String name;
   private String nodeInformation;

   LinkedList nodeList = new LinkedList();

   public void Name(String name){
       this.name = name;
   }

   public void addNode (NodeL node){
      nodeList.add(name + node.getAddress() + node.getPort());
  }

  @Override      
  public String toString() {
     StringBuilder sb = new StringBuilder();
     for(Object node : nodeList) {
        sb.append(node + "\n");
     }
     return sb.toString();
   }
}

NodeManager 的run 方法：

 @Override
 public void run() {

 NodeList nodelist = new NodeList();
 while(true){
    try {
        //byte[] buffer = new byte [1024];
        in = new BufferedReader(new            InputStreamReader(serverSocket.getInputStream()));  
        out = new PrintWriter(this.serverSocket.getOutputStream(),  true);
        String received = in.toString();

        nodeIP = serverSocket.getInetAddress();
        nodePort = serverSocket.getPort();
        System.out.println("Node IP: " + nodeIP);
        System.out.println("Node Port number: " + nodePort);

        nodelist.addNode(new NodeL(address, port));
        System.out.println("Current nodes connected: " + nodelist);
        break;       
        } catch (Exception error) {

        }
  }
}