2. 程式人生 > 實用技巧 >jsp+servlet實戰酷炫部落格+聊天系統

jsp+servlet實戰酷炫部落格+聊天系統

阿新 • • 發佈：2020-12-26

專案介紹

本專案使用jsp+servlet+mysql架構搭建可聊天的酷炫部落格系統。介面非常好看，除了登入註冊個人中心修改外，部落格還新增背景音樂，可線上交友聊天，發表動態，相互評論等，喜歡的博文還能新增收藏。

開發環境：

  1. jdk 8
  2. intellij idea
  3. tomcat 8
  4. mysql 5.7

所用技術：

  1. jsp+servlet
  2. js+ajax
  3. layui
  4. jdbc+C3P0

部落格訪問地址

http://localhost:8090/indexServlet

專案目錄結構

執行效果

  • 登入

  • 首頁

  • 動態評論

  • 關注列表

  • 個人資料

  • 聊天頁面

核心程式碼:

  1. 註冊使用郵箱驗證碼
//郵件物件
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 ="[email protected]";	//傳送人郵箱--測試郵箱
	//傳送郵件方法
	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 ;
    }
}
  1. 上傳頭像
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();
    }
}
  1. 個人聊天（傳送訊息及讀取訊息實現）
//訊息採用讀取資料庫模式實現，並非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 class="qqBox">
    <div class="BoxHead">
        <div class="headImg">
            <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 class="internetName">${userInfo.userName}</div>
    </div>
    <div class="context">
        <div class="conRight">
            <div class="Righthead">
                <div class="headName">${userInfo.nickName}</div>
                <div class="headConfig">
                    <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 class="RightCont">
                <ul class="newsList">

                </ul>
            </div>
            <div class="RightFoot">
                <div class="footTop">
                    <ul>
                        <li><img src="images/chat/20170926103645_31.jpg"/></li>
                        <li class="ExP"><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 class="inputBox">
                    <textarea id="dope" style="width: 99%;height: 75px; border: none;outline: none;" name="" rows="" cols=""></textarea>
                    <button class="sendBtn">傳送(s)</button>
                </div>
            </div>
        </div>
    </div>
</div>
  1. 關注 粉絲 喜歡統計
//每一項根據使用者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版本及其他三方開源的通訊主件版本，敬請關注及更新

相關推薦

jsp+servlet實戰酷炫部落格+聊天系統

專案介紹 本專案使用jsp+servlet+mysql架構搭建可聊天的酷炫部落格系統。介面非常好看，除了登入註冊個人中心修改外，部落格還新增背景音樂，可線上交友聊天，發表動態，相互評論等，喜歡的博文還能新增收藏。

jsp+servlet實戰編寫購物商城

專案介紹 本專案使用jsp+servlet+mysql架構搭建美妝購物商城，主要分為使用者端和商城端，使用者端主要有首頁展示，商品資訊、購物車、訂單和個人中心幾個大的模組，每個模組都包含主要的電商功能；商戶端主要是對商

JSP384個人空間部落格網站系統

個人空間部落格系統基於java的servlet進行開發,基於B/S架構模式,開發軟體有：Myeclipse,mysql資料庫,Tomcat伺服器，使用MVC三層分層思想,通過這些技術的實現，整個系統的效能得到了大大的提高。並且文件方面

基於JavaWeb的SSH部落格管理系統（原始碼+資料庫）

部落格，又譯為網路日誌、部落格或部落閣等，是一種通常由個人管理、不定期張貼新的文章的網站。部落格上的文章通常根據張貼時間，以倒序方式由新到舊排列。許多部落格專注在特定的課題上提供評論或新聞，其他

BBS專案部落格論壇系統

1.BBS專案開發流程 1 # 1.需求分析 2架構師+產品經理+開發者組長 3在跟客戶談需求之前，會大致先了解客戶的需求，然後自己先設計一套比較好寫方案

docker實戰之極速搭建ghost個人部落格

前言 初衷 最近深入學習了大火的docker容器，想要做一個小專案練練手，剛剛想把之前自己搭的部落格小站升級為更加geek。因此就要了這一次從無到有的極速搭建ghost部落格教程。

Spring Boot實戰（七）：Spring Boot實現仿部落格園傳送通知郵件

郵件服務已經是基礎性服務了 ，是網站的必備功能之一，當註冊了某些網站的時候，郵箱裡通常會收到一封註冊成功通知郵件或者點選啟用賬號的郵件，部落格園也是如此。本文使用Spring Boot，通過QQ郵箱來模仿部落格園傳

[Go] GO語言實戰-為部落格園增加gofly線上客服功能

gofly最近準備完善對外的js引用功能,類似很多知名客服系統那樣直接引入js就可以使用,現在只是簡單的實現了下

實戰丨打造一個雙端自動釋出的部落格體系（上）

專案背景 對於很多開發小GG 來說，雲開發不僅僅是一個雲服務，更是幫助他們實現心中夢想，腦中靈感的利器，這不，這就有個開發 GG 拿雲開發結合 Git 打造了一個可以自動釋出、構建，並進行多端釋出的部落格體系。只要

Hexo部落格加入聊天系統DaoVoice

關於 DaoVoice DaoVoice 是一款革命性的應用運營平臺，致力於幫助企業實現以使用者為中心的「精益運營」體系。

08.flask部落格專案實戰三之表單

配套視訊教程 本文B站配套視訊教程 實現：如何通過Web表單接受使用者的輸入。

07.flask部落格專案實戰二之模板使用

配套視訊教程 本文B站配套視訊教程 模板定義 如有一個預期：html主頁有一個 歡迎使用者的標題。目前這個應用程式還沒使用者的概念，也沒使用者系統。但可用一個模擬使用者，用Python字典實現：

06.flask部落格專案實戰一之專案框架搭建

配套視訊教程 本文B站配套視訊教程 1、建立一個目錄，名為：microblog； 2、建立虛擬環境

10.flask部落格專案實戰五之使用者登入功能

配套視訊教程 本文B站配套視訊教程 密碼雜湊 使用者模型有一個password_hash欄位，到目前為止尚未使用。它是用於儲存使用者密碼的雜湊值，密碼用於驗證使用者在登入過程中輸入的密碼。密碼雜湊是一個複雜的主題，應交

09.flask部落格專案實戰四之資料庫

配套視訊教程 本文B站配套視訊教程 資料庫能為應用程式提供有效檢索的持久資料。這是本章學習的內容。

15.flask部落格專案實戰十之傳送郵件

配套視訊教程 本文B站配套視訊教程 本章將學習應用程式如何向用戶傳送電子郵件，以及如何在電子郵件支援下構建密碼修改功能。

14.flask部落格專案實戰九之分頁功能

配套視訊教程 本文B站配套視訊教程 這章將學習如何對資料庫中條目列表進行分頁。

13.flask部落格專案實戰八之關注功能

配套視訊教程 本文B站配套視訊教程 這章將學習如何實現類似於Twitter和其他社交網路的“粉絲”或“關注”，比如關注你。

20.flask部落格專案實戰十五之藍圖

配套視訊教程 本文B站配套視訊教程 本章將使用適合大型應用程式的樣式重新構建應用程式。

19.flask部落格專案實戰十四之 Ajax

配套視訊教程 本文B站配套視訊教程 PS：獲取百度翻譯API的appid和secretKey的過程在此略過，請參考文件。