高性能消息队列中间件MQ

news2024/11/20 7:13:23

毕业后工作半年，在自己的讲课中需要介绍消息队列，以前在大学也有经常接触message queen，但却还不够深入了解掌握，这次写个专门针对mq的文章理清头绪。

以下是学习mq的知识框架，我会不定时更新补充
在这里插入图片描述

RabbitMQ概念_MQ

消息队列

MQ全称Message Queue（消息队列），是在消息的传输过程中保
存消息的容器。多用于系统之间的异步通信
同步通信相当于两个人当面对话，你一言我一语。必须及时回复。
在这里插入图片描述

异步通信相当于通过第三方转述对话，可能有消息的延迟，但不需要二人时刻保持联系。
在这里插入图片描述

消息

两台计算机间传送的数据单位。消息可以非常简单，例如只包含文
本字符串；也可以更复杂，可能包含嵌入对象。

队列

数据结构中概念。在队列中，数据先进先出，后进后出。
在这里插入图片描述

RabbitMQ概念_MQ的优势

应用解耦

在电商平台中，用户下订单需要调用订单系统，此时订单系统还需
要调用库存系统、支付系统、物流系统完成业务。此时会产生两个
问题：

  1. 如果库存系统出现故障，会造成整个订单系统崩溃。
  2. 如果需求修改，新增了一个X系统，此时必须修改订单系统的代码。

在这里插入图片描述
如果在系统中引入MQ，即订单系统将消息先发送到MQ中，MQ再
转发到其他系统，则会解决以下问题：

  1. 由于订单系统只发消息给MQ，不直接对接其他系统，如果库存系统出现故障，不影响整个订单。
  2. 如果需求修改，新增了一个X系统，此时无需修改订单系统的代码，只需修改MQ将消息发送给X系统即可。
    在这里插入图片描述

异步提速

如果订单系统同步访问每个系统，则用户下单等待时长如下：
在这里插入图片描述
如果引入MQ，则用户下单等待时长如下：

在这里插入图片描述

削峰填谷

假设我们的系统每秒只能承载1000请求，如果请求瞬间增多到每秒
5000，则会造成系统崩溃。此时引入mq即可解决该问题
在这里插入图片描述
使用了MQ之后，限制消费消息的速度为1000，这样一来，高峰期
产生的数据势必会被积压在MQ中，高峰就被“削”掉了，但是因为消
息积压，在高峰期过后的一段时间内，消费消息的速度还是会维持
在1000，直到消费完积压的消息，这就叫做“填谷”。
在这里插入图片描述

RabbitMQ概念_MQ的劣势

在这里插入图片描述

系统可用性降低
系统引入的外部依赖越多，系统稳定性越差。一旦MQ宕机，就会对业务造成影响。

系统复杂度提高
MQ的加入大大增加了系统的复杂度，以前系统间是同步的远程调用，现在是通过MQ进行异步调用。

一致性问题
A系统处理完业务，通过MQ给B、C、D三个系统发消息数据，如果B系统、C系统处理成功，D系统处理失败，则会造成数据处理的不一致。

# RabbitMQ概念_MQ应用场景

抢红包、秒杀活动、抢火车票等

这些业务场景都是短时间内需要处理大量请求，如果直接连接系统处理业务，会耗费大量资源，有可能造成系统瘫痪
在这里插入图片描述
而使用MQ后，可以先让用户将请求发送到MQ中，MQ会先保存请求消息，不会占用系统资源，且MQ会进行消息排序，先请求的秒杀成功，后请求的秒杀失败。
在这里插入图片描述

消息分发

如电商网站要推送促销信息，该业务耗费时间较多，但对时效性要求不高，可以使用MQ做消息分发。
在这里插入图片描述

数据同步

假如我们需要将数据保存到数据库之外，还需要一段时间将数据同步到缓存（如Redis）、搜索引擎（如Elasticsearch）中。此时可以将数据库的数据作为消息发送到MQ中，并同步到缓存、搜索引擎中。
在这里插入图片描述

异步处理

