java课程设计局域网文件传输系统源代码

文件传输源代码

package fileTrans;

import java.io.IOException;

import java.net.Socket;

import java.util.LinkedList;

import java.util.List;

import javax.swing.JOptionPane;

public class AcceptThread extends Thread {

// TODO Auto-generated constructor stub

pathList=new LinkedList<String>();

fileLengthList=new LinkedList<Long>();

}

@Override

public void run() {

// TODO Auto-generated method stub

super.run();

while(true){

try {

// TODO Auto-generated catch block

e.printStackTrace();

JOptionPane.showMessageDialog(null,

MessageTypeInterface.TCP_SERVER_PORT+"端口被占用！");

}

}

}

public void addSavePath(String path){

pathList.add(path);

}

public void addFileLength(Long fileLength){

fileLengthList.add(fileLength);

}

}

package fileTrans;

import java.io.InputStream;

import java.net.InetAddress;

import java.net.ServerSocket;

import java.net.Socket;

import javax.swing.JOptionPane;

public class FileReciveThread extends Thread {

private String savePath=null;

this.fileLength=fileLength;

recivedLength=new Long(0);

}

public void run() {

// TODO Auto-generated method stub

super.run();

long st=System.currentTimeMillis();

BufferedInputStream in=new BufferedInputStream(socket.getInputStream());

BufferedOutputStream out=new BufferedOutputStream(new

byte[] b=new byte[1000];

int a=0;

new FileTransProcessThread(fileLength, this).start();

while((a=in.read(b))>0){

recivedLength+=a;

in.close();

e.printStackTrace();

}

}

public String getSavePath() {

return savePath;

}

public void setSavePath(String savePath) {

this.savePath = savePath;

}

public Long getRecivedLength(){

return recivedLength;

import java.io.BufferedInputStream;

import java.io.BufferedOutputStream;

import java.io.FileInputStream;

import java.io.IOException;

import java.io.OutputStream;

import java.net.Socket;

import javax.swing.JOptionPane;

public class FileSendThread extends Thread {

private String sendFilePath=null;

private InetSocketAddress serverSocket=null;

private Long fileLength;

public FileSendThread(String sendFilePath, InetSocketAddress serverSocket) {

}else{

fileLength=new Long(0);

}

sendedLength=new Long(0);

}

@Override

public void run() {

// TODO Auto-generated method stub

super.run();

long st=System.currentTimeMillis();

try {

s.connect(serverSocket);

new FileTransProcessThread(fileLength, this).start();

while((a=in.read(b))>0){

out.write(b, 0, a);

}

in.close();

out.close();