1.實作京淘專案權限控制

1.1 需求分析

如果用戶沒有進行登錄操作時,訪問購物車/訂單等敏感操作時將不允許訪問,應該重定向到系統的登錄頁面.

知識點:
1. AOP: 對原有的方法進行擴展.在原有的基礎之上提供了額外的操作. 業務控制的.Service層
2. 攔截器: 控制了程式的執行軌跡.滿足條件時才會執行任務. 控制的request物件/response物件控制用戶的請求.
3. 資料傳輸. request物件 /ThreadLocal

1.2 關于攔截器說明

1.2.1 SpringMVC程式呼叫流程

在這里插入圖片描述

1.2.2 攔截器作業原理

在這里插入圖片描述

1.2.3 攔截器配置

@Configuration						  //配置web.xml組態檔
public class MvcConfigurer implements WebMvcConfigurer{
	
	//開啟匹配后綴型配置,為了將來程式實作靜態頁面的跳轉而準備的
	@Override
	public void configurePathMatch(PathMatchConfigurer configurer) {
		
		configurer.setUseSuffixPatternMatch(true);
	}

	//添加攔截器配置
	@Autowired
	private UserInterceptor userInterceptor;

	@Override
	public void addInterceptors(InterceptorRegistry registry) {

		registry.addInterceptor(userInterceptor).addPathPatterns("/cart/**","/order/**");
	}
}

1.2.3 攔截器業務實作

package com.jt.interceptor;

import com.jt.pojo.User;
import com.jt.thread.UserThreadLocal;
import com.jt.util.CookieUtil;
import com.jt.util.ObjectMapperUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;
import org.springframework.web.servlet.HandlerInterceptor;
import redis.clients.jedis.JedisCluster;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

//處理器攔截器
//一般在介面中定義default可以使得實作類不必重寫所有的介面的方法.
@Component  //將攔截器交給Spring容器管理
public class UserInterceptor implements HandlerInterceptor {

    @Autowired
    private JedisCluster jedisCluster;

    /**
     * 回傳值說明:
     *      boolean:  true   放行
     *             :  false  攔截  一般配合重定向的方式使用
     *
     * 業務說明:
     *      如果用戶已經登錄則程式放行.否則攔截
     * 判斷依據:  1.是否有cookie 2.redis中是否有記錄.
     * @param request
     * @param response
     * @param handler
     * @return
     * @throws Exception
     */
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {

        //1.動態獲取JT_TICKET資料
        String ticket = CookieUtil.getCookieValue("JT_TICKET",request);
        if(!StringUtils.isEmpty(ticket)){
            //2.判斷redis中是否有資料
            if(jedisCluster.exists(ticket)){
                //4.動態獲取user資訊.將用戶資訊交給request物件傳遞給下一級
                String userJSON = jedisCluster.get(ticket);
                User user = ObjectMapperUtil.toObject(userJSON,User.class);
                //當前的物件會攜帶當前的用戶資訊!!!!
                request.setAttribute("JT_USER",user);

                //2.利用ThreadLocal的方式動態傳參
                UserThreadLocal.set(user);
                return true;    //表示放行
            }
            //3.將無效的cookie洗掉.
            CookieUtil.deleteCookie("JT_TICKET","/","jt.com",response);
        }

        //重定向到用戶的登錄頁面.
        response.sendRedirect("/user/login.html");
        return false;
    }

    /**
     * 說明:利用攔截器方法清空資料
     * @param request
     * @param response
     * @param handler
     * @param ex
     * @throws Exception
     */
    @Override
    public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {

        //1.洗掉Request物件的資料
        request.removeAttribute("JT_USER");

        //2.洗掉ThreadLocal中的資料
        UserThreadLocal.remove();
    }
}

1.3 ThreadLocal

1.3.1 ThreadLocal介紹

1.名詞解釋: 本地執行緒變數
2.作用: 在多執行緒條件下使用ThreadLocal可以實作現場內資料的共享.
在這里插入圖片描述

1.3.2 ThreadLocal API

public class UserThreadLocal {

    //1.定義變數
    private static ThreadLocal<User> thread = new ThreadLocal<>();

