Java网络聊天之文件传送

吃猫的鱼

  这次带给大家的是Java Socket文件传送，给出核心代码：
  1.发送
 
class SendFile implements Runnable {  public void run() {   JFileChooser fc = new JFileChooser();   int return_value = fc.showOpenDialog(b2);   if (return_value == JFileChooser.APPROVE_OPTION) {    File file = fc.getSelectedFile();    try {     PORT = getPort(t3.getText());     serverIP = getIP();     // 通过打开一个到实际文件的连接来创建一个 FileInputStream，该文件通过文件系统中的 File 对象     // file 指定。     FileInputStream fos = new FileInputStream(file);     Socket socket = new Socket(serverIP, PORT);// 创建连接到指定服务器的套接字     socket.setSoTimeout(20);     DataOutputStream out = new DataOutputStream(socket.getOutputStream());     out.writeUTF(file.getName());// 以与机器无关方式使用 UTF-8  修改版编码将一个字符串写入基础输出流。     ta1.append("File " + file.getName() + " begins to send!\n");     OutputStream netOut = socket.getOutputStream();     // BufferedOutputStream,该类实现缓冲的输出流。通过设置这种输出流，应用程序就可以将各个字节写入基础输出流中，而不必为每次字节写入调用基础系统。     OutputStream doc = new DataOutputStream(new BufferedOutputStream(netOut));     byte[] buf = new byte[2048];     // 从此输入流中将最多 buf.length 个字节的数据读入一个字节数组中。     int num = fos.read(buf);     if (num != (-1))      ta1.append("File is sending...\n");     while (num != (-1))// 是否读完文件     {      doc.write(buf, 0, num);// 将指定字节数组中从偏移量0 开始的 num个字节写入基础输出流。      doc.flush();// 清空此数据输出流。      num = fos.read(buf);// 继续从文件中读取数据     }     if (num == (-1))      ta1.append("The file sending is over.\n");     fos.close();     netOut.close();     Thread.sleep(500);    } catch (Exception ex) {    }   }  } }  2.接收
class ReceiveFile implements Runnable {// static final int INPORT1 = 8888;//端口号public void run() {try {ServerSocket server;server = new ServerSocket(SERVERPORT);// 创建绑定到特定端口的服务器套接字。Socket sock;// 创建一个Socket对象。服务器端便可以利用这个Socket对象与客户进行通讯。while (true) {sock = server.accept();// 侦听并接受到此套接字的连接InetAddress addr = sock.getInetAddress();// 返回套接字连接的地址。System.out.println(addr.getHostAddress());// 使用指定的基础 InputStream 创建一个 DataInputStream。DataInputStream infilename = new DataInputStream(sock.getInputStream());// 从流infilename中读取用 UTF-8 修改版格式编码的 Unicode 字符格式的字符串；然后以String 形式返回此字符串。String filename = new String(infilename.readUTF());System.out.println("filename=" + filename);ta1.append("File" + filename + " is from" + addr.getHostAddress() + "\n");File file = new File("C:" + filename);// 创建一个File实例// 当且仅当不存在具有此抽象路径名指定的名称的文件时，原子地创建由此抽象路径名指定的一个新的空文件。file.createNewFile();// 创建从中读取和向其中写入（可选）的随机存取文件流，该文件由 File 参数指定。RandomAccessFile raf = new RandomAccessFile(file, "rw");InputStream netIn = sock.getInputStream();// 返回此套接字的输入流。// BufferedInputStream(netIn),创建 BufferedInputStream// 并保存其参数，以便将来使用。DataInputStream in = new DataInputStream(new BufferedInputStream(netIn));byte[] buf = new byte[2048];// 从所包含的输入流中读取一定数量的字节，并将它们存储到缓冲区数组 buf 中。int num = in.read(buf);if (num != (-1))ta1.append("File is sending...\n");while (num != (-1))// 是否读完所有数据{// 将 num 个字节从指定字节数组写入到此文件，并从偏移量 0处开始。raf.write(buf, 0, num);// 将数据写往文件// 尝试跳过输入的 num 个字节以丢弃跳过的字节。raf.skipBytes(num);// 顺序写文件字节num = in.read(buf);// 继续读取文件}if (num == (-1))ta1.append("The file has been saved to C disk" + "\n");in.close();raf.close();}} catch (Exception e) {System.out.println("receive error!");}}}