Made websocket rsocket transport to be default service-transport implementation

Author: artem-v

services-transport-parent/services-transport-rsocket/src/main/java/io/scalecube/services/transport/rsocket/RSocketClientTransportFactory.java

@@ -1,9 +1,12 @@
 package io.scalecube.services.transport.rsocket;
 
+import io.netty.channel.ChannelOption;
 import io.rsocket.transport.ClientTransport;
 import io.rsocket.transport.netty.client.TcpClientTransport;
+import io.rsocket.transport.netty.client.WebsocketClientTransport;
 import io.scalecube.net.Address;
 import java.util.function.Function;
+import reactor.netty.http.client.HttpClient;
 import reactor.netty.resources.LoopResources;
 import reactor.netty.tcp.TcpClient;
 
@@ -26,5 +29,29 @@ static Function<LoopResources, RSocketClientTransportFactory> tcp() {
                         .runOn(loopResources));
   }
 
+  /**
+   * Returns default rsocket websocket client transport factory.
+   *
+   * @see WebsocketClientTransport
+   * @return factory function for {@link RSocketClientTransportFactory}
+   */
+  static Function<LoopResources, RSocketClientTransportFactory> websocket() {
+    return (LoopResources loopResources) ->
+        (RSocketClientTransportFactory)
+            address ->
+                WebsocketClientTransport.create(
+                    HttpClient.newConnection()
+                        .tcpConfiguration(
+                            tcpClient ->
+                                tcpClient
+                                    .runOn(loopResources)
+                                    .host(address.host())
+                                    .port(address.port())
+                                    .option(ChannelOption.TCP_NODELAY, true)
+                                    .option(ChannelOption.SO_KEEPALIVE, true)
+                                    .option(ChannelOption.SO_REUSEADDR, true)),
+                    "/");
+  }
+
   ClientTransport clientTransport(Address address);
 }

services-transport-parent/services-transport-rsocket/src/main/java/io/scalecube/services/transport/rsocket/RSocketServerTransportFactory.java

@@ -1,10 +1,13 @@
 package io.scalecube.services.transport.rsocket;
 
+import io.netty.channel.ChannelOption;
 import io.rsocket.transport.ServerTransport;
 import io.rsocket.transport.netty.server.CloseableChannel;
 import io.rsocket.transport.netty.server.TcpServerTransport;
+import io.rsocket.transport.netty.server.WebsocketServerTransport;
 import java.net.InetSocketAddress;
 import java.util.function.Function;
+import reactor.netty.http.server.HttpServer;
 import reactor.netty.resources.LoopResources;
 import reactor.netty.tcp.TcpServer;
 
@@ -33,7 +36,42 @@ static Function<LoopResources, RSocketServerTransportFactory> tcp(int port) {
             TcpServerTransport.create(
                 TcpServer.create()
                     .runOn(loopResources)
-                    .bindAddress(() -> new InetSocketAddress(port)));
+                    .bindAddress(() -> new InetSocketAddress(port))
+                    .option(ChannelOption.TCP_NODELAY, true)
+                    .option(ChannelOption.SO_KEEPALIVE, true)
+                    .option(ChannelOption.SO_REUSEADDR, true));
+  }
+
+  /**
+   * Returns default rsocket websocket server transport factory (shall listen on port {@code 0}).
+   *
+   * @see WebsocketServerTransport
+   * @return factory function for {@link RSocketServerTransportFactory}
+   */
+  static Function<LoopResources, RSocketServerTransportFactory> websocket() {
+    return websocket(0);
+  }
+
+  /**
+   * Returns default rsocket websocket server transport factory.
+   *
+   * @param port port
+   * @see WebsocketServerTransport
+   * @return factory function for {@link RSocketServerTransportFactory}
+   */
+  static Function<LoopResources, RSocketServerTransportFactory> websocket(int port) {
+    return loopResources ->
+        () ->
+            WebsocketServerTransport.create(
+                HttpServer.create()
+                    .tcpConfiguration(
+                        tcpServer ->
+                            tcpServer
+                                .runOn(loopResources)
+                                .bindAddress(() -> new InetSocketAddress(port))
+                                .option(ChannelOption.TCP_NODELAY, true)
+                                .option(ChannelOption.SO_KEEPALIVE, true)
+                                .option(ChannelOption.SO_REUSEADDR, true)));
   }
 
   ServerTransport<CloseableChannel> serverTransport();

services-transport-parent/services-transport-rsocket/src/main/java/io/scalecube/services/transport/rsocket/RSocketServiceTransport.java

@@ -26,9 +26,9 @@ public class RSocketServiceTransport implements ServiceTransport {
   private HeadersCodec headersCodec;
   private Collection<DataCodec> dataCodecs;
   private Function<LoopResources, RSocketServerTransportFactory> serverTransportFactory =
-      RSocketServerTransportFactory.tcp();
+      RSocketServerTransportFactory.websocket();
   private Function<LoopResources, RSocketClientTransportFactory> clientTransportFactory =
-      RSocketClientTransportFactory.tcp();
+      RSocketClientTransportFactory.websocket();
 
   // resources
   private EventLoopGroup eventLoopGroup;