一对一聊天ajax实现
生活随笔
收集整理的這篇文章主要介紹了
一对一聊天ajax实现
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
前端頁面：
好友列表：
好友列表代碼：
一對一聊天：
后端處理：
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")/*登錄驗證*/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){解決通過服務器向頁面彈出對話框? // 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\"}");}/*驗證賬戶是否已經存在*/@RequestMapping(value="/findUsername.action")public void findUsername(String id,HttpServletRequest request, HttpServletResponse response, HttpSession session) throws IOException{System.out.println("驗證賬戶");PrintWriter out = response.getWriter();if(registerDemo.queryById(id) == null){out.println("{\"state\":true }");}else{out.println("{\"state\":false }");System.out.println("賬戶已經存在");}}@RequestMapping(value="/register.action")/*若要直接往response中寫內容而不經過視圖解析器時可以使用@ResponseBody* @ResponseBody加上之后對返回ajax數據造成失效* *//*用戶注冊: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")/*發送消息*/public void AjaxSendMessage(String content, String sender, String receiver, String time, HttpServletRequest request, HttpServletResponse response){Chat chat = new Chat();System.out.println("內容"+content);chat.setSender(sender);StringBuilder str = new StringBuilder(content);/*將時間拼接到消息中 %作為標識符*/str.append("%").append(time);content = str.toString();chat.setMessage(content);chat.setReceiver(receiver);int insert = registerDemo.insert(chat);if(insert > 0){System.out.println("消息存儲到數據庫中"+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);/*接受消息按照時間進行排序并且區分發送者和接受者 注意：當用戶發送消息的時候前端已經添加了div此時并不需要去重復添加工作*/List<Chat> list = new ArrayList<>();list = listSender;list.addAll(listReceiver);for (Chat chat : list) {System.out.println("排序前:"+chat.getSender()+chat.getMessage()+chat.getReceiver());}/*時間排序*/Collections.sort(list,new Comparator<Chat>() {@Overridepublic int compare(Chat o1, Chat o2) {//一開始沒設計好，按照時分秒存儲的消息排序，隔天消息亂序輸出 /* 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);*///按照年月日時分秒存儲的消息記錄排序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截取時間*/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");導致前端通過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集合才能轉換為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;/*驗證是否已經添加過好友，避免重復添加操作*/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){/*用來存儲關聯好友信息*/List<String> list = new ArrayList<>();/*獲取當前用戶的好友*/List<String> myFriend = registerDemo.queryFriendListById(username);/*找出好友的好友*/for (String id : myFriend) {List<String> list2 = registerDemo.queryFriendListById(id);list.addAll(list2);}System.out.println("我的好友"+myFriend);/*推薦算法實現*/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);//把自己賬戶添加進去做去重操作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;}/*去重操作，去掉已經添加完的好友*/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框架，控制層處理獲取所有待處理的業務邏輯，持久化的操作用了mybatis，數據庫表的設計分為：好友列表表單和聊天信息表單，其中字段如圖：
加%號是為了和時間區分開，因為一開始數據庫未設計好在獲取聊天記錄的時候又需要按照時間進行排序，因為再添加字段的話又需要在mapper中配置一些信息，因此為了減少工作量直接在%后面追加內容用以區分。
聊天原理：因為http是無狀態的短鏈接，所以一次ajax請求結束后會自動斷開鏈接，因為如果想持續保持通訊的話必須添加一個定時器來定時通過ajax從服務器取數據，達到通訊的目的，該方法的性能特別的差，不建議使用，因為之前并沒有學習websocket又想著用自己所學的知識來實現這通訊功能因為并沒有去考慮性能的問題，如果用websocket寫的話性能會更好，因為可以通過socket代碼塊來操作傳輸層tcp的連接與斷開，因為tcp協議是長連接，它并不像應用層的http協議在處理一次請求之后就斷開并且所以的狀態信息都被清空了，因為它也是無狀態的短連接，而相反使用tcp可以避免這個問題，如果如果websocket來實現一對一通訊的話，把用戶的id通過map進行存儲，這樣我們就可以通過key獲取value來達到一對一的通訊，而前面做的websocket的時候存儲用戶的時候是用set存儲然后再遍歷set集合讓各個客戶端都可以接受到聊天信息。
總結
以上是生活随笔為你收集整理的一对一聊天ajax实现的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： java核心技术-jvm基础知识
- 下一篇： Word2vec加TextRank算法生