用 nodejs 简单的搭建了一个 http sever，可以处理 post 请求，执行比如“job1(post)”，“job2(post)”这样的请求，但是这些不同的 job 只能同步执行，也就是一个执行完了再执行另一个。
所以有没有简单的实现，先把 post 请求存到队列里面，然后依次执行？
This topic created in 1944 days ago, the information mentioned may be changed or developed.
Supplement 1 · Jul 10, 2021
我的意思是，http server 处理 post 请求时，会立马执行 job(post)函数（ job 本身就是 async function ）。所以收到两个连续的 post 请求时，会立马执行两个连续的 job(post)。由于 job(post)是 async function，所以会“同时执行”，互相产生冲突。现在只想让 job 执行完一个再执行下一个。
 |
opentradeJul 10, 2021
1
类似 WSGI 的东西吧，Python 的比较多，nodejs 的没用过
|
 |
dengshenJul 10, 2021 via iPhone
2
rx 。流编程
|
 |
beginorJul 10, 2021 via Android
3
promise ？
|
 |
RrrrrrJul 10, 2021
4
事件驱动了解一下？
|
 |
5
Async.js
|
 |
simple2025Jul 10, 2021
6
没懂
|
 |
streamrxJul 10, 2021 via iPhone
7
async 不就行了
|
 |
SanonzJul 10, 2021 via iPhone
8
|
 |
9
|
1 |
uswJul 10, 2021
10
桥豆麻袋，“同时执行”和“”产生冲突“具体是啥。async 函数如果没有 await 可咋整
|
 |
qpingJul 10, 2021
11
web 请求天然就是异步的，想要搞成同步就把消息存在队列里面，然后另外搞个线程处理这个队列
|
 |
MegrezZhuJul 10, 2021
12
同时执行产生冲突——那冲突的资源是什么？ CPU ？ IO ？
如果只是想一个个执行的话，post handler 就只接收任务然后加到一个 job queue 里呗，然后自己起一个 worker 一个个拿去执行，这是最 naive 的方法…… |
 |
debuggerxJul 10, 2021 via Android
13
听描述 应该是客户端 也就是请求端做串行吧
job1 请求拿到返回了再去执行 job2 请求就好了 |
 |
14
|
 |
muzuigetJul 10, 2021
15
把 job 放到一个包成一个 promise，把这些 promise 放到一个数组里，然后一个个 await 这个数组的元素。
|
 |
ExinJul 10, 2021
16
连数组都不需要，最简单的实现如下
```js let last = Promise.resolve() onPost(post => last = last.then(() => job(post))) ``` |
 |
loveJul 10, 2021
17
我自己的小服务程序也是这样。
收到请求，放在内存中请求列表，同时在硬盘上存一份 JSON 请求，然后另一个 async 函数会循环处理请求列表并删除硬盘上的对应文件。当程序重启时会加载硬盘上的所有请求，以免不小心程序各种原因重启时漏掉队列中的请求。 |
 |
April5Jul 10, 2021
18
bull
|
 |
duan602728596Jul 11, 2021
19
当初为了实现多文件上传并限制同时上传数，写的一个实现队列的方法，你可以拿去参考参考
https://github.com/duan602728596/Q/blob/main/src/Queue.ts |
 |
zbinlinJul 11, 2021
20
|
 |
zhennannJul 11, 2021
21
两种思路：
1 、采用分布式锁 redlock 2 、采用 redis 做消息队列 |
 |
cszchenJul 11, 2021 via iPhone
22
node 天生就是异步啊，不需要你额外封装，大家都是头疼怎么同步，所以才有了 Promise
|
 |
23
需求是希望收到的所有请求之间按照顺序一个一个执行是吧？
可以用消息队列的思想，就是来请求会异步插入到一个队列里，然后单线程一个一个地消费。 最简陋的做法是在一个 module 的根作用域下声明一个 Array，然后每次来请求都 unshift 一个消息，服务里单独跑一个循环去从数组里 pop 消息出来处理，处理完再 pop 下一个。 有分布式需求的话就用 Redis 、RabbitMQ 之类的消息队列中间件，可以启动一个集群服务作为生产者往队列里插消息，然后启动一个消费者服务来同步一条条消费。 |
 |
sorapingJul 12, 2021
24
事件循环吧，已经内置了 uvlib，io 请求自动进入到事件队列里
|
 |
jianhuaJul 12, 2021
25
多台服务器的话，需要一个消息队列，因为你要维护简单，redis 就可以了，实现一个简单的 pub/sub 。
单台服务器，生产者消费者写过没有。。。 |
 |
tanrunhaoJul 12, 2021
26
最简单是搞个 全局数组， 启动时候 setInterval 轮询数组执行， 然后请求时候把任务放进去。 这样基本满足需求
|
 |
xcstreamJul 19, 2021
27
async function(){
await f1() await f2() } () |
Select Language