ssh整合Ajax实现多屏同步弹幕效果

package com.ambow.action; import java.io.IOException; import java.text.SimpleDateFormat; import java.util.Calendar; import java.util.Date; import java.util.List; import javax.annotation.Resource; import javax.servlet.http.HttpServletResponse; import org.apache.struts2.interceptor.ServletResponseAware; import org.springframework.context.annotation.Scope; import org.springframework.stereotype.Controller; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.ambow.entity.Chat; import com.ambow.service.ChatService; import com.opensymphony.xwork2.ModelDriven; @Controller @Scope("prototype") public class ChatAction implements ModelDriven<Chat>,ServletResponseAware{ @Resource private ChatService chatService; private Chat chat=new Chat(); //模型驱动 public Chat getModel() { return chat; } private String cont; public void setCont(String cont) { this.cont = cont; } public String getCont() { return cont; } //添加response private HttpServletResponse response=null; public void setServletResponse(HttpServletResponse response) { this.response=response; } //ajax回写 public void ajaxWrite(String context) throws IOException{ response.setContentType("text/html;charset=utf-8"); response.setCharacterEncoding("utf-8"); response.getWriter().write(context); response.getWriter().flush(); response.getWriter().close(); } //将弹幕记录添加到数据库 public void add() { System.out.println("----------add执行------------"); try { chat.setContent(new String (cont.getBytes("iso8859-1"),"utf-8")) ; //SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");//设置日期格式 //chat.setTime(df.format(new Date()));// new Date()为获取当前系统时间 chat.setTime(new Date());// new Date()为获取当前系统时间 chatService.addsay(chat); } catch (Exception e) { e.printStackTrace(); } } //将弹幕记录回写到页面 public void speak() { //时间操作 Calendar beforeTime = Calendar.getInstance(); beforeTime.add(Calendar.SECOND, -1);// 1秒钟之前的时间 Date beforeD = beforeTime.getTime(); System.out.println("----------speak执行-----------"+new Date()); System.out.println("----------speak执行--上一秒-----"+beforeD); try { JSONArray ja=new JSONArray(); List<Chat> chatlist=chatService.findsayByDate(beforeD); for(Chat c:chatlist){ JSONObject jo=new JSONObject(); jo.put("content", c.getContent()); jo.put("time", c.getTime()); ja.add(jo); } ajaxWrite(ja.toString()); } catch (Exception e) { e.printStackTrace(); } } }