java实现文件传输

在windows下装了个linux虚拟机,两者之间传输文件挺麻烦的.写了个简单的文件传输程序,来方便自己数据传送.

server 端:

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

class CPThread extends Thread...{
    Socket socket = null;
    public CPThread(Socket socket)...{
        this.socket = socket;
    }
    public void run()...{
        try...{
            InputStream in = 
                      socket.getInputStream();
            PrintWriter out = 
                  new PrintWriter(
                    new BufferedWriter(
                      new OutputStreamWriter(
                        socket.getOutputStream())),true);
            
            while(true)
            ...{
                //第一个參数为命令
                byte cmd[] = new byte[128];
                int b = 0;
                while(b<cmd.length)...{
                    b += in.read(cmd, b, cmd.length-b);
                }
                int ends = 0;
                for(int i=0;i<cmd.length;i++)...{
                    if(cmd[i]==‘-0‘)...{
                        ends = i;
                        break;
                    }
                }
                String cmds = new String(cmd,0,ends);
                if("exit".equals(cmds))...{
                    System.exit(0);
                }
                else if("cp".equals(cmds))...{
                    byte[] filename = new byte[256];
                    b = 0;
                    while(b<filename.length)...{
                        b += in.read(filename, b, filename.length-b);
                    }
                    ends = 0;
                    for(int i=0;i<filename.length;i++)...{
                        if(filename[i]==‘-0‘)...{
                            ends = i;
                            break;
                        }
                    }
                    String filenames = new String(filename,0,ends);
                    File fileout = new File(filenames);
                    if(fileout.isFile())...{
                        throw new Exception("file exists"+fileout.getAbsolutePath());
                    }
                    FileOutputStream fos = new FileOutputStream(fileout);
                    
                    byte[] filesize = new byte[64];
                    b = 0;
                    while(b<filesize.length)...{
                        b += in.read(filesize, b, filesize.length-b);
                    }
                    
                    ends = 0;
                    for(int i=0;i<filesize.length;i++)...{
                        if(filesize[i]==‘-0‘)...{
                            ends = i;
                            break;
                        }
                    }
                    String filesizes = new String(filesize,0,ends);
                    
                    System.out.println("filesize:"+filesizes);
                    int ta = Integer.parseInt(filesizes);
                    byte[] buf = new byte[1024*10];
                    //InputStream ins = socket.getInputStream();
                    while(true)...{
                        if(ta==0)...{
                            break;
                        }
                        int len = ta;
                        if(len>buf.length)...{
                            len = buf.length;
                        }
                        int rlen = in.read(buf, 0, len);
                        
                        //int rlen = ins.read(buf, 0, len);
                        ta -= rlen;
                        if(rlen>0)...{
                            fos.write(buf,0,rlen);
                            fos.flush();
                        }
                        else...{
                            break;
                        }
                    }
                    out.println("cp finish!");
                    fos.close();
                    break;
                }
                else...{
                    System.out.println("err command!");
                    out.println("err command!");
                    break;
                }
            }
            socket.close();
        }catch(Exception e)...{
            e.printStackTrace();
            
        }
    }
}
public class JCPServer ...{

    /** *//**
     * @param args
     */
    public static void main(String[] args) throws Exception ...{
        // TODO Auto-generated method stub
        int num = args.length;
        if(num<=0)...{
            System.out.println("please input server port!");
            System.exit(0);
        }
        int port = Integer.parseInt(args[0]);
        System.out.println("you input port:"+port);
        //绑定接受数据端口
        ServerSocket s = new ServerSocket(port);
        while(true)...{
            Socket socket = s.accept();
            new CPThread(socket).start();
        }
    }

}

client 端

import java.io.BufferedWriter;
import java.io.File;
import java.io.FileInputStream;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;


public class JCPClient ...{

