优化servlet

目的

减少Servlet的数量，现在是一个功能一个Servlet，将其优化为一个模块一个Servlet，相当于在数据库中一张表对应一个Servlet，在Servlet中提供不同的方法，完成用户的请求。

如何解决测试时控制台中文乱码：

设置→maven →Runner→VM Options→-Dfile.encoding=gb2312

UserServlet的编写

将之前的Servlet实现的功能，抽取到UserServlet中的不同方法中实现，并且将UserService创建抽取到成员变量位置

package cn.itcast.travel.web.servlet;

import cn.itcast.travel.domain.ResultInfo;
import cn.itcast.travel.domain.User;
import cn.itcast.travel.service.UserService;
import cn.itcast.travel.service.impl.UserServiceImpl;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.commons.beanutils.BeanUtils;

import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import java.io.IOException;
import java.lang.reflect.InvocationTargetException;
import java.util.Map;

/**
 * @author 乱码酱
 * @date ：2023-01-04 08:39
 * @program: hello_maven
 * @create:
 */@WebServlet("/user/*")// /user/registpublicclassUserServletextendsHttpServlet {
    //声明UserService业务对象privateUserServiceservice=newUserServiceImpl();

    /**
     * 注册功能
     * @param request
     * @param response
     * @throws ServletException
     * @throws IOException
     */publicvoidregist(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {

        //验证校验Stringcheck= request.getParameter("check");
        //从sesion中获取验证码HttpSessionsession= request.getSession();
        Stringcheckcode_server= (String) session.getAttribute("CHECKCODE_SERVER");
        session.removeAttribute("CHECKCODE_SERVER");//为了保证验证码只能使用一次//比较if(checkcode_server == null || !checkcode_server.equalsIgnoreCase(check)){
            //验证码错误ResultInfoinfo=newResultInfo();
            //注册失败
            info.setFlag(false);
            info.setErrorMsg("验证码错误");
            //将info对象序列化为jsonObjectMappermapper=newObjectMapper();
            Stringjson= mapper.writeValueAsString(info);
            response.setContentType("application/json;charset=utf-8");
            response.getWriter().write(json);
            return;
        }

        //1.获取数据
        Map<String, String[]> map = request.getParameterMap();

        //2.封装对象Useruser=newUser();
        try {
            BeanUtils.populate(user,map);
        } catch (IllegalAccessException e) {
            e.printStackTrace();
        } catch (InvocationTargetException e) {
            e.printStackTrace();
        }

        //3.调用service完成注册//UserService service = new UserServiceImpl();booleanflag= service.regist(user);
        ResultInfoinfo=newResultInfo();
        //4.响应结果if(flag){
            //注册成功
            info.setFlag(true);
        }else{
            //注册失败
            info.setFlag(false);
            info.setErrorMsg("注册失败!");
        }

        //将info对象序列化为jsonObjectMappermapper=newObjectMapper();
        Stringjson= mapper.writeValueAsString(info);

        //将json数据写回客户端//设置content-type
        response.setContentType("application/json;charset=utf-8");
        response.getWriter().write(json);

    }

    /**
     * 登录功能
     * @param request
     * @param response
     * @throws ServletException
     * @throws IOException
     */publicvoidlogin(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {
        //1.获取用户名和密码数据
        Map<String, String[]> map = request.getParameterMap();
        //2.封装User对象Useruser=newUser();
        try {
            BeanUtils.populate(user,map);
        } catch (IllegalAccessException e) {
            e.printStackTrace();
        } catch (InvocationTargetException e) {
            e.printStackTrace();
        }

        //3.调用Service查询// UserService service = new UserServiceImpl();Useru= service.login(user);

        ResultInfoinfo=newResultInfo();

        //4.判断用户对象是否为nullif(u == null){
            //用户名密码或错误
            info.setFlag(false);
            info.setErrorMsg("用户名密码或错误");
        }
        //5.判断用户是否激活if(u != null && !"Y".equals(u.getStatus())){
            //用户尚未激活
            info.setFlag(false);
            info.setErrorMsg("您尚未激活，请激活");
        }
        //6.判断登录成功if(u != null && "Y".equals(u.getStatus())){
            request.getSession().setAttribute("user",u);//登录成功标记//登录成功
            info.setFlag(true);
        }

        //响应数据ObjectMappermapper=newObjectMapper();

        response.setContentType("application/json;charset=utf-8");
        mapper.writeValue(response.getOutputStream(),info);
    }

    /**
     * 查询单个对象
     * @param request
     * @param response
     * @throws ServletException
     * @throws IOException
     */publicvoidfindOne(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {
//        //从session中获取登录用户//        Object user = request.getSession().getAttribute("user");//        //将user写回客户端       /* ObjectMapper mapper = new ObjectMapper();//        response.setContentType("application/json;charset=utf-8");//        mapper.writeValue(response.getOutputStream(),user);*///        writeValue(user,response);//从session中获取登录用户Objectuser= request.getSession().getAttribute("user");
//        将user写回客户端ObjectMappermapper=newObjectMapper();
        response.setContentType("application/json;charset=utf-8");
        mapper.writeValue(response.getOutputStream(),user);
    }

    /**
     * 退出功能
     * @param request
     * @param response
     * @throws ServletException
     * @throws IOException
     */publicvoidexit(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {
        //1.销毁session
        request.getSession().invalidate();

        //2.跳转登录页面
        response.sendRedirect(request.getContextPath()+"/login.html");
    }

    /**
     * 激活功能
     * @param request
     * @param response
     * @throws ServletException
     * @throws IOException
     */publicvoidactive(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {
        //1.获取激活码Stringcode= request.getParameter("code");
        if(code != null){
            //2.调用service完成激活//UserService service = new UserServiceImpl();booleanflag= service.active(code);

            //3.判断标记Stringmsg=null;
            if(flag){
                //激活成功
                msg = "激活成功，请<a href='login.html'>登录</a>";
            }else{
                //激活失败
                msg = "激活失败，请联系管理员!";
            }
            response.setContentType("text/html;charset=utf-8");
            response.getWriter().write(msg);
        }
    }
}

页面路径的更改

register.html中将"registUserServlet"改成"user/regist"

UserServlet中将所有方法写在一起，方便调用，对应的.html中的路径也要发生改变，login.html中"loginServlet"改成"user/login"

header.html中"findUserServlet"改成"user/findOne"

激活邮件，发送邮件正文则是在USerServiceImpl,需要将路径

"<a href='http://localhost/travel/activeUserServlet?code="中"activeUserServlet"部分替换成"user/active"

退出则是header.html中的"exitServlet"改成"user/exit"

BaseServlet编写

package cn.itcast.travel.web.servlet;

import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;

/**
 * @author 乱码酱
 * @date ：2023-01-03 17:58
 * @program: hello_maven
 * @create:BaseServlet
 */@WebServlet("/baseServlet")publicclassBaseServletextendsHttpServlet {
    @Overrideprotectedvoidservice(HttpServletRequest req, HttpServletResponse resp)throws ServletException, IOException {
        //System.out.println("baseServlet的service方法被执行了...");//完成方法分发//1.获取请求路径Stringuri= req.getRequestURI(); //   /travel/user/add
        System.out.println("请求uri:"+uri);//  /travel/user/add//2.获取方法名称                         从后往前数，所以要+1StringmethodName= uri.substring(uri.lastIndexOf('/') + 1);
        System.out.println("方法名称："+methodName);
        //3.获取方法对象Method//谁调用我？我代表谁
        System.out.println(this);//UserServlet的对象cn.itcast.travel.web.servlet.UserServlet@4903d97etry {
            //获取方法Methodmethod=this.getClass().getMethod(methodName, HttpServletRequest.class, HttpServletResponse.class);
            //4.执行方法//暴力反射 可用于私密方法//method.setAccessible(true);
            method.invoke(this,req,resp);
            //invoke就是调用类中的方法，最简单的用法是可以把方法参数化invoke(class, method)
        } catch (NoSuchMethodException e) {
            e.printStackTrace();
        } catch (IllegalAccessException e) {
            e.printStackTrace();
        } catch (InvocationTargetException e) {
            e.printStackTrace();
        }
        
    }

}

【错误】

在查看代码时发现两个错误，一个是没有指定的js文件，一个是读不到文件

问题一：GET http://localhost/travel/js/angular.min.js net::ERR_ABORTED 404 (Not Found)

问题二：Uncaught TypeError: Cannot read properties of null (reading 'name')

at Object.eval [as success] (eval at <anonymous> (jquery-1.11.0.min.js:2:2616), <anonymous>:5:36)

at j (jquery-1.11.0.min.js:2:27136)

at Object.fireWith [as resolveWith] (jquery-1.11.0.min.js:2:27949)

at x (jquery-1.11.0.min.js:4:22244)

at XMLHttpRequest.b (jquery-1.11.0.min.js:4:26298)

【问题一解决】没有指定的js文件：

去官网https://code.angularjs.org找了一个

下载过来

【问题二解决】没获取到值

出现原因：这是由于还没登录，data.name 还没获取到值，所以为null

方法1：可以不管，它不会影响其他功能，当你登录后，就不会报这个错了

方法2：给它一个if判断是否为null

分类数据展示

效果

分析

代码实现

后台代码

在BaseServlet中添加序列化方法

/**
     * 直接将传入的对象序列化为json，并且写回客户端
     * @param obj
     */publicvoidwriteValue(Object obj,HttpServletResponse response)throws IOException {
        ObjectMappermapper=newObjectMapper();
        response.setContentType("application/json;charset=utf-8");
        mapper.writeValue(response.getOutputStream(),obj);
    }

    /**
     * 将传入的对象序列化为json，返回调用者
     * @param obj
     * @return
     */public String writeValueAsString(Object obj)throws JsonProcessingException {
        ObjectMappermapper=newObjectMapper();
        return mapper.writeValueAsString(obj);
    }

我们在读取数据时是从数据库读取而不是前台给定，所以将之前的前台代码注释

查询分类数据代码

heder.html

//    查询分类数据
        $.get("category/findAll", {}, function (data) {
            //data（一个数组）: [{cid:1,came:国内游}，{}，{}]varlis='<li class="nav-active"><a href="index.html">首页</a></li>';
            //遍历数组，拼接字符串<li>for (vari=0; i < data.length; i++) {
                varli='<li><a href="route_list.html">' + data[i].cname + '</a></li>';
                lis += li;
            }
        //拼接收藏排行榜的li,<li><a href="favoriterank.html">收藏排行榜</a></li>
            lis += '<li><a href="favoriterank.html">收藏排行榜</a></li>';
            //将lis字符串，设置到ul的html内容中
            $("#category").html(lis);

        });

