qq_39197347 2019-04-25 11:18 采纳率: 0%
浏览 551
已结题

限定使用Socket通信,内存4G去传输10G的文本。并且读取过程需要换行,应该如何实现?

题目描述:
限定使用socket通信来完成。需要实现的功能是:客户端读取10G的文本
文件以"换行啦啦啦"作为换行符、将文件中的内容、按行发送给服务端。服务端接收数据后、将文本文件保存在服务端所在电脑的磁盘上。合理使用线程!!

  • 写回答

3条回答 默认 最新

  • ꧁gaoKuo꧂ 2019-04-25 11:32
    关注
        public static void main(String[] args) throws IOException {
            //监听端口
            ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
            //切换非阻塞
            serverSocketChannel.configureBlocking(false);
            //绑定端口
            serverSocketChannel.bind(new InetSocketAddress("localhost",9696));
            //注册选择器
            Selector selector = Selector.open();
            serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
            FileChannel outChannel = FileChannel.open(Paths.get("你的文件"), StandardOpenOption.WRITE, StandardOpenOption.CREATE);
            while (selector.select() > 0){
                Set<SelectionKey> selectionKeys = selector.selectedKeys();
                Iterator<SelectionKey> iterator = selectionKeys.iterator();
                while(iterator.hasNext()){
                    SelectionKey selectionKey = iterator.next();
                    if(selectionKey.isAcceptable()){
                        SocketChannel client = serverSocketChannel.accept();
                        client.configureBlocking(false);
                        client.register(selector, SelectionKey.OP_READ);
                    }else if(selectionKey.isReadable()){
                        SocketChannel client = (SocketChannel) selectionKey.channel();
                        ByteBuffer buffer = ByteBuffer.allocate(1024);
                        while (client.read(buffer) > 0){
                            buffer.flip();
                            //byte[] bytes = new byte[buffer.limit()];
                            //buffer.get(bytes);
                            outChannel.write(buffer);
                        }
                    }
                    iterator.remove();
                }
            }
        }
    

    换行符自个替换

    评论

报告相同问题?

悬赏问题

  • ¥15 关于#matlab#的问题:在模糊控制器中选出线路信息,在simulink中根据线路信息生成速度时间目标曲线(初速度为20m/s,15秒后减为0的速度时间图像)我想问线路信息是什么
  • ¥15 banner广告展示设置多少时间不怎么会消耗用户价值
  • ¥16 mybatis的代理对象无法通过@Autowired装填
  • ¥15 可见光定位matlab仿真
  • ¥15 arduino 四自由度机械臂
  • ¥15 wordpress 产品图片 GIF 没法显示
  • ¥15 求三国群英传pl国战时间的修改方法
  • ¥15 matlab代码代写,需写出详细代码,代价私
  • ¥15 ROS系统搭建请教(跨境电商用途)
  • ¥15 AIC3204的示例代码有吗,想用AIC3204测量血氧,找不到相关的代码。