mirror of
https://gitee.com/acl-dev/acl.git
synced 2024-12-14 17:00:52 +08:00
106 lines
3.0 KiB
C++
106 lines
3.0 KiB
C++
#include "stdafx.h"
|
|
#include "http_servlet.h"
|
|
|
|
http_servlet::http_servlet(acl::redis_client_cluster& cluster, size_t max_conns)
|
|
{
|
|
// 创建 session 存储对象
|
|
session_ = new acl::redis_session(cluster, max_conns);
|
|
}
|
|
|
|
http_servlet::~http_servlet(void)
|
|
{
|
|
delete session_;
|
|
}
|
|
|
|
bool http_servlet::doUnknown(acl::HttpServletRequest&,
|
|
acl::HttpServletResponse& res)
|
|
{
|
|
res.setStatus(400);
|
|
res.setContentType("text/html; charset=");
|
|
// 发送 http 响应头
|
|
if (res.sendHeader() == false)
|
|
return false;
|
|
// 发送 http 响应体
|
|
acl::string buf("<root error='unkown request method' />\r\n");
|
|
(void) res.getOutputStream().write(buf);
|
|
return false;
|
|
}
|
|
|
|
bool http_servlet::doGet(acl::HttpServletRequest& req,
|
|
acl::HttpServletResponse& res)
|
|
{
|
|
return doPost(req, res);
|
|
}
|
|
|
|
bool http_servlet::doPost(acl::HttpServletRequest& req,
|
|
acl::HttpServletResponse& res)
|
|
{
|
|
#if 0
|
|
const char* session_name = req.getSession().getAttribute("session_name");
|
|
if (*session_name == 0)
|
|
{
|
|
req.getSession().setAttribute("session_name", "name");
|
|
req.getSession().setMaxAge(100);
|
|
}
|
|
session_name = req.getSession().getAttribute("session_name");
|
|
|
|
const char* session_user = req.getSession().getAttribute("session_user");
|
|
if (*session_user == 0)
|
|
req.getSession().setAttribute("session_user", "user");
|
|
session_user = req.getSession().getAttribute("session_user");
|
|
#else
|
|
const char* session_name = "name", *session_user = "user";
|
|
#endif
|
|
|
|
// 取得浏览器 cookie
|
|
const char* cookie_name = req.getCookieValue("cookie_name");
|
|
|
|
bool keep_alive = req.isKeepAlive();
|
|
|
|
const char* param1 = req.getParameter("name1");
|
|
const char* param2 = req.getParameter("name2");
|
|
|
|
// 创建 xml 格式的数据体
|
|
acl::xml1 body;
|
|
body.get_root()
|
|
.add_child("root", true)
|
|
.add_child("session", true)
|
|
.add_child("session_name", true)
|
|
.set_text(session_name)
|
|
.get_parent()
|
|
.add_child("session_user", true)
|
|
.set_text(session_user)
|
|
.get_parent()
|
|
.get_parent()
|
|
.add_child("cookie", true)
|
|
.add_child("cookie_name", true)
|
|
.set_text(cookie_name ? cookie_name : "")
|
|
.get_parent()
|
|
.get_parent()
|
|
.add_child("params", true)
|
|
.add_child("param", true)
|
|
.add_attr("name1", param1 ? param1 : "null")
|
|
.get_parent()
|
|
.add_child("param", true)
|
|
.add_attr("name2", param2 ? param2 : "null");
|
|
acl::string buf;
|
|
body.build_xml(buf);
|
|
|
|
#if 0
|
|
res.setContentType("text/xml; charset=utf-8") // 设置响应字符集
|
|
.setKeepAlive(keep_alive) // 设置是否保持长连接
|
|
//.setContentLength(buf.length());
|
|
#else
|
|
res.setContentType("text/xml; charset=utf-8") // 设置响应字符集
|
|
.setKeepAlive(keep_alive) // 设置是否保持长连接
|
|
.setContentEncoding(true) // 设置是否压缩数据
|
|
.setChunkedTransferEncoding(true); // 采用 chunk 传输方式
|
|
#endif
|
|
|
|
//logger("access http://%s%s", req.getRemoteAddr(), req.getRequestUri());
|
|
|
|
// 发送 http 响应体，因为设置了 chunk 传输模式，所以需要多调用一次
|
|
// res.write 且两个参数均为 0 以表示 chunk 传输数据结束
|
|
return res.write(buf) && res.write(NULL, 0);
|
|
}
|