android websocket 订阅

要在Android应用中使用WebSocket进行订阅，你可以使用Java的WebSocket库，比如OkHttp或Java-WebSocket。下面是一个使用OkHttp库的示例代码：

首先，确保你的项目中已经添加了OkHttp库的依赖。

implementation 'com.squareup.okhttp3:okhttp:4.9.1'

然后，在你的代码中创建WebSocket连接并进行订阅：

import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.WebSocket;
import okhttp3.WebSocketListener;

public class MainActivity extends AppCompatActivity {
    private static final String WS_URL = "wss://example.com/socket";  // WebSocket服务器的URL

    private WebSocket webSocket;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        OkHttpClient client = new OkHttpClient();

        Request request = new Request.Builder()
                .url(WS_URL)
                .build();

        WebSocketListener listener = new WebSocketListener() {
            @Override
            public void onOpen(WebSocket webSocket, Response response) {
                // 连接成功时的处理逻辑
                Log.d("WebSocket", "连接成功");
            }

            @Override
            public void onMessage(WebSocket webSocket, String text) {
                // 接收到消息时的处理逻辑
                Log.d("WebSocket", "收到消息：" + text);
            }

            @Override
            public void onClosed(WebSocket webSocket, int code, String reason) {
                // 连接关闭时的处理逻辑
                Log.d("WebSocket", "连接关闭");
            }

            @Override
            public void onFailure(WebSocket webSocket, Throwable t, Response response) {
                // 连接失败时的处理逻辑
                Log.d("WebSocket", "连接失败：" + t.getMessage());
            }
        };

        webSocket = client.newWebSocket(request, listener);
    }
    
    @Override
    protected void onDestroy() {
        super.onDestroy();
        webSocket.close(1000, "Activity destroyed");
    }
}

以上代码创建了一个WebSocket连接，并实现了WebSocketListener接口以处理连接状态和接收到的消息。你可以根据需要自行处理WebSocket事件。

请注意，这只是一个基本示例，实际上，你需要根据你的具体需求进行订阅和消息处理。