场景是面试时被问到，一次性请求100多万个前端请求，请问你如果进行后端处理。因为之前的电商也没有一次性这么大的业务量，所以只是前端nginx做了对应的负载均衡技术。所以回答的不是那么流畅。面试官的回答你可以用RabbitMQ做分流,削峰,异步处理，之前项目中没有用到这个技能，回来学习下做下总结：
日常业务开发中，开发人员都知道，RabbitMQ常用于并发，流量大的场景，因为RabbitMQ属于中间件需要维护，所以一般小项目几乎不会使用。而在大型并发环境下，大量的流量积压到接口中，使mysql或者oracle连接分配出现不够使用的情况，此时就可以使用RabbitMQ来解决。
RabbitMQ是由Rabbit公司研发和维护的，最终是在Pivotal
RabbitMQ严格的遵循AMQP协议，高级消息队列协议，帮助我们在进程之间异步消息。
RabbitMQ的用途和作用
- 异步处理
采用异步通知的方式，就比如我们在抢票的时候，点击提交，系统会返回一个提示正在努力抢票中，而实际是你的订单正在mq列队中排队处理，处理结果会后续异步通知结果。
- 削峰：当流量洪峰到达接口时，可以用现实中的举例，mq相当于一个独木桥，mysql就相当于河对岸，使大量的人从容有序的排队过河，而不会出现所有人全部淌水过河到河对岸，大大减少了数据库的压力。
- 解耦
- 生产消息的应用和消费消息的应用不是同一语言可以解耦
- 生产消息的应用 宕机 不会影响到消费者消费的消息
配置RabbitMQ
首先需要在SpringBoot 项目中添加RabbitMQ依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
配置 RabbitMQ连接
package cn.juwatech.config; import org.springframework.amqp.core.Queue; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @Configuration public class RabbitMQConfig { @Bean public Queue messageQueue() { return new Queue("messageQueue", true); } }
消息生产者
package cn.juwatech.service; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @Service public class MessageProducer { @Autowired private RabbitTemplate rabbitTemplate; public void sendMessage(String message) { rabbitTemplate.convertAndSend("messageQueue", message); } }
消息消费者
package cn.juwatech.service; import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.stereotype.Service; @Service public class MessageConsumer { @RabbitListener(queues = "messageQueue") public void receiveMessage(String message) { System.out.println("消费消息: " + message); // 模拟消息处理耗时操作 try { Thread.sleep(1000); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } } }
发送消息
package cn.juwatech; import cn.juwatech.service.MessageProducer; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.CommandLineRunner; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; @SpringBootApplication public class Application implements CommandLineRunner { @Autowired private MessageProducer messageProducer; public static void main(String[] args) { SpringApplication.run(Application.class, args); } @Override public void run(String... args) throws Exception { for (int i = 0; i < 100; i++) { messageProducer.sendMessage("消息ID: " + i); } } }