对分类数据进行缓存优化

分析发现，分类的数据在每一次页面加载后都会重新请求数据库来加载，对数据库的压力比较大，而且分类的数据不会经常产生变化，所以可以使用redis来缓存这个数据。

分析：

优化代码实现

【出错】获取种类有异常数据

测试时发现获取种类有异常数据，回到数据库一看发现是数据库出错，于是修改数据库，但是修改后重启还是原来的异常数据，怀疑是浏览器自带的缓存问题，清空浏览器缓存还是无效，初步怀疑是redis缓存的问题

但是页面刷新还是原来的错误数据

【解决方法】

光清除浏览器缓存可不够，还要清除redis缓存

flushdb ——> 清空当前数据库中的所有 key

flushall ——> 清空整个 Redis 服务器的数据(删除所有数据库的所有 key )

到这里就清除完毕，不需要重启，不过大家要注意，你们服务器的缓存数据是否重要，是否可以清除，一定要确定清楚，否则不要轻易清除。

重新刷新记录正确，redis也查询得到数据

而且第一次显示是从数据库查询得到

删除控制台数据刷新网页，数据将从缓存中读取

CategoryServiceImpl 代码

package cn.itcast.travel.service.impl;

import cn.itcast.travel.dao.CategoryDao;
import cn.itcast.travel.dao.impl.CategoryDaoImpl;
import cn.itcast.travel.domain.Category;
import cn.itcast.travel.service.CategoryService;
import cn.itcast.travel.util.JedisUtil;
import redis.clients.jedis.Jedis;

