Android：为何Application类中无法正确关闭WebSocket连接？

核心问题排查 #

1. onResume逻辑完全倒置 #

你当前的onResume方法判断逻辑写反了：

@OnLifecycleEvent(Lifecycle.Event.ON_RESUME)
public void onResume() {
    if (webSocket == null) return;
    connect();
}

这段代码的意思是如果没有WebSocket连接，就什么都不做，和你预期的「前台时建立连接」完全相反，导致应用回到前台时根本不会触发连接建立。

2. 主动关闭时的异步处理问题 #

OkHttp的webSocket.close()是异步操作，你直接在disconnect里把webSocket设为null，可能导致关闭帧还没发送完成就丢失引用，服务端无法收到正确的关闭信号。

3. ProcessLifecycleOwner事件触发依赖缺失（可能） #

如果你的项目没有添加lifecycle-process依赖，ProcessLifecycleOwner的生命周期事件不会正常触发，导致onPause/onDestroy根本没被调用。

修正后的完整代码 #

public class Main extends Application implements LifecycleObserver {

    private static WeakReference<Context> context;
    private WebSocket webSocket;
    private OkHttpClient client;
    private Request request;
    public static final int SOCKET_CLOSE_CODE = 1000;

    @Override
    public void onCreate() {
        super.onCreate();
        context = new WeakReference<>(getApplicationContext());
        ProcessLifecycleOwner.get().getLifecycle().addObserver(this);
        // 初始化OkHttpClient，添加超时配置避免连接残留
        this.client = new OkHttpClient.Builder()
                .pingInterval(10, TimeUnit.SECONDS) // 心跳包维持连接，同时检测死连接
                .build();
        this.request = new Request.Builder().url("ws://192.168.1.9:8080").build();
    }

    public void connect() {
        // 避免重复创建连接
        if (webSocket != null && webSocket.send("").isSuccessful()) {
            return;
        }
        webSocket = client.newWebSocket(request, new WebSocketListener() {
            @Override
            public void onOpen(WebSocket webSocket, Response response) {
                super.onOpen(webSocket, response);
                // 连接建立成功的回调逻辑
            }

            @Override
            public void onMessage(WebSocket webSocket, String text) {
                super.onMessage(webSocket, text);
                // 处理文本消息
            }

            @Override
            public void onClosing(WebSocket webSocket, int code, String reason) {
                // 服务端发起关闭，客户端必须回应关闭帧
                webSocket.close(code, reason);
                super.onClosing(webSocket, code, reason);
            }

            @Override
            public void onClosed(WebSocket webSocket, int code, String reason) {
                super.onClosed(webSocket, code, reason);
                // 连接真正关闭后再置空引用
                Main.this.webSocket = null;
            }

            @Override
            public void onFailure(WebSocket webSocket, Throwable t, Response response) {
                super.onFailure(webSocket, t, response);
                // 连接失败时自动清理引用
                Main.this.webSocket = null;
            }
        });
    }

    @OnLifecycleEvent(Lifecycle.Event.ON_RESUME)
    public void onAppResume() {
        // 前台时，没有连接则建立
        if (webSocket == null) {
            connect();
        }
    }

    @OnLifecycleEvent(Lifecycle.Event.ON_PAUSE)
    public void onAppPause() {
        // 后台时主动关闭连接
        if (webSocket != null) {
            disconnect();
        }
    }
    
    private void disconnect() {
        // 发送关闭帧，异步等待onClosed回调置空
        webSocket.close(SOCKET_CLOSE_CODE, "App entered background");
        // 不要在这里直接置空webSocket，交给onClosed处理
    }

    @OnLifecycleEvent(Lifecycle.Event.ON_DESTROY)
    public void onAppDestroy() {
        if (client != null) {
            // 彻底清理OkHttp资源
            client.dispatcher().executorService().shutdownNow();
            client.connectionPool().evictAll();
            // 关闭所有剩余连接
            if (webSocket != null) {
                webSocket.cancel();
                webSocket = null;
            }
        }
    }
}

关键修正点说明 #

• 修正onResume逻辑：改为「没有连接时才建立连接」，确保应用回到前台时自动恢复WebSocket连接。
• 异步关闭处理：将webSocket置空操作移到onClosed回调中，保证关闭帧发送完成后再清理引用，服务端能正确收到关闭信号。
• 添加心跳配置：通过pingInterval配置心跳包，既能维持长连接，也能及时检测死连接，避免无效连接残留。
• 完善资源清理：在onAppDestroy中调用shutdownNow()强制终止OkHttp的线程池，同时调用cancel()强制关闭WebSocket，确保应用销毁时彻底清理所有连接资源。
• 避免重复连接：在connect方法中先检查当前连接是否可用，避免重复创建WebSocket实例。

依赖检查 #

确保你的build.gradle（Module级别）中添加了ProcessLifecycleOwner的依赖：

dependencies {
    implementation "androidx.lifecycle:lifecycle-process:2.6.1"
    implementation "com.squareup.okhttp3:okhttp:4.11.0"
}

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