centos环境搭建nsq单点

简言

下载

启动nsq(单节点)

        1. 启动nsqd

        2. 启动nsqlookupd

        3. 启动nsqadmin

查看状态


简言

1. nsq是go语言实现的分布式消息处理平台,类似我们常用的kafka,rocket mq等,目的是用来大规模地处理每天数以十亿计级别的消息。它具有分布式和去中心化拓扑结构,该结构具有无单点故障、故障容错、高可用性以及能够保证消息的可靠传递的特征

2. nsq官网地址 https://nsq.io/

3. nsq安装包地址 NSQ Docs 1.2.1 - Installing

4. nsq分为3种服务进程

    nsqd: 负责接收消息,消息排队、重试、持久化,推送消息给客户端,可以有多个

    nsqlookupd: 负责管理各个nsqd,存储nsqd的元数据和服务信息,客户端(我们的程序)就是通过查询 nsqlookupd来实现服务发现,可以有多个

    nsqadmin: 方便我们查看、管理nsq的UI网页工具,汇总nsq的实时统计,一般1个就够了

下载

1. 打开上面的nsq安装包地址,可以看到各个系统,各个版本的nsq安装包,当前最新版本是nsq-1.2.1,我是centos系统,所以下载 nsq-1.2.1.linux-amd64.go1.16.6.tar.gz,如下图

 2. 下载到我们的电脑上,放在/soft目录下,这个目录专门存放我们的软件,如下图

 3. 运行命令 tar -zxvf nsq-1.2.1.linux-amd64.go1.16.6.tar.gz 解压到当前目录,然后

cd到目录 nsq-1.2.1.linux-amd64.go1.16.6/bin,可以看到内容如下图

启动nsq(单节点)

1. 启动nsqd

命令如下,192.168.136.129是本机IP,参数 --lookupd-tcp-address=192.168.136.129:4160 表示要连接的nsqlookupd的地址是192.168.136.129:4160

nohup ./nsqd --lookupd-tcp-address=192.168.136.129:4160 &

  nsqd会默认监听4150端口(tcp使用),4151端口(http使用)  ,可以使用lsof 命令看到这两个端口已经被nsqd监听  

2. 启动nsqlookupd

nohup ./nsqlookupd &

nsqlookupd会默认监听本地的4160端口(tcp使用),4161端口(http使用)。其中4160端口是给各个nsqd连接用的,也就解释了为什么步骤1中要连这个地址了。当然也可以通过指定参数-tcp-address=xxxx 和 -http-address=xxxx来监听其他端口

监听如下图

3. 启动nsqadmin

nohup ./nsqadmin --lookupd-http-address=192.168.136.129:4161 &

注意:nsqadmin必须明确指定参数lookupd-http-address,这样它才知道要通讯的nsqlookup地址,nsqadmin会默认监听本地的4171端口,我们在浏览器上访问的就是这个地址

查看状态

我们查看下刚才启动的各个nsq进程,如下图

 打开浏览器,地址输入http://192.168.136.129:4171/ 

其中192.168.136.129:4171就是刚才nsqadmin监听的地址,如下图

 这个时候还没有topic(主题),也没有channel(监听通道)

点击页面的Nodes,可以查看所有的nsq节点,此时只有一个节点,就是刚才启动的nsq进程,如下图

点击页面的Lookup,可以查看所有的nsqlookup节点,此时也是只有一个节点,也就是刚才启动的,如下图

下一篇博客我们讲如何搭建nsq集群

linux环境搭建nsq集群_YZF_Kevin的博客-CSDN博客

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/3085.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Java集合工具:列表查找之position和find

操作集合时&#xff0c;查找列表中的元素是常见操作&#xff0c;本文记录两个平常使用的List查找工具方法。 使用示例 Testpublic void testPositionAndFind() {List<Integer> list Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);//查找list中2的下标&#xff0c;不存…

如何用Jmeter做性能测试

目录 性能测试的概念 性能测试类型 性能测试应用场景&#xff08;领域&#xff09; 性能测试常用的指标 性能测试流程 需求分析 搭建测试环境 测试场景设计 测试用例设计和脚本开发 测试数据准备 性能测试执行和管理 性能测试结果分析与调优 测试报告和跟踪 性能测…

AtcoderABC244场

A - Last LetterA - Last Letter 题目大意 给定一个长度为N的字符串S&#xff0c;由小写英文字母组成&#xff0c;打印出S的最后一个字符。 思路分析 题目要求打印出字符串S的最后一个字符&#xff0c;可以直接通过访问S的最后一个元素来获取该字符。可以使用字符串的back()…

用Arthas快速定位线上JVM问题!

Arthas分析FullGC问题定位 对于FullGC那一定不会陌生,一般来说会采用横切FullGC前置拦截(-XX:+HeapDumpBeforeFullGC)和后置拦截(-XX:+HeapDumpAfterFullGC),导出FullGC发生前后的heap dump文件,以便于我们进行FullGC原因的分析和定位。 推测分析问题之FullGC的频率过高…

unity背景缓动动效

这算是一个很常见的小功能&#xff0c;比如我们在玩横版游戏的时候&#xff0c;背景动画会以一定的频率运动&#xff0c;其实现方式也有很多种。 比如&#xff0c;使用UGUI的imageanimtion动画的方式&#xff0c;自己k桢实现。 还可以使用材质球本身的功能来实现&#xff0c;关…

WPF 自定义控件完成库容表盘显示效果

先看一下显示效果&#xff1a; 需要注意的地方有以下几点&#xff1a; 表盘的刻度分部&#xff0c;长刻度和短刻度显示。在数值80W时&#xff0c;需要更改刻度盘的颜色渐变。在数值80W时&#xff0c;更改库容总数背景的显示&#xff0c;也是颜色渐变。刻度盘控件属性定义&…

