用于客户端和服务器通信自动重新连接的 Java 套接字程序

Question

我想开发客户端和服务器通信，我已经为客户端和服务器编写了一些代码，但是一旦客户端和服务器连接，就不需要一次又一次地重新连接。但是，在我当前的代码中，它们会一次又一次地重新连接。

1. InetAddress host = InetAddress.getLocalHost();
2. Socket s = new Socket(host.getHostName(), 4321);

第二行每次都会创建新的连接，这就是我要解决的问题（他们只需要连接一次）。

ClientClass.java

public class CientClass {

public static void main(String[] args)  
  {
    System.out.println("CLIENT SITE");
    while (true) {
        try {
            InetAddress host = InetAddress.getLocalHost();
            Socket s = new Socket(host.getHostName(), 4321);
            DataOutputStream dout = new DataOutputStream(s.getOutputStream());
            Scanner sc = new Scanner(System.in);
            System.out.println("Ener for server:");
            String data = sc.next();
            dout.writeUTF(data);
        }
        catch (Exception e) {
            System.out.println(e);
            e.printStackTrace();
        }
    }
  }
}

Serverclass.java

public class Serverclass {

public static void main(String[] args) {
    System.out.println("SERVER SITE");
    while (true) {
        try {
            ServerSocket ss = new ServerSocket(4321);
            Socket s = ss.accept();
            DataInputStream din = new DataInputStream(s.getInputStream());
            String str = (String) din.readUTF();
            System.out.println("message:" + str);
            ss.close();
        }
        catch (Exception e) {
            System.out.println(e);
            e.printStackTrace();
        }
    }
  }
}

clientClass 从控制台读取命令并发送到服务器，但它不应在初始连接后继续重新连接。

在重启服务器的情况下，客户端应该自动连接，并且客户端应该能够向服务器发送命令。

我想我不需要更改服务器类代码。只需要更改clientClass代码。怎么样？

Answer 1

好的，有两个主要原因会始终建立新连接。

首先，对于 ServerClass 中 while(true) 循环的每个循环，您正在创建一个新的服务器套接字并通过调用 ServerSocket.accept() 等待新连接，这也是一个阻塞操作，这意味着服务器会一直阻塞直到新连接到达。

这种行为的第二个原因是，您总是通过创建新套接字来强制从 ClientClass 建立新连接。 套接字建立端到端的连接。创建并连接后，您无需再创建一个。

对您来说最方便的解决方法是替换 while(true) 循环，使其仅以某种方式涵盖真正的发送/接收逻辑：

客户端类

  try
  {
    InetAddress host = InetAddress.getLocalHost();
    Socket s = new Socket( host.getHostName(), 4321 );
    DataOutputStream dout = new DataOutputStream( s.getOutputStream() );
    while ( isAlive )
    {
      Scanner sc = new Scanner( System.in );
      System.out.println( "Ener for server:" );
      String data = sc.next();
      dout.writeUTF( data );
    }
  }
  catch ( Exception e )
  {
    System.out.println( e );
    e.printStackTrace();
  }

服务器类

try
      {
        ServerSocket ss = new ServerSocket( 4321 );
        Socket s = ss.accept();
        DataInputStream din = new DataInputStream( s.getInputStream() );
        while ( isAlive )
        {
          String str = (String) din.readUTF();
          System.out.println( "message:" + str );
        }
        ss.close();
      }
      catch ( Exception e )
      {
        System.out.println( e );
        e.printStackTrace();
      }