NATS_11：NATS集群构建与验证

NATS服务集群化

　　NATS支持每一个服务按照集群模式方式运行。你可以将这些服务组织在一起形成一个集群来提高服务器的容量的消息传递系统，并可以提升整个系统的弹性话和高可用性。

　　注意,NATS集群服务器转发是通过一个跳跃来完成的。这意味着每个gnatsd当从一个客户端接收到消息之后通过路由信息会立即转发给对应注册的gnatsd实例。接收到的消息通过一个路由才会分发给本地的客户。因此一个完整的集群网,或完全图,建议NATS以功能作为目的方式来形象的描述整个过程。

概览

　　除了可以监听一个客户端应用端口,gnatsd还可以监听一个“集群” URL(-cluster 选项)。另外，gnatsd服务器可以将该URL添加到它其中的 -routes 参数用以加入集群。这些选项可以指定在一个配置文件。

　　例如：

　　非集群化的启动

　gnatsd -p 4222 -m 8222

　　一个最简单的集群化启动

  # Server A on 10.10.0.1gnatsd -p 4222 -cluster nats://10.10.0.1:5222# Server B on 10.10.0.2gnatsd -p 4222 -cluster nats://10.10.0.2:5222 -routes nats://10.10.0.1:5222

　　或者采用另外一种方式

   # Server A on 10.10.0.1gnatsd -p 4222 -cluster nats://10.10.0.1:5222 -routes nats://10.10.0.2:5222# Server B on 10.10.0.2gnatsd -p 4222 -cluster nats://10.10.0.2:5222 -routes nats://10.10.0.1:5222

　　客户端连接到集群中的任何一个服务器都将会保持连接到服务器集群,即使它最初的连接被关闭了,只要至少有一个服务器存活那么就可以连上整个集群。

实例

　　首先，下面的例子将会演示如何在同一个主机上运行3个服务器组建的集群。我们将先启动第一个服务并使用 -d 命令行参数产生调试信息

　gnatsd -a 127.0.0.1 -p 4222 -m 8222 -cluster nats://127.0.0.1:4248 -D

　　或者我们使用类似的配置文件实现和上面一样的效果，具体配置文件我们命名为 seed.conf ，内容如下：

# Cluster Seed Node
listen: 127.0.0.1:4222
http: 8222cluster {listen: 127.0.0.1:4248
}

　　那么我们可以通过指定配置文件启动服务，其中 -config 参数可以简写为：-c

　gnatsd -config ./seed.conf -D

　　运行启动服务会产生以下日志内容：

[12064] 2017/04/06 18:58:46.007119 [INF] Starting nats-server version 0.9.6
[12064] 2017/04/06 18:58:46.007215 [DBG] Go build version go1.8
[12064] 2017/04/06 18:58:46.007224 [INF] Starting http monitor on 127.0.0.1:8222
[12064] 2017/04/06 18:58:46.007347 [INF] Listening for client connections on 127.0.0.1:4222
[12064] 2017/04/06 18:58:46.007391 [DBG] Server id is s03C0PiftvdfFO3MnQzrft
[12064] 2017/04/06 18:58:46.007396 [INF] Server is ready
[12064] 2017/04/06 18:58:46.007778 [INF] Listening for route connections on 127.0.0.1:4248

　　接下来让我们启动另外两个服务，它们路由都指向第一个服务

　gnatsd -a 127.0.0.1 -p 5222 -m 8222 -cluster nats://localhost:5248 -routes nats://localhost:4248 -D

　　在同一个主机上运行时,我们需要通过 -p 参数来指定不同的客户端连接端口以及通过参数 -cluster 来指定对应的集群用于接受其他路由。注意,参数 -routes 指定参数 -cluster 地址为第一个服务地址(localhost:4248)
　　查看日志，可以看到它连接和注册一个路由到第一个启动的服务信息

