管理
一旦 JetStream 集群运行，与 CLI 和 nats CLI 的交互与以前相同。对于这些示例，让我们假设我们有一个 5 服务器集群，n1-n5，位于名为 C1 的集群中。
账户级别
Within an account there are operations and reports that show where users data is placed and which allow them some basic interactions with the RAFT system.
创建集群流
使用 nats CLI 添加流时，将询问副本数量，当您选择大于 1 的数字时（我们建议 1、3 或 5），数据将使用上述 RAFT 协议存储在集群中的多个节点上。
nats str add ORDERS --replicas 3
示例输出提取：
....
Information for Stream ORDERS created 2021-02-05T12:07:34+01:00
....
Configuration:
....
Replicas: 3
Cluster Information:
Name: C1
Leader: n1-c1
Replica: n4-c1, current, seen 0.07s ago
Replica: n3-c1, current, seen 0.07s ago
上面您可以看到，在所有显示流信息的情况下（例如添加后或使用 nats stream info）都会报告集群信息。
这里我们在 NATS 集群 C1 中有一个流，其当前领导者是节点 n1-c1，它有 2 个跟随者 - n4-c1 和 n3-c1。
current 表示跟随者是最新的并且拥有所有消息，这里两个集群对等节点都是最近看到的。
副本数量一旦配置就无法编辑。
查看流放置和统计信息
用户可以获取关于其流的总体统计信息以及这些流放置的位置：
Obtaining Stream stats
+----------+-----------+----------+--------+---------+------+---------+----------------------+
| Stream | Consumers | Messages | Bytes | Storage | Lost | Deleted | Cluster |
+----------+-----------+----------+--------+---------+------+---------+----------------------+
| ORDERS | 4 | 0 | 0 B | File | 0 | 0 | n1-c1*, n2-c1, n3-c1 |
| ORDERS_3 | 4 | 0 | 0 B | File | 0 | 0 | n1-c1*, n2-c1, n3-c1 |
| ORDERS_4 | 4 | 0 | 0 B | File | 0 | 0 | n1-c1*, n2-c1, n3-c1 |
| ORDERS_5 | 4 | 0 | 0 B | File | 0 | 0 | n1-c1, n2-c1, n3-c1* |
| ORDERS_2 | 4 | 1,385 | 13 MiB | File | 0 | 1 | n1-c1, n2-c1, n3-c1* |
| ORDERS_0 | 4 | 1,561 | 14 MiB | File | 0 | 0 | n1-c1, n2-c1*, n3-c1 |
+----------+-----------+----------+--------+---------+------+---------+----------------------+
强制流和消费者领导者选举
每个 RAFT 组都有一个领导者，在需要时由组选举产生。通常没有理由干扰这个过程，但您可能希望在方便的时候触发领导者变更。领导者选举将代表对流的短暂中断，因此如果您知道稍后将在节点上工作，可能值得提前将领导权移开。
将领导权从节点移开不会将其从集群中移除，也不会阻止其再次成为领导者，这仅仅是一个触发的领导者选举。
nats stream cluster step-down ORDERS
14:32:17 Requesting leader step down of "n1-c1" in a 3 peer RAFT group
14:32:18 New leader elected "n4-c1"
Information for Stream ORDERS created 2021-02-05T12:07:34+01:00
...
Cluster Information:
Name: c1
Leader: n4-c1
Replica: n1-c1, current, seen 0.12s ago
Replica: n3-c1, current, seen 0.12s ago
对于消费者也是如此，nats consumer cluster step-down ORDERS NEW。
系统级别
系统用户可以查看元组的状态 - 但不能查看单个流或消费者。
查看集群状态
我们有集群状态的高级报告：
nats server report jetstream --user admin --password s3cr3t!
+--------------------------------------------------------------------------------------------------+
| JetStream Summary |
+--------+---------+---------+-----------+----------+--------+--------+--------+---------+---------+
| Server | Cluster | Streams | Consumers | Messages | Bytes | Memory | File | API Req | API Err |
+--------+---------+---------+-----------+----------+--------+--------+--------+---------+---------+
| n3-c2 | c2 | 0 | 0 | 0 | 0 B | 0 B | 0 B | 1 | 0 |
| n3-c1 | c1 | 6 | 24 | 2,946 | 27 MiB | 0 B | 27 MiB | 3 | 0 |
| n2-c2 | c2 | 0 | 0 | 0 | 0 B | 0 B | 0 B | 3 | 0 |
| n1-c2 | c2 | 0 | 0 | 0 | 0 B | 0 B | 0 B | 14 | 2 |
| n2-c1 | c1 | 6 | 24 | 2,946 | 27 MiB | 0 B | 27 MiB | 15 | 0 |
| n1-c1* | c1 | 6 | 24 | 2,946 | 27 MiB | 0 B | 27 MiB | 31 | 0 |
+--------+---------+---------+-----------+----------+--------+--------+--------+---------+---------+
| | | 18 | 72 | 8,838 | 80 MiB | 0 B | 80 MiB | 67 | 2 |
+--------+---------+---------+-----------+----------+--------+--------+--------+---------+---------+
+---------------------------------------------------+
| RAFT Meta Group Information |
+-------+--------+---------+---------+--------+-----+
| Name | Leader | Current | Offline | Active | Lag |
+-------+--------+---------+---------+--------+-----+
| n1-c1 | yes | true | false | 0.00s | 0 |
| n1-c2 | | true | false | 0.05s | 0 |
| n2-c1 | | true | false | 0.05s | 0 |
| n2-c2 | | true | false | 0.05s | 0 |
| n3-c1 | | true | false | 0.05s | 0 |
| n3-c2 | | true | false | 0.05s | 0 |
+-------+--------+---------+---------+--------+-----+
这是一个完整的集群范围报告，可以使用 --account 将报告限制到特定账户。
这里我们看到流、消息、API 调用等在 2 个超级集群中的分布情况以及 RAFT 元组的概述。
在元组报告中，服务器 n2-c1 不是最新的，已经有 9 秒没有被看到，它还落后 2 个 raft 操作。
此报告是使用原始数据构建的，可以从监控端口上的 /jsz url 获取，或通过 nats 使用：
nats server req jetstream --user admin --password s3cr3t! --help
usage: nats server request jetstream [<flags>] [<wait>]
Show JetStream details
Flags:
-h, --help Show context-sensitive help (also try --help-long and --help-man).
--version Show application version.
-s, --server=NATS_URL NATS server urls
--user=NATS_USER Username or Token
--password=NATS_PASSWORD Password
--creds=NATS_CREDS User credentials
--nkey=NATS_NKEY User NKEY
--tlscert=NATS_CERT TLS public certificate
--tlskey=NATS_KEY TLS private key
--tlsca=NATS_CA TLS certificate authority chain
--timeout=NATS_TIMEOUT Time to wait on responses from NATS
--js-api-prefix=PREFIX Subject prefix for access to JetStream API
--js-event-prefix=PREFIX Subject prefix for access to JetStream Advisories
--js-domain=DOMAIN JetStream domain to access
--context=CONTEXT Configuration context
--trace Trace API interactions
--limit=2048 Limit the responses to a certain amount of records
--offset=0 Start at a certain record
--name=NAME Limit to servers matching a server name
--host=HOST Limit to servers matching a server host name
--cluster=CLUSTER Limit to servers matching a cluster name
--tags=TAGS ... Limit to servers with these configured tags
--account=ACCOUNT Show statistics scoped to a specific account
--accounts Include details about accounts
--streams Include details about Streams
--consumer Include details about Consumers
--config Include details about configuration
--leader Request a response from the Meta-group leader only
--all Include accounts, streams, consumers and configuration
Args:
[<wait>] Wait for a certain number of responses
nats server req jetstream --user admin --password s3cr3t! --leader
这将产生关于集群当前状态的大量原始信息 - 这里仅从领导者请求它。
强制元组领导者选举
与上面的流和消费者类似，元组允许领导者卸任。元组是集群范围的，跨越所有账户，因此要管理元组，您必须使用 SYSTEM 用户。
nats server raft step-down --user admin --password s3cr3t!
17:44:24 Current leader: n2-c2
17:44:24 New leader: n1-c2
驱逐对等节点
通常在关闭 NATS 时，包括使用跛脚鸭模式，集群会注意到这一点并继续运行。一个 5 节点集群可以承受 2 个节点宕机。
但可能有一种情况，您知道一台机器永远不会返回（重新上线），并且您想向 JetStream 发出信号，表明该机器不会返回。这将从相关流及其所有消费者中移除它。
节点被移除后，集群会注意到副本数量不再被遵守，并将立即选择新节点并开始向其复制数据。新节点将使用与现有流相同的放置规则进行选择。
nats stream cluster peer-remove ORDERS
? Select a Peer n4-c1
14:38:50 Removing peer "n4-c1"
14:38:50 Requested removal of peer "n4-c1"
此时，流和所有消费者都将从组中移除 n4-c1，它们都将开始新的对等节点选择和数据复制。
$ nats stream info ORDERS
....
Cluster Information:
Name: c1
Leader: n3-c1
Replica: n1-c1, current, seen 0.02s ago
Replica: n2-c1, outdated, seen 0.42s ago
我们可以看到选择了一个新的副本，流重新回到了复制级别 3，并且 n4-c1 在此流或其任何消费者中不再活跃。