经过昨天的简单的营业，本人准备扩大规模
定个小目标，比如先卖它一个亿...
那么再扩大规模之前，我们会遇到一些问题：
如何保证每个来了的顾客都能拿到面包呢？
我怎么保证他拿到面包并且给我钱了？
（像我这么抠的人是绝对不可能容忍跑单的）
如果来了多个顾客，正好第一个顾客还是个土豪，一口气说要二百个，但是第二个也在等，是不是我先要保证第一个不走，第二个也不走呢？还得考虑到第一个顾客应该要拿多点（不然他应该会不爽，毕竟人家先来嘛）
...
很多问题，我们先一个个解决。
第一个问题，就从保证我的店小二在搬面包的时候不坑我吧！
我们先保证面包能确认到了面包店！
首先我们需要改造一下面包店的配置，先给开个窗口，用来确认面包到了面包店
#开启服务端（面包店）确认面包已经送出去了，这里有两种确认方式，先说returns
publisher-returns: true
publisher-confirms: true
窗口有了，就得考虑营业员确认的事情了。咋确认呢？
是等他放在窗口了就确认？（如果他不认识店内的路，那就只能在这里确认了。别问我为啥会找不到路，我店大！1.2w平）可是我们这这么多么窗口，他要是弄丢了是不是得要扣工资？(我是不是很合情合理？)那我是不是要知道他没有丢？
还是等到营业员拿到花里胡哨的展示柜里了才算确认？
所以我们分两种情况：
- 放在窗口就算吧（不进入queue只是到了Exchange，也就是窗口），但是我怕他放错了店，所以我得知道他有没有放对窗子，所以我们来一个；
//这里就是上面配置文件中的confirms了，只保证面包到了窗口，可是没有真正的进入到我花重金买的花里胡哨展示柜里面
//这里是昨天开业时的装修，（配置类）我们需要让这个窗子用起来
public class AppConfig implements RabbitTemplate.ReturnCallback{
//这里会要实现一个returnedMessage方法
@Override
public void returnedMessage(Message message, int i, String s, String s1, String s2) {
System.out.println("面包到达了窗口（可惜不是我家的，所以可以扣工资了）");
}
//然后在这里把自己注册到Rabbit里面（也就是跟营业员打好招呼，告诉他们没啥事了就去窗口拿）
@PostConstruct
public void init(){
template.setReturnCallback(this);
}
}
//然后需要让小二走丢一次，方便我们扣工资
@RestController
public class Producer {
@Autowired
RabbitTemplate template;
@GetMapping("/makeLover")
public String makeLover(){
for (int i = 0; i < 5; i++) {
String msg = "send msg = " + i;
//在这里加个0 方便小二走丢...
template.convertAndSend(AppConfig.EXCHANGE_NAME,AppConfig.ROUTING_KEY+"0",msg);
}
return "OK";
}
然后我们开始测试一下...
明天我们再解决顾客们的公平性~
image-20200324150321536.png
这可真是人开心呢~
但是他如果真的送到了窗口，我得知道营业员有没有拿到店里对不对...
因为我只能收到小二走丢了的消息，他要走对了我就没办法扣他工资了，那我是不是要另外找个扣钱的呢？
想来想去，我只能看看能不能扣营业员的了
那我们就试试
- 这次我们就保证面包到了窗口，但是由于营业员没有拿进去导致面包不见的情况...（我又有理由扣工资了呢）
//还是这个窗口，我们再搞搞保证有扣工资的理由
public class AppConfig implements RabbitTemplate.ReturnCallback,RabbitTemplate.ConfirmCallback{
//这里会要实现一个returnedMessage方法
@Override
public void returnedMessage(Message message, int i, String s, String s1, String s2) {
System.out.println("面包到达了窗口（可惜不是我家的，所以可以扣工资了）");
}
@Bean
public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
//同时我们需要把RabbitTemplate开启一个配置
// 必须设置为 true，不然当小二放在窗口之后，但是没有通知到营业员时，不会触发 ReturnCallback 回调
rabbitTemplate.setMandatory(true);
return rabbitTemplate;
}
//这里会告诉我有没有真的到我那个重金的展示柜
//同时，这里的消息会比小二的消息来得快
//也就是这个方法会比returnedMessage先调用
@Override
public void confirm(CorrelationData correlationData, boolean b, String s) {
if (b){
System.out.println("面包到达了花里胡哨的展示柜");
}else {
System.out.println("好嘛，面包丢了");
}
}
//然后在这里把自己注册到Rabbit里面（也就是跟营业员打好招呼，告诉他们没啥事了就去窗口拿）
@PostConstruct
public void init(){
template.setReturnCallback(this);
template.setConfirmCallback(this);
}
}
@RestController
public class Producer {
@Autowired
RabbitTemplate template;
@GetMapping("/makeLover")
public String makeLover(){
for (int i = 0; i < 5; i++) {
String msg = "send msg = " + i;
//让营业员找不到窗口...然后他就会把面包丢了 然后，你懂我意思吧？
template.convertAndSend(AppConfig.EXCHANGE_NAME+"0",AppConfig.ROUTING_KEY,msg);
}
return "OK";
}
}
然后我们尝试测试：
image-20200324151303805.png
我可真是开心呢
但是如果到了呢？我们再看看
@RestController
public class Producer {
@Autowired
RabbitTemplate template;
@GetMapping("/makeLover")
public String makeLover(){
for (int i = 0; i < 5; i++) {
String msg = "send msg = " + i;
template.convertAndSend(AppConfig.EXCHANGE_NAME,AppConfig.ROUTING_KEY,msg);
}
return "OK";
}
}
image-20200324151407262.png
这种稍微正常的操作就这样完成了。。保证了我面包的后勤工作...
然后我们就要考虑到消费者的给钱问题了
首先我们先来个确认，让顾客确认自己想要的面包到手了
listener:
simple:
# 这里开启消费方（买面包的人）确认面包已经到手了
acknowledge-mode: manual
然后：
@Component
@RabbitListener(queues = AppConfig.QUEUE_NAME)
public class Consumer {
@RabbitHandler
//这里的channel就是收银台了，我们从queue(花里胡哨的那个柜子)里面拿出来之后，要去Cahnnel确认是不是自己要的
//那个面包
public void getLover(String msg, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG)Long id){
try {
if (msg.contains("1")) {
//这里代表顾客收到了一个面包，false等于是他要一个个对比是不是自己要的，ture的话他就直接
//全部打包了
channel.basicAck(tag, false);
System.out.println(msg+"顾客确认");
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
image-20200324154557859.png
OK，这里顾客给到了我们消息说自己已经拿到了自己想要的面包了
那么如果不是的话：
// 代表消费者拒绝一条或者多条消息，第二个参数表示一次是否拒绝多条消息，第三个参数表示是否把当前消息重新入队
// channel.basicNack(deliveryTag, false, false);
// 代表消费者拒绝当前消息，第二个参数表示是否把当前消息重新入队
// channel.basicReject(deliveryTag,false);
这里本老板就不做测试了哈...
观众老爷自行测试~
然后又到了激动人心的时候了，既然顾客拿到了面包，他得给钱吧。
那我咋知道她有没有给钱呢？？？
RabiitMQ本身是不带这个功能的，如果要实现的话，需要使用到spring的@SendTo()注解
@RabbitListener(queues = AppConfig.QUEUE_NAME)
@SendTo()//这里写入需要的queue，会自动添加到队列
这种做法需要消费者开一个队列，也就是相当于开了一个专门的窗口，每次给钱之后，会直接添加到那个窗口
那我就知道收到了钱没有~
这个观众老爷们自己试试~
为啥我不测试？
朕乏了~
歇息了~
