Websockets
In addition to using RPC-style interfaces, KVision support two-way type-safe connections via websockets, based on Kotlin coroutines channels.
Common code
The way the websocket connections are defined is in many ways similar to defining remote methods (see previous chapters). You start by declaring two interface methods in the common code, which will be used in the frontend and backend parts. The methods needs to have specific signatures:
When you establish the websocket connection, you will be able to send objects of type M
from the client to the server and send objects of type N
from the server to the client. Both types M
and N
need to fulfill the criteria described in this chapter. Of course type M
can be the same as N
.
Both methods need to have the same name and both should have default, empty implementations in the interface.
Frontend application
To actually create a websocket connection, you call the second method. When the method is called, the connection is established and it lasts as long as the method is running. The connection is terminated when the method is finished. It's a suspending method, so you can easily use loops (even while(true)
) and structured concurrency with coroutineScope
builders.
Backend code
On the backend side you just have to implement the first interface method. It will be automatically called when a new client is connected, and it should run as long as the connection is active.
Of course the server can send data to the output channel at any time. So you can even ignore the input at all.
If you want to have more control over the client connection and more information about it, you can inject WebSocketServerSession
when using Ktor module. This object gives you access to, among others, the ApplicationCall
object.
When using Spring Boot module, you can autowire WebSocketSession
object.
When using Javalin, you can inject WsContext
and WsSession
objects.
With Micronaut you can inject WebSocketSession
object.
Disconnection
When the user leaves or closes the browser page the websocket connection is closed. On the backend side you will find both input and output channels closed and then you should return from the backend method.
On the other hand, when the server is stopped the connection is closed as well. But on the frontend side you have the possibility to re-establish the connection when the server is online again. Just run your frontend method again after a few seconds.
Last updated