[12083] 2017/04/06 19:17:04.551954 [INF] Starting nats-server version 0.9.6
[12083] 2017/04/06 19:17:04.552038 [DBG] Go build version go1.8
[12083] 2017/04/06 19:17:04.552047 [INF] Starting http monitor on 127.0.0.1:8223
[12083] 2017/04/06 19:17:04.552139 [INF] Listening for client connections on 127.0.0.1:5222
[12083] 2017/04/06 19:17:04.552170 [DBG] Server id is FZz1WSobE9ltpRnRIvVyBx
[12083] 2017/04/06 19:17:04.552174 [INF] Server is ready
[12083] 2017/04/06 19:17:04.552266 [INF] Listening for route connections on localhost:5248
[12083] 2017/04/06 19:17:04.556239 [DBG] Trying to connect to route on localhost:4248
[12083] 2017/04/06 19:17:04.557549 [DBG] 127.0.0.1:4248 - rid:1 - Route connection created
[12083] 2017/04/06 19:17:04.557578 [DBG] 127.0.0.1:4248 - rid:1 - Route connect msg sent
[12083] 2017/04/06 19:17:04.557891 [DBG] 127.0.0.1:4248 - rid:1 - Registering remote route "pC3oopm6SevB2Di1o5L5I3"
[12083] 2017/04/06 19:17:04.557905 [DBG] 127.0.0.1:4248 - rid:1 - Route sent local subscriptions

　　查看第一个服务的日志信息，我们可以看到反馈日志信息

[12069] 2017/04/06 19:17:04.557578 [DBG] 127.0.0.1:63928 - rid:1 - Route connection created
[12069] 2017/04/06 19:17:04.557937 [DBG] 127.0.0.1:63928 - rid:1 - Registering remote route "FZz1WSobE9ltpRnRIvVyBx"
[12069] 2017/04/06 19:17:04.557948 [DBG] 127.0.0.1:63928 - rid:1 - Route sent local subscriptions

　　最后，我们来启动第三个也就是最后一个服务

　gnatsd -a 127.0.0.1 -p 6222 -m 8224 -cluster nats://localhost:6248 -routes nats://localhost:4248 -D

　　当前服务打印日志信息如下

[12092] 2017/04/06 19:21:45.684036 [INF] Starting nats-server version 0.9.6
[12092] 2017/04/06 19:21:45.684123 [DBG] Go build version go1.8
[12092] 2017/04/06 19:21:45.684132 [INF] Starting http monitor on 127.0.0.1:8224
[12092] 2017/04/06 19:21:45.684237 [INF] Listening for client connections on 127.0.0.1:6222
[12092] 2017/04/06 19:21:45.684266 [DBG] Server id is VFCs2SMxmVnkcCKar2eQbq
[12092] 2017/04/06 19:21:45.684270 [INF] Server is ready
[12092] 2017/04/06 19:21:45.684357 [INF] Listening for route connections on localhost:6248
[12092] 2017/04/06 19:21:45.686608 [DBG] Trying to connect to route on localhost:4248
[12092] 2017/04/06 19:21:45.687497 [DBG] 127.0.0.1:4248 - rid:1 - Route connection created
[12092] 2017/04/06 19:21:45.687518 [DBG] 127.0.0.1:4248 - rid:1 - Route connect msg sent
[12092] 2017/04/06 19:21:45.687862 [DBG] 127.0.0.1:4248 - rid:1 - Registering remote route "pC3oopm6SevB2Di1o5L5I3"
[12092] 2017/04/06 19:21:45.687875 [DBG] 127.0.0.1:4248 - rid:1 - Route sent local subscriptions
[12092] 2017/04/06 19:21:45.688174 [DBG] 127.0.0.1:63949 - rid:2 - Route connection created
[12092] 2017/04/06 19:21:45.688414 [DBG] 127.0.0.1:63949 - rid:2 - Registering remote route "FZz1WSobE9ltpRnRIvVyBx"
[12092] 2017/04/06 19:21:45.688426 [DBG] 127.0.0.1:63949 - rid:2 - Route sent local subscriptions

　　再来看第一个服务终端日志打印信息

[12069] 2017/04/06 19:21:45.687523 [DBG] 127.0.0.1:63948 - rid:2 - Route connection created
[12069] 2017/04/06 19:21:45.687829 [DBG] 127.0.0.1:63948 - rid:2 - Registering remote route "VFCs2SMxmVnkcCKar2eQbq"
[12069] 2017/04/06 19:21:45.687842 [DBG] 127.0.0.1:63948 - rid:2 - Route sent local subscriptions

