mina传文件案例，客户端加服务端

package com.psbc.socket; import java.io.BufferedInputStream; import java.io.BufferedOutputStream; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.File; import java.io.FileOutputStream; import java.net.ServerSocket; import java.net.Socket; import java.util.Date; import java.util.UUID; import org.apache.ibatis.session.SqlSession; import com.psbc.mapper.FileRepositoryMapper; import com.psbc.model.FileRepository; import com.psbc.util.DBUtil; import com.psbc.util.DateUtil; public class SocketServer { private int port = 8085; private void start() { Socket socket = null; try { ServerSocket serverSocket = new ServerSocket(port); while (true) { System.out.println("等待客户端连接，连接端口：" + port); socket = serverSocket.accept(); System.out.println("建立socket链接"); DataInputStream dis = new DataInputStream( new BufferedInputStream(socket.getInputStream())); String savePath = "D:\\filedoc\\"; String fileName = ""; // 文件名 String channel = ""; //传送渠道 String prefix = ""; // 文件前缀 String suffix = ""; // 文件后缀 int bufferSize = 8192; byte[] buf = new byte[bufferSize]; // 文件缓存区 long len = 0; // 文件总长度 fileName = dis.readUTF(); channel = dis.readUTF(); prefix = fileName.substring(0, fileName.lastIndexOf(".")); suffix = fileName.substring(fileName.lastIndexOf(".")); String year = ""; String month = ""; String day = ""; String date = DateUtil.getString(new Date(),"yyyy_MM_dd"); year = date.substring(0, date.indexOf("_")); month = date.substring(date.indexOf("_") + 1, date .lastIndexOf("_")); day = date.substring(date.lastIndexOf("_") + 1); savePath += year + "\\" + month + "\\" + day + "\\"; File dir = new File(savePath); if (!dir.exists()) { dir.mkdirs(); } savePath += prefix + System.currentTimeMillis() + suffix; // 文件存放绝对路径 len = dis.readLong(); DataOutputStream dosFile = new DataOutputStream( new BufferedOutputStream(new FileOutputStream(savePath))); System.out.println("File size()：" + len + "bytes"); System.out.println("开始接收文件！"); while (true) { int read = 0; if (dis != null) { read = dis.read(buf); } if (read == -1) { break; } dosFile.write(buf, 0, read); } System.out.println("接收完成，文件存为：" + savePath); DataOutputStream dosUUID = new DataOutputStream(socket.getOutputStream()); UUID uuid = UUID.randomUUID(); //String fileId = String.valueOf(uuid).replaceAll("-", ""); String fileId = String.valueOf(uuid); SqlSession session = DBUtil.getSession().openSession(); FileRepository fr = new FileRepository(); fr.setFileId(fileId); fr.setFileType(suffix); fr.setFileSize((int)len); fr.setFilePath(savePath); fr.setSourceChannel(channel); fr.setCreateTime(new Date()); FileRepositoryMapper frMapper = session.getMapper(FileRepositoryMapper.class); frMapper.insert(fr); session.commit(); session.close(); System.out.println("数据库插入成功！"); System.out.println("fileId：" + fileId); dosUUID.writeUTF(fileId); dosUUID.flush(); System.out.println("发送完成！"); dis.close(); dosFile.close(); dosUUID.close(); socket.close(); } } catch (Exception e) { e.printStackTrace(); } } public static void main(String[] args) { new SocketServer().start(); } }