訂閱的時(shí)候，客戶端的 RDY 狀態(tài)為 0。意味著沒有消息會(huì)被發(fā)送到客戶端。當(dāng)客戶端已經(jīng)準(zhǔn)備好接受消息時(shí)，需要把 RDY 設(shè)置為 #。比如設(shè)置為 100，不需要任何附加命令，將會(huì)有 100 條消息推送到客戶端（每次服務(wù)端都會(huì)相應(yīng)的減少 RDY 的值）。

V2 版本的協(xié)議讓客戶端擁有心跳功能。每隔 30 秒（默認(rèn)設(shè)置），nsqd 將會(huì)發(fā)送一個(gè) _heartbeat_ 響應(yīng)，并期待返回。如果客戶端空閑，發(fā)送 NOP命令。如果 2 個(gè) _heartbeat_ 響應(yīng)沒有被應(yīng)答， nsqd 將會(huì)超時(shí)，并且強(qiáng)制關(guān)閉客戶端連接。IDENTIFY 命令可以用來改變/禁用這個(gè)行為。

注意

除非 stated，所有的傳輸?shù)亩?jí)制大小/整數(shù)都是網(wǎng)絡(luò)字節(jié)順序。(列如. big endian)
有效的話題（topic)和通道（channel)名必須是字符[.a-zA-Z0-9_-] 和數(shù)字 1 < length <= 64 (在 nsqd 0.2.28 版本前最長 32 位)

命令

IDENTIFY

更新服務(wù)器上的客戶端元數(shù)據(jù)和協(xié)商功能。

IDENTIFY\n
[ 4-byte size in bytes ][ N-byte JSON data ]

注意: 這個(gè)命令包含 JSON 的相關(guān)內(nèi)容，包括：

short_id (nsqd v0.2.28+ 版本之后已經(jīng)拋棄，使用 client_id 替換)這個(gè)標(biāo)示符是描述的簡易格式（比如，主機(jī)名）
long_id (v0.2.28+ 版之后已經(jīng)拋棄，使用 hostname 替換)這個(gè)標(biāo)示符是描述的長格式。(比如. 主機(jī)名全名)
client_id 這個(gè)標(biāo)示符用來消除客戶端的歧義 (比如. 一些指定給消費(fèi)者)
hostname 部署了客戶端的主機(jī)名
feature_negotiation (nsqd v0.2.19+) bool，用來標(biāo)示客戶端支持的協(xié)商特性。如果服務(wù)器接受，將會(huì)以 JSON 的形式發(fā)送支持的特性和元數(shù)據(jù)。
heartbeat_interval (nsqd v0.2.19+) 心跳的毫秒數(shù).

有效范圍: 1000 <= heartbeat_interval <= configured_max (-1 禁用心跳)

--max-heartbeat-interval (nsqd 標(biāo)志位) 控制最大值

默認(rèn)值 --client-timeout / 2
output_buffer_size (nsqd v0.2.21+) 當(dāng) nsqd 寫到這個(gè)客戶端時(shí)將會(huì)用到的緩存的大小（字節(jié)數(shù)）。

有效范圍: 64 <= output_buffer_size <= configured_max (-1 禁用輸出緩存)

--max-output-buffer-size (nsqd 標(biāo)志位) 控制最大值

默認(rèn)值 16kb
output_buffer_timeout (nsqd v0.2.21+)超時(shí)后，nsqd 緩沖的數(shù)據(jù)都會(huì)刷新到此客戶端。

有效范圍: 1ms <= output_buffer_timeout <= configured_max (-1 禁用 timeouts)

--max-output-buffer-timeout (nsqd 標(biāo)志位) 控制最大值

默認(rèn)值 250ms

警告: 使用極小值 output_buffer_timeout (< 25ms) 配置客戶端，將會(huì)顯著提高 nsqd CPU 的使用率（通常客戶端連接時(shí) > 50 ）。

