redis事件监听及在订单系统中的使用

https://blog.csdn.net/qq_37334135/article/details/77717248

通常在网上买好物品，或者说手机扫码后，点击付款，这时就会向后台发送请求，生成订单信息，以及够买商品的信息存入到数据库对应的表比如：订单表和商品销售表，或者还有物流信息表等。简单起见，就拿扫码购物来说，这里就不需要物流信息表了，只需要订单表，商品销售表，而且一次只能买一个商品，对应生成一个订单。
注：这里用到的是spring data +redis,也用到了spring data +jpa所以前提这两个都了解。
订单表字段有：订单id、创建时间、修改时间、付款方式、金额、支付状态、订单编号；
商品销售表字段有：id、创建时间、修改时间，支付状态，商品id（外键），订单id（外键），用户id（外键）；
有三个外键，那么肯定还有另外的商品表，用户表
商品表字段：id、创建时间、修改时间、商品名称、价格；
用户表：id、创建时间、修改时间、邮箱、用户名、密码、电话。
所以一个涉及4张表

流程大致是：用户点击付款，发送请求，后台接收到请求后，生成订单信息和商品销售信息，保存到数据库表中。同时把订单信息存入到redis中，key可以设为订单编号，同时设置过期时间。到了过期时间后，redis监听器监听到了过期的key，取出该key查询数据库订单表，如果发现支付状态不是成功（用户为付款，需要使订单失效），那么修改支付状态为失败（也就是用户下单后一直不付款，到了一定时间后，那么就应该让这个订单作废。如果用户付款了，在支付宝回调的接口里面会将支付状态修改为成功）。

创建spring boot项目，如果用的eclipse的话最好安装STS插件。

1、MySql、jpa、redis配置

server.port=8081

spring.datasource.url=jdbc:mysql://localhost:3306/logistic
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.driver-class-name=com.mysql.jdbc.Driver

spring.jpa.properties.hibernate.hbm2ddl.auto=update
spring.jpa.properties.hibernate.dialect=org.hibernate.dialect.MySQL5InnoDBDialect
spring.jpa.show-sql= true
spring.jpa.properties.hibernate.format_sql=true

spring.redis.host=192.168.25.128
spring.redis.pool.max-active=1000
spring.redis.pool.max-idle=100
spring.redis.pool.max-wait=-1
spring.redis.pool.min-idle=0
spring.redis.port=6379
spring.redis.timeout=0

2、创建好项目后编写4个实体类

@Entity
@Table(name="t_goods")
public class Goods {

    @Id
    @GeneratedValue
    private long id;
    private String name;
    private Integer price;

    @Column(name="create_time")
    @Temporal(TemporalType.TIMESTAMP)
    private Date createTime;
    @Column(name="modified_time")
    @Temporal(TemporalType.TIMESTAMP)
    private Date modifiedTime;
    get、set方法
}

@Entity
@Table(name = "t_user")
public class User {

    @Id
    @GeneratedValue(strategy=GenerationType.IDENTITY)
    private Long id;

    @Column(name="user_name")
    private String userName;

    private String password;

    private String telephone;

    private String email;

    @Column(name="create_time")
    @Temporal(TemporalType.DATE)
    private Date createTime;
    @Column(name="modified_time")
    @Temporal(TemporalType.TIMESTAMP)
    private Date modifiedTime;
    get、set方法   
}

@Entity
@Table(name="t_order")
public class Order {
    @Id
    @GeneratedValue(strategy=GenerationType.IDENTITY)
    private Long id;
    private Date createTime= new Date();
    private Date modifiedTime = new Date();
    //金额
    private Integer payment;
    //0：待支付 1：支付成功 2：支付失败
    private Integer status;
    //支付方式 0:支付宝 1:微信
    private Integer channel;
    //订单编号
    private String tradeNo;
    get、set方法
}

@Entity
@Table(name="t_goods_sells")
public class GoodsSell {

    @Id
    @GeneratedValue
    private long id;
    @ManyToOne
    private Goods goods;
    @OneToOne
    private Order order;
    @ManyToOne
    private User user;
    private int count;
    //0:待付款 1:已付款 2:未付款
    private int status;

    @Column(name="create_time")
    @Temporal(TemporalType.TIMESTAMP)
    private Date createTime;
    @Column(name="modified_time")
    @Temporal(TemporalType.TIMESTAMP)
    private Date modifiedTime;
    get、set方法
}

3、4个Repository接口（对应4个实体类）

@Repository
public interface GoodsRepository extends CrudRepository<Goods, Long>{
}

@Repository
public interface UserRepository extends CrudRepository<User, Long>{
}

@Repository
public interface PayOrderRepository extends JpaRepository<Order, Long>{

    //根据订单编号查询订单信息
    @Query(value="SELECT o FROM Order o WHERE o.tradeNo=?1")
    Order findOrderByTradeNo(String tradeNo);

    //根据订单id修改订单状态
    @Modifying
    @Query("UPDATE Order o SET o.status=?1 WHERE o.id=?2")
    int setStatusByOrderId(int status, long orderId);
}

