通過unix域套接字支持netty數據包數據包？

我剛剛開始關注一些項目的netty，並且已經能夠獲得一些簡單的客戶端和服務器示例，它們運行使用INET和unix域套接字來回發送消息。我也能夠通過INET套接字發送數據報包。但是我需要通過UNIX域套接字發送數據報包。這是在netty中支持的嗎？如果是這樣，有人可以指向我的文檔或例子嗎？我懷疑這不支持，因爲DatagramPacket顯式地使用InetSocketAddress。如果不支持，將它添加到netty是否可行？通過unix域套接字支持netty數據包數據包？

來源

2016-04-22 Wes Hunter

-1

這是netty支持嗎？

是的。以下是我寫的一個簡單例子。

import io.netty.bootstrap.Bootstrap; 
import io.netty.bootstrap.ServerBootstrap; 
import io.netty.buffer.ByteBuf; 
import io.netty.channel.*; 
import io.netty.channel.epoll.EpollDomainSocketChannel; 
import io.netty.channel.epoll.EpollEventLoopGroup; 
import io.netty.channel.epoll.EpollServerDomainSocketChannel; 
import io.netty.channel.unix.DomainSocketAddress; 

/** 
* @author louyl 
*/ 
public class App { 
    public static void main(String[] args) throws Exception { 
     String sockPath = "/tmp/echo.sock"; 
     final ServerBootstrap bootstrap = new ServerBootstrap(); 
     EventLoopGroup serverBossEventLoopGroup = new EpollEventLoopGroup(); 
     EventLoopGroup serverWorkerEventLoopGroup = new EpollEventLoopGroup(); 
     bootstrap.group(serverBossEventLoopGroup, serverWorkerEventLoopGroup) 
      .localAddress(new DomainSocketAddress(sockPath)) 
      .channel(EpollServerDomainSocketChannel.class) 
      .childHandler(
       new ChannelInitializer<Channel>() { 
        @Override 
        protected void initChannel(final Channel channel) throws Exception { 
         channel.pipeline().addLast(
          new ChannelInboundHandlerAdapter() { 
           @Override 
           public void channelActive(final ChannelHandlerContext ctx) throws Exception { 
            final ByteBuf buff = ctx.alloc().buffer(); 
            buff.writeBytes("This is a test".getBytes()); 
            ctx.writeAndFlush(buff).addListeners(new ChannelFutureListener() { 
              @Override 
              public void operationComplete(ChannelFuture future) { 
               future.channel().close(); 
               future.channel().parent().close(); 
              } 
             }); 
           } 
          } 
                ); 
        } 
       } 
         ); 
     final ChannelFuture serverFuture = bootstrap.bind().sync(); 

     final Bootstrap bootstrapClient = new Bootstrap(); 
     EventLoopGroup clientEventLoop = new EpollEventLoopGroup(); 
     bootstrapClient.group(clientEventLoop) 
      .channel(EpollDomainSocketChannel.class) 
      .handler(new ChannelInitializer<Channel>() { 
        @Override 
        protected void initChannel(final Channel channel) throws Exception { 
         channel.pipeline().addLast(
          new ChannelInboundHandlerAdapter() { 
           @Override 
           public void channelRead(final ChannelHandlerContext ctx, final Object msg) throws Exception { 
            final ByteBuf buff = (ByteBuf) msg; 
            try { 
             byte[] bytes = new byte[buff.readableBytes()]; 
             buff.getBytes(0, bytes); 
             System.out.println(new String(bytes)); 
            } finally { 
             buff.release(); 
            } 
            ctx.close(); 
           } 

           @Override 
           public void exceptionCaught(final ChannelHandlerContext ctx, final Throwable cause) throws Exception { 
            System.out.println("Error occur when reading from Unix domain socket: " + cause.getMessage()); 
            ctx.close(); 
           } 
          } 
                ); 
        } 
       } 
       ); 
     final ChannelFuture clientFuture = bootstrapClient.connect(new DomainSocketAddress(sockPath)).sync(); 

     clientFuture.channel().closeFuture().sync(); 
     serverFuture.channel().closeFuture().sync(); 
     serverBossEventLoopGroup.shutdownGracefully(); 
     serverWorkerEventLoopGroup.shutdownGracefully(); 
     clientEventLoop.shutdownGracefully(); 
    } 
}

來源

2016-04-29 04:00:53 louxiu

通過unix域套接字支持netty數據包數據包？

回答

相關問題