這依賴于 Go 的 timers 的實(shí)現(xiàn)，它通過 Go 的優(yōu)先隊(duì)列運(yùn)行時(shí)間維護(hù)。
tls_v1 (nsqd v0.2.22+) 允許 TLS 來連接

--tls-cert and --tls-key (nsqd 標(biāo)志位s) 允許 TLS 并配置服務(wù)器證書

如果服務(wù)器支持 TLS，將會(huì)回復(fù) "tls_v1": true。

客戶端讀取 IDENTIFY 響應(yīng)后，必須立即開始 TLS 握手。

完成 TLS 握手后服務(wù)器將會(huì)響應(yīng) OK.
snappy (nsqd v0.2.23+) 允許 snappy 壓縮這次連接

--snappy (nsqd 標(biāo)志位) 允許服務(wù)端支持

客戶端不允許同時(shí) snappy 和 deflate。
deflate (nsqd v0.2.23+) 允許 deflate 壓縮這次連接

--deflate (nsqd 標(biāo)志位) 允許服務(wù)端支持

客戶端不允許同時(shí) snappy 和 deflate。
deflate_level (nsqd v0.2.23+) 配置 deflate 壓縮這次連接的級(jí)別

--max-deflate-level (nsqd 標(biāo)志位) 配置允許的最大值

有效范圍: 1 <= deflate_level <= configured_max

值越高壓縮率越好，但是 CPU 負(fù)載也高。
sample_rate (nsqd v0.2.25+) 投遞此次連接的消息接收率。

有效范圍: 0 <= sample_rate <= 99 (0 禁用)

默認(rèn)值 0
user_agent (nsqd v0.2.25+) 這個(gè)客戶端的代理字符串

默認(rèn)值: <client_library_name>/<version>
msg_timeout (nsqd v0.2.28+) 配置服務(wù)端發(fā)送消息給客戶端的超時(shí)時(shí)間

成功后響應(yīng)：

OK

注意: 如果客戶端發(fā)送了 feature_negotiation (并且服務(wù)端支持)，響應(yīng)體將會(huì)是 JSON。

錯(cuò)誤后的響應(yīng)內(nèi)容:

E_INVALID
E_BAD_BODY

SUB

訂閱話題（topic) /通道（channel)

SUB <topic_name> <channel_name>\n