    public static void set(User user){  //賦值
        thread.set(user);
    }

    public static User get(){           //取值

        return thread.get();
    }

    public static void remove(){        //移除
        thread.remove();
    }
}

1.3.3 練習題

問: 在JT-WEB攔截器中使用ThreadLocal進行資料傳參,
問題1:JT-WEB的Controller中能否獲取資料? 可以
問題2:jt-cart的Service層中能否獲取資料不可以
因為:jt-web服務器與jt-cart的服務器的通訊是通過Dubbo框架的RPC實作的. RPC相當于開啟了一個新的執行緒,所以無法通訊.

1.3.4 關于ThreadLocal總結

1.在同一個執行緒內可以使用ThreadLocal
2.“一般條件下” 在同一個tomcat內的執行緒為同一個執行緒.

2.訂單專案實作

2.1 專案創建jt-order

2.1.1 創建專案

在這里插入圖片描述

2.1.2 添加繼承/依賴/插件

<parent>
        <artifactId>jt</artifactId>
        <groupId>org.example</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>

    <!--添加依賴項-->
    <dependencies>
        <dependency>
            <groupId>org.example</groupId>
            <artifactId>jt-common</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
    </dependencies>

    <!--添加插件-->
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

2.1.3 編輯POM.xml組態檔

server:
  port: 8095
  servlet:
    context-path: /
spring:
  datasource:
    #driver-class-name: com.mysql.jdbc.Driver
    #如果需要專案發布,則資料庫地址必須配置遠程資料庫
    url: jdbc:mysql://127.0.0.1:3306/jtdb?serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=utf8&autoReconnect=true&allowMultiQueries=true
    username: root
    password: root
  
  #配置視圖決議器
  mvc:
    view:
      prefix: /WEB-INF/views/
      suffix: .jsp
      
#mybatis-plush配置
mybatis-plus:
  type-aliases-package: com.jt.pojo
  mapper-locations: classpath:/mybatis/mappers/*.xml
  configuration:
    map-underscore-to-camel-case: true

#日志記錄 輸出資料庫的日志資訊.
logging:
  config: classpath:logging-config.xml
  level: 
    com.jt.mapper: debug
    
dubbo:
  scan:
    basePackages: com.jt    #指定dubbo的包路徑
  application:
    name: provider-order     #指定服務名稱(必須指定)
  registry:
    address: zookeeper://192.168.126.129:2181?backup=192.168.126.129:2182,192.168.126.129:2183
  protocol:  #指定協議
    name: dubbo  #使用dubbo協議(tcp-ip)  web-controller直接呼叫sso-Service
    port: 20883 #每個服務都應該有自己特定的埠

2.2 訂單確認頁面跳轉

2.2.1 頁面分析

在這里插入圖片描述
2).頁面取值說明

當用戶點擊去結算時,應該跳轉到訂單確認頁面 order-cart.jsp,應該展現用戶的購物車相關資訊.之后提交訂單即可.

2.2.2 編輯OrderController

package com.jt.controller;

import com.alibaba.dubbo.config.annotation.Reference;
import com.jt.pojo.Cart;
import com.jt.service.DubboCartService;
import com.jt.thread.UserThreadLocal;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;

import java.util.List;

@Controller
@RequestMapping("/order")
public class OrderController {

    @Reference(check = false,timeout = 3000)
    private DubboCartService cartService;

    /**
     * 訂單確認頁面跳轉
     * 1.url地址:http://www.jt.com/order/create.html
     * 2.引數說明:  暫時沒有
     * 3.回傳值:  order-cart.jsp頁面
     * 4.頁面的取值:  ${carts}
     */
    @RequestMapping("/create")
    public String findCartByUserId(Model model){ //request域

        Long userId = UserThreadLocal.get().getId();
        List<Cart> cartList = cartService.findCartListByUserId(userId);
        model.addAttribute("carts",cartList);
        return "order-cart";
    }
}

2.2.3 頁面效果展現

在這里插入圖片描述

2.3 訂單表說明

2.3.1 訂單表

在這里插入圖片描述

2.3.2 訂單表注意事項

