一个非阻塞、事件驱动的 Swift Disque 客户端，无耻地复制了 构建于 Vapor 的 Redis 客户端之上。Disque 是由 Salvatore Sanfilippo (@antirez) 创建的分布式作业队列，从 Redis "fork" 而来。
- 分布式 - Disque 集群是多主结构，每个节点都具有相同的角色，因此生产者和消费者可以连接到任何节点。 同一个队列的生产者和消费者不需要连接到同一个节点。
- 容错 - 作业被同步复制到多个节点，这样当一个作业被添加到队列时，该作业会被复制到 N 个节点，然后该节点才会将作业 ID 返回给客户端。 即使 N-1 个节点发生故障，该作业仍然会被传递。
- 可调持久性 - 默认情况下，Disque 将作业存储在内存中，但是，可以通过启用 AOF (类似于 Redis) 来配置 Disque 将作业持久化到磁盘。
- 可定制的传递语义：默认情况下，作业具有至少一次的传递语义，但如果重试时间设置为 0，则作业将具有至多一次的传递语义。 对于至少一次传递，作业会自动重新排队，直到作业被消费者确认或直到作业过期。
- 作业优先级 - 消费者可以通过一个
GETJOB命令从多个队列中获取作业。 Disque 将从定义的队列中搜索作业，首先从最左边的队列开始，模拟作业优先级。 - 计划/延迟作业 - 作业可以被计划/延迟一段时间。 延迟的作业在延迟到期之前不会传递给消费者。
1. 使用 Docker 启动 Disque 容器，或遵循 Disque 的 安装说明。
docker run -d --rm -p 7711:7711 --name disque efrecon/disque:1.0-rc1
2 将依赖项添加到 Package.swift。
.package(url: "https://github.com/johnbona/disque", from: "0.1.0")
3. 在 configure.swift 中注册 provider 和 config。
public func configure(_ config: inout Config, _ env: inout Environment, _ services: inout Services ) throws {
// ...
try services.register(DisqueProvider())
var databases = DatabasesConfig()
let disqueConfig = DisqueDatabase(config: DisqueClientConfig())
databases.add(database: disqueConfig, as: .disque)
services.register(databases)
}
4. 从连接池中获取连接并使用 Disque 客户端。
return req.withPooledConnection(to: .disque) { disque -> Future<[Job<TestJob>]> in
return disque.get(count: 1, from: ["test-queue"], as: TestJob.self)
}
Disque 的所有命令（除了 HELLO、QPEEK、QSCAN、JSCAN）都在 Swift 中实现，作业正文符合 Codable。
return req.withPooledConnection(to: .disque) { disque -> Future<[Job<TestJob>]> in
return disque.get(count: 1, from: ["test-queue"], as: TestJob.self)
}
return req.withPooledConnection(to: .disque) { disque -> Future<[Job<TestJob>]> in
return disque.get(count: 1, from: ["high-priority", "low-priority"], as: TestJob.self)
}
req.withPooledConnection(to: .disque) { disque -> Future<String> in
return try disque.add(job: TestJob(), to: "test-queue")
}
req.withPooledConnection(to: .disque) { disque -> Future<Int> in
return try disque.ack(jobIDs: ["D-00000000-000000000000000000000000-0000"])
}
- Disque 仓库和文档
- 来自 @antirez 的原始 Disque 公告，其中包含架构细节：消息队列的冒险
- 加入 Vapor 的 Discord 频道以获得支持
- 如有任何意见或问题，请随时在 Twitter 上联系 (@johnbona)
Disque 在 MIT 许可下发布。