如何使用Scarlet在Android上通过WebSocket连接? [英] How to connect via WebSocket on Android using Scarlet?
问题描述
README.md中的代码
Code from README.md
val scarletInstance = Scarlet.Builder()
.webSocketFactory(okHttpClient.newWebSocketFactory(GDAX_URL))
.addMessageAdapterFactory(MoshiMessageAdapter.Factory())
.addStreamAdapterFactory(RxJava2StreamAdapterFactory())
.build()
版本和依赖项:
implementation 'com.tinder.scarlet:scarlet:0.1.8'
implementation "com.github.tinder.scarlet:scarlet-websocket-okhttp:0.1.7"
implementation "com.github.tinder.scarlet:scarlet-stream-adapter-rxjava2:0.2.4"
implementation "com.github.tinder.scarlet:scarlet-message-adapter-moshi:0.2.4"
implementation "com.github.tinder.scarlet:scarlet-lifecycle-android:0.2.4"
推荐答案
首先,您应该使用接口声明一个WebSocket客户端.使用猩红色的注释(例如 @Receive
和 @Send
)定义如何处理WebSocket通信,如以下示例所示:
First of all, you should declare a WebSocket client using an interface. Use Scarlet annotations such as @Receive
and @Send
to define how you are going to handle the WebSocket communication, as the following example:
interface NewsService {
@Receive
fun observeWebSocketEvent(): Flowable<WebSocket.Event>
@Send
fun sendSubscribe(subscribe: Subscribe)
@Receive
fun observeNews(): Flowable<MyNews>
}
下一步是创建Scarlet Interface的实现,并订阅在WebSocket连接期间发出的数据流.在下面的示例中,使用了Moshi和RxJava,但是Scarlet提供了其他方式来处理和操作数据.
Next step is create an implementation of your Scarlet Interface and subscribe the data stream emitted during the WebSocket connection. In the following example , Moshi and RxJava are being used however Scarlet provide other ways to handle and manipulate the data.
val scarletInstance = Scarlet.Builder()
.webSocketFactory(okHttpClient.newWebSocketFactory(BASE_URL))
.addMessageAdapterFactory(MoshiMessageAdapter.Factory())
.addStreamAdapterFactory(RxJava2StreamAdapter.Factory())
.build()
//service created
val newsService = scarletInstance.create<NewsService>()
//define websocket event observer
newsService.observeWebSocketEvent()
.filter { it is WebSocket.Event.OnConnectionOpened<*> }
.subscribe({
newsService.sendSubscribe()
})
// news data result
newsService.observeNews()
.subscribe({ news ->
Log.d(TAG, news.toString())
})
这篇关于如何使用Scarlet在Android上通过WebSocket连接?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!