1.訂單的ID號不是主鍵自增
2.訂單狀態資訊由 1-6 注意狀態說明
在這里插入圖片描述

2.4 SpringMVC中引數格式說明

2.4.1 簡單引數傳值問題

說明:頁面傳參中 name屬性必須與mvc中的資料保持一致.
1.頁面資訊

<input  type="text" name="name" value="二郎神"/>
<input  type="text" name="age" value="3500"/>

2.服務端接收

public String  saveUser(String name,Integer age){....}

2.4.2 利用物件的方式接收引數

1.頁面資訊

<input  type="text" name="name" value="二郎神"/>
<input  type="text" name="age" value="3500"/>

2.服務端接收

public String  saveUser(User user){....}

2.4.3 mvc為物件的參考賦值

問題:如何解決重名提交的問題???
方案: 可以將物件進行封裝,之后采用物件參考賦值的方式實作該功能.
注意事項: 屬性的名稱必須一致,否則賦值失敗.

1.頁面資訊

<input  type="text" name="name" value="二郎神"/>
<input  type="text" name="age" value="3500"/>
<input  type="text" name="dog.name" value="嘯天犬"/>
<input  type="text" name="dog.age" value="5000"/>

2.服務端接收

public class User { 
	private String name;
	private Integer age;
	private Dog dog;
}

public class Dog{
	private String name;
	private Integer age;
}
public String  saveUser(User user){....}

2.4.4 訂單物件定義

采用為物件參考賦值的操作. 但是該屬性不屬于資料庫,所以需要額外的配置.
在這里插入圖片描述

2.5 訂單入庫

2.5.1 業務說明

當用戶點擊提交訂單時要求實作三張表同時入庫業務功能,并且保證orderId的值是一致的.

1.頁面URL請求
在這里插入圖片描述
2.頁面引數

3.頁面JS分析

jQuery.ajax( {
			type : "POST",
			dataType : "json",
			url : "/order/submit",
			//key=value&key2=value2&....
			data : $("#orderForm").serialize(),
			cache : false,
			success : function(result) {
				if(result.status == 200){
					location.href = "/order/success.html?id="+result.data;
				}else{
					$("#submit_message").html("訂單提交失敗，請稍后重試...").show();
				}
			},
			error : function(error) {
				$("#submit_message").html("親愛的用戶請不要頻繁點擊, 請稍后重試...").show();
			}
		});

2.5.2 編輯OrderController

 /**
     * 完成訂單業務提交
     * 1.url地址: /order/submit
     * 2.頁面引數: 整個form表單
     * 3.回傳值結果: SysResult物件(orderId). json資料
     */
    @RequestMapping("/submit")
    @ResponseBody
    public SysResult submit(Order order){
        Long userId = UserThreadLocal.get().getId();
        order.setUserId(userId);
        String orderId = orderService.saveOrder(order);
        if(StringUtils.isEmpty(orderId)){
            return SysResult.fail();
        }
        return SysResult.success(orderId);
    }

2.5.2 編輯OrderService

package com.jt.service;

import java.util.Calendar;
import java.util.Date;
import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;

import com.alibaba.dubbo.config.annotation.Service;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.jt.mapper.OrderItemMapper;
import com.jt.mapper.OrderMapper;
import com.jt.mapper.OrderShippingMapper;
import com.jt.pojo.Order;
import com.jt.pojo.OrderItem;
import com.jt.pojo.OrderShipping;

@Service
public class OrderServiceImpl implements DubboOrderService {
	
	@Autowired
	private OrderMapper orderMapper;
	@Autowired
	private OrderShippingMapper orderShippingMapper;
	@Autowired
	private OrderItemMapper orderItemMapper;


