springboot与mq（3）

package com.aynu.controller;

import com.aynu.beans.Car;
import com.aynu.service.ICarService;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;

@Controller
@RequestMapping("/car")
@SuppressWarnings("all")
public  class CarController {

    @Autowired
    private ICarService carService;
    @Autowired
    RabbitTemplate rabbitTemplate;

    private final static String Exchange_NAME ="hello";
    String routingKey ="goods.delete";
    private final static String QUEUE_NAME ="hello1";

    List<Car> list = new ArrayList<Car>();
    // 定时任务
    @Scheduled(cron = "0/20 * * * * *")
    @RequestMapping("/task")
    public void  task() throws IOException, TimeoutException {
        Car car = new Car();
        car.setCar_plate("豫B123");
        car.setSpeed(80);
        Car car1 = new Car();
        car1.setCar_plate("豫B223");
        car1.setSpeed(120);
        list.add(car);
        list.add(car1);
        int flag = 0;
        for (Car Acar:list){
            flag = (int) carService.judgeException(Acar);
            if(flag == 1){
//                carService.addException(Acar);
                System.out.println("开始发送");
                rabbitTemplate.convertAndSend(Exchange_NAME,routingKey,Acar);
                System.out.println("发送完毕");
            }
        }
    }

    @RabbitListener(queues = "hello1")
    public void receive(Car car) {
        System.out.println("接受消息："+car);
        list.add(car);
//        model.addAttribute("car",list);
//        return "/car/carException.jsp";
    }
    @RequestMapping("/receive")
    public String handle(Model model){
        model.addAttribute("car",list);
        return "/car/carException.jsp";
    }
}