import java.util.ArrayList;
import java.util.List;
import java.util.Set;

/**
 * @author 乱码酱
 * @date ：2023-01-04 10:58
 * @program: hello_maven
 * @create:
 */publicclassCategoryServiceImplimplementsCategoryService {

    privateCategoryDaocategoryDao=newCategoryDaoImpl();

    @Override//查询所有方法public List<Category> findAll() {
        //1.从redis中查询//1.1获取jedis客户端Jedisjedis= JedisUtil.getJedis();
        //1.2可使用sortedset排序查询(有序且唯一)
        Set<String> categorys = jedis.zrange("category", 0, -1);
        List<Category> cs = null;
        //2.判断查询的集合是否为空if (categorys == null || categorys.size() == 0) {
            System.out.println("从数据库查询....");
            //3.如果为空,需要从数据库查询,在将数据存入redis//3.1 从数据库查询
            cs = categoryDao.findAll();
            //3.2 将集合数据存储到redis中名为category的keyfor (inti=0; i < cs.size(); i++) {
                jedis.zadd("category", cs.get(i).getCid(), cs.get(i).getCname());
            }
        } else {
            System.out.println("从redis中查询.....");

            //4.如果不为空,将set的数据存入list
            cs = newArrayList<Category>();
            for (String name : categorys) {
                Categorycategory=newCategory();
                category.setCname(name);
                cs.add(category);

            }
        }

        return cs;
    }
}