基于java服务端的html聊天室

package com.sunny.main; import java.io.BufferedInputStream; import java.io.BufferedOutputStream; import java.io.File; import java.io.FileOutputStream; import java.io.IOException; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.SQLException; import java.sql.Statement; import java.text.SimpleDateFormat; import java.util.Date; import java.util.Iterator; import java.util.List; import java.util.Map; import javax.servlet.ServletException; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpSession; import org.apache.commons.fileupload.FileItem; import org.apache.commons.fileupload.FileUploadException; import org.apache.commons.fileupload.disk.DiskFileItem; import org.apache.commons.fileupload.disk.DiskFileItemFactory; import org.apache.commons.fileupload.servlet.ServletFileUpload; import org.apache.commons.fileupload.util.Streams; public class UploadServlet extends HttpServlet { private static final long serialVersionUID = 1L; /** * 实现多文件的同时上传 */ public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { HttpSession session = request.getSession(); // 设置接收的编码格式 request.setCharacterEncoding("UTF-8"); Date date = new Date();// 获取当前时间 SimpleDateFormat sdfFileName = new SimpleDateFormat("yyyyMMddHHmmss"); SimpleDateFormat sdfFolder = new SimpleDateFormat("yyMM"); String newfileName = sdfFileName.format(date);// 文件名称 String fileRealPath = "";// 文件存放真实地址 String fileRealResistPath = "";// 文件存放真实相对路径 // 名称 界面编码 必须 和request 保存一致..否则乱码 // String name = request.getParameter("name"); String name = session.getAttribute("LOGINUSER").toString(); String firstFileName = ""; // 获得容器中上传文件夹所在的物理路径 String savePath = this.getServletConfig().getServletContext() .getRealPath("/") + "uploads\\" + newfileName + "\\"; File file = new File(savePath); if (!file.isDirectory()) { file.mkdirs(); } try { DiskFileItemFactory fac = new DiskFileItemFactory(); ServletFileUpload upload = new ServletFileUpload(fac); upload.setHeaderEncoding("UTF-8"); // 获取多个上传文件 // Map<String, List<FileItem>> // filemap=upload.parseParameterMap(request); List<FileItem> fileList = upload.parseRequest(request); // 遍历上传文件写入磁盘 Iterator it = fileList.iterator(); while (it.hasNext()) { Object obit = it.next(); if (obit instanceof DiskFileItem) { DiskFileItem item = (DiskFileItem) obit; // 如果item是文件上传表单域 // 获得文件名及路径 String fileName = item.getName(); if (fileName != null) { firstFileName = item.getName().substring( item.getName().lastIndexOf("\\") + 1); String formatName = firstFileName .substring(firstFileName.lastIndexOf("."));// 获取文件后缀名 fileRealPath = savePath + newfileName + formatName;// 文件存放真实地址 BufferedInputStream in = new BufferedInputStream( item.getInputStream());// 获得文件输入流 BufferedOutputStream outStream = new BufferedOutputStream( new FileOutputStream(new File(fileRealPath)));// 获得文件输出流 Streams.copy(in, outStream, true);// 开始把文件写到你指定的上传文件夹 // 上传成功，则插入数据库 if (new File(fileRealPath).exists()) { // 虚拟路径赋值 fileRealResistPath = fileRealPath .substring(fileRealPath.lastIndexOf("\\") + 1); // 保存到数据库 String user = session.getAttribute("LOGINUSER") .toString(); Connection cnn = null; PreparedStatement pst = null; try { //将文件信息插入数据库 Class.forName("com.mysql.jdbc.Driver"); cnn = DriverManager .getConnection("jdbc:mysql://localhost:3306/file?user=root&password="); String sql="insert into file(user,path,realname) values('"+user+"','"+newfileName+"','"+fileName+"')"; pst = cnn.prepareStatement(sql); pst.executeUpdate(); } catch (SQLException e) { e.printStackTrace(); } catch (ClassNotFoundException e) { e.printStackTrace(); } finally { try { if (pst != null) { pst.close(); pst = null; } if (cnn != null) { cnn.close(); cnn = null; } } catch (SQLException e) { e.printStackTrace(); } } //加入聊天信息中 String str=user+"上传了文件："+"<a href='uploads/"+newfileName+"/"+newfileName+".zip'>"+fileName+"</a>"; HelloServlet.strSendConentList.add(str); } } } } } catch (FileUploadException ex) { ex.printStackTrace(); System.out.println("没有上传文件"); return; } response.getWriter().write("1"); } public void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException { doGet(req, resp); } }