netty 传输文件， - 知否问答 - 万象云+社区

public void connect(int port, String host, final String filePath) throws Exception { EventLoopGroup group = new NioEventLoopGroup(); System.out.println("1"); try { Bootstrap b = new Bootstrap(); b.group(group).channel(NioSocketChannel.class).option(ChannelOption.TCP_NODELAY, true).handler(new ChannelInitializer<SocketChannel>() { @Override protected void initChannel(SocketChannel ch) throws Exception { LengthFieldBasedFrameDecoder(Integer.MAX_VALUE,0,4,0,4)); ch.pipeline().addLast(new ObjectDecoder(ClassResolvers.weakCachingConcurrentResolver(null))); ch.pipeline().addLast(new ObjectEncoder()); System.out.println("2"); ch.pipeline().addLast(new EchoClientHandler(filePath)); } }); ChannelFuture f = b.connect(host, port).sync(); System.out.println("4"); f.channel().closeFuture().sync(); } finally { group.shutdownGracefully(); } } @Test public void testClient() { int port = 7777; try { //String filePath="E://DSC_4597.JPG"; //String filePath="G:\\msgShare\\example.jpg"; String filePath="G:\\msgShare\\boforeInferFile\\example.jpg"; System.out.println("3"); new EchoClient().connect(port, "127.0.0.1", filePath); } catch (Exception e) { e.printStackTrace(); } }

private static final Logger LOGGER=LoggerFactory.getLogger(EchoClientHandler.class); private int dataLength = 1024; public RandomAccessFile randomAccessFile; private int sumCountpackage = 0; private String filePath; public EchoClientHandler(String filePath) { this.filePath=filePath; } public void channelActive(ChannelHandlerContext ctx) { System.out.println(this.filePath); try { File file=new File(filePath); randomAccessFile = new RandomAccessFile(file, "r"); randomAccessFile.seek(0); if ((randomAccessFile.length() % dataLength) == 0) { sumCountpackage = (int) (randomAccessFile.length() / dataLength); } else { sumCountpackage = (int) (randomAccessFile.length() / dataLength) + 1; } byte[] bytes = new byte[dataLength]; LOGGER.debug("文件总长度:"+randomAccessFile.length()); if (randomAccessFile.read(bytes) != -1) { EchoFile msgFile = new EchoFile(); msgFile.setSumCountPackage(sumCountpackage); msgFile.setCountPackage(1); msgFile.setBytes(bytes); msgFile.setFile_md5(file.getName()); ctx.writeAndFlush(msgFile); } else { System.out.println("文件已经读完"); } } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException i) { i.printStackTrace(); } } public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { if (msg instanceof EchoFile) { EchoFile msgEchoFile = (EchoFile) msg; int countPackage = msgEchoFile.getCountPackage(); randomAccessFile.seek(countPackage * dataLength - dataLength); int byteLength = 0; // 剩余的文件长度 long remainderFileCount = randomAccessFile.length() - randomAccessFile.getFilePointer(); LOGGER.debug("剩余文件长度:"+remainderFileCount); if (remainderFileCount < dataLength) { LOGGER.debug("小于固定长度："+remainderFileCount); byteLength = (int) remainderFileCount; } else { byteLength = dataLength; } byte[] bytes = new byte[byteLength]; if (randomAccessFile.read(bytes) != -1 && remainderFileCount > 0) { msgEchoFile.setCountPackage(countPackage); msgEchoFile.setBytes(bytes); ctx.writeAndFlush(msgEchoFile); } else { randomAccessFile.close(); ctx.close(); System.out.println("文件已经读完--------" + remainderFileCount); } } } public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) { cause.printStackTrace(); try { randomAccessFile.close(); } catch (IOException e) { e.printStackTrace(); } ctx.close(); } public void channelInactive(ChannelHandlerContext ctx) throws Exception { LOGGER.debug("服务器断开连接"); randomAccessFile.close(); }

private final String path; private final NioEventLoopGroup bossGroup; private final NioEventLoopGroup workerGroup; private final String serverName; public FileServer(String path) { this.path = path; this.bossGroup = new NioEventLoopGroup(); this.workerGroup = new NioEventLoopGroup(); this.serverName = "FileServer-" + System.currentTimeMillis(); } public void start() throws Exception { serverChannel = new NioServerSocketChannel(); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringEncoderUTF8()); serverChannel.pipeline().addLast(new StringDecoder()); serverChannel.pipeline().addLast(new StringEncoder()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringEncoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringEncoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringEncoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringEncoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringEncoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringEncoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringEncoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringEncoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringEncoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringEncoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringEncoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringEncoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringEncoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringEncoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringEncoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringEncoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringEncoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringEncoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringEncoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringEncoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new StringDecoderUTF8()); serverChannel.pipeline().addLast(new String

回答动态

: 神奇的四哥：发布了悬赏问题阿里云幻兽帕鲁服务器更新之后。服务器里面有部分玩家要重新创建角色是怎么回事啊？预计能赚取 0积分收益

: 神奇的四哥：发布了悬赏问题函数计算不同地域的是不能用内网吧？预计能赚取 0积分收益

: 神奇的四哥：发布了悬赏问题ARMS可以创建多个应用嘛?预计能赚取 0积分收益

: 神奇的四哥：发布了悬赏问题在ARMS如何申请加入公测呀？预计能赚取 0积分收益

: 神奇的四哥：发布了悬赏问题前端小程序接入这个arms具体是如何接入监控的，这个init方法在哪里进行添加？预计能赚取 0积分收益

: 神奇的四哥：发布了悬赏问题阿里云幻兽帕鲁服务器刚到期，是不是就不能再导出存档了呢？预计能赚取 0积分收益

: 神奇的四哥：发布了悬赏问题阿里云幻兽帕鲁服务器的游戏版本不兼容尝试更新怎么解决？预计能赚取 0积分收益

: 神奇的四哥：发布了悬赏问题阿里云幻兽帕鲁服务器服务器升级以后就链接不上了，怎么办？预计能赚取 0积分收益

: 神奇的四哥：发布了悬赏问题阿里云幻兽帕鲁服务器转移以后服务器进不去了，怎么解决？预计能赚取 0积分收益

: 神奇的四哥：发布了悬赏问题阿里云幻兽帕鲁服务器修改参数后游戏进入不了，是什么情况？预计能赚取 0积分收益

在 万象知否，学习技能、解决问题

回答动态

在万象知否，学习技能、解决问题