需要全部代码请点赞关注收藏后评论区留言私信~~~
一、系统简介
分布式优惠券后台应用系统服务于两类用户群体,一类是商户,商户可以根据自己的实际情况即进行优惠券投放,另一类是平台消费用户,用户可以去领取商户发放的优惠券
二、整体架构
分布式优惠券后台应用系统采用SpringBoot作为主体开发框架,使用Kafka消息队列实现优惠券从商户到用户的传递,Mysql存储商户信息,HBase存储用户信息,优惠券信息等,Redis保存优惠券的缓存信息 系统整体架构如下
对于商户投放子系统,商户注册生成对应的商户实体信息,并保存到Mysql数据库,商户可以投放自己商家的优惠券,且优惠券有自己的Token存放于Redis中,投放的优惠券信息将由Kafka向用户消费子系统发送,而商户投放的优惠券并不在Mysql中进行存储,而是在商户投放子系统中放送消息给Kafka,用户消费子系统通过侦听Kafka消息获得Kafka分布式信息并存储到HBase中,用户通过读取Redis中的优惠券信息领取消费券,并将自己领取到的优惠券信息存放在HBase中
三、表结构设计
mysql表结果设计如何 存放商户基本信息
HBase表结构设计
在HBase中建立三个表,分别是消费用户表,优惠券表和优惠券领取表
四、系统实现
1:新建MAVEN工程 引入相关依赖包
2:修改applicaiton.yml文件 包括mysql和kafka的连接相关配置
3:建立各个类包存放路径
4:核心代码实现
五、效果展示
商户投放子系统成功启动效果如下
用户子系统成功启动效果如下
发放优惠券界面如下
数据库表插入情况如下
六、部分代码
部分代码如下 需要全部代码请点赞关注收藏后评论区留言私信~~~
package com.coupon.passbook.controller;
import com.coupon.passbook.log.LogConstants;
import com.coupon.passbook.log.LogGenerator;
import com.coupon.passbook.service.IUserService;
import com.coupon.passbook.vo.Response;
import com.coupon.passbook.vo.User;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
import javax.servlet.http.HttpServletRequest;
/**
* <h1>创建用户服务</h1>
* Created by Qinyi.
*/
@Slf4j
@RestController
@RequestMapping("/passbook")
public class CreateUserController {
/** 创建用户服务 */
private final IUserService userService;
/** HttpServletRequest */
private final HttpServletRequest httpServletRequest;
@Autowired
public CreateUserController(IUserService userService,
HttpServletRequest httpServletRequest) {
this.userService = userService;
this.httpServletRequest = httpServletRequest;
}
/**
* <h2>创建用户</h2>
* @param user {@link User}
* @return {@link Response}
* */
@ResponseBody
@PostMapping("/createuser")
Response createUser(@RequestBody User user) throws Exception {
LogGenerator.genLog(
httpServletRequest,
user.getId(),
LogConstants.ActionName.CREATE_USER,
user
);
return userService.createUser(user);
}
}
控制器2
package com.coupon.passbook.controller;
import com.coupon.passbook.log.LogConstants;
import com.coupon.passbook.log.LogGenerator;
import com.coupon.passbook.service.IFeedbackService;
import com.coupon.passbook.service.IGainPassTemplateService;
import com.coupon.passbook.service.IInventoryService;
import com.coupon.passbook.service.IUserPassService;
import com.coupon.passbook.vo.Feedback;
import com.coupon.passbook.vo.GainPassTemplateRequest;
import com.coupon.passbook.vo.Pass;
import com.coupon.passbook.vo.Response;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
import javax.servlet.http.HttpServletRequest;
/**
* <h1>Passbook Rest Controller</h1>
* Created by Qinyi.
*/
@Slf4j
@RestController
@RequestMapping("/passbook")
public class PassbookController {
/** 用户优惠券服务 */
private final IUserPassService userPassService;
/** 优惠券库存服务 */
private final IInventoryService inventoryService;
/** 领取优惠券服务 */
private final IGainPassTemplateService gainPassTemplateService;
/** 反馈服务 */
private final IFeedbackService feedbackService;
/** HttpServletRequest */
private final HttpServletRequest httpServletRequest;
@Autowired
public PassbookController(IUserPassService userPassService,
IInventoryService inventoryService,
IGainPassTemplateService gainPassTemplateService,
IFeedbackService feedbackService,
HttpServletRequest httpServletRequest) {
this.userPassService = userPassService;
this.inventoryService = inventoryService;
this.gainPassTemplateService = gainPassTemplateService;
this.feedbackService = feedbackService;
this.httpServletRequest = httpServletRequest;
}
/**
* <h2>获取用户个人的优惠券信息</h2>
* @param userId 用户 id
* @return {@link Response}
* */
@ResponseBody
@GetMapping("/userpassinfo")
Response userPassInfo(Long userId) throws Exception {
LogGenerator.genLog(
httpServletRequest,
userId,
LogConstants.ActionName.USER_PASS_INFO,
null
);
return userPassService.getUserPassInfo(userId);
}
/**
* <h2>获取用户使用了的优惠券信息</h2>
* @param userId 用户 id
* @return {@link Response}
* */
@ResponseBody
@GetMapping("userusedpassinfo")
Response userUsedPassInfo(Long userId) throws Exception {
LogGenerator.genLog(
httpServletRequest,
userId, LogConstants.ActionName.USER_USED_PASS_INFO,
null
);
return userPassService.getUserUsedPassInfo(userId);
}
/**
* <h2>用户使用优惠券</h2>
* @param pass {@link Pass}
* @return {@link Response}
* */
@ResponseBody
@PostMapping("/userusepass")
Response userUsePass(@RequestBody Pass pass) {
LogGenerator.genLog(
httpServletRequest,
pass.getUserId(),
LogConstants.ActionName.USER_USE_PASS,
pass
);
return userPassService.userUsePass(pass);
}
/**
* <h2>获取库存信息</h2>
* @param userId 用户 id
* @return {@link Response}
* */
@ResponseBody
@GetMapping("/inventoryinfo")
Response inventoryInfo(Long userId) throws Exception {
LogGenerator.genLog(
httpServletRequest,
userId,
LogConstants.ActionName.INVENTORY_INFO,
null
);
return inventoryService.getInventoryInfo(userId);
}
/**
* <h2>用户领取优惠券</h2>
* @param request {@link GainPassTemplateRequest}
* @return {@link Response}
* */
@ResponseBody
@PostMapping("/gainpasstemplate")
Response gainPassTemplate(@RequestBody GainPassTemplateRequest request)
throws Exception {
LogGenerator.genLog(
httpServletRequest,
request.getUserId(),
LogConstants.ActionName.GAIN_PASS_TEMPLATE,
request
);
return gainPassTemplateService.gainPassTemplate(request);
}
/**
* <h2>用户创建评论</h2>
* @param feedback {@link Feedback}
* @return {@link Response}
* */
@ResponseBody
@PostMapping("/createfeedback")
Response createFeedback(@RequestBody Feedback feedback) {
LogGenerator.genLog(
httpServletRequest,
feedback.getUserId(),
LogConstants.ActionName.CREATE_FEEDBACK,
feedback
);
return feedbackService.createFeedback(feedback);
}
/**
* <h2>用户获取评论信息</h2>
* @param userId 用户 id
* @return {@link Response}
* */
@ResponseBody
@GetMapping("/getfeedback")
Response getFeedback(Long userId) {
LogGenerator.genLog(
httpServletRequest,
userId,
LogConstants.ActionName.GET_FEEDBACK,
null
);
return feedbackService.getFeedback(userId);
}
/**
* <h2>异常演示接口</h2>
* @return {@link Response}
* */
@ResponseBody
@GetMapping("/exception")
Response exception() throws Exception {
throw new Exception("Welcome To IMOOC");
}
}
** 创作不易 觉得有帮助请点赞关注收藏~~~**
版权归原作者 showswoller 所有, 如有侵权,请联系我们删除。