From 3ef95de1ecee05d41ebd51d6a29dd855cd3c31b4 Mon Sep 17 00:00:00 2001
From: Ivan <ivanli@live.cn>
Date: Sun, 11 Apr 2021 12:22:25 +0800
Subject: [PATCH] commit

---
 Programmer/webhook.md                      | 10 ++++
 Programmer/全能的 redis - Message Queue.md | 65 ++++++++++++++++++++++
 2 files changed, 75 insertions(+)
 create mode 100644 Programmer/webhook.md
 create mode 100644 Programmer/全能的 redis - Message Queue.md

diff --git a/Programmer/webhook.md b/Programmer/webhook.md
new file mode 100644
index 0000000..0f391a2
--- /dev/null
+++ b/Programmer/webhook.md
@@ -0,0 +1,10 @@
+# Webhook
+
+## 概述
+大家第一次见到 webhook 是在何时何地？感觉这个名词似乎这两年在国内才出圈，但这个概念很早之前就有了。webhook 也是一种跨进程通信的技术，采用了 WEB 技术栈的协议，能够利用该技术向远程服务推送信息。
+
+## 比较辨析
+webhook 其实就是 WEB + hook 的集合体。
+同为 WEB 技术栈的 WEB API 与 webhook 间，可以看做是包含与被包含的概念，webhook 基于 WEB API，借助 WEB API 提供的接口，让消息源服务能通过 API 调用到 hook。
+
+未采用类似 hook 技术的项目，消息源作为数据生产者，消费者若想订阅消息，则必须建立长连接或者采用轮询机制来实现。这类机制在消息不密集时比较耗费连接资源。
\ No newline at end of file
diff --git a/Programmer/全能的 redis - Message Queue.md b/Programmer/全能的 redis - Message Queue.md
new file mode 100644
index 0000000..e5ff7a6
--- /dev/null
+++ b/Programmer/全能的 redis - Message Queue.md	
@@ -0,0 +1,65 @@
+# 全能的 Redis - Message Queue
+
+## 前言
+
+众所周知，专业的消息队列有很多，但是，Redis 又不是不行？XD
+如果可以，在生产环境中还是选择 RabbitMQ、Kafka 之类的服务，它们生态好，符合大部分项目的需求。而我选择 Redis 作为消息队列，主要还是因为不希望我的个人项目引入太多依赖，毕竟我自己没有多少服务器资源，还是得向苹果公司学习，以环保为重 /doge。
+
+## 我经历的 Redis 消息队列
+
+这不是第一次，也不是最后一次。之前开发过的项目，有些对消息队列的需求还是很少且很弱的，只是为了解决一个问题才借助 redis 的部分特性实现一些 MQ 的特性，或多或少会有一些瑕疵，但是现在看来还是十分合理的选择。
+
+### 阻塞列表 (Blocking List)
+
+阻塞列表其实是还是普通列表，只是在出栈的时候使用了阻塞的方式来等待值的到来。
+
+相关的方法有以下几个：
+
+- `BLPOP`、`BRPOP`：阻塞式弹出，用于消费时取出队列中的值
+- `BRPOPLPUSH`：在同一个队列中，把最右边的消息重新插入到左边，用来重新加入队列
+- `LPUSH`、`RPUSH`: 向队列添加消息
+
+拥有上面几个命令，我们就可以借助 Redis 实现一个简单的消息队列。
+我们定义消息队列队头在左(Left)，队尾在右(Right)，消息遵循 FIFO 原则进行消费。
+
+// TODO: 添加示例代码
+
+```flow
+  pStart=>start: Start
+  pEnd=>end: End
+  lpush=>operation: LPUSH
+  
+  pStart->lpush->pEnd
+
+```
+
+上图是生产者发布消息的流程图。流程非常简单，只要往 redis 存放数据就成了。
+
+```flow
+  cStart=>start: Start
+  cEnd=>end: End
+  brpop=>operation: BRPOP
+  consume=>operation: 执行任务
+  consumeSucceeded=>condition: 任务执行是否成功？
+  repush=>operation: LPUSH
+  isExit=>condition: 是否退出？
+  
+  cStart->brpop->cEnd
+  brpop->consume->consumeSucceeded
+  consumeSucceeded(no)->repush->brpop
+  consumeSucceeded(yes)->isExit(yes)->cEnd
+  consumeSucceeded(yes)->isExit(no)->brpop
+```
+
+上图是消费者消费消息的流程图。阻塞地读取消息，然后拿着消息执行任务。如果执行成功，那么再去读取消息；否则，把消息重新插入到消息队列中。
+
+这个方案很简单轻量，但有一个缺点，生产者可以和其他 redis 操作共用一个 redis 连接，但是消费者必须独立使用一个连接。主要是因为消费者在阻塞等待消息的这段时间，其他 redis 将会一同阻塞。同样的，如果要使用这个方案，最好给 `BRPOP` 一个超时时间，避免意外情况导致程序卡死在这。
+
+## 阻塞列表 + `BRPOPLPUSH`
+
+上面的方案有一定的问题，就是消费者如果在读取消息和完成任务之间出现了 Crash 之类的情况，导致失败的任务没有重新回到消息队列，进而导致消息丢失。如果消息丢了就丢了没啥事，那问题还不算大，但是对消息可靠性有一定要求的话，可以增加一个“working queue”，消费者读取任务时，将任务转移到 working queue 中，待任务完成后再将任务移除。
+
+生产者的工作流程和之前一样，主要是消费者这边增加了一个　working queue。
+
+
+顺带一提，Redis 6.2 开始还加了一个 `BLMOVE`，提供了不同列表之间的头、尾元素移动到另一个列表的头、尾。