0
点赞
收藏
分享

微信扫一扫

二百二十九、离线数仓——离线数仓Hive从Kafka、MySQL到ClickHouse的完整开发流程

火热如冰 04-06 16:00 阅读 2
学习javaservlettomcat

一、监听器Listener

1 Listener介绍

  • Listener 监听器它是 JavaWeb 的三大组件之一。JavaWeb 的三大组件分别是：Servlet 程 序、Listener 监听器、Filter 过滤器

  • Listener 是 JavaEE 的规范，就是接口

  • 监听器的作用是，监听某种变化(一般就是对象创建/销毁, 属性变化), 触发对应方法完成 相应的任务
  • JavaWeb 中的监听器（共八个）, 目前最常用的是 ServletContextListener

2 ServletContextListener 监听器 

2.1 作用 

        监听 ServletContext 创建或销毁 ( 当我们 Web 应用启动时 ，就会创建 ServletContext) ，

即生命周期监听，应用场景 (1) 加载初始化的配置文件；比如 spring 的配置文件 (2) 任务调

度（配合定时器 Timer/TimerTask)

2.2 相关方法

2.3 应用实例 

package com.hspedu.listener;

import javax.servlet.ServletContext;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;

public class HspServletContextListener implements ServletContextListener {
    /*
        1. 当一个类实现了ServletContextListener时，该类就是一个监听器
        2. 该类可以监听的事件 由该类实现的监听接口决定
        3. 比如实现了ServletContextListener 则该类就可监听ServletContext对象的创建和销毁。以此类推
        4.HspServletContextListener就是一个监听者
        5.当web应用启动时，就会产生一个ServletContextEvent的事件，会调用监听器的对应事件处理方法
        6. contextInitialized同时会传递事件对象
        7. 程序员可以通过ServletContextEvent事件对象来获取需要的信息，再进行业务处理
        8.tomcat怎么知道这个监听器的存在？因为我们需要在web.xml配置
     */
    @Override
    public void contextInitialized(ServletContextEvent servletContextEvent) {
        ServletContext servletContext =servletContextEvent.getServletContext();
        System.out.println("监听到了"+servletContext+"被创建");

    }

    @Override
    public void contextDestroyed(ServletContextEvent servletContextEvent) {
        ServletContext servletContext =servletContextEvent.getServletContext();
        System.out.println("监听到了"+servletContext+"被销毁");
    }
}

 2.4 配置 web.xml

3 ServletContextAttributeListener 监听器 

3.1 介绍 

作用：监听 ServletContext 属性变化

相关方法

3.2 案例

 创建ServletContextAttributeListener

package com.hspedu.listener;

import javax.servlet.ServletContextAttributeEvent;
import javax.servlet.ServletContextAttributeListener;

public class MyServletContextAttributeListener implements ServletContextAttributeListener {
    @Override
    public void attributeAdded(ServletContextAttributeEvent servletContextAttributeEvent) {
        System.out.println("添加了 servletContext 属性名= " + servletContextAttributeEvent.getName() + " 属 性 值 =" +
                servletContextAttributeEvent.getValue());
    }

    @Override
    public void attributeRemoved(ServletContextAttributeEvent servletContextAttributeEvent) {
        System.out.println("删除了 servletContext 属性名= " + servletContextAttributeEvent.getName() + " 属 性 值 =" +
                servletContextAttributeEvent.getValue());
    }

    @Override
    public void attributeReplaced(ServletContextAttributeEvent servletContextAttributeEvent) {
        //拿到的属性是修改之前的
        System.out.println("替换了 servletContext 属性名= " + servletContextAttributeEvent.getName() + " 属 性 值 =" +
                servletContextAttributeEvent.getValue());
    }
}

配置 web.xml

创建Servlet

package com.hspedu.servlet;

import javax.servlet.ServletContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;

public class HiServlet extends HttpServlet {
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        //给ServletContext添加相关的属性
        ServletContext servletContext =request.getServletContext();
        servletContext.setAttribute("name","linran");
        servletContext.setAttribute("name","lin");
        servletContext.removeAttribute("name");

