<>背景

在系统的某个阶段,并发访问数(流量)会急剧膨胀,在瞬时时间内(1秒或数秒),达到一个临界点,许多系统往往在这个阶段奔溃而失去响应,比如商家促销活动进行秒杀,或618,双11等等。系统在其他时间业务压力往往不大。要怎么解决这种临界压力呢,那就要进行流量的削峰填谷了

<>什么是削峰填谷

百度百科的解析是

削峰填谷(Peak
cut)是调整用电负荷的一种措施。根据不同用户的用电规律,合理地、有计划地安排和组织各类用户的用电时间。以降低负荷高峰,填补负荷低谷。减小电网负荷峰谷差,使发电、用电趋于平衡

意思是错开用户用电时段,当然对我们系统直接这样干肯定不适合的,总不能说你明天再下单吧。

<>解决方案

那怎么样即让用户买到商品,又不致于大量请求直接兑到数据造成数据库奔溃。。需要系统进行如下改造

改造之前

改造之后

很明显,改造之后的系统架构加入了消息队列MQ,这里可以试ActiveMQ,RabbitMQ,RcoketMQ,
Kafka等任何一种,根据自己业务进行技术选型。这样充分发挥了消息中间件处理速度快特点解决并发问题。

<>示例

下面列举一个RabbmitMQ生产者和消费者代码

* 添加依赖 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>
spring-boot-starter-amqp</artifactId> <version>1.5.2.RELEASE</version> </
dependency>
* 生产者 package com.rabbitMQ.pro; import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection; import com.rabbitmq.client.Channel;
public classProducer { private final static String QUEUE_NAME = "hello2";//
队列名不能重复 之前已有就会失败 public static void main(String[] argv) throws java.io.
IOException{ /* 使用工厂类建立Connection和Channel,并且设置参数 */ ConnectionFactory factory =
new ConnectionFactory(); factory.setHost("192.168.10.111");// MQ的IP factory.
setPort(5672);// MQ端口 factory.setUsername("asdf");// MQ用户名 factory.setPassword
("123456");// MQ密码 Connection connection = factory.newConnection(); Channel
channel= connection.createChannel(); /* 创建消息队列,并且发送消息 */ channel.queueDeclare(
QUEUE_NAME, false, false, false, null); String message = "消息2"; channel.
basicPublish("", QUEUE_NAME, null, message.getBytes()); System.out.println(
"生产了个'" + message + "'"); /* 关闭连接 */ channel.close(); connection.close(); } }
* 消费者 package com.rabbitMQ.pro; import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection; import com.rabbitmq.client.Channel;
import com.rabbitmq.client.QueueingConsumer; public class Consumer { private
final static String QUEUE_NAME= "hello2"; public static void main(String[] argv)
throws java.io.IOException, java.lang.InterruptedException { /* 建立连接 */
ConnectionFactory factory= new ConnectionFactory(); factory.setHost(
"192.168.10.111");// MQ的IP factory.setPort(5672);// MQ端口 factory.setUsername(
"asdf");// MQ用户名 factory.setPassword("123456");// MQ密码 Connection connection =
factory.newConnection(); Channel channel = connection.createChannel(); /*
声明要连接的队列 */ channel.queueDeclare(QUEUE_NAME, false, false, false, null); System.
out.println("等待消息产生:"); /* 创建消费者对象,用于读取消息 */ QueueingConsumer consumer = new
QueueingConsumer(channel); channel.basicConsume(QUEUE_NAME, true, consumer); /*
读取队列,并且阻塞,即在读到消息之前在这里阻塞,直到等到消息,完成消息的阅读后,继续阻塞循环 */ while (true) {
QueueingConsumer.Delivery delivery = consumer.nextDelivery(); String message =
new String(delivery.getBody()); System.out.println("收到消息'" + message + "'"); } }
}
<>总结

为了解决系统峰值问题,就要进行削峰填谷,加入消息中间件,把时间拉长,解决瞬时压力问题。当然上面只是列举了RabbitMQ,
还有支持更大并发业务的RocketMQ及Kafka,大家可以举一反三

技术
©2019-2020 Toolsou All rights reserved,
增量发布包OPC Client 核心源码Object.values()的用法hive数据仓库中的建模方式,为什么选择这种建模方式?linux mysql 每天自动备份C#方法重载(overload)、重写(覆盖)(override)、隐藏(new)所译即所学的语言学习工具Duolingo获2000万美元投资,用户数达1250万中国疫情发展趋势分析预测(python实现)js中箭头函数的作用用python制作文字特效