    /** *//**
     * @param args
     */
    public static void main(String[] args)throws Exception ...{
        // TODO Auto-generated method stub
        int num = args.length;
        if(num<=3)...{
            System.out.println("please input server ip port filefrom fileto!");
            System.exit(0);
        }
        System.out.println("host:"+args[0]);
        System.out.println("port:"+args[1]);
        System.out.println("filefrom:"+args[2]);
        System.out.println("fileto:"+args[3]);
        InetAddress addr = InetAddress.getByName(args[0]);
        Socket socket = 
              new Socket(addr, Integer.parseInt(args[1]));
        OutputStream out = socket.getOutputStream();
        byte[] cmd = new byte[128];
        byte[] tcmd = "cp".getBytes();
        for(int i=0;i<tcmd.length;i++)...{
            cmd[i] = tcmd[i];
        }
        cmd[tcmd.length] = ‘-0‘;
        out.write(cmd,0,cmd.length);
        //文件名称
        byte[] file = new byte[256];
        byte[] tfile = args[3].getBytes();
        for(int i=0;i<tfile.length;i++)...{
            file[i] = tfile[i];
        }
        file[tfile.length] = ‘-0‘;
        out.write(file,0,file.length);
        
        //大小
        File filein = new File(args[2]);
        byte[] size = new byte[64];
        byte[] tsize = (""+filein.length()).getBytes();
        
        for(int i=0;i<tsize.length;i++)...{
            size[i] = tsize[i];
        }
        size[tsize.length] = ‘-0‘;
        out.write(size,0,size.length);
        
        FileInputStream fis = null;
        byte[] buf = new byte[1024*10];
        //char[] bufC = new char[1024*10];
        fis = new FileInputStream(filein);
        int readsize = 0;
        //OutputStream ops = socket.getOutputStream();
        while((readsize = fis.read(buf, 0, buf.length))>0)...{
            out.write(buf,0,readsize);
            out.flush();
        }
        socket.close();
    }

}

时间: 2024-10-06 11:10:25

java实现文件传输的相关文章

java 接口 文件传输

调用接收端 @ApiOperation(value = "文件请求展示方法") @RequestMapping(value = "/showFile", method = RequestMethod.GET) public void showFile(HttpServletRequest request, HttpServletResponse response) throws Exception { //获取接口url String url = "htt

java对于文件传输时---编码格式的一些设置方法

- ----转 读文件: BufferedReader 从字符输入流中读取文本,缓冲各个字符,从而提供字符.数组和行的高效读取. 可以指定缓冲区的大小,或者可使用默认的大小.大多数情况下,默认值就足够大了. 通常,Reader 所作的每个读取请求都会导致对基础字符或字节流进行相应的读取请求.因此,建议用 BufferedReader 包装所有其 read() 操作可能开销很高的 Reader(如 FileReader 和 InputStreamReader).例如, BufferedReader

java socket通信-传输文件图片--传输图片

ClientTcpSend.java   客户端发送类 package com.yjf.test; import java.io.DataOutputStream; import java.io.File; import java.io.FileInputStream; import java.net.InetSocketAddress; import java.net.Socket; public class ClientTcpSend { public static String clien

Java基于Socket文件传输示例(转)

最近需要进行网络传输大文件,于是对基于socket的文件传输作了一个初步的了解.在一位网友提供的程序基础上,俺进行了一些加工,采用了缓冲输入/输出流来包装输出流,再采用数据输入/输出输出流进行包装,加快传输的速度.废话少说,先来看服务器端的程序. 1.服务器端 package sterning; import java.io.BufferedInputStream; import java.io.DataInputStream; import java.io.DataOutputStream;

java UDP聊天与文件传输

package rgy.com.UDP3; import java.awt.Font; import java.awt.GridLayout; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.awt.event.KeyAdapter; import java.awt.event.KeyEvent; import java.io.File; import java.io.Fil

C++,java信息,文件传输

java客户端 1 package client; 2 3 import java.io.DataOutputStream; 4 import java.io.File; 5 import java.io.FileInputStream; 6 import java.io.IOException; 7 import java.net.InetSocketAddress; 8 import java.net.Socket; 9 10 /** 11 * 文件发送客户端主程序 12 * @author

Java基于Socket文件传输示例

最近需要进行网络传输大文件,于是对基于socket的文件传输作了一个初步的了解.在一位网友提供的程序基础上,俺进行了一些加工,采用了缓冲输入/输出流来包装输出流,再采用数据输入/输出输出流进行包装,加快传输的速度.废话少说,先来看服务器端的程序. 1.服务器端 package localSocket; import java.io.BufferedInputStream; import java.io.DataInputStream; import java.io.DataOutputStrea

java基于P2P的聊天和文件传输实例

用java的NIO技术编写的 1. 支持聊天功能 2. 拖拽文件能够实现文件传输功能.也能够是目录 3. 启动时能够选择server端或client端启动 4. 本人原创.学习NIO和java的网络通信一定会不错 5. 下载下来能够直接导致eclipse.然后执行 代码下载路径例如以下: http://download.csdn.net/detail/tqtihihc/8266793 截图:

Java使用Socket传输文件遇到的问题(转)

1.写了一个socket传输文件的程序,发现传输过去文件有问题.找了一下午终于似乎找到了原因,记录下来警示一下: 接受文件的一端,向本地写文件之前使用Thread.sleep(time)休息一下就解决了问题. 个人认为可能是传输过程中,接收端向磁盘写速度有点慢,被后面的覆盖导致错误. //---------------------------------------------------------------------------------------------------------