2
这个问题提出了运行使用生产者/消费者设计创建了一个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