        System.out.println("HoServlet 处理完毕");
    }

    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        doPost(request,response);
    }
}

 4 其它监听器

4.1 HttpSessionListener 监听器

作用：监听 Session 创建或销毁，即生命周期监听

相关方法

4.2 HttpSessionAttributeListener 监听器 

作用：监听 Session 属性的变化

相关方法

  4.3 ServletRequestListener 监听器

 作用：监听 Request 属性变化

 相关方法

 4.4  ServletRequestListener 监听器

作用：监听 Request 创建或销毁，即 Request 生命周期监听

相关方法

可以用来监控, 某个 IP 访问我们网站的频率, 日志记录 ,访问资源的情况 

二、过滤器 Filter 

1 Filter 过滤器说明

1.1 为啥要过滤器

1.2 过滤器介绍 

  • Filter 过滤器它是 JavaWeb 的三大组件之一(Servlet 程序、Listener 监听器、Filter 过滤器)
  • Filter 过滤器是 JavaEE 的规范，是接口

  • Filter 过滤器它的作用是：拦截请求，过滤响应。 

1.3 应用场景 

权限检查 日记操作  事务管理

2 Filter 过滤器基本原理

3 Filter 过滤器快速入门

3.1 需求

在 web 工程下，有后台管理目录 manage ，要求 该目录下所有资源 （ html 、图片、

jsp 、 Servlet 等）用户登录后才能访问

 

 3.2 login.jsp

<%--
  User: Linran
  Date: 2024/4/2
  Time: 16:44
  Version: 1.0
  To change this template use File | Settings | File Templates.
--%>
<%@ page contentType="text/html;charset=UTF-8" language="java" %>
<html>
<head>
    <title>管理后台登录</title>
</head>
<body>
    <h1>管理后台登录</h1>
    <form action="<%=request.getContextPath()%>/loginCheckServlet" method="post">
        u:<input type="text" name="username"><br><br>
        p:<input type="password" name="password"><br><br>
        <input type="submit" value="用户登录">
    </form>

</body>
</html>

 3.3 LoginCLServlet

package com.hspedu.servlet;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import java.io.IOException;

public class LoginCheckServlet extends HttpServlet {
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        //获取用户名和密码
        //假设密码是123456就可以通过
        String username=request.getParameter("username");
        String password=request.getParameter("password");

        if("123456".equals(password)){
            //加入session
            HttpSession session = request.getSession();
            session.setAttribute("username",username);
            session.setAttribute("password",password);

            request.getRequestDispatcher("/manage/admin.jsp").forward(request,response);
        }else {
            request.getRequestDispatcher("/login.jsp").forward(request,response);
        }
    }

    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        doPost(request,response);
    }
}

3.4 admin.jsp

<%--
  User: Linran
  Date: 2024/4/2
  Time: 16:48
  Version: 1.0
  To change this template use File | Settings | File Templates.
--%>
<%@ page contentType="text/html;charset=UTF-8" language="java" %>
<html>
<head>
    <title>后台管理</title>
    <base href="<%=request.getContextPath()%>/manage/">
</head>
<body>
    <h1>后台管理</h1>
    <a href="#"> 用户列表</a>||<a href="#">添加用户</a>||<a href="#">删除用户</a>
    <hr>
<img src="1.jpeg">
</body>
</html>

3.5 ManageFilter

package com.hspedu.filter;

import javax.servlet.*;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;
import java.io.IOException;

public class ManageFilter implements Filter {
    @Override
    public void init(FilterConfig filterConfig) throws ServletException {
        //当Tomcat 创建filter后会调用该方法进行初始化
        System.out.println("ManageFilter init 被调用.....");

    }

    @Override
    public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
        //当每次调用该filter时，dofilter就会被调用
        System.out.println("ManageFilter doFilter 被调用");
        //如果这里没有调用继续请求的方法，则停止在这

