一对一聊天ajax实现
生活随笔
收集整理的這篇文章主要介紹了
一对一聊天ajax实现
小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.
前端頁面：
好友列表：
好友列表代碼：
一對一聊天：
后端處理：
package com.itcast.constroller;import java.io.IOException; import java.io.PrintWriter; import java.text.DateFormat; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Collections; import java.util.Comparator; import java.util.Date; import java.util.HashMap; import java.util.HashSet; import java.util.List; import java.util.Map; import java.util.Map.Entry; import java.util.Set;import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpSession;import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; import org.springframework.ui.Model; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.ResponseBody; import org.springframework.web.servlet.ModelAndView;import com.itcast.pojo.Chat; import com.itcast.pojo.Commend; import com.itcast.pojo.Commends; import com.itcast.pojo.RegisterPojo; import com.itcast.pojo.User; import com.itcast.service.RegisterDemo;import net.sf.json.JSONArray;@Controller public class ItemConstroller{@Autowiredprivate RegisterDemo registerDemo;@RequestMapping(value="/login.action")/*登錄驗(yàn)證*/public ModelAndView showLoginPage(String username, String password,HttpServletRequest request, HttpServletResponse response, HttpSession session, Model model) throws IOException {response.setCharacterEncoding("UTF-8");User user = new User();user.setUsername(username);user.setPassword(password);/*獲取用戶信息*/User myUser = registerDemo.queryByUser(user);ModelAndView mv = new ModelAndView();if(myUser!=null){request.getSession().setAttribute("user", myUser);mv.setViewName("friend.jsp");}else{mv.setViewName("login.jsp");}return mv;} /* public String showLoginPage(String username, String password,HttpServletRequest request, HttpServletResponse response, HttpSession session, Model model) throws IOException {User user = new User();response.setCharacterEncoding("UTF-8");user.setUsername(username);user.setPassword(password);User myUser = registerDemo.queryByUser(user);if(myUser==null){解決通過服務(wù)器向頁面彈出對話框? // PrintWriter out=response.getWriter(); // out.print("<script language=\"javascript\">alert('登錄失敗！');window.location.href='/chat1/login.jsp'</script>");return "redirect:/login.jsp";}else{return "redirect:/friend.html";}}*/@RequestMapping(value="/test.action")public void test(String id, HttpServletRequest request, HttpServletResponse response) throws IOException{String str = request.getParameter(id);System.out.println(str);response.getWriter().write("{\"msg\":\"ok\"}");}/*驗(yàn)證賬戶是否已經(jīng)存在*/@RequestMapping(value="/findUsername.action")public void findUsername(String id,HttpServletRequest request, HttpServletResponse response, HttpSession session) throws IOException{System.out.println("驗(yàn)證賬戶");PrintWriter out = response.getWriter();if(registerDemo.queryById(id) == null){out.println("{\"state\":true }");}else{out.println("{\"state\":false }");System.out.println("賬戶已經(jīng)存在");}}@RequestMapping(value="/register.action")/*若要直接往response中寫內(nèi)容而不經(jīng)過視圖解析器時(shí)可以使用@ResponseBody* @ResponseBody加上之后對返回ajax數(shù)據(jù)造成失效* *//*用戶注冊:RegisterPojo為注冊的信息類*/public void ItemUpdate(User user, HttpServletRequest request, HttpServletResponse response, HttpSession session) throws IOException{PrintWriter out = response.getWriter();user.setGroupsum(3);System.out.println(user.toString());if(user.getCompany() == null && user.getEmail() == null && user.getPassword() == null && user.getSex() == null && user.getTel() == null && user.getUsername() == null){out.println("{\"isSuccess\":false}");}else{if(registerDemo.insert(user)>0){System.out.println("注冊成功");out.println("{\"isSuccess\":true}");}else{System.out.println("注冊失敗");out.println("{\"isSuccess\":false}");}}}@RequestMapping(value="/chat.action")/*發(fā)送消息*/public void AjaxSendMessage(String content, String sender, String receiver, String time, HttpServletRequest request, HttpServletResponse response){Chat chat = new Chat();System.out.println("內(nèi)容"+content);chat.setSender(sender);StringBuilder str = new StringBuilder(content);/*將時(shí)間拼接到消息中 %作為標(biāo)識符*/str.append("%").append(time);content = str.toString();chat.setMessage(content);chat.setReceiver(receiver);int insert = registerDemo.insert(chat);if(insert > 0){System.out.println("消息存儲到數(shù)據(jù)庫中"+content);}else{System.out.println("消息存儲失敗");}}@RequestMapping(value="/message.action")/*ajax接收消息*/public <T> void AjaxReceiveMessage(String username, String friendid, HttpServletRequest request, HttpServletResponse response) throws IOException{request.setCharacterEncoding("utf-8");response.setContentType("text/html;charset=utf-8");PrintWriter out = response.getWriter();//測試 // System.out.println("3333333333333333333"+username+"---"+friendid);List<Chat> listSender = registerDemo.queryBySenderAndReceiver(username,friendid);List<Chat> listReceiver = registerDemo.queryBySenderAndReceiver(friendid, username);/*接受消息按照時(shí)間進(jìn)行排序并且區(qū)分發(fā)送者和接受者 注意：當(dāng)用戶發(fā)送消息的時(shí)候前端已經(jīng)添加了div此時(shí)并不需要去重復(fù)添加工作*/List<Chat> list = new ArrayList<>();list = listSender;list.addAll(listReceiver);for (Chat chat : list) {System.out.println("排序前:"+chat.getSender()+chat.getMessage()+chat.getReceiver());}/*時(shí)間排序*/Collections.sort(list,new Comparator<Chat>() {@Overridepublic int compare(Chat o1, Chat o2) {//一開始沒設(shè)計(jì)好，按照時(shí)分秒存儲的消息排序，隔天消息亂序輸出 /* String[] split = o1.getMessage().split("%");int len = split.length;String time1 = split[len-1];String[] tm = time1.split(":");Integer[] a = new Integer[3];a[0] = Integer.valueOf(tm[0]);a[1] = Integer.valueOf(tm[1]);a[2] = Integer.valueOf(tm[2]);Time t1 = new Time(a[0], a[1], a[2]);String[] split2 = o2.getMessage().split("%");len = split2.length;String time2 = split2[len-1];String[] tm2 = time2.split(":");Integer[] b = new Integer[3];b[0] = Integer.valueOf(tm2[0]);b[1] = Integer.valueOf(tm2[1]);b[2] = Integer.valueOf(tm2[2]);Time t2 = new Time(b[0],b[1],b[2]);return t1.compareTo(t2);*///按照年月日時(shí)分秒存儲的消息記錄排序DateFormat format = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");String[] split = o1.getMessage().split("%");String[] split2 = o2.getMessage().split("%");Date d1 = new Date();Date d2 = new Date();try {d1 = format.parse(split[split.length-1]);d2 = format.parse(split2[split2.length-1]);} catch (ParseException e) {e.printStackTrace();}return d1.compareTo(d2);}});/*更改message截取時(shí)間*/for (int i = 0; i < list.size(); i++) {Chat chat = list.get(i);String[] s = chat.getMessage().split("%");chat.setMessage(s[0]);}for (Chat chat : list) {//System.out.println("排序后:"+chat.getSender()+chat.getMessage()+chat.getReceiver());}if(list.size()>0){JSONArray json = JSONArray.fromObject(list); //System.out.println("消息："+json);out.println(json); }else{System.out.println("獲取信息失敗");}}/*獲取好友列表*/@RequestMapping(value="/friendList.action")public ModelAndView FriendList(String username, HttpServletRequest request, HttpServletResponse response){List<String> list = registerDemo.queryFriendListById(username);for (String s : list) {System.out.println("好友id："+s);}ModelAndView mv = new ModelAndView();List<User> ll = new ArrayList<>();if(list.size()>0){for (String id : list) {if(!id.equals("")){User u = registerDemo.queryUserByid(id);ll.add(u);}} }else{System.out.println("好友為空");}for (int i = 0; i < ll.size(); i++) {if(ll.get(i).getUsername().equals(username)){ll.remove(i);}}request.setAttribute("list", ll); // mv.addObject("list",list);/*mv.setViewName("redirect:friendList.jsp");導(dǎo)致前端通過jstl無法獲取值問題？*/mv.setViewName("friendList.jsp");return mv;}/*查找好友*/@RequestMapping(value="/addFriend.action")public <T> void addFriend(String username, HttpServletRequest request, HttpServletResponse response) throws IOException{response.setContentType("text/html;charset=utf-8");User user = registerDemo.queryById(username);if(user!=null){/*加入list集合才能轉(zhuǎn)換為jsonArray*/List<User> list = new ArrayList<>();list.add(user);System.out.println("查找的用戶信息:"+user.getName()+user.getUsername());PrintWriter out = response.getWriter();JSONArray json = JSONArray.fromObject(list);System.out.println(json);out.println(json); }else{System.out.println("查找的用戶不存在");}}/*添加好友*/@RequestMapping(value="/add.action")public void add(String username, String id, HttpServletRequest request, HttpServletResponse response) throws IOException{response.setContentType("text/html;charset=utf-8");if("".equals(id)||"".equals(username)) return;/*驗(yàn)證是否已經(jīng)添加過好友，避免重復(fù)添加操作*/System.out.println("賬戶："+username);List<String> list = registerDemo.queryFriendListById(username);PrintWriter out = response.getWriter();boolean flag = true;for (String string : list) {if(string.equals(id)){flag = false;out.println(0);}}if(flag){out.println(1);registerDemo.addFriendById(username,id);registerDemo.addFriendById(id,username);}}/*好友推薦*/@RequestMapping(value="/commend.action")public ModelAndView command(String username, HttpServletRequest request, HttpServletResponse response){/*用來存儲關(guān)聯(lián)好友信息*/List<String> list = new ArrayList<>();/*獲取當(dāng)前用戶的好友*/List<String> myFriend = registerDemo.queryFriendListById(username);/*找出好友的好友*/for (String id : myFriend) {List<String> list2 = registerDemo.queryFriendListById(id);list.addAll(list2);}System.out.println("我的好友"+myFriend);/*推薦算法實(shí)現(xiàn)*/Set<String> set = new HashSet<>();set.addAll(list);Map<String,Integer> map = new HashMap<>();for(String str : set){map.put(str, 0);}for(String str : list){Integer sum = map.get(str);map.put(str, sum++);}List<Map.Entry<String, Integer>> listEntry = new ArrayList<>(map.entrySet());Collections.sort(listEntry, new Comparator<Entry<String,Integer>>() {@Overridepublic int compare(Entry<String, Integer> o1, Entry<String, Integer> o2) {return o2.getValue().compareTo(o1.getValue());}});List<Commend> l = new ArrayList<>();myFriend.add(username);//把自己賬戶添加進(jìn)去做去重操作for (String ss : myFriend) {System.out.println("我的朋友:"+ss);}boolean flag = true;for (Entry<String, Integer> e : listEntry) {for(String ch : myFriend){if(ch.equals(e.getKey())){flag = false;}}if(flag){l.add(new Commend(e.getKey(),e.getValue()));}flag = true;}/*去重操作，去掉已經(jīng)添加完的好友*/System.out.println("用戶"+username);ModelAndView mv = new ModelAndView();for (Commend commend : l) {System.out.println("推薦好友123+："+commend.getTimes()+commend.getUsername());}/*如果沒有好友推薦就推薦所有用戶*/List<String> lUser = registerDemo.selectUser(username); for (String s : lUser) {l.add(new Commend(s, -1));}List<Commends> names = new ArrayList<>();for (Commend c : l) {User user = registerDemo.queryById(c.getUsername());names.add(new Commends(c.getUsername(),c.getTimes(),user.getName()));}request.setAttribute("list", names);/*mv.addObject("list",l);*/mv.setViewName("searchFriend.jsp");return mv;} }用的springmvc框架，控制層處理獲取所有待處理的業(yè)務(wù)邏輯，持久化的操作用了mybatis，數(shù)據(jù)庫表的設(shè)計(jì)分為：好友列表表單和聊天信息表單，其中字段如圖：
加%號是為了和時(shí)間區(qū)分開，因?yàn)橐婚_始數(shù)據(jù)庫未設(shè)計(jì)好在獲取聊天記錄的時(shí)候又需要按照時(shí)間進(jìn)行排序，因?yàn)樵偬砑幼侄蔚脑捰中枰趍apper中配置一些信息，因此為了減少工作量直接在%后面追加內(nèi)容用以區(qū)分。
聊天原理：因?yàn)閔ttp是無狀態(tài)的短鏈接，所以一次ajax請求結(jié)束后會(huì)自動(dòng)斷開鏈接，因?yàn)槿绻氤掷m(xù)保持通訊的話必須添加一個(gè)定時(shí)器來定時(shí)通過ajax從服務(wù)器取數(shù)據(jù)，達(dá)到通訊的目的，該方法的性能特別的差，不建議使用，因?yàn)橹安]有學(xué)習(xí)websocket又想著用自己所學(xué)的知識來實(shí)現(xiàn)這通訊功能因?yàn)椴]有去考慮性能的問題，如果用websocket寫的話性能會(huì)更好，因?yàn)榭梢酝ㄟ^socket代碼塊來操作傳輸層tcp的連接與斷開，因?yàn)閠cp協(xié)議是長連接，它并不像應(yīng)用層的http協(xié)議在處理一次請求之后就斷開并且所以的狀態(tài)信息都被清空了，因?yàn)樗彩菬o狀態(tài)的短連接，而相反使用tcp可以避免這個(gè)問題，如果如果websocket來實(shí)現(xiàn)一對一通訊的話，把用戶的id通過map進(jìn)行存儲，這樣我們就可以通過key獲取value來達(dá)到一對一的通訊，而前面做的websocket的時(shí)候存儲用戶的時(shí)候是用set存儲然后再遍歷set集合讓各個(gè)客戶端都可以接受到聊天信息。
總結(jié)
以上是生活随笔為你收集整理的一对一聊天ajax实现的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： java核心技术-jvm基础知识
- 下一篇： Word2vec加TextRank算法生