开始
service层
下面来实现业务逻辑
商户的服务的起点就是收到消息,
函数式的方法,不需要显示的实现的。
用这种匿名类和匿名方法实现就可以了。
首先把body反序列化成dto。应ObjectMapper
拿到dto后需要做业务校验。在数据库里面找一下,消费者要的这个产品是不是可用的。然后找下消费者要的商户是不是可用的,是否是营业的,如果是,那么就计算下价格。就把订单处理的结果返回给我们。
注入两个dao层。
首先查一下有没有这个商品
else的判断,确认订单的状态设置为false
调用
谁来调用delivertCallback方法呢?
写一个handleMessage方法。加上@Async因为它要用异步线程去执行。
抛出异常
做监听
注册上监听器后,程序休眠
队列的绑定关系做好了吗?谁监听这个队列,谁要做好这个队列的声明
先声明exchange
再声明队列
声明绑定关系
线程池
再做线程池,然后调用一下这个异步的方法。
新建线程池的config
内容直接复制上一个微服务的
rabbit的配置类,让方法启动起来。
直接复制过来。也是和上一个服务是一样的。
这样商户微服务就开发好了