NSQ是一个基于Go语言的分布式实时消息平台,它基于MIT开源协议发布,代码托管在GitHub。NSQ可用于大规模系统中的实时消息服务,并且每天能够处理数亿级别的消息,其设计目标是为在分布式环境下运行的去中心化服务提供一个强大的基础架构。
NSQ具有分布式、去中心化的拓扑结构,该结构具有无单点故障、故障容错、高可用性以及能够保证消息的可靠传递的特征。NSQ非常容易配置和部署,且具有最大的灵活性,支持众多消息协议。另外,官方还提供了拆箱即用Go和Python库。如果读者兴趣构建自己的客户端的话,还可以参考官方提供的协议规范。

一. 搭建主NSQ服务

1. 创建主服务器(虚拟机)

IP: 192.168.0.210

2. 拉取NSQ镜像

> docker pull nsqio/nsq  #拉取nsq镜像
> docker images          #查看nsq镜像

3. 启动nsqlookupd服务

> docker run -d --name lookupd -p 4160:4160 -p 4161:4161 nsqio/nsq:latest /nsqlookupd> #docker exec -ti lookupd /bin/sh    #进入容器,查看nsq目录结构
> #docker rm -f `docker ps -qa`       #删除所有容器

最重要的服务,是整个集群的总控室,包括服务发现和节点拓扑信息的管理。nsqlookupd有以下特点:

  1. 唯一性,在集群中的节点只能指向唯一的nsqlookupd服务
  2. 去中心化,即使nsqlookupd崩溃,也会不影响正在运行的nsqd服务
  3. 充当nsqd和naqadmin信息交互的中间件
  4. 提供一个http查询服务,给客户端定时更新nsqd的地址目录

4. 启动nsqadmin管理系统

> docker run -d --name nsqadmin -p 4171:4171 nsqio/nsq /nsqadmin --lookupd-http-address=192.168.0.210:4161

nsqadmin可以部署在任何一个安装有nsq服务的机器上,只需要指定唯一的lookupd-http-address服务IP地址

浏览器打开:http://192.168.0.210:4171/ ,此时的NSQd Nodes为空

二. 部署NSQd节点服务

1.在主服务器(192.168.0.210)上开启一个nsqd节点服务

> docker run -d --name nsqd -p 4150:4150 -p 4151:4151 nsqio/nsq:latest /nsqd --broadcast-address=192.168.0.210 --lookupd-tcp-address=192.168.0.210:4160

2.创建从服务器(IP:192.168.0.159),拉取镜像docker pull nsqio/nsq,启动一个nsqd服务,此时已有两个nsqd节点

> docker run -d --name nsqd -p 4150:4150 -p 4151:4151 nsqio/nsq:latest /nsqd --broadcast-address=192.168.0.159 --lookupd-tcp-address=192.168.0.210:4160

--broadcast-address:当前服务器IP地址,--lookupd-tcp-address:指向的lookupd服务器IP地址

三. 测试

1.打开任意一个shell终端,执行:

> curl -d 't1' 'http://192.168.0.210:4151/pub?topic=p1' #一个topic可多次添加
> curl -d 't2' 'http://192.168.0.210:4151/pub?topic=p2' 
> curl -d 't1' 'http://192.168.0.159:4151/pub?topic=q1'
> curl -d 't2' 'http://192.168.0.159:4151/pub?topic=q2'
> curl -d 't3' 'http://192.168.0.159:4151/pub?topic=q3' 

2.nsqlookupd奔溃测试(在主服务器):

> docker stop lookupd  #停止nsqlookupd服务
> curl -d 'tpp' 'http://192.168.0.210:4151/pub?topic=pp'  # topic可以正常发布
> docker stop nsqd #停止nsqd服务
> curl -d 'tpp' 'http://192.168.0.210:4151/pub?topic=pp'  # topic可以正常发布
#显式: curl: (7) Failed connect to 192.168.0.210:4151; 拒绝连接

参考:
https://www.cnblogs.com/li-peng/p/7729174.html

转载于:https://www.cnblogs.com/Hollson/p/9160718.html

