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,一经查实,立即删除!

相关文章

如何用Jmeter做性能测试

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

AtcoderABC244场

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

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

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

unity背景缓动动效

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

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

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

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

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

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

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

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

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

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

一、引言 (一)需求: 服务器中的微服务只允许内部人员调用或是内网人员进行调用,拒绝外网人员访问。 (二)如何实现需求? 网关 (三)网关的功能 身份认证和权限校验服务…

java线上故障排查套路总结

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

Principle Component Analysis

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

day39-Oracle分区表

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

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

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

[深度学习入门]什么是神经网络?[神经网络的架构、工作、激活函数]

目录 一、前言二、神经网络的架构——以手写数字识别三、神经网络的工作1、单输入单输出感知器函数2、二维输入参数3、三维输入参数 四、激活函数1、激活函数2、ReLU激活函数3、非线性激活函数(1)二输入二输出的神经网络的架构(2)…

基于预测控制模型的自适应巡航控制仿真与机器人实现(Matlab代码实现)

目录 💥1 概述 📚2 运行结果 🎉3 参考文献 👨‍💻4 Matlab代码 💥1 概述 自适应巡航控制技术为目前由于汽车保有量不断增长而带来的行车安全、驾驶舒适性及交通拥堵等问题提供了一条有效的解决途径&am…

数据结构(王道)——数据结构之 二叉树的存储结构

一、顺序存储 静态顺序存储 顺序存储的二叉树结构特性: 顺序存储的非完全二叉树特性 不完全二叉树的可能会浪费大量空间,所以一般顺序存储二叉树比较少用。 图示为什么很少用顺序存储来存二叉树 顺序存储的二叉树总结: 二、链式存储 二叉链表…

TCP的三次握手过程

TCP 是面向连接的协议,所以使用 TCP 前必须先建立连接,而建立连接是通过三次握手来进行的。三次握手的过程如下图: 刚开始客户端处于 closed 的状态,服务端处于 listen 状态。 第一次握手:客户端给服务端发一个 SYN 报…

stb_image简单使用

简介stb_image stb_image 是一个非常轻量级的、单文件的图像加载库,用于加载和解码多种图像格式(如BMP、JPEG、PNG、GIF等)的图像数据。它由Sean T. Barrett开发,并以公共领域(Public Domain)许可发布&…

Redis实战案例21-消息队列

1. 基于JVM的阻塞队列的局限 JVM内存限制问题,大量订单出现时,可能会超过JVM阻塞队列上限;阻塞队列并不能持久化,因为内存不能持久化,出现异常或者宕机之类的故障时,出现数据丢失; 所以引出消息…

关于GPT、AI绘画、AI提词器等AI技术的探讨

目前的AI潮流非常火热,CHATGPT可谓是目前大模型人工智能的代表,刚开始听说chatGPT可以写代码,写作,写方案,无所不能。还有AI绘画也很NB作为一个程序员,为了体验这些A&…