TCP套接字服务器的CPU时间超过限制'

问题描述：

这个问题提出了运行使用生产者/消费者设计创建了一个socket服务器的同时，程序日志，错误cpu time limit exceeded坠毁。我还发现，cpu使用率超过90%的时间。这里是服务器的代码，它可能会出错，我该如何优化？TCP套接字服务器的CPU时间超过限制'

我用这个方法queue以避免为每个请求的那么多的threads创建。

在主方法（主线程）

//holds socket instances 
ConcurrentLinkedQueue<Socket> queue = new ConcurrentLinkedQueue<>(); 

//create producer thread 
Thread producer = new Thread(new RequestProducer(queue)); 
//create consumer thread 
Thread consumer = new Thread(new RequestConsumer(queue)); 

producer.start(); 
consumer.start();

RequestProducer螺纹

//this holds queue instance coming from main thread 
ConcurrentLinkedQueue<Socket> queue 

//constructor, initiate queue 
public RequestProducer(
    ConcurrentLinkedQueue<Socket> queue 
) { 
    this.queue = queue; 
} 

public void run() { 
    try { 
     //create serversocket instance on port 19029 
     ServerSocket serverSocket = new ServerSocket(19029); 
     while (true) { 
      try { 
       //keep accept connections 
       Socket socket = serverSocket.accept(); 
       //add socket to queue 
       queue.offer(socket); 
      } catch (ConnectException ce) {//handle exception 
      } catch (SocketException e) {//handle exception 
      } 
     } 
    } catch (IOException ex) {//handle exception} 
}

RequestConsumer螺纹

//this holds queue instance coming from main thread, same as requestproducer 
ConcurrentLinkedQueue<Socket> queue 

//constructor, initiate queue 
public RequestConsumer(
    ConcurrentLinkedQueue<Socket> queue 
) { 
    this.queue = queue; 
} 

public void run() { 
    try { 
     Socket socket = null; 
     while (true) { 
      //get head of the queue (socket instance) 
      socket = queue.poll(); 
      if (null != socket) { 
       //process data stream 
       String in = DataStreamUtil.parseAsciiSockStream(socket.getInputStream()); 
       //close socket conection 
       socket.close(); 
       //excecute database insert of processed data 
       excecuteDbInsert(in); 
      } 
     } 
    } catch (IOException | ParseException ex) {//handle exceptions} 
}

的数据流分析器

public static String parseAsciiSockStream(InputStream in) throws IOException { 
    StringBuilder builder = new StringBuilder(); 
    if (null != in) { 
     byte[] b = new byte[BYTE_STREAM_MAX]; 
     int length = in.read(b); 
     for (int i = 0; i < length; i++) { 
      builder.append((char) (int) b[i]); 
     } 
     in.close(); 
    } 
    return builder.toString(); 
}

Java程序不'超过错误cpu时间限制的崩溃'。这是一个PHP错误消息。不清楚你在问什么。 – EJP

我的'Java的罐子GpsServer.jar> /var/log/gps-server-log.log 2>＆1'命令，几分钟后，我看到了这个服务器在此日志文件被卡住，最后一行是启动这个程序'超过cpu时限“。我还写了'暴发户conf'文件来启动服务器作为服务。 –

@EJP这绝对不是一个PHP错误信息，可与Java中发生过。它是Linux中的Signal 24（SIGXCPU）。 – F0G

答

CPU时间超过限制，由于积极的while(true)循环到你的消费者。下面是你如何解决问题的一个例子。

您可以在while循环添加简单的Thread.sleep(1)进入消费或使用等待/通知模式来限制CPU的消耗。

RequestProducer线程

import java.io.IOException; 
import java.net.ConnectException; 
import java.net.ServerSocket; 
import java.net.Socket; 
import java.net.SocketException; 
import java.util.concurrent.ConcurrentLinkedQueue; 

public class RequestProducer implements Runnable { 
    //this holds queue instance coming from main thread 
    final ConcurrentLinkedQueue<Socket> queue; 

    //constructor, initiate queue 
    public RequestProducer(
      ConcurrentLinkedQueue<Socket> queue 
    ) { 
     this.queue = queue; 
    } 

    public void run() { 
     try { 
      //create serversocket instance on port 19029 
      ServerSocket serverSocket = new ServerSocket(19029); 
      while (true) { 
       try { 
        //keep accept connections 
        Socket socket = serverSocket.accept(); 
        //add socket to queue 
        queue.offer(socket); 
        synchronized (queue) { 
         System.out.println("notifying"); 
         queue.notify(); 
        } 
       } catch (ConnectException ce) {//handle exception 
       } catch (SocketException e) {//handle exception 
       } 
      } 
     } catch (IOException ex) {//handle exception} 
     } 

    } 
}

RequestConsumer线程

import java.io.IOException; 
import java.net.Socket; 
import java.text.ParseException; 
import java.util.concurrent.ConcurrentLinkedQueue; 

public class RequestConsumer implements Runnable { 
    //this holds queue instance coming from main thread, same as requestproducer 
    final ConcurrentLinkedQueue<Socket> queue; 

    //constructor, initiate queue 
    public RequestConsumer(
      ConcurrentLinkedQueue<Socket> queue 
    ) { 
     this.queue = queue; 
    } 

    public void run() { 
     try { 
      Socket socket = null; 
      while (true) { 
       //get head of the queue (socket instance) 
       System.out.println("Waiting for new socket"); 
       synchronized (queue) { 
        queue.wait(); 
       } 
       System.out.println("Acquired new socket"); 

       socket = queue.poll(); 
       try { 
        if (null != socket) { 
         //process data stream 
         String in = DataStreamUtil.parseAsciiSockStream(socket.getInputStream()); 
         //close socket conection 
         socket.close(); 
         //excecute database insert of processed data 
         //excecuteDbInsert(in); 

         System.out.println(in); 
        } 
       } finally { 
        if (socket != null) { 
         socket.close(); 
        } 
       } 

      } 
     } catch (IOException ex) {//handle exceptions} 
     } catch (InterruptedException e) { 
      e.printStackTrace(); 
      Thread.currentThread().interrupt(); 
     } 
    } 

}

的数据流分析器

import java.io.IOException; 
import java.io.InputStream; 

public class DataStreamUtil { 
    public static String parseAsciiSockStream(InputStream in) throws IOException { 
     StringBuilder builder = new StringBuilder(); 
     if (null != in) { 
      byte[] b = new byte[BYTE_STREAM_MAX]; 
      System.out.println("Waiting for input"); 
      int length = in.read(b); 
      System.out.println("Got input"); 
      for (int i = 0; i < length; i++) { 
       builder.append((char) (int) b[i]); 
      } 
      in.close(); 
     } 
     return builder.toString(); 
    } 
}

TCP套接字服务器的CPU时间超过限制'

相关推荐