无法使用Tinder Scarlet连接到% ws

Question

正在尝试测试与% ws的连接，但服务器看不到任何连接。我想我错过了什么，你能告诉我我错过了什么吗？

日志：

D/Connection$ Connect :应该连接

D/连接$connect: WaitingToRetry

D/ Connection $connect:在WebSocket连接上失败

D/Connection$ Connect :应该连接

D/连接$connect: WaitingToRetry

D/ Connection $connect:在WebSocket连接上失败

下面是我的代码：

在MainActivity中

override fun onCreate(savedInstanceState: Bundle?) {
    super.onCreate(savedInstanceState)
    setContentView(R.layout.activity_main)

    Connection.connect()
}

对象(单例)

object Connection {
    fun connect() {

        val okHttpClient = OkHttpClient.Builder()
            .readTimeout(0, TimeUnit.MILLISECONDS)
            .build()

        val protocol = OkHttpWebSocket(
            okHttpClient,
            OkHttpWebSocket.SimpleRequestFactory(
                { Request.Builder().url("ws://someURL").build() },
                { ShutdownReason.GRACEFUL }
            )
        )

        val configuration = Scarlet.Configuration(
            streamAdapterFactories = listOf(RxJava2StreamAdapterFactory())
        )

        val scarletInstance = Scarlet(protocol, configuration)

        val webSocketService = scarletInstance.create<WebSocketService>()

    webSocketService.observeStateTransition()
        .observeOn(Schedulers.io())
        .subscribe({ stateTransition ->
            val event = stateTransition.event
            val description = when (event) {
                is Event.OnLifecycleStateChange -> when (event.lifecycleState) {
                    LifecycleState.Started -> Timber.d("On Lifecycle Start")
                    LifecycleState.Stopped -> Timber.d("On Lifecycle Stop")
                    LifecycleState.Completed -> Timber.d("On Lifecycle Terminate")
                }
                is Event.OnProtocolEvent -> {
                    when (stateTransition.toState) {
                        is State.WillConnect -> Timber.d("WaitingToRetry")
                        is State.Connecting -> Timber.d("Connecting")
                        is State.Connected -> Timber.d("Connected")
                        is State.Disconnecting -> Timber.d("Disconnecting")
                        State.Disconnected -> Timber.d("Disconnected")
                        State.Destroyed -> Timber.d("Destroyed")
                    }
                }
                Event.OnShouldConnect -> Timber.d("Should Connect")
            }
        }, {
            e ->
            Timber.e(e)
        })

    webSocketService.observeWebSocketEvent()
        .observeOn(Schedulers.io())
        .subscribe({
            event ->
            val description = when(event){
                is WebSocketEvent.OnConnectionOpened -> Timber.d("On WebSocket Connection Opened")
                is WebSocketEvent.OnMessageReceived -> Timber.d("On WebSocket NewMessageUpdate Received")
                is WebSocketEvent.OnConnectionClosing -> Timber.d("On WebSocket Connection Closing")
                is WebSocketEvent.OnConnectionClosed -> Timber.d("On WebSocket Connection Closed")
                is WebSocketEvent.OnConnectionFailed -> Timber.d("On WebSocket Connection Failed")
            }
        },
            {
                Timber.e(it)
            })


    }
}

接口

interface WebSocketService {
@Receive
fun observeStateTransition(): Flowable<StateTransition>

@Receive
fun observeWebSocketEvent(): Flowable<WebSocketEvent>
}

Answer 1

通过将android:usesCleartextTraffic="true"添加到清单文件中，您可以通过WS://实际使用Scarlet。

Answer 2

问题是我使用的是ws://，但我认识到Scarlet只适用于wss:/