　　而第二个服务终端也会打印出相应连接信息如下

[12083] 2017/04/06 19:21:45.687990 [DBG] Trying to connect to route on 127.0.0.1:6248
[12083] 2017/04/06 19:21:45.688224 [DBG] 127.0.0.1:6248 - rid:2 - Route connection created
[12083] 2017/04/06 19:21:45.688235 [DBG] 127.0.0.1:6248 - rid:2 - Route connect msg sent
[12083] 2017/04/06 19:21:45.688383 [DBG] 127.0.0.1:6248 - rid:2 - Registering remote route "VFCs2SMxmVnkcCKar2eQbq"
[12083] 2017/04/06 19:21:45.688395 [DBG] 127.0.0.1:6248 - rid:2 - Route sent local subscriptions

　　从以上的日志信息可以看出，一个完整的网络NATS集群就已经搭建完毕。

转载于:https://www.cnblogs.com/liang1101/p/6674717.html

NATS_11：NATS集群构建与验证相关推荐

Docker——docker-registry私有仓库集群构建
摘要随着docker使用的镜像越来越多,就需要有一个保存镜像的地方,这就是仓库.目前常用的两种仓库:公共仓库和私有仓库.最方便的就是使用公共仓库上传和下载,下载公共仓库的镜像是不需要注册的,但是上传 ...
KubeSphere——KubeSphere集群构建实战
摘要 KubeSphere 愿景是打造一个以 Kubernetes 为内核的云原生分布式操作系统,它的架构可以非常方便地使第三方应用与云原生生态组件进行即插即用(plug-and-play)的集成,支 ...
Orleans的集群构建
听闻一周前,微软公布了.net core2.0,以及各种各样的其他core2.0.大家都很兴奋.微妈的诚意真是满满的.这次开源势头让我感觉到了微妈的技术实力之雄厚.我在这里祝福C#越来越好.细心的人似 ...
基于YARN集群构建运行PySpark Application
文章转载:https://www.tuicool.com/articles/eaYVN3v Spark Application可以直接运行在YARN集群上,这种运行模式,会将资源的管理与协调统一交给Y ...
kubernetes入门到精通（一）：内容编排与k8s介绍，集群构建教程，如何开启dashboard
集群环境容器部署的困境怎么分配这 10 台服务器?2 万台呢? 容器编排工具 docker compose,单机容器编排工具 docker swam 跨主机的,集群容器编排工具 kubernetes ...
mongodb 集群shard_mongodb集群构建方案（二）
0.创建网段 docker network create mongo 1.编写yaml文件,,这里我命名fates-mongo-compose.yaml 以下这个文件,建立3个mongo shard服 ...
Docker 中的网络管理与集群构建
Docker中的网络与数据管理一.Docker网络管理 1.Docker默认网络管理 docker的网络模式注:docker有三种网络模式,默认的为bridge,配置后可以和宿主机通信,host和 ...
[k8s]jenkins配合kubernetes插件实现k8s集群构建的持续集成
另一个结合harbor自动构建镜像的思路: 即code+baseimage一体的方案 - 程序员将代码提交到代码仓库gitlab - 钩子触发jenkins master启动一次构建 - jenkin ...
MongodDB集群设置登录账号密码（增加key-file以供集群内部相互验证身份）
在部署mongodb集群的时候,有些安全性要求比较高的地方,需要启用密码验证的方式,登录mongo集群. 下面的方式是在mongodb 3.6版本的基础上,3个节点的集群里设置的. 生成集群验证key ...
DockerCompose MongoDB 副本集(集群) （客户端验证密码 - 集群内部使用mongodbKeyfile验证）部署
本部署MongoDB副本集是没有用其他的配置什么的(例如: mongodb-compass).是最简单的一个我是为了mongodb的事务才配置的这个副本集,要使用mongodb的事务必须要副本集. ...

NATS_11：NATS集群构建与验证

NATS服务集群化

概览

实例

NATS_11：NATS集群构建与验证相关推荐

最新文章

热门文章