登錄方式調(diào)整

第1步：從zmall-common的pom.xml中移除spring-session-data-redis依賴

注意：
1）本次不采用spring-session方式，改用redis直接存儲(chǔ)用戶登錄信息，主要是為了方便之后的jmeter壓測(cè)；
2）這里只注釋調(diào)用spring-session的依賴，保留redis的依賴；

第2步：在zmall-common公共模塊中定義RedisConfig配置類

@Configuration
public class RedisConfig {@Beanpublic RedisTemplate<String,Object> restTemplate(RedisConnectionFactory redisConnectionFactory){RedisTemplate<String,Object> redisTemplate=new RedisTemplate<>();//String類型Key序列化redisTemplate.setKeySerializer(new StringRedisSerializer());//String類型Value序列化redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());//Hash類型Key序列化redisTemplate.setHashKeySerializer(new StringRedisSerializer());//Hash類型Value序列化redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());redisTemplate.setConnectionFactory(redisConnectionFactory);return redisTemplate;}
}

第3步：在zmall-common公共模塊中配置redis相關(guān)服務(wù)

IRedisServcie

public interface IRedisService {/*** 將登陸用戶對(duì)象保存到Redis中，并以token來命名* @param token* @param user*/void setUserToRedis(String token, User user);/*** 根據(jù)token令牌從Redis中獲取User對(duì)象* @param token* @return*/User getUserByToken(String token);
}

RedisServcieImple

@Service
public class RedisServiceImpl implements IRedisService {@Autowiredprivate RedisTemplate<String,Object> redisTemplate;@Overridepublic void setUserToRedis(String token, User user) {String key="user:"+token;redisTemplate.boundValueOps(key).set(user,7200,TimeUnit.SECONDS);}@Overridepublic User getUserByToken(String token) {return (User) redisTemplate.opsForValue().get("user:"+token);}
}

用戶登錄成功后，將用戶對(duì)象保存到Redis中，并設(shè)置超時(shí)時(shí)間7200秒。

第4步：配置自定義參數(shù)解析UserArgumentResolver、WebConfig

UserArgumentResolver

/*** 自定義用戶參數(shù)類*/
@Component
public class UserArgumentResolver implements HandlerMethodArgumentResolver {@Autowiredprivate IRedisService redisService;/*** 只有supportsParameter方法執(zhí)行返回true，才能執(zhí)行下面的resolveArgument方法* @param methodParameter* @return*/@Overridepublic boolean supportsParameter(MethodParameter methodParameter) {Class<?> type = methodParameter.getParameterType();return type== User.class;}@Overridepublic Object resolveArgument(MethodParameter methodParameter,ModelAndViewContainer modelAndViewContainer,NativeWebRequest nativeWebRequest,WebDataBinderFactory webDataBinderFactory) throws Exception {HttpServletRequest req= (HttpServletRequest) nativeWebRequest.getNativeRequest();//從cookie獲取token令牌String token = CookieUtils.getCookieValue(req, "token");//判斷cookie中的token令牌是否為空if(StringUtils.isEmpty(token))throw new BusinessException(JsonResponseStatus.TOKEN_ERROR);//根據(jù)token令牌獲取redis中存儲(chǔ)的user對(duì)象，方便jmeter測(cè)試User user = redisService.getUserByToken(token);if(null==user)throw new BusinessException(JsonResponseStatus.TOKEN_ERROR);return user;}
}

WebConfig

@Component
public class WebConfig implements WebMvcConfigurer {@Autowiredprivate UserArgumentResolver userArgumentResolver;@Overridepublic void addArgumentResolvers(List<HandlerMethodArgumentResolver> resolvers) {resolvers.add(userArgumentResolver);}@Overridepublic void addResourceHandlers(ResourceHandlerRegistry registry) {//添加靜態(tài)資源訪問映射//registry.addResourceHandler("/static/**")//        .addResourceLocations("classpath:/static/");}
}

第5步：用戶登錄業(yè)務(wù)調(diào)整，將spring-session方式更改為redis方式存儲(chǔ)登錄用戶信息。

//5.通過UUID生成token令牌并保存到cookie中
String token= UUID.randomUUID().toString().replace("-","");
//將隨機(jī)生成的Token令牌保存到Cookie中，并設(shè)置1800秒超時(shí)時(shí)間
CookieUtils.setCookie(req,resp,"token",token,7200);
//6.將token令牌與spring session進(jìn)行綁定并存入redis中
//HttpSession session = req.getSession();
//session.setAttribute(token,us);
//將token令牌與user綁定后存儲(chǔ)到redis中，方便jmeter測(cè)試
redisService.setUserToRedis(token,us);

這里采用Redis方式直接存儲(chǔ)登錄用戶信息，只為后續(xù)使用Jmeter壓測(cè)時(shí)提供便利。正常運(yùn)行使用項(xiàng)目還是可以使用spring-session方式。

第6步：修改商品服務(wù)zmall-product模塊中的index方法，將之前從HttpSession中獲取登錄用戶信息改換成User對(duì)象參數(shù)方式

@RequestMapping("/index.html")
public String index(Model model, User user){System.out.println(user);
}

在調(diào)用index方法之前，先由自定義的參數(shù)解析器進(jìn)行參數(shù)解析并返回解析結(jié)果User，所以在這里可直接在方法參數(shù)中獲取的User對(duì)象。

第7步：重啟zmall-user和zmall-product模塊，完成用戶登錄后，直接在瀏覽器地址欄輸入：http://zmall.com/product-serv/index.html，查看zmall-product模塊中的控制臺(tái)是否已經(jīng)獲取到登錄用戶對(duì)象信息。

生成秒殺訂單

綁定秒殺商品

添加sellDetail.html頁面到zmall-product模塊中；實(shí)現(xiàn)首頁秒殺商品展示，必須保證秒殺商品狀態(tài)為已激活、且秒殺商品的活動(dòng)時(shí)間為有效時(shí)間范圍之內(nèi)。

