java web利用mvc结构实现简单聊天室功能

 简单聊天室采用各种内部对象不适用数据库实现。

一个聊天室要实现的基本功能是:

        1.用户登录进入聊天室,

   2.用户发言

   3.用户可以看见别人发言

刚才算是简单的需求分析了,现在就应该是进行mvc结构的设计:

  1.视图,有登陆页面login.jsp,聊天页面chat.jsp,其中chat.jsp利用框架实现,包括两部分,用户发言sendMessage.jsp和聊天信息的查看content.jsp;

  2.模型,包括聊天信息的显示(类Message)和聊天信息的管理(类MessageService);

  3.控制器,登录功能的控制器LoginServlet,添加消息的控制器AddMessageServlet。

  整个程序实现的大致流程是这样的:每当一个用户登录聊天室,根据用户的userid把用户添加进application对象的ArrayList中,在application中保存的是当前所有在聊天的用户;用户登陆成功之后,通过控制器LoginServlet把application对象遍历,输出所有的消息,消息存储在application(消息格式:用户名+消息);用户发言,通过控制器AddMessageServlet,先在session中取出用户名,把当前消息放在application中,保存更新后的消息,跳转到聊天页面。

精简源代码:

1.登陆界面login.jsp

 <body>
<h1>欢迎进入聊天室</h1>
<form action="login">
用户名:<input type="text" name="userid"><br> <input type="submit" value="进入"> <input type="reset" value="重写"> </form> </body>

2.聊天界面整体框架chat.jsp

<frameset rows="*,20%">
<frame name="content" src="content.jsp">
<frame name="sendMessage" target="content" src="sendMessage.jsp">
<noframes>
<body>
<p>此网页使用了框架,但你的浏览器不支持框架</p>
</body>
</noframes>
</frameset>

3.用户发言sendMessage.jsp

 <body>
<form action="addmessage" target="content">
发言:<input type="text" name="info"> <input type="submit"
value="确定">
</form>
</body>

4.显示聊天信息

 <body>
<%
//页面每隔1秒自动刷新一遍
response.setHeader("refresh","1");
%> <c:forEach items="${allMessage}" var="message">
${message.userid }
在${message.time }说:<font color="green">${message.info }</font>
<br>
</c:forEach>
</body>

5.登录控制器LoginServlet

 public class LoginServlet extends HttpServlet {

     public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
// 获取用户输入
String userid = request.getParameter("userid");
userid = new String(userid.getBytes("utf-8")); // 获取application对象
ServletContext application = this.getServletContext();
// 获取application对象中user
ArrayList<String> users = (ArrayList<String>) application
.getAttribute("users"); // 判断用户名是否存在
if (users != null && users.contains(userid)) {
request.setAttribute("errorinfo", "用户" + userid + "已经存在");
RequestDispatcher rd;
rd = request.getRequestDispatcher("login.jsp");
rd.forward(request, response);
} else {
if (users == null)// 如果当前application中没有user,初始化user对象
{
users = new ArrayList<String>();
}
users.add(userid);
application.setAttribute("users", users); // 为每一个用户设置一个session
HttpSession session = request.getSession(true);
session.setAttribute("userid", userid); response.sendRedirect("chat.jsp"); } } public void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
doGet(request, response);
} }

6.添加消息的控制器AddMessageServlet

 public class AddMessageServlet extends HttpServlet {

     public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException { // 从request中取出用户的个人信息 HttpSession session = request.getSession(true);
String userid = (String) session.getAttribute("userid"); // 从request对象中取出用户新增的聊天信息 String info = request.getParameter("info");
info = new String(info.getBytes("utf-8")); // 取出所有的聊天信息
ServletContext application = this.getServletContext();
ArrayList<Message> allMessage = (ArrayList<Message>) application
.getAttribute("allMessage"); // 创建消息对象
Message message = new Message(userid, info); // 创建业务对象
MessageService service = new MessageService(allMessage); // 调用业务逻辑
service.addMessages(message); // 保存更新后的消息
application.setAttribute("allMessage", service.getAllMessages()); // 转向聊天页面
response.sendRedirect("content.jsp"); } public void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
doGet(request, response);
} }

7.聊天信息Message.java

 //聊天信息的表示
public class Message {
private String userid; private String info; public Message(String userid,String info)
{
this.userid = userid;
//this.sex=sex;
this.info=info;
this.time=(new SimpleDateFormat("hh:mm:ss")).format(new Date());//将时间格式化 }
public String getUserid() {
return userid;
}
public void setUserid(String userid) {
this.userid = userid;
} public String getInfo() {
return info;
}
public void setInfo(String info) {
this.info = info;
}
public String getTime() {
return time;
}
public void setTime(String time) {
this.time = time;
}
private String time; }

8.聊天信息管理MessageService.java

 public class MessageService {
private ArrayList<Message> allMessages;
public MessageService(ArrayList<Message> allMessages)
{
this.allMessages=allMessages;
}
public ArrayList<Message> getAllMessages()
{
return allMessages;
} public void addMessages(Message message)
{
//先判断聊天信息列表是否为空,为空则新建聊天列表
if(allMessages==null)
{
allMessages=new ArrayList<Message>();
}
else
{
allMessages.add(0,message);//将指定的元素插入此列表中的指定位置。向右移动当前位于该位置的元素(如果有)以及所有后续元素(将其索引加 1)。
}
} }

收获:通过这么一个小小的web程序,加深了对mvc模式的理解。

mvc的传值方式(个人理解):视图层通过表单提交的方式把信息放在request对象中,在控制器中通过request对象获取视图层的数据,获取的数据经过模型层的业务逻辑处理,把相应的结果放在response对象中传回浏览器显示在视图中。

  小知识点:

    application对象只有一个,每一个用户都有自己的session,每个用户的每个请求都对应着一个新的request对象(request只能在一次请求时共享信息)。

    标准标签库的使用:循环输出<c:forEach var="变量名" items="集合对象">循环体</c:forEach>

   最后,部署自己的应用到服务器下就可以使用了。 

上一篇:[Java][web]利用Spring随时随地获得Request和Session


下一篇:常见Web安全漏洞--------防盗链