客户端-服务器聊天中的客户端 CPU 负载 30-50%答案

【问题标题】：Client in Client-Server Chat CPU load 30-50%客户端-服务器聊天中的客户端 CPU 负载 30-50%
【发布时间】：2016-01-13 04:54:49
【问题描述】：

客户端连接到服务器，服务器向客户端发送 1 条消息，客户端必须等待另一条消息。当客户端在 while(true) 循环中等待时，它会将 CPU 加载到 50%。我尽量做到这一点，以了解它是如何工作的。

附：所有的 catch() 都已经隐藏起来，以最小化这里的代码。

客户：

public class SocketClient 
{
   String host;
   int port;
   static Socket connection;
   BufferedReader bfr;

    public SocketClient(String host, int port)
    {
        this.port = port; 
        this.host = host;   
    }

    public void connect() throws UnknownHostException, IOException, Exception
    {
        connection = new Socket(new String(host), port);
        System.out.println("Client is ready.");

        bfr = new BufferedReader(new InputStreamReader(connection.getInputStream()));
    }

     public void readInput() throws IOException
     {
           String input;   
           if(input = bfr.readLine()) != null)
           {
               System.out.println(input); 
           }
     }

      public static void main(String[] args) throws UnknownHostException, IOException, Exception 
      {
          SocketClient socketClient = new SocketClient("localhost", 19999);

           try {    
               socketClient.connect();

               try
               {
                  while(true)
                  {
                     socketClient.readInput();
                  }
               }

           }
     }
}

服务器：

   public class MultipleSocketServer implements Runnable {

  private Socket connection;
  private String TimeStamp;
  private int ID;

  static PrintWriter writer;
  private static File file;

  public static void main(String[] args) 
         throws FileNotFoundException, UnsupportedEncodingException 
  {

  int port = 19999;
  int count = 0;

  file = new File("E:/test.txt");
  writer = new PrintWriter(file, "UTF-8");

    try
    {
      ServerSocket socket = new ServerSocket(port);
      System.out.println("MultipleSocketServer Initialized");

      while (true) 
      {
        Socket connection = socket.accept();
        Runnable runnable = new MultipleSocketServer(connection, ++count);
        Thread thread = new Thread(runnable);
        thread.start();
      }
    }
  }


MultipleSocketServer(Socket s, int i) {
  this.connection = s;
  this.ID = i;
}

public void run() {
    try {

      System.out.println("Connected: " + connection.getLocalSocketAddress() + " at port " + connection.getPort());    
      writer.println(ID + ": " + connection.getLocalSocketAddress() + " at port " + connection.getPort());
      writer.flush();


      BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(connection.getOutputStream()));
      writer.write("MultipleSocketServer repsonded at " + new java.util.Date().toString());
      writer.write("\n");
      writer.flush(); 

    }
    finally {
      try {
        connection.close();
     }
    }
   }
 }

【问题讨论】：

您的问题是什么？请说明清楚，以便我们了解您的问题以及我们如何提供帮助

标签： java multithreading sockets client-server chat

【解决方案1】：

分析

似乎服务器端发送数据后关闭了连接。

客户端有如下无限循环：

while (true)
{
    socketClient.readInput();
}

循环会导致CPU消耗：方法bfr.readLine()方法调用会在连接关闭后立即返回null。

解决方案

请考虑将客户端的循环改为读取直到“连接结束”：

String input;
while ((input = bfr.readLine()) != null) {
    System.out.println(input);
}

【讨论】：