Android WorkManager能否向周期运行的Worker传参，如何复用其中的WebSocket发消息？

• WorkManager 不支持向已经处于运行状态的Worker动态传递参数，Data 只能在构造 WorkRequest 入队时传入，运行中的周期任务无法接收新的输入参数。
• 你当前的 WebSocketWorker 实现存在先天缺陷：doWork 方法创建WebSocket后直接返回了 Result.success()，系统会认为本次周期任务执行完成，Worker实例会被销毁，你创建的WebSocket没有被任何实例持有，虽然OkHttp会维持连接一段时间，但随时可能因为进程优先级降低被系统回收，你也完全没有途径拿到这个连接的引用。

方案一：使用前台Service+单例WebSocket管理器（推荐，适合实时聊天、频繁发消息场景） #

长连接本身不适合用WorkManager实现，WorkManager的定位是处理可延迟、不需要实时交互的异步任务，常驻长连接应该用前台Service保证进程优先级，同时用单例管理器持有WebSocket实例，全应用复用连接。

实现步骤： #

1. 实现单例WebSocket管理类，统一维护连接状态和发送逻辑：

@Singleton
class WebSocketManager @Inject constructor() {
    private var webSocket: WebSocket? = null
    private val client = OkHttpClient()

    inner class MyWebSocketListener : WebSocketListener() {
        override fun onMessage(webSocket: WebSocket, text: String) {
            Timber.d("收到消息: %s", text)
            // 可在此处将消息通过SharedFlow/EventBus等方式通知到UI层
        }

        override fun onFailure(webSocket: WebSocket, t: Throwable, response: Response?) {
            t.localizedMessage?.let { Timber.e("连接失败: %s", it) }
            this@WebSocketManager.webSocket = null
            // 可在此处添加重连逻辑
        }

        override fun onOpen(webSocket: WebSocket, response: Response) {
            this@WebSocketManager.webSocket = webSocket
        }

        override fun onClosed(webSocket: WebSocket, code: Int, reason: String) {
            this@WebSocketManager.webSocket = null
        }
    }

    // 建立连接，可在前台Service启动时调用
    fun connect() {
        if (webSocket != null) return
        val request = Request.Builder().url("ws://***.***.**.***:8000/ws/chat/lobby/").build()
        client.newWebSocket(request, MyWebSocketListener())
    }

    // 发送消息，UI层和其他组件可直接调用
    fun sendMessage(message: String): Boolean {
        return webSocket?.send(message) ?: false
    }

    // 断开连接，Service销毁时调用
    fun disconnect() {
        webSocket?.close(1000, "主动断开连接")
        webSocket = null
    }
}

2. 实现前台Service，在Service中调用connect方法维持连接，启动时设置前台通知保证进程优先级。
3. UI层发送消息直接调用单例的sendMessage方法即可：

// 注入单例管理器，如果你用Hilt的话直接加这个注解即可
@Inject
lateinit var webSocketManager: WebSocketManager

binding.sendButton.setOnClickListener {
    val message = binding.chatMessageEditText.text.toString()
    if(message.isNotEmpty()) {
        val sendSuccess = webSocketManager.sendMessage(message)
        if (sendSuccess) {
            binding.chatMessageEditText.text.clear()
        } else {
            // 连接未建立时可以先缓存消息，等连接恢复后再发送
            Toast.makeText(this, "当前连接未建立，消息已缓存", Toast.LENGTH_SHORT).show()
        }
    }
}

方案二：使用一次性Worker发送消息（适合低频率发消息场景） #

如果你不需要实时接收消息，只是偶尔发送消息，可以采用每次发送新建连接的方式，无需复用长连接。

实现步骤： #

1. 实现发送消息的一次性Worker：

@HiltWorker
class SendMessageWorker @AssistedInject constructor(
    @Assisted appContext: Context,
    @Assisted workerParams: WorkerParameters
) : CoroutineWorker(appContext, workerParams) {
    override suspend fun doWork(): Result {
        val message = inputData.getString("MESSAGE_KEY") ?: return Result.failure()
        return try {
            val request = Request.Builder().url("ws://***.***.**.***:8000/ws/chat/lobby/").build()
            val client = OkHttpClient()
            client.newWebSocket(request, object : WebSocketListener() {
                override fun onOpen(webSocket: WebSocket, response: Response) {
                    // 连接建立成功后发送消息，发送完断开连接
                    webSocket.send(message)
                    webSocket.close(1000, "消息发送完成")
                }
            })
            Result.success()
        } catch (e: Throwable) {
            Timber.e("消息发送失败: %s", e.localizedMessage)
            Result.failure()
        }
    }
}

2. 点击发送按钮时构造一次性WorkRequest传入消息参数，入队执行：

binding.sendButton.setOnClickListener {
    val message = binding.chatMessageEditText.text.toString()
    if(message.isNotEmpty()) {
        // 构造输入参数
        val inputData = Data.Builder()
            .putString("MESSAGE_KEY", message)
            .build()
        // 创建一次性任务
        val sendWork = OneTimeWorkRequestBuilder<SendMessageWorker>()
            .setInputData(inputData)
            .build()
        // 入队执行
        WorkManager.getInstance(this).enqueue(sendWork)
        binding.chatMessageEditText.text.clear()
    }
}

内容的提问来源于stack exchange，提问作者abdullah celik