在电商系统中，订单完成后，需要及时的通知子系统（进销存系统发货，用户服务积分，发送短信）进行下一步操作。为了保证订单系统的高性能，应该直接返回订单结果，之后让MQ通知子系统做其他非实时的业务操作。这样能保证核心业务的高效及时。
在这里插入图片描述

离线处理

在银行系统中，如果要查询近十年的历史账单，这是非常耗时的
操作。如果发送同步请求，则会花费大量时间等待响应。此时使
用MQ发送异步请求，等到查询出结果后获取结果即可。
在这里插入图片描述

RabbitMQ概念_AMQP

RabbitMQ是由Erlang语言编写的基于AMQP的MQ产品。

AMQP

即Advanced Message Queuing Protocol(高级消息队列协议)，是一个网络协议，专门为消息中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受不同中间件产品，不同开发语言等条件的限制。2006年AMQP规范发布，类比HTTP。

AMQP工作过程

生产者(Publisher)将消息发布到交换机(Exchange)，交换机根据规
则将消息分发给交换机绑定的队列(Queue)，队列再将消息投递给
订阅了此队列的消费者。
在这里插入图片描述

RabbitMQ概念_RabbitMQ工作原理

在这里插入图片描述

Producer
消息的生产者。也是一个向交换机发布消息的客户端应用程序。
Connection
连接。生产者/消费者和RabbitMQ服务器之间建立的TCP连接。
Channel
信道。是TCP里面的虚拟连接。例如：Connection相当于电缆，Channel相当于独立光纤束，一条TCP连接中可以创建多条信道，增加连接效率。无论是发布消息、接收消息、订阅队列都是通过信道完成的。
Broker
消息队列服务器实体。即RabbitMQ服务器
Virtual host
虚拟主机。出于多租户和安全因素设计的，把AMQP的基本组件
划分到一个虚拟的分组中。每个vhost本质上就是一个mini版的
RabbitMQ服务器，拥有自己的队列、交换机、绑定和权限机
制。当多个不同的用户使用同一个RabbitMQ服务器时，可以划
分出多个虚拟主机。RabbitMQ默认的虚拟主机路径是 /
Exchange
交换机。用来接收生产者发送的消息，并根据分发规则，将这些
消息分发给服务器中的队列中。不同的交换机有不同的分发规
则。
Queue
消息队列。用来保存消息直到发送给消费者。它是消息的容器，
也是消息的终点。消息一直在队列里面，等待消费者链接到这个
队列将其取走。
Binding
消息队列和交换机之间的虚拟连接，绑定中包含路由规则，绑定
信息保存到交换机的路由表中，作为消息的分发依据。
Consumer
消息的消费者。表示一个从消息队列中取得消息的客户端应用程
序。

RabbitMQ为什么使用信道而不直接使用TCP连接通信？
TCP连接的创建和销毁开销特别大。创建需要3次握手，销毁需
要4次分手。高峰时每秒成千上万条TCP连接的创建会造成资源
巨大的浪费。而且操作系统每秒处理TCP连接数也是有限制的，
会造成性能瓶颈。而如果一条线程使用一条信道，一条TCP链接
可以容纳无限的信道，即使每秒成千上万的请求也不会成为性
能的瓶颈。

RabbitMQ安装_安装Erlang

RabbitMQ安装_安装RabbitMQ

RabbitMQ安装_账户管理

RabbitMQ安装_管控台

RabbitMQ安装_Docker安装

我这里就不教了，大家自行百度哈
ps：大家如果实在不会，又比较需要学习怎么安装，那就多@我，留评论我再来补充（手动狗头），毕竟这篇文章是偏概念和理清mq是个啥的

RabbitMQ简单模式_概念

RabbitMQ共有六种工作模式：简单模式（Simple）、工作队列模式（Work Queue）、发布订阅模式（Publish/Subscribe）、路由模式（Routing）、通配符模式（Topics）、远程调用模式（RPC，不常用，课程不对此模式进行讲解)

首先我们讲解简单模式：
在这里插入图片描述
特点：

  1. 一个生产者对应一个消费者，通过队列进行消息传递。
  2. 该模式使用direct交换机，direct交换机是RabbitMQ默认交换机。

RabbitMQ简单模式_项目搭建

接下来我们使用JAVA代码操作RabbitMQ，让其按照简单模式进行
工作。

