文件名称：redis-smq:适用于Node.js的简单高性能Redis消息队列
文件大小：62KB
文件格式：ZIP
更新时间：2024-06-01 17:53:34
nodejs redis queue jobs message-queue
RedisSMQ-另一个简单的Redis消息队列 用于Node.js的简单高性能Redis消息队列。 有关RedisSMQ设计的更多详细信息，请参见 特征 持久性：如果使用者使用失败，则不会丢失任何消息。 原子：消息仅一次发送给一个使用者（以FIFO顺序），因此您永远不会陷入消息可以被处理多次的情况。 高性能消息处理：有关更多详细信息，请参见。 可伸缩：队列可以由在同一主机或不同主机上运行的许多并发使用者使用。 消息到期：如果消息在队列中的时间超过TTL（生存时间），则消息将到期且不会被使用。 消息消耗超时：使用者消耗消息的时间。 如果超过超时，则取消消息处理，并将消息重新排队以再次使用。 延迟和调度消息传递：从版本1.0.19开始，持久性调度程序已内置到RedisSMQ消息队列中。 调度程序接受延迟消息，重复消息传递，重复之间的间隔和CRON表达式。 高度优化：没有承诺，
【文件预览】：
redis-smq-master
----.jshintignore(10B)
----example()
--------typescript()
--------javascript()
----index.js(269B)
----docs()
--------api()
----package.json(1KB)
----test()
--------config.js(286B)
--------test15.test.js(2KB)
--------test16.test.js(3KB)
--------test03.test.js(654B)
--------test07.test.js(1KB)
--------test12.test.js(953B)
--------jest.setup.js(610B)
--------test05.test.js(1010B)
--------test04.test.js(918B)
--------test10.test.js(1KB)
--------test13.test.js(2KB)
--------test02.test.js(593B)
--------test09.test.js(1KB)
--------common.js(3KB)
--------test06.test.js(1KB)
--------test01.test.js(336B)
--------test08.test.js(1KB)
--------test14.test.js(6KB)
--------test11.test.js(2KB)
----.prettierrc(180B)
----jest.config.js(254B)
----LICENSE(1KB)
----src()
--------heartbeat-monitor.js(2KB)
--------producer-redis-keys.js(1KB)
--------events.js(1KB)
--------ticker.js(841B)
--------gc.js(8KB)
--------producer.js(2KB)
--------mq-redis-keys.js(2KB)
--------power-state-manager.js(2KB)
--------producer-stats-provider.js(941B)
--------message.js(7KB)
--------consumer-stats-provider.js(3KB)
--------heartbeat.js(8KB)
--------lock-manager.js(2KB)
--------scheduler.js(9KB)
--------consumer-redis-keys.js(4KB)
--------logger.js(539B)
--------stats.js(2KB)
--------consumer.js(10KB)
--------instance.js(8KB)
--------stats-aggregator.js(10KB)
--------redis-client.js(854B)
--------instance-redis-keys.js(2KB)
--------gc-message-collector.js(5KB)
----.eslintrc.js(596B)
----index.d.ts(653B)
----.gitignore(62B)
----CHANGELOG.md(3KB)
----types()
--------misc()
--------instance.ts(103B)
--------producer.ts(426B)
--------config.ts(436B)
--------consumer.ts(604B)
--------message.ts(2KB)
----README.md(13KB)