我希望我的應用程式在使用 workmanager 時在后臺讀取電子郵件并發送通知，我的作業經理在執行幾次后停止作業，在后臺任務上拋出 NetworkOnMainThreadException：我想制作一個可靠的應用程式，用于為新收到的電子郵件發送通知意味著我需要它每 15 分鐘永遠執行一次。你知道我怎樣才能避免這個問題嗎？
作業管理器類：
class WorkerMan(private val mContext: Context, workerParameters: WorkerParameters) :
Worker(mContext, workerParameters) {
@SuppressLint("RestrictedApi", "CheckResult")
val email = inputData.getString("email")
val password = inputData.getString("password")
@SuppressLint("RestrictedApi")
override fun doWork(): Result {
println("WorkManager: Work called")
println("WorkMananager time: " LocalTime.now())
try {
// Thread.sleep(5000)
val session = Session.getDefaultInstance(Properties())
val store = session.getStore("imaps")
store.connect(
"mail.metropolitan.ac.rs",
993,
email,
password
)
val inbox = store.getFolder("INBOX")
inbox.open(Folder.READ_ONLY)
val messages = inbox.search(
FlagTerm(Flags(Flags.Flag.SEEN), false)
)
Arrays.sort(
messages
) { m1: Message, m2: Message ->
try {
return@sort m2.sentDate.compareTo(m1.sentDate)
} catch (e: MessagingException) {
throw RuntimeException(e)
}
}
Thread.sleep(1000)
println("- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - ")
println("WorkManager Started")
println("WorkMananager email: " email)
val current = LocalTime.now()
println("WorkMananager time: " current)
println("Messages amount: " messages.size)
println("- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - ")
for (message in messages) {
// if (message.receivedDate.toInstant() >= Instant.now().minusMillis(1000 * 33 * 60)) {
if (true) {
// Thread.sleep(3000)
println("=====================================================")
println("NOTIFIKACIJA")
var title = ""
for (element in message.from) {
title = element.toString().substringAfter("<").substringBefore(">")
title = " "
}
println("Title :" title)
println("Subject :" message.subject)
println("Datum i vreme : " message.receivedDate)
title.replace("[", "")
title.replace("]", "")
FirebaseMessaging.getInstance().token.addOnSuccessListener { token: String ->
if (!TextUtils.isEmpty(token)) {
Log.d("TAG", "retrieve token successful : $token")
try {
send(token, message.subject, title)
} catch (e: MessagingException) {
e.printStackTrace()
}
} else {
Log.w("TAG", "token should not be null...")
}
}.addOnFailureListener { e: Exception? -> }.addOnCanceledListener {}
.addOnCompleteListener { task: Task<String> ->
Log.v(
"TAG",
"This is the token : " task.result
)
}
//
}
}
println("=====================================================")
Log.d("WorkManager", "Job finished")
}catch (e : Exception){
Log.d("WorkManager error", "doWork not executed")
Log.d("WorkManager error", "error: ")
Log.d("WorkManager error", e.printStackTrace().toString())
}
return Result.Success();
}
}
fun send(to: String?, body: String?, title: String?): String? {
try {
val apiKey =
"AAAA_Xfga4Q:APA91bH1cASekbIF7zSiqVkOtEJdQX2-qLO6yJp_iiTzYetdy6pRBl-uq28a27sdzDUvAUI51XO7IQaiKk_eccW0fTeFj8-4z7236mzoFaniTPMYR4Xmhzn5RYkAh-ON3tXKnELu7IEC"
val url = URL("https://fcm.googleapis.com/fcm/send")
val conn = url.openConnection() as HttpURLConnection
conn.doOutput = true
conn.requestMethod = "POST"
conn.setRequestProperty("Content-Type", "application/json")
conn.setRequestProperty("Authorization", "key=$apiKey")
conn.doOutput = true
val message = JSONObject()
message.put("to", to)
message.put("priority", "high")
val notification = JSONObject()
notification.put("title", title)
notification.put("body", body)
message.put("notification", notification)
val os = conn.outputStream
os.write(message.toString().toByteArray())
os.flush()
os.close()
val responseCode = conn.responseCode
println("\nSending 'POST' request to URL : $url")
println("Post parameters : $message")
println("Response Code : $responseCode")
println("Response Code : " conn.responseMessage)
val `in` = BufferedReader(InputStreamReader(conn.inputStream))
var inputLine: String?
val response = StringBuffer()
while (`in`.readLine().also { inputLine = it } != null) {
response.append(inputLine)
}
`in`.close()
// print result
println(response.toString())
return response.toString()
} catch (e: Exception) {
Log.d("WorkManager error", "send not executed")
Log.d("WorkManager error", "error: ")
Log.d("WorkManager error", e.printStackTrace().toString())
}
return "error"
}
調度作業管理器的功能：
@SuppressLint("RestrictedApi")
private fun startWorker(email: String, password: String) {
if (enableMailNotifications == 1) {
// val constraints = Constraints.Builder()
// .setRequiredNetworkType(NetworkType.CONNECTED).build()
val data = Data.Builder()
data.put("email", email)
data.put("password", password)
val build: PeriodicWorkRequest = PeriodicWorkRequest.Builder(
WorkerMan::class.java,
15,
TimeUnit.MINUTES,
15,
TimeUnit.MINUTES,
)
.addTag("WorkManager")
.setInputData(data.build())
// .setConstraints(constraints)
.build()
WorkManager.getInstance(this)
.enqueueUniquePeriodicWork("WorkManager", ExistingPeriodicWorkPolicy.REPLACE, build)
}else{
println("WorkManager not called: Mail Notifications are turned off")
}
}
編輯：完整的堆疊跟蹤：
pastebin.com/BVxyA4uF pastebin.com/ujYtNu60
uj5u.com熱心網友回復：
我通過呼叫解決了一個問題
FirebaseMessaging.getInstance().token.addOnSuccessListener
在 MainActivity 中并將令牌作為 WorkManager 的 inputData 傳遞。
data.put("token", token)
并通過以下方式在 WorkManager 類中檢索它：
val token = inputData.getString("token")
轉載請註明出處，本文鏈接：https://www.uj5u.com/qiye/401984.html