接收大量FCM消息时内存泄漏

Question

我们目前正在开发一款使用Pusher Beams的kotlin应用程序。它运行得非常好，直到每秒收到一定数量的通知(4+(。然后通常会失败，只有以下两个例外之一：

Fatal Exception: java.lang.OutOfMemoryError: Could not allocate JNI Env
at java.lang.Thread.nativeCreate(Thread.java)
at java.lang.Thread.start(Thread.java:730)
at java.util.concurrent.ThreadPoolExecutor.addWorker(ThreadPoolExecutor.java:941)
at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1359)
at okhttp3.ConnectionPool.put(ConnectionPool.java:153)

或

Fatal Exception: android.database.CursorWindowAllocationException: Cursor window allocation of 2048 kb failed. 
at android.database.CursorWindow.<init>(CursorWindow.java:108)
at android.database.AbstractWindowedCursor.clearOrCreateWindow(AbstractWindowedCursor.java:198)
at android.database.sqlite.SQLiteCursor.fillWindow(SQLiteCursor.java:138)
at android.database.sqlite.SQLiteCursor.getCount(SQLiteCursor.java:132)

由于这两个异常似乎都拒绝分配更多内存，我们使用Profiler分析了该应用程序。在那里，消费看起来很稳定，直到崩溃。此外，LeakCanary没有报告任何(已知(泄漏。。。只有MessagingService的实例和okhttp的连接似乎存活/打开的时间超过了必要的时间。

这里是我的服务片段：

class NotificationService : MessagingService() {
...
override fun onMessageReceived(remoteMessage: RemoteMessage) {
val data = remoteMessage.data
if(data.containsKey("action")){
val action = data["action"].toString()
if(action == "ticketUpdate"){
val json = Json(JsonConfiguration.Stable)
val tickets: List<Ticket> = json.parse(Ticket.serializer().list, data["tickets"].toString())
val ticketIterator = tickets.iterator()
ticketIterator.forEach { ticket ->
ticketHelper.updateTicket(ticket)
}
}
}
}
}

• 我们是否错误地处理传入消息
• 如何继续调试此问题
• 我没有发现fcm消息的吞吐量有任何限制。推进器部分是否存在任何已知问题

Answer 1

花了一段时间，但解决了我的问题：

https://github.com/pusher/push-notifications-android/pull/106