关键词：
高并发场景之RabbitMQ
上次我们介绍了在单机、集群下高并发场景可以选择的一些方案，传送门：高并发场景之一般解决方案
但是也发现了一些问题，比如集群下使用ConcurrentQueue或加锁都不能解决问题，后来采用Redis队列也不能完全解决问题，
因为使用Redis要自己实现分布式锁
这次我们来了解一下一个专门处理队列的组件：RabbitMQ，这个东西天生支持分布式队列。
下面我们来用RabbitMQ来实现上一篇的场景
一、新建RabbitMQ.Receive
private static ConnectionFactory factory = new ConnectionFactory
{ HostName = "192.168.1.109", UserName = "ljr", Password = "root", VirtualHost = "/" };
1 static void Main(string[] args)
2 {
3 using (var connection = factory.CreateConnection())
4 {
5 using (var channel = connection.CreateModel())
6 {
7 var consumer = new EventingBasicConsumer();
8 consumer.Received += (model, ea) =>
9 {
10 var body = ea.Body;
11 var message = Encoding.UTF8.GetString(body);
12 Console.WriteLine(" [x] Received {0}", message);
13
14 var total = DbHelper.ExecuteScalar("Select Total from ConCurrency where Id = 1", null).ToString();
15 var value = int.Parse(total) + 1;
16
17 DbHelper.ExecuteNonQuery(string.Format("Update ConCurrency Set Total = {0} where Id = 1", value.ToString()), null);
18 };
19
20 channel.QueueDeclare(queue: "queueName", durable: false, exclusive: false, autoDelete: false, arguments: null);
21 channel.BasicConsume(queue: "queueName", noAck: true, consumer: consumer);
22
23 Console.WriteLine(" Press [enter] to exit.");
24 Console.ReadLine();
25 }
26 }
27 }
二、新建RabbitMQ.Send
1 static void Main(string[] args)
2 {
3 for (int i = 1; i <= 500; i++)
4 {
5 Task.Run(async () =>
6 {
7 await Produce();
8 });
9
10 Console.WriteLine(i);
11 }
12
13 Console.ReadKey();
14 }
15
16 public static Task Produce()
17 {
18 return Task.Factory.StartNew(() =>
19 {
20 using (var connection = factory.CreateConnection())
21 {
22 using (var channel = connection.CreateModel())
23 {
24 var body = Encoding.UTF8.GetBytes(Guid.NewGuid().ToString());
25 channel.QueueDeclare(queue: "queueName", durable: false, exclusive: false, autoDelete: false, arguments: null);
26 channel.BasicPublish(exchange: "", routingKey: "queueName", basicProperties: null, body: body);
27 }
28 }
29 });
30 }
这里是模拟500个用户请求，正常的话最后Total就等于500
我们来说试试看，运行程序
2.1、打开接收端
2.2 运行客户端
2.3、可以看到2边几乎是实时的，再去看看数据库
三、我们在集群里执行
最后数据是1000
springboot整合rabbitmq之典型应用场景实战二
实战前言RabbitMQ作为目前应用相当广泛的消息中间件，在企业级应用、微服务应用中充当着重要的角色。特别是在一些典型的应用场景以及业务模块中具有重要的作用，比如业务服务模块解耦、异步通信、高并发限流、超时业务... 查看详情
springboot整合rabbitmq之典型应用场景实战三
实战前言RabbitMQ作为目前应用相当广泛的消息中间件，在企业级应用、微服务应用中充当着重要的角色。特别是在一些典型的应用场景以及业务模块中具有重要的作用，比如业务服务模块解耦、异步通信、高并发限流、超时业务... 查看详情
springboot整合rabbitmq之典型应用场景实战一
实战前言RabbitMQ作为目前应用相当广泛的消息中间件，在企业级应用、微服务应用中充当着重要的角色。特别是在一些典型的应用场景以及业务模块中具有重要的作用，比如业务服务模块解耦、异步通信、高并发限流、超时业务... 查看详情
rabbitmq和kafka怎么选？
MQ框架非常之多，今天简单说一下有代表性的两个MQ(rabbitmq和kafka)。经常会有人问rabbitmq和kafka到底哪个好呢？其实没有好与不好之分，只有哪个更合适，首先要根据自己项目的业务场景和需求来选择更合适的一个MQ。在应用场景... 查看详情
高并发高负载解决方案之----------数据库分库分表的应用场景及解决方案
数据库分库分表的应用场景及解决方案 现实业务场景中，为了保障客户体验并满足业务的线性增长。会对数据量巨大，且业务会始终进行的产品进行分表分库策略。但是如何合理的根据业务采取争取的分表分库... 查看详情
聊聊高并发系统之限流特技(代码片段)
在开发高并发系统时,有很多手段用来保护系统：缓存、降级和限流。缓存的目的是提升系统访问速度和增大系统处理能力，可谓是抗高并发流量的银弹；而降级是当服务出问题或者影响到核心流程的性能则需要暂时屏蔽掉... 查看详情
高并发系统之限流特技
在开发高并发系统时有三把利器用来保护系统：缓存、降级和限流。缓存的目的是提升系统访问速度和增大系统能处理的容量，可谓是抗高并发流量的银弹；而降级是当服务出问题或者影响到核心流程的性能则需要暂时屏蔽掉，... 查看详情
java高级工程师进阶学习：kafka应用场景
三大内容：Java并发编程Java高并发编程高并发系统设计Java并发编程1.概览2.进程与线程3.Java线程4.共享模型之管程5.共享模型之内存6.共享模型之无锁7.共享模型之不可变8.共享模型之工具并发编程—模式篇：并发编程—应用... 查看详情
聊聊高并发系统之限流特技-1开涛
在开发高并发系统时有三把利器用来保护系统：缓存、降级和限流。缓存的目的是提升系统访问速度和增大系统能处理的容量，可谓是抗高并发流量的银弹；而降级是当服务出问题或者影响到核心流程的性能则需要暂时屏蔽掉，... 查看详情
rabbitmq(代码片段)
RabbitMQ是用Erlang实现的一个高并发高可靠AMQP消息队列服务器。支持消息的持久化、事务、拥塞控制、负载均衡等特性，使得RabbitMQ拥有更加广泛的应用场景。 使用场景：场景1：单发送单接收 使用场景：简单的发送与... 查看详情
jmeter之仿真高并发测试（集合点）
...启动了就会直接发送测试请求；--如果要模拟在一瞬间高并发量测试的时候，需要调高线程数量，这很耗测试机器的性能，往往无法支持较大的并发数，无法控制每次测试的瞬间并发量；（2）如果使用了constantthroughputtimer，可以... 查看详情
springboot实战实现分布式锁一之重现多线程高并发场景
实战前言：上篇博文我总体介绍了我这套视频课程：“SpringBoot实战实现分布式锁”总体涉及的内容，从本篇文章开始，我将开始介绍其中涉及到的相关知识要点，感兴趣的小伙伴可以关注关注学习学习！！工欲善其事，必先利... 查看详情
8.软件架构设计：大型网站技术架构与业务架构融合之道---高并发问题(代码片段)
第8章高并发问题8.1问题分类 8.1.1侧重于“高并发读”的系统 1.场景一：搜索引擎 读写的差异： a)数量级 b)响应时间 c)频率 2.场景二：电商的商品搜索 3.场景三：电商系统的商品描述，图片和价格 8.1... 查看详情
zuul修改请求头响应头（死磕）(代码片段)
...）WindowsZookeeper安装（带视频）LinuxZookeeper安装（带视频）RabbitMQ离线安装（带视频）Nacos安装（带视频）ElasticSearch安装,带视频**小视频以及所需工具的百度网盘链接，请参见疯狂创客圈高并发社群博客前言由于SpingSecurity+SpringSessi... 查看详情
大流量高并发系统之限流特技
在开发高并发系统时有三把利器用来保护系统：缓存、降级和限流。缓存的目的是提升系统访问速度和增大系统能处理的容量，可谓是抗高并发流量的银弹；而降级是当服务出问题或者影响到核心流程的性能则需要暂... 查看详情
高并发缓存之缓存介绍redis基本应用介绍(代码片段)
前言本篇文章主要介绍缓存得概念、作用、场景、组件；以及redis介绍、应用场景分析常见客户端使用。以及spring缓存注解得介绍。缓存为什么需要缓存其实就是为了加强服务器检索效率；也是由于持久化层数据库访问数... 查看详情
高并发业务接口的开发思路（转）
高并发业务除了需要有支撑高并发的服务器架构，还需要根据业务需求和架构体系。.设计出合理的开发方案，这里根据一个实践过业务场景分析开发思路，罗列出高并发接口需要注意的点，以及设计上的巧思，共勉之，望共鸣.... 查看详情
springsecurity原理+实战
...）WindowsZookeeper安装（带视频）LinuxZookeeper安装（带视频）RabbitMQ离线安装（带视频）Nacos安 查看详情