Android 端 WebSocket 通信：打造实时互动的应用程序

2023-04-20 13:43:09

Android 端 WebSocket 通信：构建实时互动的应用程序

WebSocket 是一种全双工通信协议，使客户端与服务器能够进行双向通信。这使其非常适合构建实时互动的应用程序，例如聊天室、在线游戏和协作编辑工具。

在 Android 端实现 WebSocket 通信

在 Android 端实现 WebSocket 通信非常简单，只需遵循以下步骤：

添加 WebSocket 依赖库

在项目中添加 WebSocket 依赖库。您可以使用 OkHttp 或 Autobahn 等库。

dependencies {
    implementation 'com.squareup.okhttp3:okhttp:4.9.0'
}

创建 WebSocketClient 对象并连接到服务器

创建 WebSocketClient 对象并连接到服务器。

WebSocketClient webSocketClient = new WebSocketClient("ws://127.0.0.1:8080/websocket") {
    @Override
    public void onOpen(ServerHandshake serverHandshake) {
        // 服务器连接成功
    }

    @Override
    public void onMessage(String message) {
        // 从服务器接收消息
    }

    @Override
    public void onClose(int code, String reason, boolean remote) {
        // 服务器连接关闭
    }

    @Override
    public void onError(Exception ex) {
        // 服务器连接错误
    }
};

监听 WebSocketClient 对象的事件

监听 WebSocketClient 对象的事件，以便在连接成功或失败时采取相应操作。

webSocketClient.connect();

发送和接收数据

可以使用 send() 方法发送数据，并使用 onMessage() 方法接收数据。

webSocketClient.send("Hello from Android!");

示例代码

以下是一个使用 WebSocket 进行通信的示例代码：

import android.os.Bundle;
import android.util.Log;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;
import androidx.appcompat.app.AppCompatActivity;
import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake;

public class MainActivity extends AppCompatActivity {

    private WebSocketClient webSocketClient;
    private EditText messageEditText;
    private Button sendButton;
    private TextView responseTextView;

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

        messageEditText = findViewById(R.id.message_edit_text);
        sendButton = findViewById(R.id.send_button);
        responseTextView = findViewById(R.id.response_text_view);

        webSocketClient = new WebSocketClient("ws://127.0.0.1:8080/websocket") {
            @Override
            public void onOpen(ServerHandshake serverHandshake) {
                Log.i("WebSocket", "Opened");
            }

            @Override
            public void onMessage(String message) {
                Log.i("WebSocket", "Received: " + message);
                responseTextView.setText(message);
            }

            @Override
            public void onClose(int code, String reason, boolean remote) {
                Log.i("WebSocket", "Closed");
            }

            @Override
            public void onError(Exception ex) {
                Log.e("WebSocket", "Error", ex);
            }
        };

        sendButton.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View view) {
                String message = messageEditText.getText().toString();
                webSocketClient.send(message);
            }
        });

        webSocketClient.connect();
    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
        webSocketClient.close();
    }
}