@Repository
public interface GoodsSellsRepository extends CrudRepository<GoodsSell, Long>{
    //根据商品id修改商品销售状态
    @Modifying
    @Query("UPDATE GoodsSell o SET o.status=?1 WHERE o.id=?2")
    int setStatusByGoodsId(int status, long goodsId);

    //根据订单id查询商品销售信息
    @Query(value="SELECT * FROM t_goods_sells t WHERE t.order_id=?1",nativeQuery=true)
    GoodsSell findOrderByOrderId(long orderId);
}

4、订单Redis接口和实现类

public interface OrderRedisService {

    public void saveOrder(String outTradeNo,OrderRedisDo redisDo);
    public String getOrder(String outTradeNo);
    public void deleteOrder(String outTradeNo);

}

@Service
public class OrderRedisServiceImpl implements OrderRedisService{

    @Autowired
    private StringRedisTemplate redisTemplate;

    /*
     * 保存订单
     */
    public void saveOrder(String outTradeNo, OrderRedisDo redisDo) {
        String key = "order:"+outTradeNo;
        //key过期时间为120秒
        redisTemplate.opsForValue().set(key, JsonUtils.objectToJson(redisDo), 120, TimeUnit.SECONDS);
    }

    /*
     * 获取订单
     */
    public String getOrder(String outTradeNo) {
        String key = "order:"+outTradeNo;
        String message = redisTemplate.opsForValue().get(key);
        return message;
    }

    /*
     * 删除订单
     */
    public void deleteOrder(String outTradeNo) {
        String key = "order:"+outTradeNo;
        redisTemplate.delete(key);
    }
}

工具类JSONUtils如下：

public class JsonUtils {

    // 定义jackson对象
    private static final ObjectMapper MAPPER = new ObjectMapper();

    /**
     * 将对象转换成json字符串。
     */
    public static String objectToJson(Object data) {
        try {
            String string = MAPPER.writeValueAsString(data);
            return string;
        } catch (JsonProcessingException e) {
            e.printStackTrace();
        }
        return null;
    }

    /**
     * 将json结果集转化为对象
     */
    public static <T> T jsonToPojo(String jsonData, Class<T> beanType) {
        try {
            T t = MAPPER.readValue(jsonData, beanType);
            return t;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }

    /**
     * 将json数据转换成pojo对象list
     */
    public static <T>List<T> jsonToList(String jsonData, Class<T> beanType) {
        JavaType javaType = MAPPER.getTypeFactory().constructParametricType(List.class, beanType);
        try {
            List<T> list = MAPPER.readValue(jsonData, javaType);
            return list;
        } catch (Exception e) {
            e.printStackTrace();
        }

        return null;
    }

}

StringRedisTemplate redisTemplate:为spring data为我们提供的redis模板，能操作常用的5中redis数据类型，分别对应如下

redisTemplate.opsForValue();
redisTemplate.opsForHash();
redisTemplate.opsForList();
redisTemplate.opsForSet();
redisTemplate.opsForZSet();

基本都提供了增删改查的方法，会使用jedis操作redis那么这个redisTemplate使用也不会是问题。

 5、redis过期监听器

@Service(value=OrderRedisListener.SERVICE_NAME)
public class OrderRedisListener implements MessageListener{

    public static final String SERVICE_NAME="com.scu.listener.OrderRedisListener";

    @Autowired
    private PayOrderRepository payOrderRepository;
    @Autowired
    private GoodsSellsRepository goodsSellsRepository;

    private static Log log = LogFactory.getLog(OrderRedisListener.class);
    @Override
    @Transactional 
    public void onMessage(Message message, byte[] pattern) {
        //获取过期的key
        String expireKey = new String(message.getBody());
        System.out.println("终于失效了");
        log.debug("key is:"+ expireKey);
        System.out.println(expireKey);
        //截取订单号
        String tradeNo = expireKey.substring(expireKey.indexOf(":")+1);
        Order order = payOrderRepository.findOrderByTradeNo(tradeNo);
        if(order!=null && order.getStatus()!=1){
            //修改订单支付状态为失败
            payOrderRepository.setStatusByOrderId(2, order.getId());
            GoodsSell goodsSell = goodsSellsRepository.findOrderByOrderId(order.getId());
//修改商品购买状态为失败           goodsSellsRepository.setStatusByGoodsId(2, goodsSell.getId());
        }
    }
}

6、配置监听容器

/**
 * redis监听容器
 * @author 12706
 */
@Configuration
public class RedisConfig {

    @Autowired
    @Qualifier(OrderRedisListener.SERVICE_NAME)
    private MessageListener messageListener;

    @Autowired
    private RedisTemplate redisTemplate;

    @Bean
    RedisMessageListenerContainer container(MessageListenerAdapter listenerAdapter) {

        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(redisTemplate.getConnectionFactory());
        container.addMessageListener(listenerAdapter, new PatternTopic("__keyevent@0__:expired"));
        return container;
    }
    @Bean
    MessageListenerAdapter listenerAdapter() {
        return new MessageListenerAdapter(messageListener);
    }
}

获取RedisMessageListenerContainer也可以写成

@Bean
    RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,
                                            MessageListenerAdapter listenerAdapter) {

        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        container.addMessageListener(listenerAdapter, new PatternTopic("__keyevent@0__:expired"));

        return container;
    }

