java swing传文件多线程，help

小弟想实现不停点发送按钮就会不停地传文件，但是传了一次就不行了，发现DEBUG的时候可行，RUN的时候就出错了
服务端：package com.pc.tr;import java.awt.BorderLayout;
import java.awt.Dimension;
import java.awt.FileDialog;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.*;
import java.net.*;
import javax.swing.JButton;
import javax.swing.JFileChooser;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JOptionPane;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
import javax.swing.filechooser.FileFilter;
import javax.swing.filechooser.FileNameExtensionFilter;public class ServerSocketFrame extends JFrame {
private JTextArea ta_info;
private File file = null;// 声明所选择图片的File对象
private JTextField tf_path;
private DataOutputStream out = null; // 创建流对象
private DataInputStream in = null; // 创建流对象
private ServerSocket server; // 声明ServerSocket对象
private Socket socket; // 声明Socket对象socket
private long lengths = -1; // 图片文件的大小
private String fileName = null;
private int count=1;
public void getServer() {
try {
server = new ServerSocket(1978); // 实例化Socket对象

ta_info.append("服务器套接字已经创建成功\n"); // 输出信息
ta_info.append("等待客户机的连接......\n"); // 输出信息


while (true) { // 如果套接字是连接状态

socket = server.accept(); // 实例化Socket对象

if(count==1){
ta_info.append("客户机连接成功......\n"); // 输出信息
}
if (socket != null && !socket.isClosed()) {
out = new DataOutputStream(socket.getOutputStream());// 获得输出流对象
in = new DataInputStream(socket.getInputStream());// 获得输入流对象
ClientHander client=new ClientHander(socket); // 调用getClientInfo()方法
Thread thread=new Thread(client);
thread.start();
/*new Thread(new Runnable(){
public void run(){
try {
String name = in.readUTF();// 读取文件名
long lengths = in.readLong();// 读取文件的长度
byte[] bt = new byte[(int) lengths];// 创建字节数组
for (int i = 0; i < bt.length; i++) {
bt[i] = in.readByte();// 读取字节信息并存储到字节数组
}
FileDialog dialog = new FileDialog(ServerSocketFrame.this, "保存");// 创建对话框
dialog.setMode(FileDialog.SAVE);// 设置对话框为保存对话框
dialog.setFile(name);
dialog.setVisible(true);// 显示保存对话框
String path = dialog.getDirectory();// 获得文件的保存路径 String newFileName = dialog.getFile();// 获得保存的文件名
long startTime = System.currentTimeMillis(); if (path == null || newFileName == null) {
return;
} String pathAndName = path + "\\" + newFileName;// 文件的完整路径 FileOutputStream fOut = new FileOutputStream(pathAndName); fOut.write(bt); fOut.flush(); fOut.close();


ta_info.append("第"+count+"文件。\n");
ta_info.append(pathAndName + "文件接收完毕。\n");
long endTime = System.currentTimeMillis();
ta_info.append("程序运行时间： " + (endTime - startTime) + "ms\n");
count++; } catch (Exception e) {
} finally {
try {
if (in != null) {
in.close();// 关闭流
}
if (socket != null) {
socket.close(); // 关闭套接字
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}).start();*/

} else {
socket = server.accept(); // 实例化Socket对象
count++;
}
}
} catch (Exception e) {
e.printStackTrace(); // 输出异常信息
}
} class ClientHander implements Runnable {

private Socket socket;
public ClientHander(Socket socket1) {
socket = socket1;
}
public void run() {
try {
String name = in.readUTF();// 读取文件名
long lengths = in.readLong();// 读取文件的长度
byte[] bt = new byte[(int) lengths];// 创建字节数组
for (int i = 0; i < bt.length; i++) {
bt[i] = in.readByte();// 读取字节信息并存储到字节数组
}
FileDialog dialog = new FileDialog(ServerSocketFrame.this, "保存");// 创建对话框
dialog.setMode(FileDialog.SAVE);// 设置对话框为保存对话框
dialog.setFile(name);
dialog.setVisible(true);// 显示保存对话框
String path = dialog.getDirectory();// 获得文件的保存路径 String newFileName = dialog.getFile();// 获得保存的文件名
long startTime = System.currentTimeMillis(); if (path == null || newFileName == null) {
return;
} String pathAndName = path + "\\" + newFileName;// 文件的完整路径 FileOutputStream fOut = new FileOutputStream(pathAndName); fOut.write(bt); fOut.flush(); fOut.close(); ta_info.append(pathAndName + "文件接收完毕。\n");
long endTime = System.currentTimeMillis();
ta_info.append("程序运行时间： " + (endTime - startTime) + "ms\n"); } catch (Exception e) {
} finally {
try {
if (in != null) {
in.close();// 关闭流
}
if (socket != null) {
socket.close(); // 关闭套接字
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
} public static void main(String[] args) { // 主方法
ServerSocketFrame frame = new ServerSocketFrame(); // 创建本类对象
frame.setVisible(true);
frame.getServer(); // 调用方法
} public ServerSocketFrame() {
super();
setTitle("服务器端程序");
setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
setBounds(100, 100, 379, 260); final JPanel panel = new JPanel();
getContentPane().add(panel, BorderLayout.NORTH); final JLabel label = new JLabel();
label.setText("路径：");
panel.add(label); tf_path = new JTextField();
tf_path.setPreferredSize(new Dimension(140, 25));
panel.add(tf_path); final JButton button_1 = new JButton(); // 监听选择视屏
button_1.addActionListener(new ActLis());
button_1.setText("选择视频");
panel.add(button_1); final JButton button = new JButton();
// 监听发送
button.addActionListener(new ActLis_1());
button.setText("发  送");
panel.add(button); final JScrollPane scrollPane = new JScrollPane();
getContentPane().add(scrollPane, BorderLayout.CENTER); ta_info = new JTextArea();
scrollPane.setViewportView(ta_info);
} class ActLis implements ActionListener {
@Override
public void actionPerformed(ActionEvent e) {
JFileChooser fileChooser = new JFileChooser();// 创建文件选择器
FileFilter filter = new FileNameExtensionFilter(
"视频文件（AVI/MPG/DAT/RM)", "AVI", "MPG", "DAT", "RM");// 创建过滤器
fileChooser.setFileFilter(filter);// 设置过滤器
int flag = fileChooser.showOpenDialog(null);// 显示打开对话框
if (flag == JFileChooser.APPROVE_OPTION) {
file = fileChooser.getSelectedFile(); // 获取选中视频文件的File对象
}
if (file != null) {
tf_path.setText(file.getAbsolutePath());// 视频文件的完整路径
fileName = file.getName();// 获得视频文件的名称
}
}
} class ActLis_1 implements ActionListener {
@Override
public void actionPerformed(ActionEvent e) {
try {
DataInputStream inStream = null;// 定义数据输入流对象
if (file != null) {
lengths = file.length();// 获得所选择视频文件的大小
inStream = new DataInputStream(new FileInputStream(file));// 创建输入流对象
} else {
JOptionPane.showMessageDialog(null, "还没有选择视频文件。");
return;
}
out.writeUTF(fileName);// 写入视频文件名
out.writeLong(lengths);// 将文件的大小写入输出流
byte[] bt = new byte[(int) lengths];// 创建字节数组
int len = -1;
while ((len = inStream.read(bt)) != -1) {// 将视频文件读取到字节数组 out.write(bt);// 将字节数组写入输出流
}
out.flush();
out.close();
ta_info.append("文件发送完毕。\n");
} catch (IOException e1) {
e1.printStackTrace();
}
}
}
}
swing多线程javasocket

解决方案 »

  1.   

    客户端：
    package com.pc.tr;import java.awt.BorderLayout;
    import java.awt.Dimension;
    import java.awt.FileDialog;
    import java.awt.event.ActionEvent;
    import java.awt.event.ActionListener;
    import java.io.*;
    import java.net.*;
    import javax.swing.JButton;
    import javax.swing.JFileChooser;
    import javax.swing.JFrame;
    import javax.swing.JLabel;
    import javax.swing.JOptionPane;
    import javax.swing.JPanel;
    import javax.swing.JScrollPane;
    import javax.swing.JTextArea;
    import javax.swing.JTextField;
    import javax.swing.filechooser.FileFilter;
    import javax.swing.filechooser.FileNameExtensionFilter;public class ServerSocketFrame extends JFrame {
    private JTextArea ta_info;
    private File file = null;// 声明所选择图片的File对象
    private JTextField tf_path;
    private DataOutputStream out = null; // 创建流对象
    private DataInputStream in = null; // 创建流对象
    private ServerSocket server; // 声明ServerSocket对象
    private Socket socket; // 声明Socket对象socket
    private long lengths = -1; // 图片文件的大小
    private String fileName = null;
    private int count=1;
    public void getServer() {
    try {
    server = new ServerSocket(1978); // 实例化Socket对象

    ta_info.append("服务器套接字已经创建成功\n"); // 输出信息
    ta_info.append("等待客户机的连接......\n"); // 输出信息


    while (true) { // 如果套接字是连接状态

    socket = server.accept(); // 实例化Socket对象

    if(count==1){
    ta_info.append("客户机连接成功......\n"); // 输出信息
    }
    if (socket != null && !socket.isClosed()) {
    out = new DataOutputStream(socket.getOutputStream());// 获得输出流对象
    in = new DataInputStream(socket.getInputStream());// 获得输入流对象
    ClientHander client=new ClientHander(socket); // 调用getClientInfo()方法
    Thread thread=new Thread(client);
    thread.start();
    /*new Thread(new Runnable(){
    public void run(){
    try {
    String name = in.readUTF();// 读取文件名
    long lengths = in.readLong();// 读取文件的长度
    byte[] bt = new byte[(int) lengths];// 创建字节数组
    for (int i = 0; i < bt.length; i++) {
    bt[i] = in.readByte();// 读取字节信息并存储到字节数组
    }
    FileDialog dialog = new FileDialog(ServerSocketFrame.this, "保存");// 创建对话框
    dialog.setMode(FileDialog.SAVE);// 设置对话框为保存对话框
    dialog.setFile(name);
    dialog.setVisible(true);// 显示保存对话框
    String path = dialog.getDirectory();// 获得文件的保存路径 String newFileName = dialog.getFile();// 获得保存的文件名
    long startTime = System.currentTimeMillis(); if (path == null || newFileName == null) {
    return;
    } String pathAndName = path + "\\" + newFileName;// 文件的完整路径 FileOutputStream fOut = new FileOutputStream(pathAndName); fOut.write(bt); fOut.flush(); fOut.close();


    ta_info.append("第"+count+"文件。\n");
    ta_info.append(pathAndName + "文件接收完毕。\n");
    long endTime = System.currentTimeMillis();
    ta_info.append("程序运行时间： " + (endTime - startTime) + "ms\n");
    count++; } catch (Exception e) {
    } finally {
    try {
    if (in != null) {
    in.close();// 关闭流
    }
    if (socket != null) {
    socket.close(); // 关闭套接字
    }
    } catch (IOException e) {
    e.printStackTrace();
    }
    }
    }
    }).start();*/

    } else {
    socket = server.accept(); // 实例化Socket对象
    count++;
    }
    }
    } catch (Exception e) {
    e.printStackTrace(); // 输出异常信息
    }
    } class ClientHander implements Runnable {

    private Socket socket;
    public ClientHander(Socket socket1) {
    socket = socket1;
    }
    public void run() {
    try {
    String name = in.readUTF();// 读取文件名
    long lengths = in.readLong();// 读取文件的长度
    byte[] bt = new byte[(int) lengths];// 创建字节数组
    for (int i = 0; i < bt.length; i++) {
    bt[i] = in.readByte();// 读取字节信息并存储到字节数组
    }
    FileDialog dialog = new FileDialog(ServerSocketFrame.this, "保存");// 创建对话框
    dialog.setMode(FileDialog.SAVE);// 设置对话框为保存对话框
    dialog.setFile(name);
    dialog.setVisible(true);// 显示保存对话框
    String path = dialog.getDirectory();// 获得文件的保存路径 String newFileName = dialog.getFile();// 获得保存的文件名
    long startTime = System.currentTimeMillis(); if (path == null || newFileName == null) {
    return;
    } String pathAndName = path + "\\" + newFileName;// 文件的完整路径 FileOutputStream fOut = new FileOutputStream(pathAndName); fOut.write(bt); fOut.flush(); fOut.close(); ta_info.append(pathAndName + "文件接收完毕。\n");
    long endTime = System.currentTimeMillis();
    ta_info.append("程序运行时间： " + (endTime - startTime) + "ms\n"); } catch (Exception e) {
    } finally {
    try {
    if (in != null) {
    in.close();// 关闭流
    }
    if (socket != null) {
    socket.close(); // 关闭套接字
    }
    } catch (IOException e) {
    e.printStackTrace();
    }
    }
    }
    } public static void main(String[] args) { // 主方法
    ServerSocketFrame frame = new ServerSocketFrame(); // 创建本类对象
    frame.setVisible(true);
    frame.getServer(); // 调用方法
    } public ServerSocketFrame() {
    super();
    setTitle("服务器端程序");
    setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
    setBounds(100, 100, 379, 260); final JPanel panel = new JPanel();
    getContentPane().add(panel, BorderLayout.NORTH); final JLabel label = new JLabel();
    label.setText("路径：");
    panel.add(label); tf_path = new JTextField();
    tf_path.setPreferredSize(new Dimension(140, 25));
    panel.add(tf_path); final JButton button_1 = new JButton(); // 监听选择视屏
    button_1.addActionListener(new ActLis());
    button_1.setText("选择视频");
    panel.add(button_1); final JButton button = new JButton();
    // 监听发送
    button.addActionListener(new ActLis_1());
    button.setText("发  送");
    panel.add(button); final JScrollPane scrollPane = new JScrollPane();
    getContentPane().add(scrollPane, BorderLayout.CENTER); ta_info = new JTextArea();
    scrollPane.setViewportView(ta_info);
    } class ActLis implements ActionListener {
    @Override
    public void actionPerformed(ActionEvent e) {
    JFileChooser fileChooser = new JFileChooser();// 创建文件选择器
    FileFilter filter = new FileNameExtensionFilter(
    "视频文件（AVI/MPG/DAT/RM)", "AVI", "MPG", "DAT", "RM");// 创建过滤器
    fileChooser.setFileFilter(filter);// 设置过滤器
    int flag = fileChooser.showOpenDialog(null);// 显示打开对话框
    if (flag == JFileChooser.APPROVE_OPTION) {
    file = fileChooser.getSelectedFile(); // 获取选中视频文件的File对象
    }
    if (file != null) {
    tf_path.setText(file.getAbsolutePath());// 视频文件的完整路径
    fileName = file.getName();// 获得视频文件的名称
    }
    }
    } class ActLis_1 implements ActionListener {
    @Override
    public void actionPerformed(ActionEvent e) {
    try {
    DataInputStream inStream = null;// 定义数据输入流对象
    if (file != null) {
    lengths = file.length();// 获得所选择视频文件的大小
    inStream = new DataInputStream(new FileInputStream(file));// 创建输入流对象
    } else {
    JOptionPane.showMessageDialog(null, "还没有选择视频文件。");
    return;
    }
    out.writeUTF(fileName);// 写入视频文件名
    out.writeLong(lengths);// 将文件的大小写入输出流
    byte[] bt = new byte[(int) lengths];// 创建字节数组
    int len = -1;
    while ((len = inStream.read(bt)) != -1) {// 将视频文件读取到字节数组 out.write(bt);// 将字节数组写入输出流
    }
    out.flush();
    out.close();
    ta_info.append("文件发送完毕。\n");
    } catch (IOException e1) {
    e1.printStackTrace();
    }
    }
    }
    }
      

  2.   

    那个。这位同学
    long lengths = in.readLong();// 读取文件的长度
    byte[] bt = new byte[(int) lengths];// 创建字节数组
    你这个你看能支持2G的文件么？