	@Override
	@Transactional	//控制事務
	public String saveOrder(Order order) {

		//1.準備訂單Id號   大量的字串拼接
		String orderId = ""+order.getUserId() + System.currentTimeMillis();

		//2.完成訂單入庫
		order.setOrderId(orderId).setStatus(1);
		orderMapper.insert(order);

		//3.完成訂單物流入庫
		OrderShipping orderShipping = order.getOrderShipping();
		orderShipping.setOrderId(orderId);
		orderShippingMapper.insert(orderShipping);

		//4.完成訂單商品入庫操作
		List<OrderItem> orderItemList = order.getOrderItems();
		//手動完成批量賦值的操作
		//insert into orderItem(....) values (xx,xxx,xxx),(xx,xx,xx),(xx,xx,xx);
		for (OrderItem orderItem : orderItemList){
			orderItem.setOrderId(orderId);
			orderItemMapper.insert(orderItem);
		}
		System.out.println("完成訂單入庫操作");

		return orderId;
	}
}

2.6 訂單查詢

2.6.1 業務分析

業務說明: 根據orderId號,檢索訂單的資料資訊.要求利用Order物件將所有的資料一起回傳.
在這里插入圖片描述

2.6.2 編輯OrderController

/**
     * 實作訂單的查詢,回傳order物件
     * url: http://www.jt.com/order/success.html?id=191600674802663
     * 引數: id 訂單的編號
     * 回傳值: success
     * 頁面取值: ${order.orderId}
     */
    @RequestMapping("/success")
    public String findOrderById(String id,Model model){

        Order order = orderService.findOrderById(id);
        model.addAttribute("order",order);
        return "success";
    }

2.6.3 編輯OrderService

@Override
	public Order findOrderById(String id) {

		Order order = orderMapper.selectById(id);
		OrderShipping orderShipping = orderShippingMapper.selectById(id);
		QueryWrapper<OrderItem> queryWrapper = new QueryWrapper<>();
		queryWrapper.eq("order_id",id);
		List<OrderItem> orderItems = orderItemMapper.selectList(queryWrapper);
		return order.setOrderShipping(orderShipping).setOrderItems(orderItems);
	}

2.6.4.頁面效果展現

在這里插入圖片描述

2.7 超時訂單的處理

2.7.1 業務說明

說明:如果訂單提交之后如果30分鐘沒有完成付款,則將訂單狀態改為6.表示訂單交易關閉.
問題:如何實作每個訂單30分鐘超時呀???

思路1: 利用資料庫的計時的函式每當order入庫之后,可以添加一個函式30分鐘之后修改狀態.
該方法不友好, 100萬的訂單剛剛入庫. 100萬個監聽的事件.
思路2: 利用訊息佇列的方式實作 redis 開啟執行緒向redis中存盤資料之后設定超時時間.當key一旦失效則修改資料庫狀態.
Redis主要做快取使用. 但是不合適.
思路3:
開啟單獨的一個執行緒(異步),每隔1分鐘查詢一次資料庫,修改超時的訂單處理即可.

2.7.2 Quartz介紹

Quartz是OpenSymphony開源組織在Job scheduling領域又一個開源專案，它可以與J2EE與J2SE應用程式相結合也可以單獨使用，Quartz可以用來創建簡單或為運行十個，百個，甚至是好幾萬個Jobs這樣復雜的程式，Jobs可以做成標準的Java組件或 EJBs，Quartz的最新版本為Quartz 2.3.2，
在這里插入圖片描述
組件說明:
1. Job 是用戶自定義的任務.
2. JobDetail 負責封裝任務的工具API.如果任務需要被執行,則必須經過jobDetail封裝.
3. 調度器: 負責時間監控,當任務的執行時間一到則交給觸發器處理
4. 觸發器: 當接收到調度器的命令則開啟新的執行緒執行job…

2.7.3 匯入jar包

 <!--添加Quartz的支持 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-quartz</artifactId>
        </dependency>

2.7.4 編輯配置類

package com.jt.conf;

