项目介绍
本项目使用jsp+servlet+mysql架构搭建可聊天的酷炫博客系统。界面非常好看,除了登录注册个人中心修改外,博客还添加背景音乐,可在线交友聊天,发表动态,相互评论等,喜欢的博文还能添加收藏。
开发环境:
- jdk 8
- intellij idea
- tomcat 8
- mysql 5.7
所用技术:
- jsp+servlet
- js+ajax
- layui
- jdbc+C3P0
博客访问地址
项目目录结构运行效果
登录
首页
动态评论
关注列表
个人资料
聊天页面
核心代码:
- 注册使用邮箱验证码
//邮件对象public class EmailModel { private String title;//标题 private String receiverEmail;//接收人邮箱 private String text;//发送内容 public static String register="欢迎来到微博客\n您的注册为:"; public static String registerTitle="注册验证码"; public static String findPwdTitle="找回密码:"; public static String findPwdText="找回密码验证码:";}// 邮件发送public class EmailUtils { private final static String authorizationCode="khdotvxxxxdba"; //授权码-自己设置 private final static String senderEmail ="1022287044@qq.com"; //发送人邮箱--测试邮箱 //发送邮件方法 public static int sendEmail(EmailModel emailModel){ try{ Properties props = new Properties(); // 开启debug调试 props.setProperty("mail.debug", "false"); // 发送服务器需要身份验证 props.setProperty("mail.smtp.auth", "true"); // 设置邮件服务器主机名 props.setProperty("mail.host", "smtp.qq.com"); // 发送邮件协议名称 props.setProperty("mail.transport.protocol", "smtp"); MailSSLSocketFactory sf = new MailSSLSocketFactory(); sf.setTrustAllHosts(true); props.put("mail.smtp.ssl.enable", "true"); props.put("mail.smtp.ssl.socketFactory", sf); Session session = Session.getInstance(props); Message msg = new MimeMessage(session); msg.setSubject(emailModel.getTitle());//标题 StringBuilder builder = new StringBuilder(); builder.append(emailModel.getText()); msg.setText(builder.toString()); msg.setFrom(new InternetAddress(senderEmail));//发送人的邮箱地址 Transport transport = session.getTransport(); //发送人的邮箱地址 //你的邮箱密码或者授权码 transport.connect("smtp.qq.com", senderEmail, authorizationCode); transport.sendMessage(msg, new Address[] { new InternetAddress(emailModel.getReceiverEmail()) });// 接收人的邮箱地址 transport.close(); return 1; }catch (Exception e){ e.printStackTrace(); return 0; } }}//注册及发送邮箱验证码public void doGet(HttpServletRequest request, HttpServletResponse response) { try{ PrintWriter printWriter=response.getWriter(); HttpSession session=request.getSession(); String action = request.getParameter("action"); String userName=request.getParameter("userName"); String password=request.getParameter("password"); if("sendEmail".equals(action)){ //发送验证码 String receiverEmail=request.getParameter("receiverEmail"); String type=request.getParameter("type"); String authCode=RandomUtil.randomNumbers(4); EmailModel emailModel=new EmailModel(); if("register".equalsIgnoreCase(type)){ //注册 User search=new User(); search.setUserName(receiverEmail); search=userService.getUser(search); if(null!=search){ printWriter.println("2"); return; }else{ emailModel.setTitle(EmailModel.registerTitle); emailModel.setText(EmailModel.register+authCode); } }else{ //找回密码 emailModel.setTitle(EmailModel.findPwdTitle); emailModel.setText(EmailModel.findPwdText+authCode); } System.out.println("邮箱验证码:"+authCode); emailModel.setReceiverEmail(receiverEmail); int result= EmailUtils.sendEmail(emailModel); session.setAttribute(receiverEmail+"#EmailCode",authCode);//注册验证码 printWriter.println(result); }else if("doRegister".equals(action)){ //注册验证 String authCode=request.getParameter("authCode");//验证码 String sessionCode=(String)session.getAttribute(userName+"#EmailCode");//注册验证码 if(null==sessionCode){ printWriter.println("3"); //验证码为空,请先获取邮箱验证码 }else if(!sessionCode.equals(authCode)){ printWriter.println("2"); //验证码错误 }else{ User user=new User(); user.setUserName(userName); user.setNickName(userName); user.setPassword(password); int result=userService.addUser(user); printWriter.println(result); //验证成功 } } }catch (Exception e){ e.printStackTrace(); return ; }}
- 上传头像
protected void doGet(HttpServletRequest request, HttpServletResponse response) { try { // 配置上传参数 PrintWriter printWriter = response.getWriter(); String fileName = ""; DiskFileItemFactory factory = new DiskFileItemFactory(); ServletFileUpload upload = new ServletFileUpload(factory); String userId = request.getParameter("userId"); String type = request.getParameter("type"); if (null != userId && !"".equals(userId)) { List<FileItem> formItems = upload.parseRequest(request); for (FileItem item : formItems) { // 迭代表单数据 if (!item.isFormField()) { String fileName2 = item.getName(); //重置乱码中文 fileName = RandomUtil.randomString(5) + (fileName2.substring(fileName2.indexOf("."))); String filePath = String.format("%s/%s", SystemConfig.fileUploadPath, fileName); File storeFile = new File(filePath); item.write(storeFile); // 保存文件到硬盘 } } if (null == type || "".equalsIgnoreCase(type)) { String userUpload = SessionUtils.getUserUpload(Integer.valueOf(userId), request); if (null != userUpload && !"".equalsIgnoreCase(userUpload)) { userUpload = userUpload + fileName + ","; } else { userUpload = fileName + ","; } SessionUtils.setUserUpload(Integer.valueOf(userId), userUpload, request); printWriter.println("0"); } else if ("headPic".equalsIgnoreCase(type)) {//头像 SessionUtils.setUserHeadPic(Integer.valueOf(userId), fileName, request); printWriter.println("0"); } } else { printWriter.println("0"); //用户信息未找到 } printWriter.close(); } catch (Exception ex) { ex.printStackTrace(); }}
- 个人聊天(发送消息及读取消息实现)
//消息采用读取数据库模式实现,并非socket或者其他通讯主件public void doGet(HttpServletRequest request, HttpServletResponse response) { HttpSession session=request.getSession(); PrintWriter printWriter=response.getWriter(); String action = request.getParameter("action"); User user= SessionUtils.getUser(request); if ("sendMsg".equals(action)) { //发送消息 String message=request.getParameter("message"); String receiveId=request.getParameter("receiveId"); Chat chat=new Chat(); chat.setUserId(user.getId()); chat.setUserName(user.getNickName()); chat.setMessage(message); chat.setStatus(0); chat.setReceiveId(Integer.valueOf(receiveId)); chat.setCreateTime(DateUtil.formatDateTime(new Date())); Posts posts=new Posts(); posts.setReleaseId(user.getId()); chatService.addChat(chat); printWriter.println("0"); session.setAttribute(user.getId()+":"+receiveId,message); //添加推送 Notice notice=new Notice(); notice.setNoticeUserId(Integer.valueOf(receiveId)); notice.setUserId(user.getId()); notice.setNoticeType(3); notice.setIsRead(0); Notice isExtis=noticeService.getNotice(notice); if(null==isExtis){ System.out.println("添加推送"); notice.setUserName(user.getUserName()); notice.setPostTitle(message); noticeService.addNotice(notice); //添加通知 }else{ System.out.println("有未读消息,不添加推送"); } }else if ("getMsg".equals(action)) { //获取消息 String sendUserId=request.getParameter("sendUserId"); //发送人id String receiveId=request.getParameter("receiveId"); //接收人 Chat chat=new Chat(); chat.setUserId(Integer.valueOf(sendUserId)); chat.setReceiveId(Integer.valueOf(receiveId)); chat.setStatus(0); List<Chat> list=chatService.getChatList(chat); if(list.size()>0){ printWriter.println(JSONUtil.toJsonStr(list)); for(Chat c:list){ c.setStatus(1); chatService.updateChat(c); } }else{ printWriter.println(""); } printWriter.close(); }}//前端jsp页面代码<div > <div > <div > <img src="images/upload/${userInfo.headPic}" /> <!--当前自己--> <input value="images/upload/${loginUser.headPic}" id="loginUserHeadPic" type="hidden"/> <input value="${loginUser.id}" id="sendUserId" type="hidden"/> <!--对方好友--> <input value="images/upload/${userInfo.headPic}" id="userInfoHeadPic" type="hidden"/> <input value="${userInfo.id}" id="receiveId" type="hidden"/> </div> <div >${userInfo.userName}</div> </div> <div > <div > <div > <div >${userInfo.nickName}</div> <div > <ul> <li><img src="images/chat/20170926103645_06.jpg"/></li> <li><img src="images/chat/20170926103645_08.jpg"/></li> <li><img src="images/chat/20170926103645_10.jpg"/></li> <li><img src="images/chat/20170926103645_12.jpg"/></li> </ul> </div> </div> <div > <ul > </ul> </div> <div > <div > <ul> <li><img src="images/chat/20170926103645_31.jpg"/></li> <li ><img src="images/chat/20170926103645_33.jpg"/></li> <li><img src="images/chat/20170926103645_35.jpg"/></li> <li><img src="images/chat/20170926103645_37.jpg"/></li> <li><img src="images/chat/20170926103645_39.jpg"/></li> <li><img src="images/chat/20170926103645_41.jpg" alt="" /></li> <li><img src="images/chat/20170926103645_43.jpg"/></li> <li><img src="images/chat/20170926103645_45.jpg"/></li> </ul> </div> <div > <textarea id="dope" name="" rows="" cols=""></textarea> <button >发送(s)</button> </div> </div> </div> </div></div>
- 关注 粉丝 喜欢统计
//每一项根据用户id单独统计在组装数据public void getLikeFansNul(Integer userId,HttpServletRequest request){ String fansSql="select count(id) from t_likeuser where likeUserId="+userId; int fansNum= JDBCUtils.getCount(fansSql); String likeSql="select count(id) from t_likeuser where userid="+userId; int likeNum= JDBCUtils.getCount(likeSql); String collectSql="select count(id) from t_collection where userid="+userId; int collectNum= JDBCUtils.getCount(collectSql); CountsVo countsVo=new CountsVo(fansNum,likeNum,collectNum); SessionUtils.setCountsVo(countsVo,request);}
项目注意事项
1: 收藏和关注才会有通知
2:收藏自己的推文没有通知
3:聊天消息推送如果有一条当前人发送的消息未读时,只保存一条未读消息
4:消息采用读取数据库模式实现,并非socket或者其他通讯主件,后期会单独起一个项目完成socket版本及其他三方开源的通信主件版本,敬请关注及更新
原文转载:http://www.shaoqun.com/a/504108.html
yeepay:https://www.ikjzd.com/w/2574
邓白氏集团:https://www.ikjzd.com/w/582
本项目使用jsp+servlet+mysql架构搭建可聊天的酷炫博客系统。界面非常好看,除了登录注册个人中心修改外,博客还添加背景音乐,可在线交友聊天,发表动态,相互评论等,喜欢的博文还能添加收藏。项目介绍本项目使用jsp+servlet+mysql架构搭建可聊天的酷炫博客系统。界面非常好看,除了登录注册个人中心修改外,博客还添加背景音乐,可在线交友聊天,发表动态,相互评论等,喜欢的博文还能添加收
心怡科技:心怡科技
3suisses:3suisses
亲测好用的一个跨境电商科学上网推广运营必用神器:亲测好用的一个跨境电商科学上网推广运营必用神器
冬天去北京冷吗?穿什么?:冬天去北京冷吗?穿什么?
东南亚社交营销增长策略:吸引与信任是营销的核心:东南亚社交营销增长策略:吸引与信任是营销的核心
没有评论:
发表评论