三分钟教你用Scarlet写一个WebSocketApp

在移动应用程序中，数据层是屏幕上显示内容的真实来源。然而，在今年早些时候在 Tinder 中集成了 WebSocket API 时，维护它成为了一个令人头疼的问题。为了在 Android 上更轻松地集成 WebSocket，Scarlet应运而生。

进贤网站制作公司哪家好，找创新互联！从网页设计、网站建设、微信开发、APP开发、成都响应式网站建设公司等网站项目制作，到程序开发，运营维护。创新互联于2013年创立到现在10年的时间，我们拥有了丰富的建站经验和运维经验，来保证我们的工作的顺利进行。专注于网站建设就选创新互联。

WebSocket 是在 Android 应用程序中实现数据层的选项之一，尤其是在应用需要实时更新数据的情况下，例如聊天、在线多人游戏和实时提要。它在客户端和服务器之间建立双向连接。当连接打开时，它们可以以低开销来回发送文本和二进制消息。本文将教大家如何在Android应用中快速实现WebSocket。

设置

要实现 Scarlet，首先将其添加到 app/build.gradle 文件。

  
 
 
 
   
  
  
  dependencies {
   
  
  
      ...
   
  
  
      // scarlet
   
  
  
      implementation 'com.tinder.scarlet:scarlet:0.1.12'
   
  
  
  }

在 Scarlet 提供的示例中，RxJava 用于帮助管理 Web 套接字发送的数据流。在 app/build.gradle 中实现它。

  
 
 
 
   
  
  
  dependencies {
   
  
  
       // rx
   
  
  
       implementation 'io.reactivex.rxjava2:rxjava:2.2.21'
   
  
  
       implementation 'io.reactivex.rxjava2:rxandroid:2.1.1'
   
  
  
       implementation 'io.reactivex.rxjava2:rxkotlin:2.4.0'
   
  
  
  }

如果大家对 Coroutine 和 Kotlin Flow 的支持感到好奇，请参阅此处：https : //github.com/Tinder/Scarlet/issues/114

现在我们设置的重要部分是服务。我们可以使用websocket-echo (wss://websocket-echo.glitch.me)测试我们的 WebSocket;

创建接口函数

接下来，创建一个interface以定义与 WebSocket 通信的函数。

  
 
 
 
   
  
  
  interface EchoService {
   
  
  
  
   
  
  
      @Receive
   
  
  
      fun observeConnection(): Flowable
   
  
  
  
   
  
  
      @Send
   
  
  
      fun sendMessage(param: String)
   
  
  
  }

如上所示，服务接口看起来与改造非常相似。大家可以使用@Receive注解来观察来自 WebSocket 的数据流，并用于@Send向WebSocket发送或订阅数据。

设置好服务后，我们可以继续在我们的活动中实现服务;在这种情况下，我没有使用任何架构,只是在Activity中实现了服务。

  
 
 
 
   
  
  
  class MainActivity : AppCompatActivity() {
   
  
  
      ...
   
  
  
      private fun setupWebSocketService() {
   
  
  
          webSocketService = provideWebSocketService(
   
  
  
              scarlet = provideScarlet(
   
  
  
                  client = provideOkhttp(),
   
  
  
                  lifecycle = provideLifeCycle(),
   
  
  
                  streamAdapterFactory = provideStreamAdapterFactory(),
   
  
  
              )
   
  
  
          )
   
  
  
      }
   
  
  
      
   
  
  
      private fun provideWebSocketService(scarlet: Scarlet) = scarlet.create(EchoService::class.java)
   
  
  
      
   
  
  
      private fun provideScarlet(
   
  
  
          client: OkHttpClient,
   
  
  
          lifecycle: Lifecycle,
   
  
  
          streamAdapterFactory: StreamAdapter.Factory,
   
  
  
      ) =
   
  
  
          Scarlet.Builder()
   
  
  
              .webSocketFactory(client.newWebSocketFactory(ECHO_URL))
   
  
  
              .lifecycle(lifecycle)
   
  
  
              .addStreamAdapterFactory(streamAdapterFactory)
   
  
  
              .build()
   
  
  
              
   
  
  
      private fun provideOkhttp() =
   
  
  
          OkHttpClient.Builder()
   
  
  
              .addInterceptor(HttpLoggingInterceptor().setLevel(HttpLoggingInterceptor.Level.BASIC))
   
  
  
              .build()
   
  
  
              
   
  
  
      private fun provideLifeCycle() = AndroidLifecycle.ofApplicationForeground(application)
   
  
  
      
   
  
  
      private fun provideStreamAdapterFactory() = RxJava2StreamAdapterFactory()
   
  
  
      ...
   
  
  
  }

测试

现在我们可以通过向 WebSocket 发送一些东西来测试下代码。WebSocket 将在它们检索时发送相同的消息。

  
 
 
 
   
  
  
  class MainActivity : AppCompatActivity() {
   
  
  
      ...
   
  
  
    
   
  
  
      private fun sendMessage(message: String) {
   
  
  
          webSocketService.sendMessage(message)
   
  
  
          adapter.addItem(Message(message = message, isFromSender = true))
   
  
  
      }
   
  
  
      
   
  
  
      @SuppressLint("CheckResult")
   
  
  
      private fun observeConnection() {
   
  
  
          webSocketService.observeConnection()
   
  
  
              .observeOn(AndroidSchedulers.mainThread())
   
  
  
              .subscribe({ response ->
   
  
  
                  Log.d("observeConnection", response.toString())
   
  
  
                  onReceiveResponseConnection(response)
   
  
  
              }, { error ->
   
  
  
                  Log.e("observeConnection", error.message.orEmpty())
   
  
  
                  Snackbar.make(binding.root, error.message.orEmpty(), Snackbar.LENGTH_SHORT).show()
   
  
  
              })
   
  
  
      }
   
  
  
  
   
  
  
      private fun onReceiveResponseConnection(response: WebSocket.Event) {
   
  
  
          when (response) {
   
  
  
              is OnConnectionOpened<*> -> changeToolbarTitle("connection opened")
   
  
  
              is OnConnectionClosed -> changeToolbarTitle("connection closed")
   
  
  
              is OnConnectionClosing -> changeToolbarTitle("closing connection..")
   
  
  
              is OnConnectionFailed -> changeToolbarTitle("connection failed")
   
  
  
              is OnMessageReceived -> handleOnMessageReceived(response.message)
   
  
  
          }
   
  
  
      }
   
  
  
  
   
  
  
      private fun handleOnMessageReceived(message: MessageScarlet) {
   
  
  
          adapter.addItem(Message(message.toValue(), false))
   
  
  
          binding.etMessage.setText("")
   
  
  
      }
   
  
  
  
   
  
  
      private fun MessageScarlet.toValue(): String {
   
  
  
          return when (this) {
   
  
  
              is Text -> value
   
  
  
              is Bytes -> value.toString()
   
  
  
          }
   
  
  
      }
   
  
  
      
   
  
  
      ...
   
  
  
  }

总结

这就是本文讨论的全部内容。Scarlet 是一个很棒的库，可让大家访问在 Android 应用程序中实现 WebSocket。大家可以通过以上教程轻松为自己的应用设置 Scarlet ，特别是如果已经熟悉 Retrofit 等工具。

本文标题：三分钟教你用Scarlet写一个WebSocketApp
路径分享：http://www.mswzjz.cn/qtweb/news22/211772.html

攀枝花网站建设、攀枝花网站运维推广公司-贝锐智能，是专注品牌与效果的网络营销公司；服务项目有等

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源：贝锐智能

贝锐智能技术为您推荐以下文章