import com.jt.quartz.OrderQuartz;
import org.quartz.CronScheduleBuilder;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class OrderQuartzConfig {

	/**
	 * 思想說明:
	 * 	如果需要執行定時任務需要考慮的問題
	 * 	1.任務多久執行一次.  1分鐘執行一次
	 * 	2.定時任務應該執行什么
	 *
	 */
	//定義任務詳情
	@Bean
	public JobDetail orderjobDetail() {
		//指定job的名稱和持久化保存任務
		return JobBuilder
				.newJob(OrderQuartz.class)		//1.定義執行的任務
				.withIdentity("orderQuartz")	//2.任務指定名稱
				.storeDurably()
				.build();
	}
	//定義觸發器
	@Bean
	public Trigger orderTrigger() {
		/*SimpleScheduleBuilder builder = SimpleScheduleBuilder.simpleSchedule()
				.withIntervalInMinutes(1)	//定義時間周期
				.repeatForever();*/
		CronScheduleBuilder scheduleBuilder 
			= CronScheduleBuilder.cronSchedule("0 0/1 * * * ?");
		return TriggerBuilder
				.newTrigger()
				.forJob(orderjobDetail())	//執行的任務
				.withIdentity("orderQuartz")	//任務的名稱
				.withSchedule(scheduleBuilder).build();
	}
}

2.7.5 編輯定時任務

package com.jt.quartz;

import java.util.Calendar;
import java.util.Date;

import com.jt.mapper.OrderMapper;
import com.jt.pojo.Order;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.quartz.QuartzJobBean;
import org.springframework.stereotype.Component;
import org.springframework.transaction.CannotCreateTransactionException;
import org.springframework.transaction.annotation.Transactional;

import com.alibaba.dubbo.config.annotation.Reference;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;


//準備訂單定時任務
@Component
public class OrderQuartz extends QuartzJobBean{

	@Autowired
	private OrderMapper orderMapper;

	/**
	 * 如果用戶30分鐘之內沒有完成支付,則將訂單的狀態status由1改為6.
	 * 條件判斷的依據:  now()-創建時間 > 30分鐘   <==>  created < now()-30
	 *
	 * sql: update tb_order set status=6,updated=#{updated} where status=1 and created< #{timeOut}
	 * @param context
	 * @throws JobExecutionException
	 */
	@Override
	@Transactional
	protected void executeInternal(JobExecutionContext context) throws JobExecutionException {

		//1.利用java工具API完成計算
		Calendar calendar = Calendar.getInstance();  //獲取當前的時間
		calendar.add(Calendar.MINUTE,-30);
		Date timeOut = calendar.getTime();	//獲取超時時間

		Order order = new Order();
		order.setStatus(6);
		//order.setUpdated(new Date());
		UpdateWrapper<Order> updateWrapper = new UpdateWrapper<>();
		updateWrapper.eq("status", "1").lt("created",timeOut);
		orderMapper.update(order, updateWrapper);
		System.out.println("定時任務執行");
	}
}

轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/109314.html

標籤：java

上一篇：商業鬼才教你代理模式

下一篇：阿里巴巴大神發布的Java零基礎筆記，實戰教程多到手軟，跪了

CGB2005-京淘20

1.實作京淘專案權限控制

1.1 需求分析

1.2 關于攔截器說明

1.2.1 SpringMVC程式呼叫流程

1.2.2 攔截器作業原理

1.2.3 攔截器配置

1.2.3 攔截器業務實作

1.3 ThreadLocal

1.3.1 ThreadLocal介紹

1.3.2 ThreadLocal API

1.3.3 練習題

1.3.4 關于ThreadLocal總結

2.訂單專案實作

2.1 專案創建jt-order

2.1.1 創建專案

2.1.2 添加繼承/依賴/插件

2.1.3 編輯POM.xml組態檔

2.2 訂單確認頁面跳轉

2.2.1 頁面分析

2.2.2 編輯OrderController

2.2.3 頁面效果展現

2.3 訂單表說明

2.3.1 訂單表

2.3.2 訂單表注意事項

2.4 SpringMVC中引數格式說明

2.4.1 簡單引數傳值問題

2.4.2 利用物件的方式接收引數

2.4.3 mvc為物件的參考賦值

2.4.4 訂單物件定義

2.5 訂單入庫

2.5.1 業務說明

2.5.2 編輯OrderController

2.5.2 編輯OrderService

2.6 訂單查詢

2.6.1 業務分析

2.6.2 編輯OrderController

2.6.3 編輯OrderService

2.6.4.頁面效果展現

2.7 超時訂單的處理

2.7.1 業務說明

2.7.2 Quartz介紹

2.7.3 匯入jar包

2.7.4 編輯配置類

2.7.5 編輯定時任務