java Swing 上传文件

package com.pp; import java.awt.FileDialog; import java.awt.Rectangle; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.io.BufferedInputStream; import java.io.BufferedWriter; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.FileWriter; import java.io.IOException; import java.net.ServerSocket; import java.net.Socket; import java.text.SimpleDateFormat; import java.util.Date; import java.util.HashMap; import java.util.Map; import javax.swing.JButton; import javax.swing.JFrame; import javax.swing.JLabel; import javax.swing.JOptionPane; import javax.swing.JTextField; import org.apache.poi.hwpf.extractor.WordExtractor; public class JFileFrams extends JFrame { private Socket s ; // private String path = "E:\\doc"; //创建文件夹目录 private static String date = new SimpleDateFormat("yyyyMMddHHmmss")//创建时间 .format(new Date()); private static String doc = "E:\\doc\\" + date + ".doc"; String fileName = null; DataInputStream dis = null; public static void main(String[] args) { JFileFrams jf = new JFileFrams(); jf.show(); try { ServerSocket server = new ServerSocket(8888); // 启动服务器 System.out.println("server start....port:8888"); int i = 0; while (true) { Socket client = server.accept(); new ServerThread(client).start(); // 启动线程 System.out.println("个数:" + (i += 1)); } } catch (Exception e) { } } public JFileFrams() { try { jbInit(); this.setDefaultCloseOperation(3); } catch (Exception ex) { ex.printStackTrace(); } } private void jbInit() throws Exception { this.getContentPane().setLayout(null); btnSanCuan.setText("上传"); btnSanCuan.addActionListener(new JFileFram_btnSanCuan_actionAdapter( this)); this.setSize(380, 250); this.setLocation(300, 300); btnLiuLang.addActionListener(new JFileFram_btnLiuLang_actionAdapter( this)); texIp.setText("127.0.0.1"); texIp.setBounds(new Rectangle(61, 11, 82, 27)); texPort.setText("8888"); texPort.setBounds(new Rectangle(62, 51, 82, 27)); lblIp.setText("IP:"); lblIp.setBounds(new Rectangle(27, 10, 37, 26)); lblPort.setText("Port:"); lblPort.setBounds(new Rectangle(23, 51, 32, 26)); button1.setText("排序"); btnLiuLang.setBounds(new Rectangle(54, 137, 90, 30)); btnLiuLang.setText("浏览"); jTextField1.setText("file"); jTextField1.setEditable(false); jTextField1.setBounds(new Rectangle(56, 99, 228, 28)); btnConnect.addActionListener(new JFileFram_btnConnect_actionAdapter( this)); this.getContentPane().add(lblIp); btnConnect.setBounds(new Rectangle(191, 50, 92, 31)); btnConnect.setText("Connect"); this.getContentPane().add(texIp); this.getContentPane().add(btnLiuLang); this.getContentPane().add(jTextField1); this.getContentPane().add(btnSanCuan); this.getContentPane().add(lblPort); this.getContentPane().add(texPort); this.getContentPane().add(btnConnect); this.getContentPane().add(button); btnSanCuan.setBounds(new Rectangle(198, 139, 89, 29)); } JButton btnSanCuan = new JButton(); JButton btnLiuLang = new JButton(); JButton button =new JButton(); JButton button1=new JButton(); JTextField texIp = new JTextField(); JTextField texPort = new JTextField(); JLabel lblIp = new JLabel(); JLabel lblPort = new JLabel(); File f = null; JTextField jTextField1 = new JTextField(); JButton btnConnect = new JButton(); DataOutputStream out = null; public void btnConnect_actionPerformed(ActionEvent e) { initConnection(); } public void btnLiuLang_actionPerformed(ActionEvent e) { // JFileChooser chooser = new JFileChooser(); // chooser.showOpenDialog(this); FileDialog fd=new FileDialog(this,"上传文件",FileDialog.LOAD); fd.show(); String jfPath=fd.getDirectory()+fd.getFile(); if("null".equals(jfPath)==false){ //浏览文件不选情况 jTextField1.setText(jfPath); //JOptionPane.showMessageDialog(null, fd.getFile(), "标题条文字串", JOptionPane.ERROR_MESSAGE); try { out.writeUTF(fd.getFile()); //文件名发送到服务器 } catch (IOException e1) { e1.printStackTrace(); } } } public void btnSanCuan_actionPerformed(ActionEvent e) { String filePath=jTextField1.getText(); if("file".equals(filePath) ){ //检查是否选择文件 JOptionPane.showMessageDialog(this, "请选择文件","提示",2); return; } try { FileInputStream fis = new FileInputStream(jTextField1.getText()); BufferedInputStream bis = new BufferedInputStream(fis); int n; while ((n = bis.read()) != -1) { //写文件 out.write(n); } bis.close(); fis.close(); out.flush(); out.close(); JOptionPane.showMessageDialog(this, "上传成功！"); initConnection(); } catch (Exception ex) { ex.printStackTrace(); } } public void initConnection(){ try { s= new Socket(texIp.getText(), Integer.parseInt(texPort .getText())); out = new DataOutputStream(s.getOutputStream()); btnConnect.setVisible(false); } catch (java.net.UnknownHostException ex) { System.out.println("远程连接地址没找到错误：请检查！"+ex); }catch(java.net.ConnectException e){ System.out.println("连接失败：请检查连接地址和端口！"+e); } catch(java.lang.NumberFormatException e){ System.out.println("端口格式错误！"+e); } catch(Exception e){ e.printStackTrace(); } } } class JFileFram_btnConnect_actionAdapter implements ActionListener { private JFileFrams adaptee; JFileFram_btnConnect_actionAdapter(JFileFrams adaptee) { this.adaptee = adaptee; } @Override public void actionPerformed(ActionEvent e) { adaptee.btnConnect_actionPerformed(e); } } class JFileFram_btnSanCuan_actionAdapter implements ActionListener { private JFileFrams adaptee; JFileFram_btnSanCuan_actionAdapter(JFileFrams adaptee) { this.adaptee = adaptee; } @Override public void actionPerformed(ActionEvent e) { adaptee.btnSanCuan_actionPerformed(e); } } class JFileFram_btnLiuLang_actionAdapter implements ActionListener { private JFileFrams adaptee; JFileFram_btnLiuLang_actionAdapter(JFileFrams adaptee) { this.adaptee = adaptee; } @Override public void actionPerformed(ActionEvent e) { adaptee.btnLiuLang_actionPerformed(e); } }