文件名称:nsqjs:NSQ的NodeJS客户端库
文件大小:55KB
文件格式:ZIP
更新时间:2024-05-19 18:22:53
nsq nsqjs nsqd JavaScript
nsqjs 客户端协议的官方客户端。 此实现尝试完全兼容并与正式的Go( )和Python( )客户端保持功能对等。 用法 新读者(主题,频道,选项) topic和channel参数是字符串,必须指定。 options参数是可选的。 以下是可以在options对象中指定的参数。 maxInFlight: 1 一次要处理的最大消息数。 此值在nsqd连接之间共享。 强烈建议此值大于nsqd连接数。 heartbeatInterval: 30 nsqd将心跳发送到此Reader的频率(以秒为单位)。 maxBackoffDuration: 128 读取器将针对任何单个退避事件退避的最长时间(秒)。 maxAttempts: 0 在将给定消息传递给DISCARD处理程序然后自动完成之前,将尝试给定消息(赋予MESSAGE处理程序)的次数。 0表示没有限制。 如果未指定DISCAR
【文件预览】:
nsqjs-main
----.travis.yml(322B)
----LICENSE-MIT(1KB)
----package.json(1KB)
----.github()
--------dependabot.yml(105B)
----test()
--------framebuffer_test.js(3KB)
--------backofftimer_test.js(2KB)
--------config_test.js(7KB)
--------rawmessage.js(361B)
--------cert.pem(2KB)
--------z_integration_test.js(11KB)
--------key.pem(2KB)
--------message_test.js(2KB)
--------nsqdconnection_test.js(8KB)
--------readerrdy_test.js(22KB)
--------lookupd_test.js(5KB)
--------wire_test.js(3KB)
--------reader_test.js(3KB)
--------writer_test.js(4KB)
--------roundrobinlist_test.js(2KB)
----.prettierrc(113B)
----_config.yml(27B)
----CNAME(9B)
----.npmignore(36B)
----.eslintrc.js(375B)
----.gitignore(31B)
----lib()
--------config.js(8KB)
--------roundrobinlist.js(1KB)
--------backofftimer.js(2KB)
--------readerrdy.js(17KB)
--------nsqdconnection.js(21KB)
--------writer.js(6KB)
--------lookupd.js(4KB)
--------message.js(5KB)
--------nsq.js(277B)
--------version.js(52B)
--------wire.js(7KB)
--------reader.js(7KB)
--------framebuffer.js(2KB)
----README.md(15KB)