JMS

由于MQ产品很多，操作方式各有不同，于是JAVA提供了一套规则
——JMS，用于操作消息中间件。JMS即Java消息服务（JavaMessage Service）应用程序接口，是一个Java平台中关于面向消息中间件的API。JMS是JavaEE规范中的一种，类比JDBC。很多MQ产品都实现了JMS规范，例如ActiveMQ。RabbitMQ官方并没有实现JMS规范，但是开源社区有JMS的实现包

创建项目

1.启动RabbitMQ

# 开启管控台插件
rabbitmq-plugins enable
rabbitmq_management
# 启动rabbitmq
rabbitmq-server -detached

2.创建普通maven项目，添加RabbitMQ依赖：

<dependencies>
    <dependency>
        <groupId>com.rabbitmq</groupId>
        <artifactId>amqpclient</artifactId>
        <version>5.14.0</version>
    </dependency>
</dependencies>

RabbitMQ简单模式_编写生产者

接下来我们编写生产者代码创建消息：

// 生产者
public class Producer {
    public static void main(String[] args)
throws IOException, TimeoutException {
        // 1.创建连接工厂
        ConnectionFactory connectionFactory
= new ConnectionFactory();
connectionFactory.setHost("192.168.0.162");
7        connectionFactory.setPort(5672);
8      
connectionFactory.setUsername("itbaizhan");
9      
connectionFactory.setPassword("itbaizhan");
10      
connectionFactory.setVirtualHost("/");
11        // 2.创建连接
12        Connection connection =
connectionFactory.newConnection();
13        // 3.建立信道
14        Channel channel =
connection.createChannel();
15        // 4.创建队列，如果队列已存在，则使用该队列
16        /**
17         * 参数1：队列名
18         * 参数2：是否持久化，true表示MQ重启后队列
还在。
19         * 参数3：是否私有化，false表示所有消费者
都可以访问，true表示只有第一次拥有它的消费者才能访问
20         * 参数4：是否自动删除，true表示不再使用队
列时自动删除队列
21         * 参数5：其他额外参数
22         */
23      
channel.queueDeclare("simple_queue",false,f
alse,false,null);
24        // 5.发送消息
25        String message = "hello!rabbitmq!";
26        /**
27         * 参数1：交换机名，""表示默认交换机
28         * 参数2：路由键，简单模式就是队列名
29         * 参数3：其他额外参数
30         * 参数4：要传递的消息字节数组
31         */
32      
channel.basicPublish("","simple_queue",null
,message.getBytes());
33        // 6.关闭信道和连接
34        channel.close();
35        connection.close();
36        System.out.println("===发送成功===");
37   }
38 }

运行生产者后，我们可以看到在RabbitMQ中创建了队列，队列中
已经有了消息。

在这里插入图片描述

RabbitMQ简单模式_编写消费者

接下来我们编写消费者代码消费消息：

// 消费者
public class Consumer {
    public static void main(String[] args)
throws IOException, TimeoutException {
        // 1.创建连接工厂
        ConnectionFactory connectionFactory
= new ConnectionFactory();
      
connectionFactory.setHost("192.168.0.162");
        connectionFactory.setPort(5672);
      
connectionFactory.setUsername("itbaizhan");
9      
connectionFactory.setPassword("itbaizhan");
10      
connectionFactory.setVirtualHost("/");
11        // 2.创建连接
12        Connection connection =
connectionFactory.newConnection();
13        // 3.建立信道
14        Channel channel =
connection.createChannel();
15        // 4.监听队列
16        /**
17         * 参数1：监听的队列名
18         * 参数2：是否自动签收，如果设置为false，
则需要手动确认消息已收到，否则MQ会一直发送消息
19         * 参数3：Consumer的实现类，重写该类方法
表示接受到消息后如何消费
20         */
21      
channel.basicConsume("simple_queue",true,ne
w DefaultConsumer(channel){
22            @Override
23            public void
handleDelivery(String consumerTag, Envelope
envelope, AMQP.BasicProperties properties,
byte[] body) throws IOException {
24                String message = new
String(body, "UTF-8");
25                System.out.println("接受消息，
消息为："+message);
26           }
27       });
		}
	}

运行消费者后，我们可以看到在RabbitMQ中的消息已经被消费。
在这里插入图片描述

RabbitMQ工作队列模式_概念

在这里插入图片描述
与简单模式相比，工作队列模式(Work Queue)多了一些消费者，该模式也使用direct交换机，应用于处理消息较多的情况。特点如下

