文章目錄

• 一、添加依賴和權限
• 二、創建 WebSocketClient 客戶端類
• 三、建立連接并發送消息

使用 https://github.com/TooTallNate/Java-WebSocket 框架 ;

一、添加依賴和權限

---

在 build.gradle 構建腳本中 , 添加依賴 :

implementation 'org.java-websocket:Java-WebSocket:1.5.2'

在 AndroidManifest.xml 清單文件中 , 添加網絡權限 :

<uses-permission android:name="android.permission.INTERNET" />

二、創建 WebSocketClient 客戶端類

---

創建 org.java_websocket.client.WebSocketClient 子類 ;

package kim.hsl.websocketdemoimport android.util.Log import org.java_websocket.client.WebSocketClient import org.java_websocket.handshake.ServerHandshake import java.lang.Exception import java.net.URIopen class MyWebSocketClient(serverUri: URI?) : WebSocketClient(serverUri) {val TAG = "MyWebSocketClient"override fun onOpen(handshakedata: ServerHandshake?) {Log.i(TAG, "onOpen handshakedata=$handshakedata")}override fun onMessage(message: String?) {Log.i(TAG, "onMessage message=$message")}override fun onClose(code: Int, reason: String?, remote: Boolean) {Log.i(TAG, "onClose code=$code reason=$reason remote=$remote")}override fun onError(ex: Exception?) {Log.i(TAG, "onError ex=$ex")} }

三、建立連接并發送消息

---

創建 客戶端 對象 : 設置 WebSocket 地址 , 使用匿名內部類的方式實現 , 主要是為了在本類中獲取 onMessage 方法中接收的來自服務器端的消息 ;

var uri: URI? = URI.create("ws://***自己實現服務器端***") var client: MyWebSocketClient = object : MyWebSocketClient(uri){override fun onMessage(message: String?) {super.onMessage(message)} }

連接服務器 : 調用 org.java_websocket.client.WebSocketClient 的 connectBlocking() 函數 , 即可連接遠程服務器并阻塞該線程 , 服務器連接成功后 , 會回調該類的 onOpen 方法 , 并解除阻塞 ;

client.connectBlocking()

向服務器發送數據 : 調用 org.java_websocket.client.WebSocketClient 的 send() 函數 , 即可向遠程服務器發送消息 , 回送的消息在 onMessage 回調方法中的 message: String? 參數可以獲取到 ;

client.send("**自定義消息**")

完整代碼如下 :

package kim.hsl.websocketdemoimport androidx.appcompat.app.AppCompatActivity import android.os.Bundle import java.net.URIclass MainActivity : AppCompatActivity() {override fun onCreate(savedInstanceState: Bundle?) {super.onCreate(savedInstanceState)setContentView(R.layout.activity_main)// 服務器端 WebSocket 地址var uri: URI? = URI.create("ws://***自己實現服務器端***")// 創建客戶端對象var client: MyWebSocketClient = object : MyWebSocketClient(uri){override fun onMessage(message: String?) {super.onMessage(message)}}// 連接遠程服務器client.connectBlocking()// 發送消息client.send("**自定義消息**")} }

執行結果如下 :

總結

以上是生活随笔為你收集整理的【Android WebSocket】Android 端 WebSocket 基本用法 ( 添加依赖和权限 | 创建 WebSocketClient 客户端类 | 建立连接并发送消息 )的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。