java文件传输

文件接收部分

FileReceiver.java

packagecom.vista.Util;

importjava.io.IOException;
importjava.net.ServerSocket;

publicclassFileReceiverextendsThread
{
privateServerSockets=null;
privateintFILE_PORT;//文件传输的监听端口
privateUseruser=null;
publicFileReceiver(Userus)
{
this.FILE_PORT=us.getUdpPort();//设置文件端口
this.user=us;
}
publicvoidrun()
{
try
{
s=newServerSocket(FILE_PORT);
System.out.println("用户端开始监听:"+s);
while(true)
{
java.net.Socketsocket=s.accept();
System.out.println("连接接受"+socket);
newFileReceiverThread(user,socket);
}
}
catch(IOExceptione)
{
e.printStackTrace();
}
catch(java.lang.Exceptionex)
{
System.err.println(ex.getMessage().toString());
ex.printStackTrace();
}
finally
{
try
{
s.close();
}
catch(IOExceptione)
{
//TODOAuto-generatedcatchblock
e.printStackTrace();
}
}
}

}

FileReceiverThread.java
packagecom.vista.Util;

importjava.io.BufferedWriter;
importjava.io.File;
importjava.io.FileOutputStream;
importjava.io.IOException;
importjava.io.OutputStreamWriter;
importjava.io.PrintWriter;
importjava.net.Socket;
importjava.util.Date;

importcom.vista.Form.SingleChatForm;

publicclassFileReceiverThreadextendsThread
{
privateSingleChatFormchatForm=null;
privatejava.net.Socketsocket=null;
privatejava.io.InputStreamin=null;//从客户端读数据的
privatejava.io.PrintWriterout=null;//向客户端写数据
privateStringserverMsg;
privateUsersender=null;
privateUserreceiver=null;
privatecom.vista.Util.SenderMsgSender=null;

publicFileReceiverThread(Userus,Socketsocket)
{
this.receiver=us;
try
{
this.socket=socket;
this.in=this.socket.getInputStream();
this.out=newPrintWriter(newBufferedWriter(newOutputStreamWriter(this.socket.getOutputStream())),true);
}
catch(IOExceptione)
{//TODOAuto-generatedcatchblock
e.printStackTrace();
}
this.start();//启动线程
}

publicvoidrun()
{
Stringinfo="";
try
{
while(true)
{
//第一个参数为命令
Datebefor=newDate();

bytecmd[]=newbyte[128];
intb=0;
while(b<cmd.length)
{
b+=in.read(cmd,b,cmd.length-b);
}
intends=0;
for(inti=0;i<cmd.length;i++)
{
if(cmd[i]==-0)
{
ends=i;
break;
}
}
Stringcmds=newString(cmd,0,ends);
if("cp".equals(cmds))
{
byte[]filename=newbyte[256];
b=0;
while(b<cmd.length)
{
b+=in.read(filename,b,filename.length-b);
}
ends=0;
for(inti=0;i<cmd.length;i++)
{
if(filename[i]==-0)
{
ends=i;
break;
}
}
Stringfilenames=newString(filename,0,ends);
filenames="F://"+filenames;

Filefileout=newFile(filenames);

FileOutputStreamfos=newFileOutputStream(fileout);

byte[]filesize=newbyte[64];
b=0;
while(b<filesize.length)
{
b+=in.read(filesize,b,filesize.length-b);
}

ends=0;
for(inti=0;i<filesize.length;i++)
{
if(filesize[i]==-0)
{
ends=i;
break;
}
}
Stringfilesizes=newString(filesize,0,ends);

System.out.println("filesize:"+filesizes);
intta=Integer.parseInt(filesizes);
byte[]buf=newbyte[1024*10];

while(true)
{
if(ta==0)
{
break;
}
intlen=ta;
if(len>buf.length)
{
len=buf.length;
}
intrlen=in.read(buf,0,len);

ta-=rlen;
if(rlen>0)
{
fos.write(buf,0,rlen);
fos.flush();
}
else
{
break;
}
}
Dateafter=newDate();
longdiff=after.getTime()-befor.getTime();
diff/=1000;

info="传输完成!文件已经保存到:"+filenames+",文件大小："+filesizes+"字节,"+"共用时间:"+diff+"秒";
intresult=javax.swing.JOptionPane.showConfirmDialog(null,info,"文件传输",javax.swing.JOptionPane.YES_NO_OPTION,javax.swing.JOptionPane.INFORMATION_MESSAGE);

fos.close();
break;
}
}
//socket.close();
}
catch(Exceptione)
{
e.printStackTrace();
}
try
{
this.socket.close();
}
catch(IOExceptionex1)
{
}

}
}

文件发送线程

FileSender.java
packagecom.vista.Util;

importjava.io.BufferedReader;
importjava.io.BufferedWriter;
importjava.io.File;
importjava.io.FileInputStream;
importjava.io.FileNotFoundException;
importjava.io.IOException;
importjava.io.InputStreamReader;
importjava.io.OutputStream;
importjava.io.OutputStreamWriter;
importjava.io.PrintWriter;
importjava.net.InetAddress;
importjava.net.Socket;
importjava.net.UnknownHostException;

publicclassFileSenderextendsThread
{
privateSocketsocket=null;//客户端socket
privateOutputStreamout=null;//向服务器写数据
privateintRECEIVER_PORT=-1;//接收者端口

privateFilefileToSend=null;//要传输的文件

publicFileSender(Filefile,intReceiver_Port)
{
this.fileToSend=file;
this.RECEIVER_PORT=Receiver_Port;//设置接收方端口
try
{
this.socket=newSocket(InetAddress.getLocalHost(),RECEIVER_PORT);
out=socket.getOutputStream();//向接收者发数据的
}
catch(UnknownHostExceptione)
{
//TODOAuto-generatedcatchblock
e.printStackTrace();
}
catch(IOExceptione)
{
//TODOAuto-generatedcatchblock
e.printStackTrace();
}
}

publicvoidrun()
{
byte[]cmd=newbyte[128];
byte[]tcmd="cp".getBytes();
for(inti=0;i<tcmd.length;i++)
{
cmd[i]=tcmd[i];
}
cmd[tcmd.length]=-0;
try
{
out.write(cmd,0,cmd.length);
}
catch(IOExceptione)
{
e.printStackTrace();
}
//文件名
byte[]file=newbyte[256];
byte[]tfile=this.fileToSend.getName().getBytes();
for(inti=0;i<tfile.length;i++)
{
file[i]=tfile[i];
}
file[tfile.length]=-0;
try
{
out.write(file,0,file.length);
}
catch(IOExceptione)
{
e.printStackTrace();
}
//大小
byte[]size=newbyte[64];
byte[]tsize=(""+this.fileToSend.length()).getBytes();

for(inti=0;i<tsize.length;i++)
{
size[i]=tsize[i];
}

size[tsize.length]=-0;
try
{
out.write(size,0,size.length);
}
catch(IOExceptione)
{
//TODOAuto-generatedcatchblock
e.printStackTrace();
}

FileInputStreamfis=null;
byte[]buf=newbyte[1024*10];
try
{
fis=newFileInputStream(this.fileToSend);
}
catch(FileNotFoundExceptione)
{
e.printStackTrace();
}
intreadsize=0;
try
{
while((readsize=fis.read(buf,0,buf.length))>0)
{
out.write(buf,0,readsize);
out.flush();
}
}
catch(IOExceptione)
{
e.printStackTrace();
}

}

}

相关推荐