• 第二十一章 数据库连接池,过滤器


    1.练习

    图书条件查询:创建图书表,编号,书名,作者,价格,出版日期;

    要求:可以按照书名和作者进行模糊查询。

     关键代码:

    数据访问dao:

    1. public class BookDaoImpl implements IBookDao {
    2. @Override
    3. public List selectAllBook() {
    4. String sql = "select * from Book";
    5. BaseDao.setPst(sql,null);
    6. List> rows = BaseDao.executeQuery();
    7. List books = new ArrayList<>();
    8. if(rows.size()>0){
    9. for (Map map: rows) {
    10. Book book = new Book(
    11. (Integer) map.get("id"),
    12. (String) map.get("name"),
    13. (String) map.get("author"),
    14. new BigDecimal(map.get("price").toString()).doubleValue(),
    15. (Date)map.get("prcDate")
    16. );
    17. books.add(book);
    18. }
    19. }
    20. return books;
    21. }
    22. @Override
    23. public List selectSomeBook(String[] conditions,int n) {
    24. String sql = "select * from book";
    25. List params = new ArrayList<>();
    26. for (String s:conditions) {
    27. params.add("%"+s+"%");
    28. }
    29. switch (n){
    30. case 1:
    31. sql = "select * from book where name like ?";
    32. break;
    33. case 2:
    34. sql = "select * from book where author like ?";
    35. break;
    36. case 3:
    37. sql = "select * from book where name like ? and author like ?";
    38. break;
    39. default:
    40. break;
    41. }
    42. BaseDao.setPst(sql, params.toArray());
    43. List> rows = BaseDao.executeQuery();
    44. List books = new ArrayList<>();
    45. if(rows.size()>0){
    46. for (Map map: rows) {
    47. Book book = new Book(
    48. (Integer) map.get("id"),
    49. (String) map.get("name"),
    50. (String) map.get("author"),
    51. new BigDecimal(map.get("price").toString()).doubleValue(),
    52. (Date)map.get("prcDate")
    53. );
    54. books.add(book);
    55. }
    56. return books;
    57. }
    58. return null;
    59. }
    60. }
    61. servlet:

      1. @WebServlet(urlPatterns = "/BookServlet/*")
      2. public class BookServlet extends HttpServlet {
      3. IBookService bookService = new BookServiceImpl();
      4. @Override
      5. protected void service(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
      6. req.setCharacterEncoding("utf-8");
      7. resp.setContentType("text/html;character=UTF-8");
      8. String uri = req.getRequestURI();
      9. String operation = uri.substring(uri.lastIndexOf("/")+1);
      10. switch (operation){
      11. case "select":
      12. this.selectBook(req,resp);
      13. break;
      14. case "selectSome":
      15. this.selectSome(req,resp);
      16. break;
      17. default:
      18. break;
      19. }
      20. }
      21. private void selectSome(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
      22. String condition_name = req.getParameter("condition_name");
      23. String condition_author = req.getParameter("condition_author");
      24. req.setAttribute("condition_name",condition_name);
      25. req.setAttribute("condition_author",condition_author);
      26. if(StringUtils.isNullOrEmpty(condition_name)&&StringUtils.isNullOrEmpty(condition_author)){
      27. this.selectBook(req,resp);
      28. }
      29. if(!StringUtils.isNullOrEmpty(condition_name)&&!StringUtils.isNullOrEmpty(condition_author)){
      30. req.setAttribute("books",bookService.selectSomeBook(new String[]{condition_name,condition_author},3));
      31. }else {
      32. if(!StringUtils.isNullOrEmpty(condition_name)){
      33. req.setAttribute("books_name",bookService.selectSomeBook(new String[]{condition_name},1));
      34. }
      35. if(!StringUtils.isNullOrEmpty(condition_author)){
      36. req.setAttribute("books_author",bookService.selectSomeBook(new String[]{condition_author},2));
      37. }
      38. }
      39. req.getRequestDispatcher("/main.jsp").forward(req,resp);
      40. }
      41. private void selectBook(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
      42. req.setAttribute("books",bookService.selectAllBook());
      43. req.getRequestDispatcher("/main.jsp").forward(req,resp);
      44. }
      45. }

      2.数据库连接池

      2.1 介绍

              数据库连接池负责分配,管理和释放数据库连接,允许程序重复的使用现有的数据库连接,而不是重新建立(JDBC则是在我们每次操作数据库的时候,创建一个连接,使用过就关闭);释放空闲事件超过最大空闲时间的数据库连接来避免因为没有释放数据库连接而引起的数据库连接遗漏;能够明显提高对数据库操作的性能。

      2.2 常见的数据库连接池

              C3P0,Proxool,Jakarta DBCP,DBPool,Druid(德鲁伊特)

      2.3 使用连接池

      2.3.1 导入jar包,并添加db.properties 

       db.properties:

      1. #驱动加载
      2. driverClassName=com.mysql.cj.jdbc.Driver
      3. #注册驱动
      4. url=jdbc:mysql://127.0.0.1:3306/test_0803?characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
      5. #连接数据库的用户名
      6. username=root
      7. #连接数据库的密码
      8. password=123456
      9. #属性类型的字符串,通过别名的方式配置扩展插件, 监控统计用的stat 日志用log4j 防御sql注入:wall
      10. filters=stat
      11. #初始化时池中建立的物理连接个数。
      12. initialSize=5
      13. #最大的可活跃的连接池数量
      14. maxActive=300
      15. #获取连接时最大等待时间,单位毫秒,超过连接就会失效。配置了maxWait之后,缺省启用公平锁,并发效率会有所下降, 如果需要可以通过配置useUnfairLock属性为true使用非公平锁。
      16. maxWait=60000
      17. #连接回收器的运行周期时间,时间到了清理池中空闲的连接,testWhileIdle根据这个判断
      18. timeBetweenEvictionRunsMillis=60000
      19. minEvictableIdleTimeMillis=300000
      20. #建议配置为true,不影响性能,并且保证安全性。 申请连接的时候检测,如果空闲时间大于timeBetweenEvictionRunsMillis, 执行validationQuery检测连接是否有效。
      21. testWhileIdle=true
      22. #申请连接时执行validationQuery检测连接是否有效,做了这个配置会降低性能。设置为false
      23. testOnBorrow=false
      24. #归还连接时执行validationQuery检测连接是否有效,做了这个配置会降低性能,设置为false
      25. testOnReturn=false
      26. #是否缓存preparedStatement,也就是PSCache。
      27. poolPreparedStatements=false
      28. #池中能够缓冲的preparedStatements语句数量
      29. maxPoolPreparedStatementPerConnectionSize=200

      2.3.2 修改原来的BaseDao文件

      1. //定义连接池数据源对象
      2. private static DataSource dataSource;
      3. //静态代码块
      4. static {
      5. try {
      6. //getClassLoader():获取类的加载器
      7. //getResourceAsStream():通过类加载器,获取指定文件的输入流对象
      8. InputStream is = BaseDAO.class.getClassLoader().getResourceAsStream("/db.properties");
      9. //使用Properis对象,加载properties文件
      10. Properties properties = new Properties();
      11. //使用properties文件,加载配置数据
      12. properties.load(is);
      13. //创建druid连接池数据源,用配置文件做参数
      14. dataSource = DruidDataSourceFactory.createDataSource(properties);
      15. } catch (IOException e) {
      16. e.printStackTrace();
      17. } catch (Exception exception) {
      18. exception.printStackTrace();
      19. }
      20. }
      1. //获取连接
      2. public static Connection getConnection(){
      3. Connection con = null;
      4. try{
      5. //加载驱动类
      6. //Class.forName(DRIVER);
      7. //获取连接
      8. //con = DriverManager.getConnection(URL,USER,PASSWORD);
      9. //从连接池数据源中获取连接对象
      10. con = dataSource.getConnection();
      11. }catch(Exception ex){
      12. ex.printStackTrace();
      13. }
      14. return con;
      15. }

      3. 过滤器

      3.1 作用

              Java过滤器可以对目标资源的请求和响应进行过滤/拦截,一般用于通过的操作;如:登录过滤,编码处理,敏感字符过滤等。

      3.2 使用

      实现接口Filter,重写方法:

             ① chain,doFilter(req,resp)放行方法;

             ② 配置访问拦截的路径。

      1. @WebFilter(urlPatterns = "/*")
      2. public class CharacterEncodingFilter implements Filter {
      3. @Override
      4. public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
      5. //设置编码
      6. servletRequest.setCharacterEncoding("utf-8");
      7. servletResponse.setContentType("text/html;character=utf-8");
      8. //请求放行
      9. filterChain.doFilter(servletRequest,servletResponse);
      10. }
      11. }

       web.xml 配置:

      1. <filter>
      2. <filter-name>MyFilterfilter-name>
      3. <filter-class>com.wen.filter.MyFilterfilter-class>
      4. filter>
      5. <filter-mapping>
      6. <filter-name>MyFilterfilter-name>
      7. <url-pattern>/*url-pattern>
      8. <dispatcher>REQUESTdispatcher>
      9. filter-mapping>

      过滤路径配置:

      ①具体的资源路径: /index.jsp 只有访问index.jsp资源时,过滤器才会被执行;

      ②拦截目录:/user/* 访问user目录下的所有资源时,过滤器会被执行;

      ③后缀名拦截:*.jsp / *.do 访问所有后缀名为.jsp .do时,过滤器会被执行;

      ④拦截所有资源: /* 访问所有资源时,过滤器都会被执行。

      设置dispatcherTypes属性:

      ①REQUEST:默认值 浏览器直接请求资源;

      ②FORWARD:转发访问资源;

      ③INCLUDE:包含访问资源;

      ④ERROR:错误跳转资源;

      ⑤ASYNC:异步访问资源。

      3.3 过滤器的执行流程

              客户端请求---->过滤器---->放行---->请求的资源---->响应---->过滤器---->客户端

        过滤器链的执行顺序:

              过滤器1--->过滤器2--->资源执行--->过滤器2--->过滤器1

      过滤器的顺序:

      ①注解配置:按照类名的字符串比较规则比较,小的先执行;

      ②web.xml配置:在上边的先执行。

      3.4 实现登录功能的过滤(白名单) 

      1. //@WebFilter(urlPatterns = "/*")
      2. public class LoginFilter implements Filter {
      3. private String[] whiteNames;
      4. @Override
      5. public void init(FilterConfig filterConfig) throws ServletException {
      6. String params = filterConfig.getInitParameter("whiteNames");
      7. whiteNames = params.split(",");
      8. }
      9. @Override
      10. public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
      11. HttpServletRequest req = (HttpServletRequest) servletRequest;
      12. HttpServletResponse resp = (HttpServletResponse) servletResponse;
      13. String uri = req.getRequestURI();
      14. String operation = uri.substring(uri.lastIndexOf("/")+1);
      15. System.out.println("请求地址"+operation);
      16. boolean isWhiteName = false;
      17. for (String s:whiteNames) {
      18. System.out.println("白名单:"+s);
      19. if(operation.equals(s)){
      20. isWhiteName=true;
      21. break;
      22. }
      23. }
      24. if(isWhiteName){
      25. filterChain.doFilter(servletRequest, servletResponse);
      26. }else {
      27. if(req.getSession().getAttribute("userName")==null){
      28. req.getRequestDispatcher("/ToLoginServlet").forward(req,resp);
      29. }else {
      30. req.getRequestDispatcher("/ToMainServlet").forward(req,resp);
      31. }
      32. }
      33. }
      34. }

      4. 监听器

      4.1 用途

              监听web应用,其信息的初始化,销毁,增加,修改,删除值;servlet监听器用于监听一些重要事件的发生,监听器对象可以在事情发生前、发生后可以做一些必要的处理。

      4.2 分类

               在一个web应用程序的整个运行周期内,web容器会创建和销毁三个重要的对象:ServletContext,HttpSession,ServletRequest。

              按监听的对象划分,可以分为:

                      ServletContext对象监听器;HttpSession对象监听器,ServletRequest对象监听器

              按监听事件分:

                      ①对象自身的创建和销毁的监听器;

                      ②对象中属性的创建和消除的监听器;

                      ③session中某个对象的状态变化的监听器。

      4.3 创建监听器

      4.3.1 监听器的注册

      ①添加注解的方式:

      @WebListener

      ②web.xml 配置

      1. <listener>
      2. <listener-class>com.wen.listener.ContextListenerlistener-class>
      3. listener>

      4.3.2 上下文监听器

      1. //@WebListener
      2. public class ContextListener implements ServletContextListener {
      3. @Override
      4. public void contextInitialized(ServletContextEvent sce) {
      5. ServletContext application = sce.getServletContext();
      6. System.out.println("上下文初始化/网站初始化:"+application);
      7. }
      8. @Override
      9. public void contextDestroyed(ServletContextEvent sce) {
      10. System.out.println("上下文销毁/网站销毁!");
      11. }
      12. }

              jsp中的application域对象与servlet中的ServletContext是一样的,jsp的编译过程:ServletContext application = pageContext.getServletContext()。

      4.3.3 session监听

      1. @WebListener
      2. public class SessionListener implements HttpSessionListener {
      3. @Override
      4. public void sessionCreated(HttpSessionEvent se) {
      5. System.out.println("session创建了:"+se.getSession().getId());
      6. }
      7. @Override
      8. public void sessionDestroyed(HttpSessionEvent se) {
      9. System.out.println("session销毁了:"+se.getSession().getId());
      10. }
      11. }

      4.3.4 session 属性的监听

      1. @WebListener
      2. public class SessionAttributeListener implements HttpSessionAttributeListener {
      3. @Override
      4. public void attributeAdded(HttpSessionBindingEvent se) {
      5. System.out.println("属性添加:"+se.getName()+" "+se.getValue());
      6. }
      7. @Override
      8. public void attributeRemoved(HttpSessionBindingEvent se) {
      9. System.out.println("属性删除:"+se.getName()+" "+se.getValue());
      10. }
      11. @Override
      12. public void attributeReplaced(HttpSessionBindingEvent se) {
      13. System.out.println("属性改变:"+se.getName()+" "+se.getValue());
      14. }
      15. }

      4.3.5 ServletRequest 监听

      1. @WebListener
      2. public class ServletRequest implements ServletRequestListener {
      3. @Override
      4. public void requestDestroyed(ServletRequestEvent sre) {
      5. System.out.println("销毁!");
      6. }
      7. @Override
      8. public void requestInitialized(ServletRequestEvent sre) {
      9. System.out.println("创建!");
      10. }
      11. }

      4.4 在线人数的统计

      1. @WebListener
      2. public class OnlineListener implements ServletContextListener, HttpSessionListener {
      3. private ServletContext application;
      4. @Override
      5. public void contextInitialized(ServletContextEvent sce) {
      6. System.out.println("网页初始化!");
      7. application = sce.getServletContext();
      8. if(application.getAttribute("count")==null){
      9. application.setAttribute("count",0);
      10. }
      11. }
      12. @Override
      13. public void contextDestroyed(ServletContextEvent sce) {
      14. }
      15. @Override
      16. public void sessionCreated(HttpSessionEvent se) {
      17. System.out.println("人数++");
      18. Integer count = (Integer) application.getAttribute("count");
      19. count++;
      20. System.out.println("count:"+count);
      21. application.setAttribute("count",count);
      22. }
      23. @Override
      24. public void sessionDestroyed(HttpSessionEvent se) {
      25. System.out.println("人数--");
      26. Integer count = (Integer) application.getAttribute("count");
      27. count--;
      28. application.setAttribute("count",count);
      29. }
      30. }

    62. 相关阅读:
      Java 线程安全的集合有哪些?
      mysql数据库基础
      Xilinx ISE系列教程(6):ModelSim联合仿真
      普冉PY32系列(六) 通过I2C接口驱动PCF8574扩展的1602LCD
      【LeetCode】2760. 最长奇偶子数组
      CADEditorX ActiveX 14.1.X
      站群服务器的优势
      Java 并发编程学习总结
      基于51单片机的超声波测距及温度显示
      SQL Server 备份与恢复
    63. 原文地址:https://blog.csdn.net/m0_71674778/article/details/126140339