  1. 一个队列对应多个消费者.
  2. 一条消息只会被一个消费者消费。
  3. 消息队列默认采用轮询的方式将消息平均发送给消费者。

RabbitMQ工作队列模式_编写生产者

接下来我们编写生产者代码创建大量消息：

public class Producer {
    public static void main(String[] args)
throws IOException, TimeoutException {
        // 1.创建连接工厂
        ConnectionFactory connectionFactory
= new ConnectionFactory();
      
connectionFactory.setHost("192.168.0.162");
        connectionFactory.setPort(5672);
      
connectionFactory.setUsername("itbaizhan");
      
connectionFactory.setPassword("itbaizhan");
      
connectionFactory.setVirtualHost("/");
        // 2.创建连接
                Connection connection =
connectionFactory.newConnection();
        // 3.建立信道
        Channel channel =
connection.createChannel();
        // 4.创建队列，持久化队列
      
channel.queueDeclare("work_queue",true,fals
e,false,null);
        // 5.发送大量消息，参数3表示该消息为持久化
消息，即除了保存到内存还会保存到磁盘中
        for (int i = 1; i <= 100; i++) {
          
channel.basicPublish("","work_queue",
MessageProperties.PERSISTENT_TEXT_PLAIN,
                   ("你好，这是今天的第"+i+"条
消息").getBytes());
       }
        // 6.关闭资源
        channel.close();
        connection.close();
   }
}

效果如下：
在这里插入图片描述

RabbitMQ工作队列模式_编写消费者

接下来我们编写三个消费者监听同一个队列：

// 消费者1
public class Consumer1 {
    public static void main(String[] args)
throws IOException, TimeoutException {
        // 1.创建连接工厂
        ConnectionFactory connectionFactory
= new ConnectionFactory();
6      
connectionFactory.setHost("192.168.0.162");
7        connectionFactory.setPort(5672);
8      
connectionFactory.setUsername("itbaizhan");
9      
connectionFactory.setPassword("itbaizhan");
10      
connectionFactory.setVirtualHost("/");
11        // 2.创建连接
12        Connection connection =
connectionFactory.newConnection();
13        // 3.建立信道
14        Channel channel =
connection.createChannel();
15        // 4.监听队列，处理消息
16      
channel.basicConsume("work_queue",true,new
DefaultConsumer(channel){
17            @Override
18            public void
handleDelivery(String consumerTag, Envelope
envelope, AMQP.BasicProperties properties,
byte[] body) throws IOException {
19                String message = new
String(body, "UTF-8");
20                System.out.println("消费者1消
费消息，消息为："+message);
21           }
22       });
   }
24 }
25
26 // 消费者2
27 public class Consumer2 {
28    public static void main(String[] args)
throws IOException, TimeoutException {
29        // 1.创建连接工厂
30        ConnectionFactory connectionFactory
= new ConnectionFactory();
31      
connectionFactory.setHost("192.168.0.162");
32        connectionFactory.setPort(5672);
33      
connectionFactory.setUsername("itbaizhan");
34      
connectionFactory.setPassword("itbaizhan");
35      
connectionFactory.setVirtualHost("/");
36        // 2.创建连接
37        Connection connection =
connectionFactory.newConnection();
38        // 3.建立信道
39        Channel channel =
connection.createChannel();
40        // 4.监听队列，处理消息
41      
channel.basicConsume("work_queue",true,new
DefaultConsumer(channel){
42            @Override
43            public void
handleDelivery(String consumerTag, Envelope
envelope, AMQP.BasicProperties properties,
byte[] body) throws IOException {
44                String message = new
String(body, "UTF-8");
45                System.out.println("消费者2消
费消息，消息为："+message);
46           }
47       });
48   }
49 }
50
51 // 消费者3
52 public class Consumer3 {
53    public static void main(String[] args)
throws IOException, TimeoutException {
54        // 1.创建连接工厂
55        ConnectionFactory connectionFactory
= new ConnectionFactory();
56      
connectionFactory.setHost("192.168.0.162");
57        connectionFactory.setPort(5672);
58      
connectionFactory.setUsername("itbaizhan");
59      
connectionFactory.setPassword("itbaizhan");
60      
connectionFactory.setVirtualHost("/");
61        // 2.创建连接
62        Connection connection =
connectionFactory.newConnection();
63        // 3.建立信道
64        Channel channel =
connection.createChannel();
65        // 4.监听队列，处理消息
66      
channel.basicConsume("work_queue",true,new
DefaultConsumer(channel){
67            @Override
68            public void
handleDelivery(String consumerTag, Envelope
envelope, AMQP.BasicProperties properties,
byte[] body) throws IOException {
69                String message = new
String(body, "UTF-8");
70                System.out.println("消费者3消
费消息，消息为："+message);
71           }
72       });
73   }
74 }

效果如下：
在这里插入图片描述

RabbitMQ发布订阅模式_概念

在这里插入图片描述
在开发过程中，有一些消息需要不同消费者进行不同的处理，如电商网站的同一条促销信息需要短信发送、邮件发送、站内信发送等。此时可以使用发布订阅模式(Publish/Subscribe)

特点

  1. 生产者将消息发送给交换机，交换机将消息转发到绑定此交换机的每个队列中。
  2. 工作队列模式的交换机只能将消息发送给一个队列，发布订阅模式的交换机能将消息发送给多个队列。发布订阅模式使用fanout交换机。

RabbitMQ发布订阅模式_编写生产者

接下来我们编写发布订阅模式的生产者：

// 生产者
public class Producer {
    public static void main(String[] args)
throws IOException, TimeoutException {
4        // 1.创建连接工厂
5        ConnectionFactory connectionFactory
= new ConnectionFactory();
6      
connectionFactory.setHost("192.168.0.162");
7        connectionFactory.setPort(5672);
8      
connectionFactory.setUsername("itbaizhan");
9      
connectionFactory.setPassword("itbaizhan");
10      
connectionFactory.setVirtualHost("/");
11        // 2.创建连接
12        Connection connection =
connectionFactory.newConnection();
13        // 3.建立信道
14        Channel channel =
connection.createChannel();
15        // 4.创建交换机
16        /**
17         * 参数1：交换机名
18         * 参数2：交换机类型
19         * 参数3：交换机持久化
20         */
21      
channel.exchangeDeclare("exchange_fanout",
BuiltinExchangeType.FANOUT,true);
22        // 5.创建队列
23      
channel.queueDeclare("SEND_MAIL",true,false
,false,null);
24      
channel.queueDeclare("SEND_MESSAGE",true,fa
lse,false,null);
25      
channel.queueDeclare("SEND_STATION",true,fa
lse,false,null);
26        // 6.交换机绑定队列
27        /**
28         * 参数1：队列名
29         * 参数2：交换机名
30         * 参数3：路由关键字，发布订阅模式写""即可
31         */
32      
channel.queueBind("SEND_MAIL","exchange_fan
out","");
33      
channel.queueBind("SEND_MESSAGE","exchange_
fanout","");
34      
channel.queueBind("SEND_STATION","exchange_
fanout","");
35        // 7.发送消息
36        for (int i = 1; i <= 10 ; i++) {
37          
channel.basicPublish("exchange_fanout","",n
ull,
38                   ("你好，尊敬的用户，秒杀商品
开抢
了！"+i).getBytes(StandardCharsets.UTF_8));
39       }
40        // 8.关闭资源
41        channel.close();
        connection.close();
   }
}
42

效果如下
在这里插入图片描述

RabbitMQ发布订阅模式_编写消费者

接下来编写三个消费者，分别监听各自的队列

// 站内信消费者
public class CustomerStation {
    public static void main(String[] args)
throws IOException, TimeoutException {
4        // 1.创建连接工厂
5        ConnectionFactory connectionFactory
= new ConnectionFactory();
6      
connectionFactory.setHost("192.168.0.162");
7        connectionFactory.setPort(5672);
8      
connectionFactory.setUsername("itbaizhan");
9      
connectionFactory.setPassword("itbaizhan");
10      
connectionFactory.setVirtualHost("/");// 默
认虚拟机
11        //2.创建连接
12        Connection conn =
connectionFactory.newConnection();
13        //3.建立信道
14        Channel channel =
conn.createChannel();
15        // 4.监听队列
16        channel.basicConsume("SEND_STATION",
true, new DefaultConsumer(channel) {
17            @Override
18            public void
handleDelivery(String consumerTag, Envelope
envelope, AMQP.BasicProperties properties,
byte[] body) throws IOException {
19                String message = new
String(body, "utf-8");
                System.out.println("发送站内
信："+message);
21           }
22       });
23   }
24 }
25
26 // 邮件消费者
27 public class Customer_Mail {
28    public static void main(String[] args)
throws IOException, TimeoutException {
29        // 1.创建连接工厂
30        ConnectionFactory connectionFactory
= new ConnectionFactory();
31      
connectionFactory.setHost("192.168.0.162");
32        connectionFactory.setPort(5672);
33      
connectionFactory.setUsername("itbaizhan");
34      
connectionFactory.setPassword("itbaizhan");
35      
connectionFactory.setVirtualHost("/");// 默
认虚拟机
36        //2.创建连接
37        Connection conn =
connectionFactory.newConnection();
38        //3.建立信道
39        Channel channel =
conn.createChannel();
40        // 4.监听队列
        channel.basicConsume("SEND_MAIL",
true, new DefaultConsumer(channel) {
42            @Override
43            public void
handleDelivery(String consumerTag, Envelope
envelope, AMQP.BasicProperties properties,
byte[] body) throws IOException {
44                String message = new
String(body, "utf-8");
45                System.out.println("发送邮
件："+message);
46           }
47       });
48   }
49 }
50
51 // 短信消费者
52 public class Customer_Message {
53    public static void main(String[] args)
throws IOException, TimeoutException {
54        // 1.创建连接工厂
55        ConnectionFactory connectionFactory
= new ConnectionFactory();
56      
connectionFactory.setHost("192.168.0.162");
57        connectionFactory.setPort(5672);
58      
connectionFactory.setUsername("itbaizhan");
59      
connectionFactory.setPassword("itbaizhan");
60      
connectionFactory.setVirtualHost("/");// 默
认虚拟机
61        //2.创建连接
62        Connection conn =
connectionFactory.newConnection();
63        //3.建立信道
64        Channel channel =
conn.createChannel();
65        // 4.监听队列
66        channel.basicConsume("SEND_MESSAGE",
true, new DefaultConsumer(channel) {
67            @Override
68            public void
handleDelivery(String consumerTag, Envelope
envelope, AMQP.BasicProperties properties,
byte[] body) throws IOException {
69                String message = newString(body, "utf-8");
70                System.out.println("发送短信："+message);
71           }
72       });
73   }
74 }

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/191368.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

TwinCAT3串口通讯EL6021模块使用-和串口调试助手自由协议通讯

TwinCAT3串口通讯EL6021模块使用-和串口调试助手自由协议通讯

目录 一、简介 二、环境介绍 三、接线连接 四、创建TwinCAT3程序工程 1、IO扫描和参数设置 2、创建PLC程序 &#xff08;1&#xff09;库文件添加 &#xff08;2&#xff09;创建任务和程序 &#xff08;3&#xff09;变量关联 &#xff08;4&#xff09;重新激活工程、运…
阅读更多...
adb的一些基本操作

adb的一些基本操作

adb的一些基本操作 Android使用的系统一般是debian系列操作系统&#xff0c;所以使用adb shell连接到手机后&#xff0c;可以使用大部分Debian系列的命令进行相关的操作 列出所有应用&#xff1a;adb shell pm list packages 列出第三方(系统)应用&#xff1a;adb shell pm li…
阅读更多...
1611_PC汇编语言_math例程分析

1611_PC汇编语言_math例程分析

全部学习汇总&#xff1a; GreyZhang/g_unix: some basic learning about unix operating system. (github.com) 这一次分析后带有注释的代码我会在笔记最后做一个完整的附加。 这一个例程&#xff0c;主要是为了阐述前面讲到的数学运算。但是从这些操作中&#xff0c;很多底层…
阅读更多...
介绍golang限流库以及漏桶与令牌桶的实现原理

介绍golang限流库以及漏桶与令牌桶的实现原理

RateLimit 限流中间件 前言 为什么需要限流中间件&#xff1f; 在大数据量高并发访问时&#xff0c;经常会出现服务或接口面对大量的请求而导致数据库崩溃的情况&#xff0c;甚至引发连锁反映导致整个系统崩溃。或者有人恶意攻击网站&#xff0c;大量的无用请求出现会导致缓…
阅读更多...
Spark JDBC采用分区读取数据库时partitionColumn, lowerBound, upperBound, numPartitions参数理解

Spark JDBC采用分区读取数据库时partitionColumn, lowerBound, upperBound, numPartitions参数理解

partitionColumn是应该用于确定分区的列。 lowerBound并upperBound确定要获取的值的范围。完整数据集将使用与以下查询对应的行&#xff1a; SELECT * FROM table WHERE partitionColumn BETWEEN lowerBound AND upperBound numPartitions确定要创建的分区数。lowerBound和之间…
阅读更多...
Unicode 和 UTF-8 详解

Unicode 和 UTF-8 详解

结论 Unicode 是 字符集 UTF-8 是 编码规则 字符集&#xff1a;为每一个字符分配唯一的ID&#xff08;如 SCII 码&#xff09; 编码规则&#xff1a;将 码位转换为字节序列的规则 背景 老规矩&#xff0c;我们用图文并茂的方式来讲解&#xff1a; ASCII 这个字符集 由于仅能…
阅读更多...
[Android Studio] Android Studio设置杂项

[Android Studio] Android Studio设置杂项

&#x1f7e7;&#x1f7e8;&#x1f7e9;&#x1f7e6;&#x1f7ea; Android Debug&#x1f7e7;&#x1f7e8;&#x1f7e9;&#x1f7e6;&#x1f7ea; Topic 发布安卓学习过程中遇到问题解决过程&#xff0c;希望我的解决方案可以对小伙伴们有帮助。 &#x1f4cb;笔记目…
阅读更多...
【HBase高级】3. HBase批量装载——Bulk load（1）Bulk load简介与案例介绍

【HBase高级】3. HBase批量装载——Bulk load（1）Bulk load简介与案例介绍

2. HBase批量装载——Bulk load 2.1 简介 很多时候&#xff0c;我们需要将外部的数据导入到HBase集群中&#xff0c;例如&#xff1a;将一些历史的数据导入到HBase做备份。我们之前已经学习了HBase的Java API&#xff0c;通过put方式可以将数据写入到HBase中&#xff0c;我们…
阅读更多...
MyBatis（三）使用MyBatis完成CRUD（增删改查）

MyBatis（三）使用MyBatis完成CRUD（增删改查）

准备工作 1、创建module&#xff08;Maven的普通Java模块&#xff09;&#xff1a;mybatis-002-crud 2、pom.xml 打包方式jar依赖&#xff1a;mybatis依赖mysql驱动依赖junit依赖logback依赖3、mybatis-config.xml放在类的根路径下 4、CarMapper.xml放在类的根路径下 5、lo…
阅读更多...
redis的完整学习

redis的完整学习

Redis 1.Nosql 单机mysql缓存机制分库分表水平拆分mysql集群&#xff1a;本质上是数据库的读写 MyISAM:表锁&#xff0c;效率低Innodb&#xff1a;行锁 特点 解耦&#xff01; 1.方便扩展 2.大数据量高性能 3.数据类型是多样型的&#xff08;不需要设计数据库&#xff…
阅读更多...
c语言 预处理

c语言 预处理

int main() {//printf("%s\n", __FILE__);//打印所在文件夹位置//printf("%d\n", __LINE__);//打印当前所在行号//printf("%s\n", __DATE__);//打印当前系统日期//printf("%s\n", __TIME__);//时间//printf("%s\n", __FUNCT…
阅读更多...
分享155个ASP源码，总有一款适合您

分享155个ASP源码，总有一款适合您

ASP源码 分享155个ASP源码&#xff0c;总有一款适合您 下面是文件的名字&#xff0c;我放了一些图片&#xff0c;文章里不是所有的图主要是放不下...&#xff0c; 154个ASP源码下载链接&#xff1a;https://pan.baidu.com/s/12oYeESSXJCd32n463LBt4w?pwd5i1n 提取码&#x…
阅读更多...
Java线程池中的execute和submit

Java线程池中的execute和submit

一、概述 execute和submit都是线程池中执行任务的方法。 execute是Executor接口中的方法 public interface Executor {void execute(Runnable command); }submit是ExecuteService接口中的方法。 public interface ExecutorService extends Executor {<T> Future<T…
阅读更多...
vue+element模仿腾讯视频电影网站（二），增加视频播放详情页

vue+element模仿腾讯视频电影网站（二），增加视频播放详情页

一.前言 1. 本项目在线预览&#xff1a;点击访问 2. 作者其他博客成品汇总预览&#xff1a;点击访问 3. 接上一篇&#xff1a;《vueelement模仿腾讯视频电影网站》 暂时源码并没有提供其他获取渠道&#xff0c;私聊作者获取即可&#xff0c;或通过博客后面名片添加作者&#…
阅读更多...
【SSM】Mybatis小技巧汇总

【SSM】Mybatis小技巧汇总

Mybatis技巧一&#xff1a;#{} 和 ${} 的区别使用 ${} 特例一&#xff08;排序&#xff09;使用 ${} 特例二&#xff08;表连接&#xff09;使用 ${} 特例三&#xff08;批量删除&#xff09;技巧二&#xff1a;typeAliases 别名机制别名 Alias 性质技巧三&#xff1a;mappersm…
阅读更多...
串级PID控制原理-1

串级PID控制原理-1

串级计算机控制系统的典型结构如图1所示&#xff0c;系统中有两个PID控制器&#xff0c;Gc2(s)称为副调节器传递函数&#xff0c;包围Gc2(s)的内环称为副回路。Gc1(s)称为主调节器传递函数&#xff0c;包围Gc1(s)的外环称为主回路。主调节器的输出控制量u1作为副回路的给定量R2…
阅读更多...
Vuex基本概念

Vuex基本概念

一、基本概念vuex&#xff1a;为了解决不关联的组件整个网站状态数据共享问题&#xff0c;专为Vue.js开发的状态管理模式。采用集中式存储管理应用的所有组件状态&#xff0c;并以相应的规则保证状态以一种可预测的方式发生变化。vuex有5个主要成员&#xff1a;state&#xff1…
阅读更多...
DAMA数据管理知识体系指南之数据架构管理

DAMA数据管理知识体系指南之数据架构管理

第4章 4.1 简介 数据架构管理是定义和维护如下规范的过程&#xff1a; 提供标准的、通用的业务术语/辞典。 表达战略性的数据需求。 为满足如上需求&#xff0c;概述高层次的整合设计。 使企业战略和相关业务架构相一致。 数据架构是用于定义数据需求、指导对数据资产的整合和…
阅读更多...
【C++】从0到1入门C++编程学习笔记 - 提高编程篇：STL常用容器（vector容器）

【C++】从0到1入门C++编程学习笔记 - 提高编程篇：STL常用容器（vector容器）

文章目录一、vector基本概念二、vector构造函数三、vector赋值操作四、vector容量和大小五、vector插入和删除六、vector数据存取七、vector互换容器八、vector预留空间一、vector基本概念 功能&#xff1a; vector数据结构和数组非常相似&#xff0c;也称为单端数组 vector…
阅读更多...
Discord多账号抢白名单，如何避免账号关联被封号？

Discord多账号抢白名单，如何避免账号关联被封号？

相信玩NFT项目的都不会对Discord陌生&#xff0c;现在NFT的项目都会开Discord伺服器&#xff0c;并且将内容公告在上面、在伺服器里互动&#xff0c;所以如果你想参与NFT的世界&#xff0c;学会使用Discord是一件非常重要的事情。 东哥前2天也出了关于discord如何使用、如何抢白…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023