 <#if kills??><#list kills as g><div class="sell_${g_index?if_exists+1}"><div class="sb_img"><a href="${ctx}/sellDetail.html?pid=${g.id}"><img src="${g.fileName}" width="242" height="356" /></a></div><div class="s_price">￥<span>${g.price}</span></div><div class="s_name"><h2><a href="${ctx}/sellDetail.html?pid=${g.id}">${g.name}</a></h2>倒計(jì)時(shí)：<span>1200</span> 時(shí) <span>30</span> 分 <span>28</span> 秒</div></div></#list></#if>

查看秒殺商品

點(diǎn)擊限時(shí)秒殺中的秒殺商品，根據(jù)秒殺商品ID查詢秒殺商品詳情信息并跳轉(zhuǎn)到sellDetail.html頁面展示秒殺商品信息。

訂單秒殺

移除seata相關(guān)

第1步：先注釋掉zmall-order和zmall-product模塊中的seata依賴

第2步：分別刪掉zmall-order和zmall-product模塊中resources目錄下的bootstrap.xml和register.conf文件

第3步：移除zmall-order中分布式事務(wù)案例中的@GlobalTransactional注解

第4步：刪除DataSourceProxyConfig該類

第5步：移除zmall-order中啟動(dòng)類上的注解參數(shù)(exclude = DataSourceAutoConfiguration.class)

//更改前：
//@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
//更改后：
@SpringBootApplication
@EnableDiscoveryClient
@MapperScan({"com.zking.zmall.mapper"})
@EnableFeignClients
public class ZmallOrderApplication {public static void main(String[] args) {SpringApplication.run(ZmallOrderApplication.class, args);}}

第6步：更換zmall-order和zmall-product中的application.yml配置中的數(shù)據(jù)庫連接池

datasource:#type連接池類型 DBCP,C3P0,Hikari,Druid,默認(rèn)為Hikari#更改前：#type: com.alibaba.druid.pool.DruidDataSource#更改后：type: com.zaxxer.hikari.HikariDataSource

生成秒殺訂單

將SnowFlake雪花ID生成工具類導(dǎo)入到zmall-common模塊中utils，然后再生成秒殺訂單時(shí)使用雪花ID來充當(dāng)秒殺訂單編號(hào)；在zmall-order模塊中完成秒殺訂單生成工作。

IOrderService

public interface IOrderService extends IService<Order> {JsonResponseBody<?> createKillOrder(User user, Integer pid);
}

OrderServiceImpl

@Transactional
@Override
public JsonResponseBody<?> createKillOrder(User user, Integer pid) {//1.判斷用戶是否登錄if(null==user)throw new BusinessException(JsonResponseStatus.TOKEN_ERROR);//根據(jù)用戶ID和秒殺商品Id判斷。。。。//2.根據(jù)秒殺商品編號(hào)獲取秒殺商品庫存是否為空Kill kill = killService.getOne(new QueryWrapper<Kill>().eq("item_id",pid));if(kill.getTotal()<1)throw new BusinessException(JsonResponseStatus.STOCK_EMPTY);//3.根據(jù)商品ID獲取商品Product product = productService.getProductById(pid);//4.秒殺商品庫存減一killService.updateKillStockById(pid);//5.生成秒殺訂單及訂單項(xiàng)SnowFlake snowFlake=new SnowFlake(2,3);Long orderId=snowFlake.nextId();//創(chuàng)建訂單Order order=new Order();order.setUserId(user.getId());order.setLoginName(user.getLoginName());order.setCost(product.getPrice());order.setSerialNumber(orderId);this.save(order);//創(chuàng)建訂單項(xiàng)OrderDetail orderDetail=new OrderDetail();orderDetail.setOrderId(orderId);orderDetail.setProductId(product.getId());orderDetail.setQuantity(1);orderDetail.setCost(product.getPrice());orderDetailService.save(orderDetail);return new JsonResponseBody();
}

前端頁面秒殺測(cè)試

在sellDetail.html頁面中添加訂單秒殺JS方法。

<script>$(function(){$('.ch_a').click(function(){let pid=$(this).attr('alt');console.log(pid);$.post('http://zmall.com/order-serv/createKillOrder',{pid:pid},function(rs){console.log(rs);if(rs.code===200)alert('秒殺成功');elsealert(rs.msg);},'json');});});
</script>

這里雖然已經(jīng)能正常展示秒殺效果，但是還是存在很多問題，比如：重復(fù)搶購問題等等問題。

utils:https://pan.baidu.com/s/1ExaC4GgEg_ofKsARkYhHXw
提取碼：kq20