本文共 37276 字，大约阅读时间需要 124 分钟。
public class RandomUtils { //当前时间 + 随机数 public static String createActive(){ return getTime()+Integer.toHexString(new Random().nextInt(900)+100); } private static String getTime(){ return new SimpleDateFormat("yyyyMMddHHmmssSSS").format(Calendar.getInstance().getTime()); } //生成订单编号 public static String createOrderId(){ return getTime(); }} public class DruidUtils { private static DruidDataSource dataSource; static { Properties properties = new Properties(); InputStream is = DruidUtils.class.getClassLoader().getResourceAsStream("druid.properties"); try { properties.load(is); dataSource = (DruidDataSource) DruidDataSourceFactory.createDataSource(properties); } catch (Exception e) { e.printStackTrace(); throw new RuntimeException("初始化连接池失败", e); } } public static DataSource getDataSource() { return dataSource; }} public class EmailUtils { public static void sendEmail(User user){ //发送方 String myAccount = "renjie9283@163.com"; //授权码，需要到自己邮箱去生成 String myPass = "cq1701"; //发件人 邮箱的 SMTP 服务器地址，如果是qq邮箱则改成smtp.qq.com String SMTPHost = "smtp.163.com"; //组成 properties Properties prop = new Properties(); prop.setProperty("mail.transport.protocol", "smtp");//设置协议类型 prop.setProperty("mail.smtp.host", SMTPHost);//定义发件人的邮箱服务器地址 prop.setProperty("mail.smtp.auth", "true");//设置请求验证 //1.Session对象 创建会话 用于和邮箱服务器进行交互 Session session = Session.getDefaultInstance(prop); //设置debug模式 可以查看详细发送信息 可略 session.setDebug(true); //2.创建方法 用来组成一封完整的邮件 //参数 session(参数配置), myAccount 发送方 , user.getEmail() 接收方 MimeMessage message = createMsg(session,myAccount,user); //4.利用Transport 发送邮件 try { Transport tran = session.getTransport(); //连接服务器 确认发送方 是否授权 tran.connect(myAccount, myPass); //发送邮件 将message 对象 传给 Transport 对象 将邮件发送出去 //参数1 要发的内容 参数2 要给哪些人发 //message.getAllRecipients() 获取到所有的收件人 | 抄送 | 密送 tran.sendMessage(message, message.getAllRecipients()); //关闭连接 tran.close(); } catch (MessagingException e) { // TODO Auto-generated catch block e.printStackTrace(); } } private static MimeMessage createMsg(Session session, String myAccount, User user) { //使用session对象 获取待发送的邮件信息 MimeMessage message = new MimeMessage(session); //3.设置发件人 收件人 标题 邮件内容 附件 发送时间等等 try { //3.1发件人 from message.setFrom(new InternetAddress(myAccount, "小米", "utf-8")); //3.2收件人 to 支持可以添加多个收件人 | 抄送 | 密送 如果想要发送给多个人 可以重复下面代码多次 /* * MimeMessage.RecipientType.TO 发送 * MimeMessage.RecipientType.CC 抄送 * MimeMessage.RecipientType.BCC 密送 * */ message.setRecipient(MimeMessage.RecipientType.TO, new InternetAddress(user.getEmail(), user.getUsername(), "utf-8")); //3.3生成邮件主题 message.setSubject("小米商城账号激活邮件","utf-8"); String ip = Inet4Address.getLocalHost().getHostAddress(); String url = "http://"+ip+":8080/myxiaomi/activate?e="+ Base64Utils.encode(user.getEmail())+"&c="+Base64Utils.encode(user.getCode()); //设置邮件正文 setContent 可以使用html标签 message.setContent(user.getUsername()+",你好欢迎注册小米商城! 请点击链接进行激活:"+url+"","text/html;charset=utf-8"); //设置邮件的发送时间 是立即发送 message.setSentDate(new Date()); //保存设置 message.saveChanges(); } catch (UnsupportedEncodingException | MessagingException | UnknownHostException e) { // TODO Auto-generated catch block e.printStackTrace(); } return message; }} public class MD5Utils { public static String md5(String str) { try { MessageDigest messageDigest = MessageDigest.getInstance("MD5"); messageDigest.update(str.getBytes("utf-8")); byte[] digest = messageDigest.digest(); //1表示正数 BigInteger bigInteger = new BigInteger(1, digest); return bigInteger.toString(16); } catch (Exception e) { e.printStackTrace(); } return null; }} public class Md5Util { public static final String SIGN_KEY = "sign_key";//签名key public static final String PARAMETER_KEY = "parameter_key";//拼装的参数key /** * 新的md5签名，首尾放secret。 * * @param key 商家key * tradeNo 流水号 * secret * @param key 分配给您的APP_SECRET */ public static String md5Signature(long id, String tradeNo, String key) { StringBuffer sb = new StringBuffer(); sb.append(key); sb.append(id); sb.append(tradeNo); sb.append(key); MessageDigest md = null; try { md = MessageDigest.getInstance("MD5"); } catch (NoSuchAlgorithmException e) { e.printStackTrace(); } String result = null; try { result = byte2hex(md.digest(sb.toString().getBytes("utf-8"))); } catch (UnsupportedEncodingException e) { e.printStackTrace(); } return result; } /** * 二行制转字符串 */ private static String byte2hex(byte[] b) { StringBuffer hs = new StringBuffer(); String stmp = ""; for (int n = 0; n < b.length; n++) { stmp = (Integer.toHexString(b[n] & 0XFF)); if (stmp.length() == 1) hs.append("0").append(stmp); else hs.append(stmp); } return hs.toString().toUpperCase(); } /*** * 对请求的参数排序，生成定长的签名 * @param paramsMap 排序后的字符串 * @param secret 密钥 * */ public static String md5Signature(Map paramsMap, String secret) { Map resultMap = new HashMap ();//用于记录返回的签名和将参数按照签名拼装的url String result = ""; StringBuilder sb = new StringBuilder(); Map treeMap = new TreeMap (); treeMap.putAll(paramsMap); sb.append(secret); Iterator iterator = treeMap.keySet().iterator(); while (iterator.hasNext()) { String name = (String) iterator.next(); sb.append(name).append(treeMap.get(name)); } sb.append(secret); resultMap.put(PARAMETER_KEY, sb.toString()); try { MessageDigest md = MessageDigest.getInstance("MD5"); /**MD5加密，输出一个定长信息摘要*/ result = byte2hex(md.digest(sb.toString().getBytes("utf-8"))); } catch (Exception e) { throw new RuntimeException("sign error !"); } resultMap.put(SIGN_KEY, result); return result; } /** * Calculates the MD5 digest and returns the value as a 16 element * byte[]. * * @param data Data to digest * @return MD5 digest */ public static byte[] md5(String data) { return md5(data.getBytes()); } /** * Calculates the MD5 digest and returns the value as a 16 element * byte[]. * * @param data Data to digest * @return MD5 digest */ public static byte[] md5(byte[] data) { return getDigest().digest(data); } /** * Returns a MessageDigest for the given algorithm. * * @param * @return An MD5 digest instance. * @throws RuntimeException when a {@link NoSuchAlgorithmException} is * caught */ static MessageDigest getDigest() { try { return MessageDigest.getInstance("MD5"); } catch (NoSuchAlgorithmException e) { throw new RuntimeException(e); } }} public class StringUtils { public static boolean isEmpty(String str) { if (str == null || str.trim().length() == 0) { return true; } else { return false; } }} public class Base64Utils { //base64编码 public static String encode(String msg){ return Base64.getEncoder().encodeToString(msg.getBytes()); } //base64解码 public static String decode(String msg){ return new String(Base64.getDecoder().decode(msg)); }}String password="abc";//密码明文String salt=UUID.randomUUID().toString();//盐Integer iter = 1000;//迭代次数String pwd = new Md5Hash(password, salt,iter).toString(); //md5加密String pwd = new Md5Hash(password, salt, iter).toBase64(); //加密后转base64String pwd = new Sha256Hash(password, salt, iter).toString();//sha256加密String pwd = new Sha256Hash(password, salt, iter).toBase64();//加密后转base64String pwd = new Sha512Hash(password, salt, iter).toString();//sha256加密String pwd = new Sha512Hash(password, salt, iter).toBase64()//加密后转base64 public class DataSourceUtils { private static DruidDataSource dataSource; private static ThreadLocal threadLocal; static { //实例化本地线程，但是为空 threadLocal = new ThreadLocal<>(); Properties properties = new Properties(); InputStream is = DataSourceUtils.class.getClassLoader().getResourceAsStream("druid.properties"); try { properties.load(is); dataSource = (DruidDataSource) DruidDataSourceFactory.createDataSource(properties); } catch (Exception e) { e.printStackTrace(); System.out.println("初始化连接池失败"); } } public static DataSource getDataSource() { return dataSource; } public static Connection getConnection() { //获取连接 Connection connection = threadLocal.get(); //第一次获取，连接肯定是空的，这时需要绑定连接 if (connection == null) { try { connection = dataSource.getConnection(); } catch (SQLException e) { e.printStackTrace(); } threadLocal.set(connection);//绑定连接 } return connection; //返回同一个线程，即同一个连接 } //开启事务处理 public static void beginTranscation() { Connection connection = getConnection(); try { connection.setAutoCommit(false); } catch (SQLException e) { e.printStackTrace(); } } //提交事务 public static void commit() { Connection connection = getConnection(); try { connection.commit(); } catch (SQLException e) { e.printStackTrace(); } } //回滚 public static void rollBack() { Connection connection = getConnection(); try { connection.rollback(); } catch (SQLException e) { e.printStackTrace(); } } //事务关闭 public static void close() { Connection connection = getConnection(); try { connection.close(); threadLocal.remove();//解除绑定 } catch (SQLException e) { e.printStackTrace(); } }} //生成令牌，单例模式public class TokenProccessor { private static final TokenProccessor INSTANCE = new TokenProccessor(); private TokenProccessor(){ } public static TokenProccessor getInstance() { return INSTANCE; } //生产令牌方法 public String makeToken() { //日期字符串+随机数=加密令牌 SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS"); String str = sdf.format(new Date())+ new Random().nextInt(999999999); //Md5加密过程 try { //1. 获取消息摘要，传入md5加密算法 MessageDigest md5 = MessageDigest.getInstance("md5"); //2. 更新数据 md5.update(str.getBytes()); //3. 加密处理，得出字节结果 byte[] digest = md5.digest(); //4. 转字符串,用Base64编码，调取编码器 return Base64.getEncoder().encodeToString(digest); } catch (NoSuchAlgorithmException e) { e.printStackTrace(); } return null; }} //将令牌给到session，以及删除令牌public class TokenTools { public static void createToke(HttpServletRequest request, String tokenKey) { //1.获取token String token = TokenProccessor.getInstance().makeToken(); //上面的方法 request.getSession().setAttribute(tokenKey, token); //tokenKey是令牌名称 } public static void removeToke(HttpServletRequest request, String tokenKey) { //2.删除token request.getSession().removeAttribute(tokenKey); }} 三种方法：
public class UploadUtils { /*UUID的打印结果是有横杆的，需要去掉横杠，并用下划线与图片文件名连接*/ /*这样就可以生成一个不重复的图片名称，避免图片覆盖*/ public static String createNewFilename(String filename) { String s = UUID.randomUUID().toString().replace("-", ""); return s + "_" + filename; } /** * @param realpath 真实路径，这里是upload文件夹，但是不能将所有文件都存到该文件夹，需要分散 * @param filename 文件名称，可以获取其哈希值，然后取后四位，即0-15（0000-1111）随机数，作为一级子文件夹 * 然后将哈希值右移四位，取次后四位，还是0-15，作为二级文件夹，这样分散处理 * 这里返回的是文件夹的路径，所以需要在controller层将文件通过【File.separator】添加到路径 */ public static String createNewPath(String realpath, String filename) { int hashCode = filename.hashCode(); //32位 int dir1 = hashCode&0xf; //得到后四位0-15 int dir2 = (hashCode>>4)&0xf; //或者是 (hashCode&0xf0)>>4，获取次4位 0-15 String newPath = realpath + File.separator + dir1 + File.separator + dir2; File file = new File(newPath); if (!file.exists()) { file.mkdirs(); } return newPath; } /*遍历，用key保存真实文件名，带有UUID的文件名，用value保存没有UUID的文件名，显示是不带UUID，视觉好看，然后下载是带UUID*/ public static void listFiles(File dir, HashMap map) { File[] files = dir.listFiles(); if (files != null) { for (File file : files) { if (file.isDirectory()) { listFiles(file, map); } else { map.put(file.getName(), file.getName().split("_")[1]); } } } }} /** * 算术验证码 */public class Captcha1 { public static void generateCaptcha(HttpServletRequest request, HttpServletResponse response) throws IOException { BufferedImage bi = new BufferedImage(68, 22, BufferedImage.TYPE_INT_RGB); Graphics g = bi.getGraphics(); Color c = new Color(200, 150, 255); g.setColor(c); g.fillRect(0, 0, 68, 22); char[] op = "+-".toCharArray(); Random r = new Random(); int index, len1 = op.length; int result = 0, firstNum = 0, secondNum = 0; char operation = '0'; String ex=""; for (int i = 0; i < 4; i++) { // 四次循环，最后生成 【数字1 运算符 数字2 等号】四个部分，如【1 + 2 =】 if (i != 1) index = r.nextInt(100); else index = r.nextInt(len1); g.setColor(new Color(r.nextInt(88), r.nextInt(188), r.nextInt(255))); if (i == 0) { //g.drawString(index+"", (i*15)+3, 18); ex+=index+" "; firstNum = index; } else if (i == 2) { //g.drawString(index+"", (i*15)+3, 18); ex+=index+" "; secondNum = index; } else if (i == 1) { //g.drawString(op[index]+"", (i*15)+3, 18); ex+=op[index]+" "; operation = op[index]; } else { //g.drawString("=", (i*15)+3, 18); ex+="="; } } // 绘制算术表达式：ex g.drawString(ex,3,18); // 计算结果 if (operation == '+') result = firstNum+secondNum; else if (operation == '-') result = firstNum-secondNum; else if (operation == '*') result = firstNum*secondNum; // 结果存入session request.getSession().setAttribute("captcha", result); // 写出验证码（ 响应请求 ） response.setDateHeader("Expires", 0L); response.setHeader("Cache-Control", "no-store, no-cache, must-revalidate"); response.addHeader("Cache-Control", "post-check=0, pre-check=0"); response.setHeader("Pragma", "no-cache"); // 指向客户端的输出流 ServletOutputStream out = response.getOutputStream(); // 写出验证码图片，响应 ImageIO.write(bi, "JPG", out); try { out.flush(); } finally { out.close(); } }} /** * simple验证码 */public class Captcha2 { public static void generateCaptcha(HttpServletRequest request, HttpServletResponse response) throws IOException { BufferedImage bi = new BufferedImage(68, 22, BufferedImage.TYPE_INT_RGB); Graphics g = bi.getGraphics(); Color c = new Color(200, 150, 255); g.setColor(c); g.fillRect(0, 0, 68, 22); char[] ch = "ABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789".toCharArray();//字符集合 Random r = new Random(); int len = ch.length, index; StringBuffer sb = new StringBuffer(); for (int i = 0; i < 4; i++) { //验证码长度 index = r.nextInt(len); g.setColor(new Color(r.nextInt(88), r.nextInt(188), r.nextInt(255))); g.drawString(ch[index]+"", (i*15)+3, 18); sb.append(ch[index]); } //存入session request.getSession().setAttribute("captcha", sb.toString()); // 写出验证码( 响应请求 ) response.setDateHeader("Expires", 0L); response.setHeader("Cache-Control", "no-store, no-cache, must-revalidate"); response.addHeader("Cache-Control", "post-check=0, pre-check=0"); response.setHeader("Pragma", "no-cache"); ServletOutputStream out = response.getOutputStream(); ImageIO.write(bi, "JPG", out); try { out.flush(); } finally { out.close(); } }} 该工具类使用注意事项：
public class AutoCookie { public static void loginCookie(String key, String value, HttpServletResponse response) { Cookie cookie = new Cookie(key, value); cookie.setHttpOnly(true); cookie.setPath("/"); cookie.setMaxAge(60*60*24); response.addCookie(cookie); } public static void logoutCookie(String key, HttpServletResponse response) { Cookie cookie = new Cookie(key, ""); cookie.setHttpOnly(true); cookie.setPath("/"); cookie.setMaxAge(0); response.addCookie(cookie); }} 外部需要ajax请求获取，会直接将其转为js对象，直接使用msg或者code属性即可。
最后的可以使用其中的put方法，该方法可以链式调用，将多个参数封装 R.ok().put....