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; // 从此输入流中将最多 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;// 从所包含的输入流中读取一定数量的字节，并将它们存储到缓冲区数组 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!");}}}
页:
[1]