        //如果继续访问目标资源
        //在调用过滤器之前，request对象已经被创建并封装
        //所以这里就可以通过servletRequest来获取很多信息，比如访问的url\session\数据
        HttpServletRequest httpServletRequest =((HttpServletRequest) servletRequest);
        HttpSession session = httpServletRequest.getSession();
        //获取username session对象

        Object username = session.getAttribute("username");
        if(username!=null){
            //用户登录过，直接放行
            filterChain.doFilter(servletRequest,servletResponse);
            //继续访问目标资源
            //servletRequest,servletResponse会传递给目标资源
            //
        }
        else {
            servletRequest.getRequestDispatcher("/login.jsp").forward(servletRequest,servletResponse);
        }
    }

    @Override
    public void destroy() {
        //当filter被销毁时，就会调用该方法
        System.out.println("ManageFilter destroy 被调用");
    }
}

3.6 web.xml

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsd"
         version="4.0">
    <!--filter一般写在最前面
        1. 我们可以发现filter配置和servlet是十分相似的，filter也是被tomcat管理和维护的
        2. url-pattern就是当请求的url和匹配的时候，就会调用该filter‘
        3. /manage/* 第一个/解析成http://ip:port/工程路径
        4：完整的路径就是http://ip:port/工程路径/manage/* 当请求的资源url满足该条件时都会调用filter




    -->
    <filter>
        <filter-name>ManageFilter</filter-name>
        <filter-class>com.hspedu.filter.ManageFilter</filter-class>
    </filter>
    <filter-mapping>
        <filter-name>ManageFilter</filter-name>
        <url-pattern>/manage/*</url-pattern>
    </filter-mapping>

    <servlet>
        <servlet-name>LoginCheckServlet</servlet-name>
        <servlet-class>com.hspedu.servlet.LoginCheckServlet</servlet-class>
    </servlet>
    <servlet-mapping>
        <servlet-name>LoginCheckServlet</servlet-name>
        <url-pattern>/loginCheckServlet</url-pattern>
    </servlet-mapping>

</web-app>

4 Filter 过滤器 url-pattern

  • url-pattern : Filter 的拦截路径, 即浏览器在请求什么位置的资源时，过滤器会进行拦截过滤

  • 精确匹配 <url-pattern>/a.jsp</url-pattern> 对应的 请求地址 http://ip[域名]:port/工程路径/a.jsp 会拦截

  • 目录匹配 <url-pattern>/manage/*</url-pattern>对应的 请求地址 http://ip[域名]:port/工程路径/manage/xx , 即 web 工程 manage 目录下所有资源 会拦截

  • 后缀名匹配 <url-pattern>*.jsp</url-pattern> 后缀名可变，比如 *.action *.do 等等对应的请求地址 http://ip[域名]:port/工程路径/xx.jsp , 后缀名为 .jsp 请求会拦截
  • Filter 过滤器它只关心请求的地址是否匹配，不关心请求的资源是否存在

5 Filter 过滤器生命周期 

6 FilterConfig 

  • FilterConfig 是 Filter 过滤器的配置类 
  • Tomcat 每次创建 Filter 的时候，也会创建一个 FilterConfig 对象，这里包含了 Filter 配置文件的配置信息。
  • FilterConfig 对象作用是获取 filter 过滤器的配置内容
package com.hspedu.filter;

import javax.servlet.*;
import java.io.IOException;
import java.util.Enumeration;

public class FilterConfig_ implements Filter {
    /*
    演示FilterConfig的使用
     */
    @Override
    public void init(FilterConfig filterConfig) throws ServletException {
        //通过filterConfig获取相关参数
        String filterName =filterConfig.getFilterName();
        System.out.println("filterName="+filterName);
        String ip =filterConfig.getInitParameter("ip");
        System.out.println("ip="+ip);
        ServletContext servletContext =filterConfig.getServletContext();
        System.out.println("servletContext="+servletContext);
        Enumeration<String> initParameterNames = filterConfig.getInitParameterNames();
        while (initParameterNames.hasMoreElements()){
            System.out.println("名字  :"+initParameterNames.nextElement());
        }

    }

    @Override
    public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
        
    }

    @Override
    public void destroy() {

    }
}

 web.xml

