Java遠(yuǎn)程傳輸文件(增加覆蓋取消等功能)

1、發(fā)送端/ *by小郭 *遠(yuǎn)程文件傳輸 */import javax.swing.*;import .*;import java.io.*;import java.awt.*;import java.lang.*;import java.awt.event.*;public class TcpSend extends JFrame implements ActionListenerprivate JButton button; private JFileChooser chooser; /private FileInputStream in;/private String filename;/b

2、yte by=new byte100000;public TcpSend()super("小郭文件傳輸發(fā)送端");this.setBounds(10,10,400,400);this.setLayout(null);this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);this.setResizable(false);this.setVisible(true);chooser=new JFileChooser();button=new JButton("發(fā)送");button.setFont(new Fo

3、nt("楷體",Font.PLAIN,30);button.setBounds(0,0,400,400);add(button);button.addActionListener(this); public void actionPerformed(ActionEvent e) chooser.showOpenDialog(this); if(chooser.showOpenDialog(this)=JFileChooser.CANCEL_OPTION) button.setText("取消文件發(fā)送");/小bug 按2次才能取消 return; Sen

4、d send=new Send(chooser.getSelectedFile();send.start();button.setText("文件已發(fā)送");public static void main(String args)new TcpSend();/end TcpSendclass Send extends Threadprivate File file; private Socket socket; private DataOutputStream Dout; private DataInputStream Din; BufferedInputStream bu

5、ffered; Send(File file) this.file = file; try socket= new Socket("localhost",1111);/localhost可以改成IP 如果是內(nèi)網(wǎng) 直接填內(nèi)網(wǎng)IP 外網(wǎng)的話IP要映射 buffered=new BufferedInputStream(socket.getInputStream();/創(chuàng)建一個(gè)緩沖區(qū)數(shù)組,保存套接字s輸入流，以便使用 Din = new DataInputStream(buffered);/數(shù)據(jù)輸入流,用來讀取 Dout = new DataOutputStream(socket.

6、getOutputStream();/數(shù)據(jù)輸出流,用來寫入由數(shù)據(jù)輸入流讀取的數(shù)據(jù) catch (IOException e) e.printStackTrace(); public void run() try Dout.writeUTF(file.getName();/將文件名寫入輸出流 JOptionPane.showMessageDialog(null,"發(fā)送的文件是："+file.getName(); boolean isAccepted = Din.readBoolean();/接收端是否讀取輸入字節(jié) if(isAccepted) / JOptionPane.sh

7、owMessageDialog(null,"對(duì)方已經(jīng)接受文件傳輸，點(diǎn)擊確定開始傳輸！"); BufferedInputStream Bin = new BufferedInputStream(new FileInputStream(file);/創(chuàng)建一個(gè)緩沖區(qū)數(shù)組,保存文件輸入流 byte by = new byte100000; int l; while( l =Bin.read(by)!= -1)/從輸入流中將各字節(jié)讀取到by數(shù)組中 只要不是=-1 如果=-1即到達(dá)流末尾就跳出循環(huán) Dout.write(by,0,l);/將by數(shù)組中從偏移地址0開始的1個(gè)字節(jié)寫入輸出流

8、。 Dout.flush();/清空數(shù)據(jù)輸出流 /l = Bin.read(by);多了這一句 照成接收的文件大小只有一半的容量 Bin.close();/關(guān)閉緩沖輸入流 / JOptionPane.showMessageDialog(null,file.toString()+"n文件發(fā)送完畢！"); /end if /end try catch (IOException e) e.printStackTrace(); finally/保證即使因?yàn)楫惓?，try里面的代碼不會(huì)被執(zhí)行，但是finally里面的語句還是會(huì)執(zhí)行，這樣可以釋放一些資源 try Din.close();

9、/關(guān)閉數(shù)據(jù)輸入流 Dout.close();/關(guān)閉數(shù)據(jù)輸出流 socket.close(); catch (IOException e) e.printStackTrace(); /end finally /end run()/end Send(線程類)*2011接收端import javax.swing.*;import .*;import java.io.*;import java.awt.*;import java.lang.*;import java.awt.event.*;public class TcpReceive extends JFrame implements Action

10、Listenerprivate JButton button1,button2; private JLabel label; private Socket socket; private ServerSocket ss; private String filename; public TcpReceive()super("小郭文件傳輸接收端");this.setBounds(420,420,400,400);setLayout(null);setVisible(true);this.setResizable(false);this.setDefaultCloseOperat

11、ion(JFrame.EXIT_ON_CLOSE);label=new JLabel();label.setText("暫時(shí)沒收到文件請(qǐng)求，請(qǐng)等待。");button1=new JButton("Accept");button2=new JButton("Cancel");add(label);add(button1);add(button2);label.setBounds(10,10,300,300);button1.setBounds(60,310,100,30);button2.setBounds(240,310,100,30

12、);button1.addActionListener(this);button2.addActionListener(this);try ss=new ServerSocket(1111);/綁定到端口1111的服務(wù)器套接字 while(!ss.isClosed() socket=ss.accept();/偵聽并接受到此套接字的連接 DataInputStream Din = new DataInputStream(socket.getInputStream();/數(shù)據(jù)輸入流,用來讀取從1111端口接收到的輸入流 filename = Din.readUTF();/讀取對(duì)方發(fā)過來的字符串（即

13、文件名） label.setText(filename); catch (IOException e) if(ss.isClosed()/端口關(guān)閉就退出 JOptionPane.showMessageDialog(this,"端口已關(guān)閉，程序退出"); System.exit(0); else e.printStackTrace(); /end構(gòu)造函數(shù)public void actionPerformed(ActionEvent e) if(e.getSource()=button1) JFileChooser chooser=new JFileChooser(); cho

14、oser.setSelectedFile(new File(filename);/路徑抽象化 chooser.showSaveDialog(this); chooser.getName(chooser.getSelectedFile(); Receive receive = new Receive(chooser.getSelectedFile(),socket);/創(chuàng)建Receive線程對(duì)象 用來啟動(dòng)線程類 if(chooser.showSaveDialog(this)=JFileChooser.APPROVE_OPTION)/bug:按2次保存才保存下來 /System.out.print

15、ln("bbb"); if(chooser.getSelectedFile().exists()/測(cè)試此抽象路徑名表示的文件或目錄是否存在 int over=JOptionPane.showConfirmDialog(this,"文件"+chooser.getSelectedFile().getName()+"已經(jīng)存在，確定覆蓋嗎？","覆蓋與否", JOptionPane.YES_NO_OPTION,JOptionPane.WARNING_MESSAGE); if(over=JOptionPane.YES_OPT

16、ION)/bug:按2次確定才能執(zhí)行 /elseSystem.out.println("aaa"); receive.start(); /end if /end if elsereceive.start(); /System.out.println("aaaa"); /bug:按2次取消才能取消 第二次取消才打印 /end if /end if if(e.getSource()=button2) if(label.getText()="暫時(shí)沒收到文件請(qǐng)求，請(qǐng)等待。") JOptionPane.showMessageDialog(thi

17、s,"沒收到請(qǐng)求哦！"); else JOptionPane.showMessageDialog(this,"正在退出！"); System.exit(0); /end if/end actionPerformedpublic static void main(String args)new TcpReceive();/end TcpReceiveclass Receive extends Thread private File file; private Socket socket; int l; public Receive(File file, S

18、ocket socket) this.file=file; this.socket=socket; public File location() return file; public void run() if(file = null) JOptionPane.showMessageDialog(null,"沒有監(jiān)聽到文件"); return; else try DataOutputStream Dout = new DataOutputStream(socket.getOutputStream();/數(shù)據(jù)輸出流,用來寫入由數(shù)據(jù)輸入流讀取的數(shù)據(jù) Dout.writeBoo

19、lean(true); catch (IOException e) e.printStackTrace(); /end else try FileOutputStream fout = new FileOutputStream(file);/創(chuàng)建一個(gè)向指定file表示的文件中寫入數(shù)據(jù)的文件輸出流。即上面的chooser.getSelectedFile() BufferedOutputStream Bout = new BufferedOutputStream(fout);/創(chuàng)建一個(gè)新的緩沖輸出流，以將數(shù)據(jù)寫入指定的輸出流。 BufferedInputStream Bin = new BufferedInputStream(socket.getInputStream();/創(chuàng)建一個(gè)緩沖區(qū)數(shù)組,保存套接字socket輸入流，以便使用 byte by = new byte100000; int l ; int yes=J