1

我在 java Socket Object 通信上有一个内存泄漏问题。

这是我的发送线程。

    // create a new thread to send the packet
@Override
public synchronized void run() {

    if(!genericSocket.isConnected()){
        if(logger.isEnabled())
            logger.logMessage(PFLogging.LEVEL_WARN, "Socket is close");
        return;
    }

    int retry = 0;
    boolean packetSent = false;

    synchronized (objWriter) {
        while ((retry < RETRY) && (!packetSent) && (genericSocket.isConnected())) {
            try {
                objWriter.writeObject(bean);

                objWriter.flush();



                // Try until the cache is reset and the memory is free
                /*
                boolean resetDone = false;
                while(!resetDone) {
                    try {
                        objWriter.reset();
                        resetDone = true;
                    } catch (IOException r) {
                        Thread.sleep(1);
                    }
                }
                */

                // No error and packet sent
                continuousError = 0;
                packetSent = true;
            } catch (Exception e) {
                continuousError++;

                if(logger.isEnabled())
                    logger.logMessage(PFLogging.LEVEL_ERROR, "Continuous Error [" + continuousError + "] sending message [" + e.getMessage() + "," + e.getCause() + "]");

                // control the number of continuous errors
                if(continuousError >= CONTINUOUS_ERROR) {
                    if(logger.isEnabled())
                        logger.logMessage(PFLogging.LEVEL_WARN, "I close the socket");
                    genericSocket.disconnect();
                }

                // next time is the time!
                retry++;
            }
        }
    }
}

缓存，当我发送大约每毫秒我的数据包增长和增长！

如果我添加注释部分，缓存是干净的，但是当我需要发送异步长消息（大约 3000 个字符）时，我看到其他消息丢失了！

还有另一种方法可以在不重置缓存的情况下清理缓存？？

4

4 回答 4

2

ObjectOutputStream.reset() 是无法避免的，因为它是清除本地哈希表的唯一方法，您可以参考 ObjectOutputStream 的 java 源代码以了解 reset() 中发生的详细信息，否则您最终会得到 OutOfMemoryError

但是你可以很好地实现一个像

private void writeObject(Object obj, ObjectOutputStream oos) throws IOException
    {
        synchronized(oos)
        {
            oos.writeObject(obj);
            oos.flush();
            oos.reset();
        }
    }

但是，您必须确保对 ObjectOutputStream 的所有写入都通过此方法进行。

于 2012-09-20T18:00:27.830 回答
1

我找到的唯一解决方案是，首先启动一个发送线程，检查线程池是否为空，在这种情况下我重置输出流。我整晚都在运行该软件来检查这一点。

谢谢大家！

马泰奥

于 2012-09-20T13:22:46.093 回答
0

我会ObjectOutputStream.reset()定期使用来清除流的对象缓存。

您甚至可以在发送每个对象后使用它。;)

于 2012-09-20T09:16:59.223 回答
0

再见 ：），

在 ObjectOutputStream.flush() 之后，您可以安全地使用 ObjectOutputStream.reset()

除非您在另一个线程中使用 objWriter somwhere 而不使用同步 (objWriter) 语句。在这种情况下，恕我直言，最好的方法是在线程中使用 objWriter，它将从同步队列发送对象（请参阅队列子类http://docs.oracle.com/javase/1.5.0/docs/api/ java/util/Queue.html，例如http://docs.oracle.com/javase/1.5.0/docs/api/java/util/concurrent/ConcurrentLinkedQueue.html）从另一个线程填充（记住使用 object.clone()，因为 objcet 本身没有同步，它可以在你写它或在队列中被其他线程修改！如果你克隆它，你的克隆将是一个安全副本）。

这样你就不需要同步语句，因为线程和 ObjectOutputStream 之间的数据流已经同步了，你会更不容易出错

于 2012-09-20T10:00:17.277 回答