HarmonyOS课程体验官招募(第四期),寻找乐于分享,精益求精的伙伴

华为开发者联盟HarmonyOS课程体验官&#xff08;第四期&#xff09;活动&#xff0c;开始招募啦&#xff01; 如果你精益求精、乐于分享&#xff1b;如果你愿意为学堂课程优化改进出谋划策&#xff0c;那就快来加入我们吧&#xff01;学堂期待与你共同成长、一起进步&#xff0…

11、动手学深度学习——语言模型和数据集:代码详解

我们了解了如何将文本数据映射为词元&#xff0c;以及将这些词元可以视为一系列离散的观测&#xff0c;例如单词或字符。 假设长度为 T T T的文本序列中的词元依次为 x 1 , x 2 , … , x T x_1, x_2, \ldots, x_T x1​,x2​,…,xT​。于是&#xff0c; x t x_t xt​&#xff08…

如何在Linux中配置网络?

在 Linux 中配置网络可以通过多种方式进行&#xff0c;以下是其中几种常见的方法&#xff1a; 使用网络管理工具&#xff1a; 大多数常见的 Linux 发行版都提供了图形界面的网络管理工具&#xff0c;如 NetworkManager 或 systemd-networkd。这些工具通常集成在系统设置&#x…

git常用命令汇总

git init: 初始化一个新的Git仓库。在项目目录中执行该命令&#xff0c;将创建一个空的Git仓库&#xff0c;用于版本控制。git clone <repository>: 克隆&#xff08;Clone&#xff09;一个远程仓库到本地。将远程仓库的代码完整地复制到本地&#xff0c;可以是一个公共的…

GPT与人类:人工智能是否能够真正复制人类语言?

人类语言是一种复杂的系统&#xff0c;它不仅包含着无数单词和语法规则&#xff0c;更重要的是具有丰富的含义和上下文。这些语言特征涉及到常识、文化、情感和经验等方面&#xff0c;是人类在长期进化和文明发展中所积累起来的丰富知识和经验的体现。然而&#xff0c;人工智能…

C/C++学习资料推荐

语言学习 C程序设计语言&#xff08; Dennis M. Ritchie 和Brian W. Kernighan&#xff09; C语言程序设计现代方法 C陷阱与缺陷 C Primer &#xff08;这本书是久负盛名的 C 经典教程。书是有点厚&#xff0c;前面 1/3 讲 C 语言&#xff0c;后面讲 C。C 的知识点实在是太多了…

ThreadLocal---线程Thread的局部变量

什么是ThreadLocal? 1、前言 在学习ThreadLocal之前&#xff0c;我们需要先确认一个事情&#xff0c;就是客户端发送的每次http请求&#xff0c;对应的在服务端都会分配一个新的线程来处理&#xff0c;在处理过程中涉及到下面类中的方法都属于相同的一个线程: LoginCheckFi…

SpringCloud学习路线(7)—— 统一网关Gateway

一、引言 &#xff08;一&#xff09;需求&#xff1a; 服务器中的微服务只允许内部人员调用或是内网人员进行调用&#xff0c;拒绝外网人员访问。 &#xff08;二&#xff09;如何实现需求&#xff1f; 网关 &#xff08;三&#xff09;网关的功能 身份认证和权限校验服务…

TJUACM假期集训个人赛(八)(cf789a-c cf791a-c)

这场打一半回宿舍有点事润了&#xff0c;态度不端正&#xff0c;下次改正 A. Anastasia and pebbles 题面 签到题&#xff0c;枚举每类石头即可&#xff0c; w a wa wa了一次因为判断错了&#xff0c;分两天取是 > k >k >k,不是 ≥ k \ge k ≥k #include<bits/s…

uniapp scroll-view滑到底部加载更多数据

官网 必须设置下面两个属性 1. scroll-y"true" 2. height:90vh; //lowerBottom触底事件 <scroll-view scrolltolower"lowerBottom" style"height:90vh;" scroll-y"true">//list:展示的数据<view class"list" v-f…

java线上故障排查套路总结

线上故障主要会包括cpu、磁盘、内存以及网络问题&#xff0c;而大多数故障可能会包含不止一个层面的问题&#xff0c;所以进行排查时候尽量四个方面依次排查一遍。同时例如jstack、jmap等工具也是不囿于一个方面的问题的&#xff0c;基本上出问题就是df、free、top 三连&#x…

Principle Component Analysis

简述PCA的计算过程 输入&#xff1a;数据集X{x1&#xff0c;x2&#xff0c;...&#xff0c;xn}&#xff0c;需降到k维 ① 去中心化&#xff08;去均值&#xff0c;即每个特征减去各自的均值&#xff09; ② 计算协方差矩阵1/nX*X^T&#xff08;1/n不影响特征向量&#xff09…

day39-Oracle分区表

0目录 Oracle分区表 1.2.3 1. Oracle分区表 1.1 作用&#xff1a; Oracle数据库的分区把表中的数据行按照分区划成几个区域&#xff0c;提高大数据量下表的性能 1.2 应用场景&#xff1a;常应用于数据量大的表 1.3 分类&#xff1a;Oracle中有范围分区&#xff08;最常见…

vue使用docxtemplater导出word实现使用textarea输入的内容换行

注:本文只做导出word并且换行操作&#xff0c;不做vue引入docxtemplater步骤 先看一下实现效果 这是文本域输入的 这是导出来的结果 可以看出来导出来的结果也是换行的呢 接下来我们手摸手操作一下流程 首先咱们捋一捋思路 知道文本域的换行的换行标识符&#xff0c;我们发…