<topic_name> - 字符串 (建議包含 #ephemeral 后綴)
<channel_name> - 字符串 (建議包含 #ephemeral 后綴)

成功后響應(yīng):

OK

錯(cuò)誤后響應(yīng):

E_INVALID
E_BAD_TOPIC
E_BAD_CHANNEL

PUB

發(fā)布一個(gè)消息到 話題（topic):

PUB <topic_name>\n
[ 4-byte size in bytes ][ N-byte binary data ]

<topic_name> - 字符串 (建議 having #ephemeral suffix)

成功后響應(yīng):

OK

錯(cuò)誤后響應(yīng):

E_INVALID
E_BAD_TOPIC
E_BAD_MESSAGE
E_PUB_FAILED

MPUB

發(fā)布多個(gè)消息到 話題（topic) (自動(dòng)):

注意: nsqd v0.2.16+ 有效

MPUB <topic_name>\n
[ 4-byte body size ]
[ 4-byte num messages ]
[ 4-byte message #1 size ][ N-byte binary data ]
      ... (repeated <num_messages> times)

<topic_name> - 字符串 (建議 having #ephemeral suffix)

成功后響應(yīng):

OK

錯(cuò)誤后響應(yīng):

E_INVALID
E_BAD_TOPIC
E_BAD_BODY
E_BAD_MESSAGE
E_MPUB_FAILED

RDY

更新 RDY 狀態(tài) (表示你已經(jīng)準(zhǔn)備好接收N 消息)

注意: nsqd v0.2.20+ 使用 --max-rdy-count 表示這個(gè)值

RDY <count>\n

<count> - a string representation of integer N where 0 < N <= configured_max

注意: 這個(gè)沒有成功后響應(yīng)

錯(cuò)誤后響應(yīng):

E_INVALID

FIN

完成一個(gè)消息 (表示成功處理)

FIN <message_id>\n

<message_id> - message id as 16-byte hex string

注意: 這里沒有成功后響應(yīng)

錯(cuò)誤后響應(yīng):

E_INVALID
E_FIN_FAILED

REQ

重新將消息隊(duì)列（表示處理失?。?/p>

這個(gè)消息放在隊(duì)尾，表示已經(jīng)發(fā)布過，但是因?yàn)楹芏鄬?shí)現(xiàn)細(xì)節(jié)問題，不要嚴(yán)格信賴這個(gè)，將來會(huì)改進(jìn)。

簡單來說，消息在傳播途中，并且超時(shí)就表示 REQ。

REQ <message_id> <timeout>\n

<message_id> - message id as 16-byte hex string
<timeout> - a string representation of integer N where N <= configured max timeout
    0 is a special case that will not defer re-queueing

注意: 這里沒有成功后響應(yīng)

錯(cuò)誤后響應(yīng):

E_INVALID
E_REQ_FAILED

TOUCH

重置傳播途中的消息超時(shí)時(shí)間

注意: 在 nsqd v0.2.17+ 可用

TOUCH <message_id>\n

<message_id> - the hex id of the message

注意: 這里沒有成功后響應(yīng)

錯(cuò)誤后響應(yīng):

E_INVALID
E_TOUCH_FAILED

CLS

清除連接（不再發(fā)送消息）

CLS\n

成功后響應(yīng)s:

CLOSE_WAIT

錯(cuò)誤后響應(yīng):

E_INVALID

NOP

No-op

NOP\n

注意: 這里沒有 response

AUTH

注意: 在 nsqd v0.2.29+ 可用

如果 IDENTIFY 響應(yīng)中有 auth_required=true，客戶端必須在 SUB, PUB 或 MPUB 命令前前發(fā)送 AUTH 。否則，客戶端不需要認(rèn)證。

當(dāng) nsqd 接收到 AUTH 命令，它通過執(zhí)行 HTTP 配置 --auth-http-address ，這個(gè)請求包括以下查詢參數(shù)：連接的遠(yuǎn)程地址，TLS 狀態(tài)，支持的認(rèn)證密碼。更多細(xì)節(jié)參見：AUTH

AUTH\n
[ 4-byte size in bytes ][ N-byte Auth Secret ]

成功后響應(yīng):

JSON 包含授權(quán)給客戶端的身份，可選的 URL，和授權(quán)過的權(quán)限列表。

{"identity":"...", "identity_url":"...", "permission_count":1}

錯(cuò)誤后響應(yīng):

E_AUTH_FAILED - An error occurred contacting an auth server
E_UNAUTHORIZED - No permissions found

數(shù)據(jù)格式

數(shù)據(jù)異步傳輸給客戶端，并且支持各種回復(fù)體，比如

[x][x][x][x][x][x][x][x][x][x][x][x]...
|  (int32) ||  (int32) || (binary)
|  4-byte  ||  4-byte  || N-byte
------------------------------------...
    size     frame type     data

客戶端必須是以下類型之一：

FrameTypeResponse int32 = 0
FrameTypeError    int32 = 1
FrameTypeMessage  int32 = 2

以及消息格式:

[x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x]...
|       (int64)        ||    ||      (hex string encoded in ASCII)           || (binary)
|       8-byte         ||    ||                 16-byte                      || N-byte
------------------------------------------------------------------------------------------...
  nanosecond timestamp    ^^                   message ID                       message body
                       (uint16)
                        2-byte
                       attempts

在线观看不卡亚洲电影_亚洲妓女99综合网_91青青青亚洲娱乐在线观看_日韩无码高清综合久久

TCP 協(xié)議規(guī)范

注意

命令

IDENTIFY

SUB

PUB

MPUB

RDY

FIN

REQ

TOUCH

CLS

NOP

AUTH

數(shù)據(jù)格式