Skip to content

Commit 37cee0b

Browse files
authored
Update NettyGrpcServerFactory.java
1 parent 4ebc963 commit 37cee0b

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

grpc-server-spring-boot-autoconfigure/src/main/java/net/devh/boot/grpc/server/serverfactory/NettyGrpcServerFactory.java

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,8 @@
3333

3434
import io.grpc.netty.GrpcSslContexts;
3535
import io.grpc.netty.NettyServerBuilder;
36+
import io.netty.channel.epoll.EpollServerDomainSocketChannel;
37+
import io.netty.channel.unix.DomainSocketAddress;
3638
import io.netty.handler.ssl.SslContextBuilder;
3739
import net.devh.boot.grpc.server.config.ClientAuth;
3840
import net.devh.boot.grpc.server.config.GrpcServerProperties;
@@ -61,7 +63,11 @@ public NettyGrpcServerFactory(final GrpcServerProperties properties,
6163
protected NettyServerBuilder newServerBuilder() {
6264
final String address = getAddress();
6365
final int port = getPort();
64-
if (GrpcServerProperties.ANY_IP_ADDRESS.equals(address)) {
66+
if (address.startsWith("unix://")) {
67+
return NettyServerBuilder
68+
.forAddress(new DomainSocketAddress(address.substring(7)))
69+
.channelType(EpollServerDomainSocketChannel.class);
70+
} else if (GrpcServerProperties.ANY_IP_ADDRESS.equals(address)) {
6571
return NettyServerBuilder.forPort(port);
6672
} else {
6773
return NettyServerBuilder.forAddress(new InetSocketAddress(InetAddresses.forString(address), port));

0 commit comments

Comments
 (0)