一、添加依赖和权限

在 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 客户端类 | 建立连接并发送消息 )相关推荐

【Android WebSocket】Android 端 WebSocket 基本用法 ( 下载 Java-WebSocket源码 | 导入 Java-WebSocket-1.5.2 工程作为依赖 )
文章目录一.下载 Java-WebSocket 源码二.Android Studio 工程导入 Java-WebSocket 源码使用 https://github.com/TooTallNat ...
vue项目使用webSocket前后端建立连接推送消息
<!DOCTYPE html> <html> <head><meta charset="utf-8"><title>we ...
kafka服务端版本号0.10.2，客户端版本号2.0 如何发送消息
项目中用到kafka,应用作为生产者,发送消息时,报错: Magic v1 does not support record headers 网上也有很多同样的博客记录这个错误,如:https://zh ...
【Android 应用开发】Google 官方 EasyPermissions 权限申请库 ( 简介 | 权限申请处理细节 | 添加依赖 | 界面权限申请结果处理 | 权限申请结果回调接口 )
文章目录一.EasyPermissions 简介二.EasyPermissions 权限申请处理细节三.添加 EasyPermissions 依赖四.权限申请结果处理方法 onRequest ...
Android Studio 解决 Cannot resolve symbol xxx 添加依赖后出现飘红
这里博主分享下自己在Android Studio中遇到"Cannot resolve symbol 'xxx'"的解决方法,希望对大家有所帮助. 1.将有问题的依赖注释掉(ctrl ...
Android之在一个类里面注册Handler发送消息在另外一个类里面接收消息
1.问题我们要在一个类里面变量或者函数变化需要改变另外一个类里面的东西,这个时候java里面除了接口回调之外,我们还可以用注册Handler来实现 2.代码实现 1.MainActivity.jav ...
js websocket建立连接时发送token给后端发送不了
第一种方式,是降token明文携带在url中,当然很多人可能觉得这种方法不够安全,也不够优雅. 那第二种方式就是利用子协议数组,将token携带在protocols里, var ws = new We ...
单枪匹马撸个聊天室, 支持Web/Android/iOS三端
单枪匹马撸个聊天室, 支持Web/Android/iOS三端原文地址: github.com/yinxin630/b- 前排提醒, 阅读本文需要对JavaScript较为熟悉, 本文将讲解核心功能点 ...
Spring boot 实现 WebSocket服务端
Spring boot 实现 WebSocket服务端这里写目录标题 Spring boot 实现 WebSocket服务端声明准备工作 1. 配置 2. WebSocket服务类 3. 编写客 ...

【Android WebSocket】Android 端 WebSocket 基本用法 ( 添加依赖和权限 | 创建 WebSocketClient 客户端类 | 建立连接并发送消息 )

文章目录

一、添加依赖和权限

二、创建 WebSocketClient 客户端类

三、建立连接并发送消息

【Android WebSocket】Android 端 WebSocket 基本用法 ( 添加依赖和权限 | 创建 WebSocketClient 客户端类 | 建立连接并发送消息 )相关推荐

最新文章

热门文章