java文件传输(JAVA文件传输的好处)

向右看齐 2023-09-25 08:14 75阅读 0赞

## JAVA 传输文件 ##

//以前写的一个文件传输的小程序，有客户端和服务器端两部分，服务器可//以一直运行，客户端传输完一个后退出，当然你也可以根据你的需要改。

//服务器端可以支持多个客户端同时上传，用到了多线程

\* 文件传输，客户端

\* @aurth anyx

//package per.anyx.ftp;

import java.net.\*;

import java.io.\*;

public class FtpClient\{

public static void main(String\[\] args)\{

if(args.length != 3)\{

System.out.println("Usage: FtpClient host\_add host\_port src\_file");

System.exit(0);

File file = new File(args\[2\]);

if(!file.exists() || !file.isFile())\{

System.out.println("File \\"" + args\[2\] + "\\" does not exist or is not a normal file.");

System.exit(0);

Socket s = null;

FileInputStream in = null;

OutputStream out = null;

try\{

s = new Socket(args\[0\], Integer.parseInt(args\[1\]));

in = new FileInputStream(file);

out = s.getOutputStream();

byte\[\] buffer = new byte\[1024\*8\];

int len = -1;

System.out.println("File tansfer statr...");

while((len=in.read(buffer)) != -1)\{

out.write(buffer, 0, len);

System.out.println("File tansfer complete...");

\}catch(Exception e)\{

System.out.println("Error: " + e.getMessage());

System.exit(1);

\}finally\{

try\{

if(in != null) in.close();

if(out != null) out.close();

if(s != null) s.close();

\}catch(Exception e)\{\}

\* 文件传输，服务器端

\* @aurth anyx

//package per.anyx.ftp;

import java.net.\*;

import java.io.\*;

public class FtpServer\{

public static void main(String\[\] args)\{

if(args.length != 1)\{

System.out.println("Usage: FtpServer server\_port");

System.exit(0);

ServerSocket ss = null;

try\{

ss = new ServerSocket(Integer.parseInt(args\[0\]));

System.out.println("FtpServer start on port ..." + args\[0\]);

while(true)\{

Socket s = ss.accept();

new FtpThread(s).start();

System.out.println(s.getInetAddress().getHostAddress() + " connected.");

\}catch(Exception e)\{

System.out.println("Error: " + e.getMessage());

\}finally\{

try\{

if(ss != null) ss.close();

\}catch(Exception e)\{\}

class FtpThread extends Thread\{

Socket s;

long fileName = 0;

public FtpThread(Socket s)\{

this.s = s;

public void run()\{

FileOutputStream out = null;

InputStream in = null;

File file = null;

file = new File("" + (fileName++));

\}while(file.exists());

try\{

out = new FileOutputStream(file);

in = s.getInputStream();

byte\[\] buffer = new byte\[1024\*8\];

int len = -1;

while((len=in.read(buffer)) != -1)\{

out.write(buffer, 0, len);

\}catch(Exception e)\{

System.out.println("Error: " + e.getMessage());

\}finally\{

try\{

if(in != null) in.close();

if(out != null) out.close();

if(s != null) s.close();

System.out.println(s.getInetAddress().getHostAddress() + " connect closed..");

\}catch(Exception e)\{\}

![java文件传输][java]

## 利用java socket实现文件传输 ##

1.服务器端

package sterning;

import java.io.BufferedInputStream;

import java.io.DataInputStream;

import java.io.DataOutputStream;

import java.io.File;

import java.io.FileInputStream;

import java.net.ServerSocket;

import java.net.Socket;

public class ServerTest \{

int port = 8821;

void start() \{

Socket s = null;

try \{

ServerSocket ss = new ServerSocket(port);

while (true) \{

// 选择进行传输的文件

String filePath = "D:\\\\lib.rar";

File fi = new File(filePath);

System.out.println("文件长度:" + (int) fi.length());

// public Socket accept() throws

// IOException侦听并接受到此套接字的连接。此方法在进行连接之前一直阻塞。

s = ss.accept();

System.out.println("建立socket链接");

DataInputStream dis = new DataInputStream(new BufferedInputStream(s.getInputStream()));

dis.readByte();

DataInputStream fis = new DataInputStream(new BufferedInputStream(new FileInputStream(filePath)));

DataOutputStream ps = new DataOutputStream(s.getOutputStream());

//将文件名及长度传给客户端。这里要真正适用所有平台，例如中文名的处理，还需要加工，具体可以参见Think In Java 4th里有现成的代码。

ps.writeUTF(fi.getName());

ps.flush();

ps.writeLong((long) fi.length());

ps.flush();

int bufferSize = 8192;

byte\[\] buf = new byte\[bufferSize\];

while (true) \{

int read = 0;

if (fis != null) \{

read = fis.read(buf);

if (read == -1) \{

break;

ps.write(buf, 0, read);

ps.flush();

// 注意关闭socket链接哦，不然客户端会等待server的数据过来，

// 直到socket超时，导致数据不完整。

fis.close();

s.close();

System.out.println("文件传输完成");

\} catch (Exception e) \{

e.printStackTrace();

public static void main(String arg\[\]) \{

new ServerTest().start();

2.socket的Util辅助类

package sterning;

import java.net.\*;

import java.io.\*;

public class ClientSocket \{

private String ip;

private int port;

private Socket socket = null;

DataOutputStream out = null;

DataInputStream getMessageStream = null;

public ClientSocket(String ip, int port) \{

this.ip = ip;

this.port = port;

/\*\* \*//\*\*

\* 创建socket连接

\* @throws Exception

\*exception

\*/

public void CreateConnection() throws Exception \{

try \{

socket = new Socket(ip, port);

\} catch (Exception e) \{

e.printStackTrace();

if (socket != null)

socket.close();

throw e;

\} finally \{

public void sendMessage(String sendMessage) throws Exception \{

try \{

out = new DataOutputStream(socket.getOutputStream());

if (sendMessage.equals("Windows")) \{

out.writeByte(0x1);

out.flush();

return;

if (sendMessage.equals("Unix")) \{

out.writeByte(0x2);

out.flush();

return;

if (sendMessage.equals("Linux")) \{

out.writeByte(0x3);

out.flush();

\} else \{

out.writeUTF(sendMessage);

out.flush();

\} catch (Exception e) \{

e.printStackTrace();

if (out != null)

out.close();

throw e;

\} finally \{

public DataInputStream getMessageStream() throws Exception \{

try \{

getMessageStream = new DataInputStream(new BufferedInputStream(socket.getInputStream()));

return getMessageStream;

\} catch (Exception e) \{

e.printStackTrace();

if (getMessageStream != null)

getMessageStream.close();

throw e;

\} finally \{

public void shutDownConnection() \{

try \{

if (out != null)

out.close();

if (getMessageStream != null)

getMessageStream.close();

if (socket != null)

socket.close();

\} catch (Exception e) \{

3.客户端

package sterning;

import java.io.BufferedOutputStream;

import java.io.DataInputStream;

import java.io.DataOutputStream;

import java.io.FileOutputStream;

public class ClientTest \{

private ClientSocket cs = null;

private String ip = "localhost";// 设置成服务器IP

private int port = 8821;

private String sendMessage = "Windwos";

public ClientTest() \{

try \{

if (createConnection()) \{

sendMessage();

getMessage();

\} catch (Exception ex) \{

ex.printStackTrace();

private boolean createConnection() \{

cs = new ClientSocket(ip, port);

try \{

cs.CreateConnection();

System.out.print("连接服务器成功!" + "\\n");

return true;

\} catch (Exception e) \{

System.out.print("连接服务器失败!" + "\\n");

return false;

private void sendMessage() \{

if (cs == null)

return;

try \{

cs.sendMessage(sendMessage);

\} catch (Exception e) \{

System.out.print("发送消息失败!" + "\\n");

private void getMessage() \{

if (cs == null)

return;

DataInputStream inputStream = null;

try \{

inputStream = cs.getMessageStream();

\} catch (Exception e) \{

System.out.print("接收消息缓存错误\\n");

return;

try \{

//本地保存路径，文件名会自动从服务器端继承而来。

String savePath = "E:\\\\";

int bufferSize = 8192;

byte\[\] buf = new byte\[bufferSize\];

int passedlen = 0;

long len=0;

savePath += inputStream.readUTF();

DataOutputStream fileOut = new DataOutputStream(new BufferedOutputStream(new BufferedOutputStream(new FileOutputStream(savePath))));

len = inputStream.readLong();

System.out.println("文件的长度为:" + len + "\\n");

System.out.println("开始接收文件!" + "\\n");

while (true) \{

int read = 0;

if (inputStream != null) \{

read = inputStream.read(buf);

passedlen += read;

if (read == -1) \{

break;

//下面进度条本为图形界面的prograssBar做的，这里如果是打文件，可能会重复打印出一些相同的百分比

System.out.println("文件接收了" + (passedlen \* 100/ len) + "%\\n");

fileOut.write(buf, 0, read);

System.out.println("接收完成，文件存为" + savePath + "\\n");

fileOut.close();

\} catch (Exception e) \{

System.out.println("接收消息错误" + "\\n");

return;

public static void main(String arg\[\]) \{

new ClientTest();

\}代码如下：

importjava.io.\*;

importjava.net.\*;

importjava.util.\*;

privateHttpURLConnectionconnection;//存储连接

privateintdownsize=-1;//下载文件大小,初始值为-1

privateintdowned=0;//文加已下载大小,初始值为0

privateRandomAccessFilesavefile;//记录下载信息存储文件

privateURLfileurl;//记录要下载文件的地址

privateDataInputStreamfileStream;//记录下载的数据流

try\{

/\*开始创建下载的存储文件,并初始化值\*/

Filetempfileobject=newFile("h:\\\\webwork-2.1.7.zip");

if(!tempfileobject.exists())\{

/\*文件不存在则建立\*/

tempfileobject.createNewFile();

savefile=newRandomAccessFile(tempfileobject,"rw");

/\*建立连接\*/

fileurl=newURL("");

connection=(HttpURLConnection)fileurl.openConnection();

connection.setRequestProperty("Range","byte="+this.downed+"-");

this.downsize=connection.getContentLength();

//System.out.println(connection.getContentLength());

newThread(this).start();

catch(Exceptione)\{

System.out.println(e.toString());

System.out.println("构建器错误");

System.exit(0);

publicvoidrun()\{

/\*开始下载文件,以下测试非断点续传,下载的文件存在问题\*/

try\{

System.out.println("begin!");

Datebegintime=newDate();

begintime.setTime(newDate().getTime());

byte\[\]filebyte;

intonecelen;

//System.out.println(this.connection.getInputStream().getClass().getName());

this.fileStream=newDataInputStream(

newBufferedInputStream(

this.connection.getInputStream()));

System.out.println("size="+this.downsize);

while(this.downsize!=this.downed)\{

if(this.downsize-this.downed>262144)\{//设置为最大256KB的缓存

filebyte=newbyte\[262144\];

onecelen=262144;

else\{

filebyte=newbyte\[this.downsize-this.downed\];

onecelen=this.downsize-this.downed;

onecelen=this.fileStream.read(filebyte,0,onecelen);

this.savefile.write(filebyte,0,onecelen);

this.downed+=onecelen;

System.out.println(this.downed);

this.savefile.close();

System.out.println("end!");

System.out.println(begintime.getTime());

System.out.println(newDate().getTime());

System.out.println(begintime.getTime()-newDate().getTime());

catch(Exception e)\{

System.out.println(e.toString());

System.out.println("run()方法有问题!");

//FileClient.java

import java.io.\*;

import java.net.\*;

public class FileClient \{

public static void main(String\[\] args) throws Exception \{

//使用本地文件系统接受网络数据并存为新文件

File file = new File("d:\\\\fmd.doc");

file.createNewFile();

RandomAccessFile raf = new RandomAccessFile(file, "rw");

// 通过Socket连接文件服务器

Socket server = new Socket(InetAddress.getLocalHost(), 3318);

//创建网络接受流接受服务器文件数据

InputStream netIn = server.getInputStream();

InputStream in = new DataInputStream(new BufferedInputStream(netIn));

//创建缓冲区缓冲网络数据

byte\[\] buf = new byte\[2048\];

int num = in.read(buf);

while (num != (-1)) \{//是否读完所有数据

raf.write(buf, 0, num);//将数据写往文件

raf.skipBytes(num);//顺序写文件字节

num = in.read(buf);//继续从网络中读取文件

in.close();

raf.close();

//FileServer.java

import java.io.\*;

import java.util.\*;

import java.net.\*;

public class FileServer \{

public static void main(String\[\] args) throws Exception \{

//创建文件流用来读取文件中的数据

File file = new File("d:\\\\系统特点.doc");

FileInputStream fos = new FileInputStream(file);

//创建网络服务器接受客户请求

ServerSocket ss = new ServerSocket(8801);

Socket client = ss.accept();

//创建网络输出流并提供数据包装器

OutputStream netOut = client.getOutputStream();

OutputStream doc = new DataOutputStream(

new BufferedOutputStream(netOut));

//创建文件读取缓冲区

byte\[\] buf = new byte\[2048\];

int num = fos.read(buf);

while (num != (-1)) \{//是否读完文件

doc.write(buf, 0, num);//把文件数据写出网络缓冲区

doc.flush();//刷新缓冲区把数据写往客户端

num = fos.read(buf);//继续从文件中读取数据

fos.close();

doc.close();

\*/java中的网络信息传输方式基于TCP协议和UD协议P的,socket是基于TCP协议的实现代码如下：

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 void main(String\[\] args) \{

int length = 0;

byte\[\] sendBytes = null;

Socket socket = null;

DataOutputStream dos = null;

FileInputStream fis = null;

try \{

socket = new Socket();

socket.connect(new InetSocketAddress("127.0.0.1", 33456),

dos = new DataOutputStream(socket.getOutputStream());

File file = new File("/root/6674541037\_c3a9c8b64c\_b.jpg");

Ffis = new FileInputStream(file);

sendBytes = new byte\[1024\];

while ((length = fis.read(sendBytes, 0, sendBytes.length)) > 0) \{

dos.write(sendBytes, 0, length);

dos.flush();

\} finally \{

if (dos != null)

dos.close();

if (fis != null)

fis.close();

if (socket != null)

socket.close();

\} catch (Exception e) \{

e.printStackTrace();

[java]: https://img0.baidu.com/it/u=2687506400,1959833738&fm=26&fmt=auto

java文件传输(JAVA文件传输的好处)

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 java文件传输(JAVA文件传输的好处)

相关 java文件传输简单方法

相关 python传输大文件_python ftplib 传输文件大小的文件，怎么传输较大文件

相关 java Socket 文件传输

相关【烦人的SFTP传输】Java通过SFTP传输文件

相关 java 利用webservice传输文件

相关 java-socket传输zip文件实例

相关 JAVA检测文件是否传输完成

相关 Java基于Socket文件传输示例

相关 Java基于Socket文件传输示例