Class WebSocket

java.lang.Object
com.codename1.io.WebSocket
public final class WebSocket extends Object

Client-side WebSocket. Connections are created via build(java.lang.String) and configured with fluent handler setters before being started with connect():

WebSocket ws = WebSocket.build("wss://example.com/chat")
    .onConnect(w        -> w.send("hello"))
    .onTextMessage((w, m) -> Log.p("recv " + m))
    .onClose((w, c, r)  -> Log.p("closed " + c + " / " + r))
    .onError((w, e)     -> Log.e(e))
    .connect();

Each handler receives the WebSocket as its first argument so it can send, query state, or close without capturing an external reference.

Handlers fire on a background thread. Use Display.getInstance().callSerially(...) inside a handler if you need to touch UI from it.

Use isSupported() to check at runtime whether the current port supports WebSocket -- older ports return false and build(java.lang.String) will throw on them.

  • Method Details

    • isSupported

      public static boolean isSupported()
      Whether the current port supports WebSocket.

    • build

      public static WebSocket build(String url)
      Create an unconnected WebSocket bound to url. The URL must use the ws:// or wss:// scheme. Call connect() to start the handshake.
      Throws:
      RuntimeException - if the current port does not support WebSocket.

    • onConnect

      public WebSocket onConnect(WebSocket.ConnectHandler handler)
      Register a handler for the connection-established event. Returns this for chaining.

    • onTextMessage

      public WebSocket onTextMessage(WebSocket.TextHandler handler)
      Register a handler for incoming text frames. Returns this for chaining.

    • onBinaryMessage

      public WebSocket onBinaryMessage(WebSocket.BinaryHandler handler)
      Register a handler for incoming binary frames. Returns this for chaining.

    • onClose

      public WebSocket onClose(WebSocket.CloseHandler handler)
      Register a handler for the close event. Returns this for chaining.

    • onError

      public WebSocket onError(WebSocket.ErrorHandler handler)
      Register a handler for transport errors. Returns this for chaining.

    • subprotocols

      public WebSocket subprotocols(String... protocols)

      Offer one or more subprotocols (RFC 6455 Sec-WebSocket-Protocol), in preference order, to negotiate during the handshake. Must be called before connect(). After the connection opens, getSelectedSubprotocol() returns the one the server chose (or null). Returns this for chaining.

      WebSocket.build("wss://api.example.com/graphql")
    .subprotocols("graphql-transport-ws")
    .onConnect(w -> Log.p("using " + w.getSelectedSubprotocol()))
    .connect();

    • getSelectedSubprotocol

      public String getSelectedSubprotocol()
      The subprotocol the server selected during the handshake, or null when none was negotiated. Valid once the WebSocket.ConnectHandler has fired.

    • connect

      public WebSocket connect()
      Start the handshake using the platform default connect timeout. Returns this for chaining; success is signalled asynchronously via the registered WebSocket.ConnectHandler.

    • connect

      public WebSocket connect(int connectTimeoutMs)
      Start the handshake with an explicit connect timeout in milliseconds. 0 means "use platform default".

    • close

      public void close()
      Close the connection. Idempotent.

    • send

      public void send(String text)
      Send a text frame. Throws IllegalStateException if the connection is not WebSocketState.OPEN.

    • send

      public void send(byte[] binary)
      Send a binary frame. Throws IllegalStateException if the connection is not WebSocketState.OPEN.

    • getReadyState

      public WebSocketState getReadyState()

    • getUrl

      public String getUrl()