Docker搭建NSQ实时分布式消息集群相关推荐

  1. Docker 搭建elasticsearch 7.6.x集群

    Docker 搭建elasticsearch 7.6.x集群 文章目录 拉取镜像 设置Elasticsearch挂载目录 编写elasticsearch.yml配置文件 node-1 node-2 n ...

  2. 使用Docker搭建高可用Mysql数据库集群

    文章目录 前言 正文 选择哪一种搭建集群的方式 PXC Replication 安装docker Docker操作的基本命令 安装PXC集群 负载均衡 双机热备 具体实现细节 安装keepalived ...

  3. 基于Docker搭建Percona XtraDB Cluster数据库集群

    本文实验的环境参数 阿里云ECS Centos7.5 Docker version 18.06.0-ce percona/percona-xtradb-cluster:5.7 Percona Xtra ...

  4. 学习Docker容器网络模型 - 搭建分布式Zookeeper集群

    ZooKeeper是一个流行的分布式协调服务.它提供了两种不同的部署方式:单机模式和分布式模式.其中单机模式的部署非常简单,网上也有很多资料,我们今天会利用Docker搭建分布式Zookeeper集群 ...

  5. 搭建高吞吐量 Kafka 分布式发布订阅消息 集群

    搭建高吞吐量 Kafka 分布式发布订阅消息 集群 简介 Kafka 是一种高吞吐的分布式发布订阅消息系统,能够替代传统的消息队列用于解耦合数据处理,缓存未处理消息等,同时具有更高的吞吐率,支持分区. ...

  6. 使用Docker Swarm搭建分布式爬虫集群

    转载自  使用Docker Swarm搭建分布式爬虫集群 在爬虫开发过程中,你肯定遇到过需要把爬虫部署在多个服务器上面的情况.此时你是怎么操作的呢?逐一SSH登录每个服务器,使用git拉下代码,然后运 ...

  7. [416]使用Docker Swarm搭建分布式爬虫集群

    在爬虫开发过程中,你肯定遇到过需要把爬虫部署在多个服务器上面的情况.此时你是怎么操作的呢?逐一SSH登录每个服务器,使用git拉下代码,然后运行?代码修改了,于是又要一个服务器一个服务器登录上去依次更 ...

  8. 搭建基于Docker社区版的Kubernetes本地集群

    搭建基于Docker社区版的Kubernetes本地集群 原文:搭建基于Docker社区版的Kubernetes本地集群 Kubernetes的本地集群搭建是一件颇费苦心的活,网上有各种参考资源,由于 ...

  9. 【Docker之Swarm详细讲解Swarm集群搭建管理节点工作节点Raft一致性协议overlay网络Docker结合Swarm部署WordPress个人博客实战】

    一.知识回顾 之前的内容都帮你整理好了,在这里哟! [0.Docker相关目录文章整理,可自行查看,包含多节内容] [1.Docker详细安装部署&阿里镜像地址配置] [2.Docker架构& ...

最新文章

  1. JAVA web项目转客户端(nativefier)
  2. Vim Vundle 插件管理器
  3. spring访问oracle函数,spring调用带参数的oracle函数应注意的问题
  4. VC++编译libpng
  5. OpenCASCADE绘制测试线束:拓扑命令之拓扑和曲面创建
  6. 在自己的电脑上搭建服务器(可供对外访问)
  7. django配置mysql
  8. 小技巧 ----- Java中的进制转换
  9. docker CEEE版本centos安装
  10. 常见的传输线阻抗计算软件(轉自笨笨熊的屋屋)
  11. 闲鱼服务端架构演进历程
  12. 一次 ASAN 找不到 symbolizer 问题的分析与解决
  13. Congfu Xu's HomePage
  14. 客户沟通的方式:礼貌待客沟通方式,技巧推广沟通方式,个性服务沟通方式
  15. 腾讯云DDoS攻击防护指南
  16. 尚硅谷智慧校园-SpringBoot最佳入手级项目
  17. U盘图标更改 简单三步教你个性化定制U盘图标!自定义修改你的U盘
  18. android横向卡片式布局,创建卡片式布局  |  Android 开发者  |  Android Developers
  19. tecplot入门实践案例
  20. 孕妇好的软件有哪些 孕妇软件哪个好 孕妇软件

热门文章

  1. win7可以安装sqlserver2008 企业版吗_MYSQLServer2008R2详细的图文安装教程
  2. cap流程图_化工工艺流程图制图图例汇编.pdf
  3. 编写jmeter测试用例_Jmeter性能测试系列篇(十)--批量用例执行结果检查设置
  4. 计数排序Counting sort
  5. URAL 2045 Richness of words (回文子串,贪心)
  6. python随机验证码函数
  7. js jQuery取消添加超链接的方法小结
  8. C#关于伪静态页面的两种实现方法
  9. poj 3411 1724
  10. c#中Show和Showdialog的区别分析