Added RSocketClientTransportFactory and RSocketClientTransportFactory

Author: artem-v

services-examples-parent/services-examples-runner/src/main/java/io/scalecube/services/examples/ExamplesRunner.java

@@ -15,6 +15,7 @@
 import io.scalecube.services.discovery.ScalecubeServiceDiscovery;
 import io.scalecube.services.discovery.api.ServiceDiscovery;
 import io.scalecube.services.transport.rsocket.RSocketServiceTransport;
+import java.net.InetSocketAddress;
 import java.nio.file.Path;
 import java.util.List;
 import java.util.Optional;
@@ -76,9 +77,10 @@ public static void main(String[] args) {
                                 () ->
                                     TcpServerTransport.create(
                                         TcpServer.create()
-                                            .wiretap(false)
-                                            .port(config.servicePort())
+                                            .bindAddress(
+                                                () -> new InetSocketAddress(config.servicePort()))
                                             .runOn(loopResources)
+                                            .wiretap(false)
                                             .noSSL())))
             .services(new BenchmarkServiceImpl(), new GreetingServiceImpl())
             .startAwait();

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

@@ -36,8 +36,8 @@ public RSocketServerTransport(
 
   @Override
   public Address address() {
-    InetSocketAddress address = serverChannel.address();
-    return Address.create(address.getHostString(), address.getPort());
+    InetSocketAddress socketAddress = serverChannel.address();
+    return Address.create(socketAddress.getAddress().getHostAddress(), socketAddress.getPort());
   }
 
   @Override

services/src/main/java/io/scalecube/services/Microservices.java

@@ -29,6 +29,8 @@
 import io.scalecube.services.transport.api.ServiceMessageDataDecoder;
 import io.scalecube.services.transport.api.ServiceTransport;
 import java.lang.management.ManagementFactory;
+import java.net.InetAddress;
+import java.net.UnknownHostException;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collections;
@@ -53,6 +55,7 @@
 import org.slf4j.LoggerFactory;
 import reactor.core.Disposable;
 import reactor.core.Disposables;
+import reactor.core.Exceptions;
 import reactor.core.publisher.DirectProcessor;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.FluxSink;
@@ -790,10 +793,7 @@ private Mono<ServiceTransportBootstrap> start(Microservices microservices) {
           .doOnSuccess(transport -> serverTransport = transport)
           .map(
               transport -> {
-                this.transportAddress =
-                    Address.create(
-                        Address.getLocalIpAddress().getHostAddress(),
-                        serverTransport.address().port());
+                this.transportAddress = prepareAddress(serverTransport.address());
                 this.clientTransport = serviceTransport.clientTransport();
                 return this;
               })
@@ -804,7 +804,7 @@ private Mono<ServiceTransportBootstrap> start(Microservices microservices) {
                   LOGGER.info(
                       "[{}][serviceTransport][start] Started, address: {}",
                       microservices.id(),
-                      this.transportAddress))
+                      this.serverTransport.address()))
           .doOnError(
               ex ->
                   LOGGER.error(
@@ -813,6 +813,20 @@ private Mono<ServiceTransportBootstrap> start(Microservices microservices) {
                       ex.toString()));
     }
 
+    private static Address prepareAddress(Address address) {
+      final InetAddress inetAddress;
+      try {
+        inetAddress = InetAddress.getByName(address.host());
+      } catch (UnknownHostException e) {
+        throw Exceptions.propagate(e);
+      }
+      if (inetAddress.isAnyLocalAddress()) {
+        return Address.create(Address.getLocalIpAddress().getHostAddress(), address.port());
+      } else {
+        return Address.create(inetAddress.getHostAddress(), address.port());
+      }
+    }
+
     private Mono<Void> shutdown() {
       return Mono.defer(
           () ->