java高并发场景RabbitMQ的使用

简介: java高并发场景RabbitMQ的使用

  场景是面试时被问到,一次性请求100多万个前端请求,请问你如果进行后端处理。因为之前的电商也没有一次性这么大的业务量,所以只是前端nginx做了对应的负载均衡技术。所以回答的不是那么流畅。面试官的回答你可以用RabbitMQ做分流,削峰,异步处理,之前项目中没有用到这个技能,回来学习下做下总结:


  日常业务开发中,开发人员都知道,RabbitMQ常用于并发,流量大的场景,因为RabbitMQ属于中间件需要维护,所以一般小项目几乎不会使用。而在大型并发环境下,大量的流量积压到接口中,使mysql或者oracle连接分配出现不够使用的情况,此时就可以使用RabbitMQ来解决。


    RabbitMQ是由Rabbit公司研发和维护的,最终是在Pivotal


    RabbitMQ严格的遵循AMQP协议,高级消息队列协议,帮助我们在进程之间异步消息。


RabbitMQ的用途和作用


  • 异步处理

采用异步通知的方式,就比如我们在抢票的时候,点击提交,系统会返回一个提示正在努力抢票中,而实际是你的订单正在mq列队中排队处理,处理结果会后续异步通知结果。


  • 削峰:当流量洪峰到达接口时,可以用现实中的举例,mq相当于一个独木桥,mysql就相当于河对岸,使大量的人从容有序的排队过河,而不会出现所有人全部淌水过河到河对岸,大大减少了数据库的压力。
  • 解耦
  1. 生产消息的应用和消费消息的应用不是同一语言可以解耦
  2. 生产消息的应用  宕机 不会影响到消费者消费的消息


配置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);
        }
    }
}

相关实践学习
消息队列RocketMQ版:基础消息收发功能体验
本实验场景介绍消息队列RocketMQ版的基础消息收发功能,涵盖实例创建、Topic、Group资源创建以及消息收发体验等基础功能模块。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
相关文章
|
18天前
|
存储 消息中间件 安全
JUC组件实战:实现RRPC(Java与硬件通过MQTT的同步通信)
【10月更文挑战第9天】本文介绍了如何利用JUC组件实现Java服务与硬件通过MQTT的同步通信(RRPC)。通过模拟MQTT通信流程,使用`LinkedBlockingQueue`作为消息队列,详细讲解了消息发送、接收及响应的同步处理机制,包括任务超时处理和内存泄漏的预防措施。文中还提供了具体的类设计和方法实现,帮助理解同步通信的内部工作原理。
JUC组件实战:实现RRPC(Java与硬件通过MQTT的同步通信)
|
8天前
|
缓存 监控 Java
Java 线程池在高并发场景下有哪些优势和潜在问题?
Java 线程池在高并发场景下有哪些优势和潜在问题?
|
11天前
|
Java 数据处理
|
14天前
|
NoSQL Java Redis
京东双十一高并发场景下的分布式锁性能优化
【10月更文挑战第20天】在电商领域,尤其是像京东双十一这样的大促活动,系统需要处理极高的并发请求。这些请求往往涉及库存的查询和更新,如果处理不当,很容易出现库存超卖、数据不一致等问题。
37 1
|
26天前
|
Java 数据处理 数据库
Java多线程的理解和应用场景
Java多线程的理解和应用场景
45 1
|
26天前
|
设计模式 缓存 Java
Java高并发处理机制
Java高并发处理机制
20 1
|
23天前
|
Java Linux 应用服务中间件
【编程进阶知识】高并发场景下Bio与Nio的比较及原理示意图
本文介绍了在Linux系统上使用Tomcat部署Java应用程序时,BIO(阻塞I/O)和NIO(非阻塞I/O)在网络编程中的实现和性能差异。BIO采用传统的线程模型,每个连接请求都会创建一个新线程进行处理,导致在高并发场景下存在严重的性能瓶颈,如阻塞等待和线程创建开销大等问题。而NIO则通过事件驱动机制,利用事件注册、事件轮询器和事件通知,实现了更高效的连接管理和数据传输,避免了阻塞和多级数据复制,显著提升了系统的并发处理能力。
35 0
|
5天前
|
消息中间件 存储 Kafka
MQ 消息队列核心原理,12 条最全面总结!
本文总结了消息队列的12个核心原理,涵盖消息顺序性、ACK机制、持久化及高可用性等内容。关注【mikechen的互联网架构】,10年+BAT架构经验倾囊相授。
|
11天前
|
消息中间件 JSON Java
开发者如何使用轻量消息队列MNS
【10月更文挑战第19天】开发者如何使用轻量消息队列MNS
38 2
|
9天前
|
消息中间件
解决方案 | 云消息队列RabbitMQ实践获奖名单公布!
云消息队列RabbitMQ实践获奖名单公布!