套接字服务器没有连接

Question

您好，我是 Java 套接字的新手，我一直在尝试创建服务器套接字。有人可以告诉我哪里出错了，因为我收到一条错误消息“地址已在使用中”。有时我没有收到错误，但它只是没有形成连接。请帮忙？这是服务器类和客户端类。

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.Writer;
import java.net.ServerSocket;
import java.net.Socket;


public class MessageServer {
public static void main(String[] args) throws IOException{

    int port = 8080;

    //int port = Integer.parseInt(args[0]); 

    ServerSocket server = new ServerSocket(port);


    while(true){
        System.out.println("Waiting for client...");
        Socket client = server.accept();

        System.out.println("Client from " + client.getInetAddress() + " connected.");
        BufferedReader in = new BufferedReader(new InputStreamReader(client.getInputStream()));
        String inputLine = in.readLine();
        System.out.println("Client said: '"+inputLine+"'");
        Writer count = new BufferedWriter(new OutputStreamWriter(client.getOutputStream()));
        byte c [] = count.toString().getBytes();
        count.flush();


        }
}

}

import java.net.*;
import java.io.*;

public class MessageSendClient {

public static void man(String args[]) throws IOException{
    Socket server1 = new Socket("143.210.72.82", 8080);
    System.out.println("Connected to " + server1.getInetAddress());
    InputStream in = server1.getInputStream();

    byte c[] = new byte[100];
    int num = in.read(c);
    String count = new String(c);

    System.out.println("Server said: " + count);
}

}

Answer 1

如果您在 Linux 8080 / 80 / 8443 中，则没有好的端口，我们使用其他端口，例如 3456。 并且始终始终从您的客户端关闭您的套接字。

更新： 首先，您不应该使用 Server.close() 关闭服务器套接字，服务器应该正在运行。这就是为什么会有while循环。从服务器获取输入流后，您应该使用 socket.close() 关闭客户端套接字。还要记住在 write() 和 flush() 之后始终使用 Close() 关闭输出流以避免副作用。制作两个类，一个用于服务器，一个用于客户端。首先启动 Java 类 Server，然后运行您的 Client 类以连接到 Server。终止您的 Client 类并再次运行它。如果您使用的是 eclipse，请在控制台中终止客户端。有时 Java 进程会重叠，因此只需使用 x 按钮终止所有正在运行的进程。改进示例代码后，您可以再次启动 Server 和 Client 类。 如果它仍然不起作用，您需要再次重新发布您的问题并在客户端和服务器的详细信息中显示您当前的代码。不知何故，我迷失了方向，您当前的状态在哪里，因为您已经批准了您的问题的答案。

Answer 2

不要使用你的 ip，而是使用 localhost 或 127.0.0.1 并尝试一个新端口，尝试使用大于 1024 的端口（这个数字以下的大多数是众所周知的端口，并且它们已注册到 IANA）

Answer 3

尝试一个新的端口。我不会使用 8080，因为它可能是（并且可能已经使用了）。也尝试在使用后始终关闭套接字。

由于我自己将套接字用于大学目的，因此这是代码（如果您需要 UDP 或 RMI，我也可以发布它们）

public class TCPClient {
  public static void main(String[] args){
    try{
      Socket socket = new Socket("127.0.0.1", 6666);

      PrintWriter data_to_server = new PrintWriter(socket.getOutputStream(), true);
      BufferedReader data_from_server =
              new BufferedReader(
                        new InputStreamReader(socket.getInputStream()));

      //Schicke Nachricht an Server
      BufferedReader system_reader = new BufferedReader(new InputStreamReader(System.in));
      long start_send = System.nanoTime();
      String msg = system_reader.readLine();
      data_to_server.println(msg);

      //Erhalte jeweilige Antwort
      msg = data_from_server.readLine();
      System.out.println("Data from Server : " + msg);
      System.out.println("Timespan: " + (System.nanoTime()-start_send));

      socket.close();
    }catch(IOException ioe){
      ioe.printStackTrace();
    }
  }
}

public static void main(String[] args) {
    try {
        TCPServer tcp = new TCPServer();
        tcp.initialize(6666);
    } catch (IOException ioe) {
        ioe.printStackTrace();
    }
}

public void initialize(int port) throws IOException {
    // Erstellen eines Server Sockets
    ServerSocket server = new ServerSocket(port);

    while (true) {
        // Warten bis die Verbindung besteht
        System.out.println("Waiting for client to connect...");
        Socket socket = server.accept();

        // Writer für die ausgehende Antwort
        PrintWriter data_to_client = new PrintWriter(
                socket.getOutputStream(), true);
        // Reader für die ankommende Nachricht
        BufferedReader data_from_client = new BufferedReader(
                new InputStreamReader(socket.getInputStream()));

        // IP-Adresse des Clients
        InetAddress remoteIp = socket.getInetAddress();

        // Erhalten der Nachricht
        String msg = data_from_client.readLine();
        System.out.println("Client " + remoteIp + " : " + msg);

        // Versenden der Antwort
        send(data_to_client, msg);
    }
}

}