因为连接工厂在spring容器中是已经存在的，如果是自己配置spring data与redis整合是需要自己配置连接工厂，但是spring boot已经帮我们配置好了，所以可以直接注入。

注意：监听器能监听到redis中过期的key是有个要求的，必须在redis配置文件redis.conf里面设置能够监听到key过期事件，配置如下：

参数说明如下：

可以测试一下，打开两个窗口，分别启动redis客户端连接，
命令： ./redis-cli

窗口1监听：

窗口2设置key及过期时间10秒

10秒后再看窗口1，监听到了过期的key

说明配置生效了。
如果用过ActiveMQ的话，会发现其实配置是很类似的，配置消费者的话会配置连接工厂，配置目的地，配置监听器，配置监听容器，两者都是用来监听消息的，主要是在onMessage方法里面进行逻辑处理。

7、Service层处理

public interface OrderService {
public String payOrder(PayOrderRequestVo requestVo);
}
1
2
3
@Service(value=OrderServiceImpl.SERVICE_NAME)
public class OrderServiceImpl implements OrderService{

public static final String SERVICE_NAME="com.scu.service.impl.OrderServiceImpl";

@Autowired
private PayOrderRepository payOrderRepository;

@Autowired
private GoodsRepository goodsRepository;

@Autowired
private UserRepository UserRepository;

@Autowired
private GoodsSellsRepository goodsSellsRepository;

@Autowired
private OrderRedisService orderRedisService;

/*
* 保存订单
*/
@Transactional
public String payOrder(PayOrderRequestVo requestVo){
//模拟生成订单号 （由支付宝或者微信生成）
String tradeNo = UUID.randomUUID().toString().replace("-", "");
//保存订单信息
Order order = new Order();
order.setCreateTime(new Date());
order.setModifiedTime(new Date());
order.setChannel(requestVo.getChannel());
order.setPayment(requestVo.getCount());
order.setTradeNo(tradeNo);
order.setStatus(0);
payOrderRepository.save(order);
//保存商品支付信息
GoodsSell goodsSell = new GoodsSell();
goodsSell.setCreateTime(new Date());
goodsSell.setModifiedTime(new Date());
goodsSell.setCount(requestVo.getCount());
goodsSell.setStatus(0);
goodsSell.setOrder(order);
//查询用户信息，关联商品销售
User user = UserRepository.findOne(requestVo.getUserId());
goodsSell.setUser(user);
//查询商品信息，关联商品销售
Goods goods = goodsRepository.findOne(requestVo.getGoodsId());
goodsSell.setGoods(goods);
goodsSellsRepository.save(goodsSell);
//信息存入redis的对象
OrderRedisDo orderRedisDo = new OrderRedisDo();
//复制部分属性
BeanUtils.copyProperties(order,orderRedisDo);
orderRedisDo.setGoodsId(requestVo.getGoodsId());
//保存信息
orderRedisService.saveOrder(tradeNo, orderRedisDo);
return tradeNo;
}
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
其中存入redis中的实OrderRedisDo类如下：

public class OrderRedisDo {

private Long id;//订单id
private Integer payment;//付款金额
private Integer channel;//支付方式
private Integer status;//支付状态
private Long goodsId;//商品id
private String tradeNo;//订单号
get、set方法
}
1
2
3
4
5
6
7
8
9
10
8、Controller

@RestController
public class OrderController {

@Autowired
private OrderService orderService;

@PostMapping("/order/pay")
public ResponseTemplate payOrder(@RequestBody PayOrderRequestVo requestVo){
String tradeNo = orderService.payOrder(requestVo);
return new ResponseTemplate(tradeNo);
}
}
1
2
3
4
5
6
7
8
9
10
11
12
@RestController注解相当于@Controller+@ResponseBody+..，返回的是个json。
ResponseTemplate是个返回信息模板

/**
* 返回信息模板
* @author 12706
*/
public class ResponseTemplate {

private int code;
private String message;
private List<String> errors;
private Object data;
public ResponseTemplate(Object data) {
super();
this.data = data;
}
public ResponseTemplate() {
super();
}
get、set方法
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
为了看的直观，目录结构还是截了下来

测试：启动项目（执行SpringDataJpaApplication的main方法）
数据库logistic会多出来4张表，手动分别添加一条记录到用户表和商品表中，用来测试。

假如id为1的用户（Tom）购买了id为1的商品（张飞牛肉），然后就会下单，但他一直没支付。那么两分钟后该订单就失效（支付状态为2，失败）。
使用postman模拟数据发送请求。

查看数据库表，订单表和商品销售表都产生了记录，且状态为0（待支付）。

过两分钟再去查看，发现订单失效（支付状态为2）

控制台输出：

sql语句

终于失效了
order:5a8378f66b4e473cba5f4014a813810e

sql语句