7 FilterChain 过滤器链 

一句话 : FilterChain: 在处理某些复杂业务时，一个过滤器不够，可以设计多个过滤器 共同完成过滤任务，形成过滤器链

 7.1 AFilter

package com.hspedu.filter;

import javax.servlet.*;
import java.io.IOException;

public class AFilter implements Filter {
    public void destroy() {
    }

    public void doFilter(ServletRequest req, ServletResponse resp, FilterChain chain) throws ServletException, IOException {
        System.out.println("=======AFilter doFilter()前置处理代码=======");
        chain.doFilter(req, resp);
        System.out.println("=======AFilter doFilter()后置处理代码=======");
    }

    public void init(FilterConfig config) throws ServletException {

    }

}

 7.2 BFilter

package com.hspedu.filter;

import javax.servlet.*;
import java.io.IOException;

public class AFilter implements Filter {
    public void destroy() {
    }

    public void doFilter(ServletRequest req, ServletResponse resp, FilterChain chain) throws ServletException, IOException {
        System.out.println("=======AFilter doFilter()前置处理代码=======");
        chain.doFilter(req, resp);
        System.out.println("=======AFilter doFilter()后置处理代码=======");
    }

    public void init(FilterConfig config) throws ServletException {

    }

}

7.3 hi.jsp

<%--
  User: Linran
  Date: 2024/4/2
  Time: 20:14
  Version: 1.0
  To change this template use File | Settings | File Templates.
--%>
<%@ page contentType="text/html;charset=UTF-8" language="java" %>
<html>
<head>
    <title>hi</title>
</head>
<body>
<h1>admin 目录下的 hi.jsp</h1>
<h1>后台管理</h1>
<a href="#">用户列表</a>||<a href="#">添加用户</a>||<a href="#">删除用户</a>
<hr/>
</body>
</html>

7.4 web.xml

 

8 FilterChain 注意事项和细节 

  • 多个 filter 和目标资源在一次 http 请求，在同一个线程中
  • 当一个请求 url 和 filter 的 url-pattern 匹配时, 才会被执行, 如果有多个匹配上，就会顺序执行，形成一个 filter 调用链(底层可以使用一个数据结构搞定
  • 多个 filter 共同执行时,因为是一次 http 请求, 使用同一个 request 对象

  • 多个 filter 执行顺序，和 web.xml 配置顺序保持一致.

  • chain.doFilter(req, resp)方法 将执行下一个过滤器的 doFilter 方法, 如果后面没有过滤器，则执行目标资源。

  • 小结：注意执行过滤器链时, 顺序是(用前面的案例分析) Http请求 -> A 过滤器 dofilter() -> A 过滤器前置代码 -> A 过滤器 chain.doFilter() -> B 过滤器 dofilter() -> B 过滤器前置代 码 -> B过滤器 chain.doFilter() -> 目标文件 -> B过滤器后置代码 -> A过滤器后置代码 -> 返回给浏览器页面/数据

 

举报

相关推荐

离线数仓项目

数据仓库

大数据学习-hive（四：离线数仓搭建流程）

big datahive学习数据仓库大数据

离线数仓和实时数仓的区别

数据离线数据仓库Hadoop大数据

离线数仓同步数据1

单例模式java开发语言

阿里云生态离线数仓

linuxrust运维

Hive+Spark离线数仓工业项目实战--数仓设计及数据采集（1）

hivesparkhadoop数仓设计

伴鱼离线数仓建设案例

大数据数据建模业务需求MySQL数据库

离线数仓（1）：什么是数据仓库

数据仓库大数据bigdata离线数仓

离线数仓之用户业务数据采集平台搭建

mysql数据库database

#Word文档导入#离线数仓关闭信息收集方案

离线数据测试评审Hadoop大数据
0 条评论