首页 > temp > 简明python教程 >
-
使用EventBus + Redis发布订阅模式提升业务执行性能(下)
前言
上一篇博客上已经实现了使用EventBus对具体事件行为的分发处理，某种程度上也算是基于事件驱动思想编程了。但是如上篇博客结尾处一样，我们源码的执行效率依然达不到心里预期。在下单流程里我们明显可以将部分行为进行异步处理，提升下单操作的执行效率。
Redis基础命令
Redis有两种方式可支持我们实现MQ功能，1、使用列表(List)相关命令特性；2、使用publish、subscribe命令特性；
这里我是采取列表相关命令实现。
使用列表(List)相关命令的特性实现
-
压入数据(发布消息)
使用列表(List)的LPUSHRPUSH命令可以从列表左边和右边压入数据;
LPUSH
将一个或多个值插入到列表头部(此处可以将列表想象成一个从左到右的链表数据结构，LPUSH就是将指定的值插入最左侧！)
如下命令，将多个元素压入list1的头部(最左侧)
|
1
|
LPUSH list1 测试1 测试2 |
执行结果如下:
上面是写入多个元素，我们也可以写入单个元素
|
1
|
LPUSH list1 测试3 |
需要留意，每次执行完LPUSH后，Redis会返回当前列表的长度。
RPUSH
在指定列表的尾部(相当于一个链表的最右侧)添加单个或多个元素
如下命令，还是在list1上添加多个元素，并查看执行后的list1元素信息
|
1
|
RPUSH list 测试4 测试5 |
同理，RPUSH也可直接写入单个元素，和LPUSH一样。
-
拉取数据(消费数据)
这里的拉取数据不单单是读取List内的元素，而是将元素从列表中取出来
BLPOP
移出并获取列表的第一个元素(从左至右)， 如果列表没有元素会阻塞当前线程，直到等待超时或发现可弹出元素为止。
如下命令，从list1这个列表获取从左至右第一个元素，在100秒内如果获取则结束阻塞，否则阻塞到100秒之后。
|
1
|
BLPOP list1 100 |
执行结果如下：
需要留意的是BLPOP命令如果拉取到数据则会返回两行数据，1行为列表的key名称，1行为获取到的元素值。如果直到阻塞结束都没有获取到元素值则直接返回命令执行超时。如下图:
BRPOP
移出并获取列表的最后一个元素(从左至右)， 如果列表没有元素会阻塞当前线程直到等待超时或发现可弹出元素为止。该命令与BLPOP除了获取的元素位置不同，其他特性全部一致。
LPOP
移出并获取列表的第一个元素(从左至右)，如获取到元素则返回元素信息，没有元素则立即返回null。
如下命令:
|
1
|
LPOP list1 |
RPOP
移出并获取列表的最后一个元素(从左至右)，如获取到元素则返回元素信息，没有元素则立即返回null。该命令与LPOP除了获取的元素位置不同其他特性全部一致；
RPOPLPUSH
移除列表的最后一个元素(最右侧的元素)，并将该元素添加到另一个列表并返回。该命令如获取到元素则返回元素信息，否则返回错误信息。
可以通过RPOPLPUSH这个命令的特性对MQ内一致性要求较高的业务进行处理，在从列表获取元素成功后将该元素添加到一个备份列表，在业务处理完毕后再从备份列表将该元素删除。
执行下面命令测试下:
|
1
|
RPOPLPUSH list1 listback |
BRPOPLPUSH
从列表中弹出一个值，将弹出的元素插入到另外一个列表中并返回它； 如果列表没有元素会阻塞列表直到等待超时或发现可弹出元素为止。
该命令其实就是在BRPOP的基础上将LPUSH的功能加上了，依旧也保留了指定超时时间内未获取到元素则阻塞线程。
执行下面命令测试下:
|
1
|
BRPOPLPUSH list1 listback 10 |
执行结果如下:
完善代码
基于上面Redis的相关命令，我们再完善下上篇博客的代码。这里我们需要新增一个控制台启动项，将它作为消费服务，原来的控制台即订单保存的控制台作为消息发布的服务。
下单代码更改为下面的样子:
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
/// <summary>/// 异步方式触发订单相关事件/// </summary>public static void AsynEventHandle(){ Guid userId = Guid.NewGuid(); Stopwatch stopwatch = new Stopwatch(); stopwatch.Start(); var order = new OrderModel() { CreateTime = DateTime.Now, Id = Guid.NewGuid(), Money = (decimal)300.00, Number = 1, ProductName = "鲜花一束", UserId = userId }; Console.WriteLine($"模拟存储订单【采取Redis做消息队列的异步方式】"); Thread.Sleep(1000); FullRedis fullRedis = new FullRedis("127.0.0.1:6379", "", 1); //这里尝试过使用redis 的订阅发布模式,在执行发布命令时候发现值但凡出现空格或者"符号则会异常... fullRedis.LPUSH("orders", new OrderModel[] { order }); stopwatch.Stop(); Console.WriteLine($"下单总耗时:{stopwatch.ElapsedMilliseconds}毫秒"); Console.ReadLine();} |
