A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

彭宾

初级黑马

  • 黑马币:0

  • 帖子:9

  • 精华:0

© 彭宾 初级黑马   /  2012-12-24 11:24  /  1755 人查看  /  2 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

下面的这个代码为什么会一直等待呢?虽然复制文件的功能实现了。


import java.net.*;
import java.io.*;

class Send
{
        public static void main(String[] args)throws Exception
        {
                Socket s=new Socket("192.168.0.104",5002);
        BufferedReader br=
                        new BufferedReader(new FileReader("wo.java"));
         BufferedWriter bwout=
        new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        BufferedReader brin=
        new BufferedReader(new InputStreamReader(s.getInputStream()));
                String str=null;
                while((str=br.readLine())!=null)
                {       
                       
                        bwout.write(str);
                        bwout.newLine();
                        bwout.flush();
                       
                }   
                        String in=brin.readLine();
                        System.out.println(in);

                 br.close();
                 s.close();
        }
}


class Rece
{
        public static void main(String[] args)throws Exception
        {
                ServerSocket ss=new ServerSocket(5002);
                Socket s=ss.accept();
                InputStream is=s.getInputStream();
                BufferedReader brin=
          new BufferedReader(new InputStreamReader(s.getInputStream()));
                BufferedWriter bw=
                                new BufferedWriter(new FileWriter("d:\\c.txt"));
                BufferedWriter bwout=
          new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
                String str=null;
                String name=s.getInetAddress().getHostAddress();
                while((str=brin.readLine())!=null)
                {
                        bw.write(str);
                        bw.newLine();
                        bw.flush();

                      
                }
                        System.out.println(name);

                        bwout.write("上传成功!");
                        bwout.newLine();
                        bwout.flush();
                s.close();
        }
}

2 个回复

正序浏览
。。。。。。。。。ok
回复 使用道具 举报
本帖最后由 李培根 于 2012-12-25 09:52 编辑

主要是缺少结束标记,帮你修改了下,看红色字体的部分,修改后运行正常。


import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
class Send
{
        public static void main(String[] args)throws Exception
        {
                Socket s=new Socket("127.0.0.1",10007);
        BufferedReader br=
                        new BufferedReader(new FileReader("wo.java"));
         BufferedWriter bwout=
        new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        BufferedReader brin=
        new BufferedReader(new InputStreamReader(s.getInputStream()));
                String str=null;
               while((str=br.readLine())!=null)
                {        
                       
                       bwout.write(str);
                        bwout.newLine();
                        bwout.flush();
                        
               }   
               s.shutdownOutput();//这里缺少结束标记,告诉服务端上传完毕,让服务端停止读取
               
               String in=brin.readLine();
               
               System.out.println(in);
                br.close();
                 s.close();
        }
}

class Rece
{
        public static void main(String[] args)throws Exception
        {
                ServerSocket ss=new ServerSocket(10007);
                Socket s=ss.accept();
                InputStream is=s.getInputStream();
                BufferedReader brin=
          new BufferedReader(new InputStreamReader(s.getInputStream()));
                BufferedWriter bw=
                                new BufferedWriter(new FileWriter("d:\\c.txt"));
                BufferedWriter bwout=
          new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
                String str=null;
                String name=s.getInetAddress().getHostAddress();
                while((str=brin.readLine())!=null)
                {
                        bw.write(str);
                        bw.newLine();
                        bw.flush();
                     
               }
                        System.out.println(name);
                       bwout.write("上传成功!");
                        bwout.newLine();
                        bwout.flush();
                s.close();
        }
}

评分

参与人数 1技术分 +1 收起 理由
崔政 + 1

查看全部评分

回复 使用道具 举报
您需要登录后才可以回帖 登录 | 加入黑马