RabbitMQ(工作队列)实现和原理步骤讲解，方式2

1. 引入AMQP的依赖

2. 创建配置文件，链接消息队列（port name MQ账号密码）

3. 创建配置类，声明队列

4. 使用消息生产者发送消息

5. 使用消息消费者接受消息

6. 引入AMQP的依赖

 		
            org.springframework.boot
            spring-boot-starter-amqp
        

2. 创建配置文件，链接消息队列（port name MQ账号密码）

server:
  port: 9002
spring:
  application:
    name: demo02
  rabbitmq:
    host: 120.55.58.250
    port: 5672
    password: guest
    username: guest
    listener:
      simple:
        prefetch: 1

3. 创建配置类，声明队列

@Configuration
public class WorkQueueConfig {
    public static String queueName="work.queue";
    @Bean
    public Queue workQueue(){
        return new Queue(queueName);
    }
}

4. 使用消息生产者发送消息

@RestController
public class TestController {
    @Autowired
    private RabbitTemplate rabbitTemplate;


    @RequestMapping("/sendMessage")
    public void sendMessage(){
        for (int i=1;i<=50;i++){
            rabbitTemplate.convertAndSend("work.queue","工作队列模式"+i);
        }
    }
}

5. 使用消息消费者接受消息

@Component
public class ReceiveListener {
    @RabbitListener(queues="work.queue")
    public void ReceiveMessage01(String message){
//        System.out.println("ReceiveMessage01"+message);
        System.out.println("ReceiveMessage01"+message);
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    @RabbitListener(queues="work.queue")
    public void ReceiveMessage02(String message){
        System.out.println("ReceiveMessage02"+message);
    }
}

1## 测试地址 http://http://localhost:9002/sendMessage