草庐IT

Golang 和 NSQ(位)

coder 2023-06-26 原文

这里有点菜鸟，但我似乎无法在任何地方找到任何示例或帮助。我有一个 NSQ 的工作实例，可以注册任务、消费者等。不幸的是我最初没有设置系统。我想做的是找出如何激活 NSQ 提供的一些内置命令行工具(nsq_to_file、nsq_tail 等)。我找到了关于如何发射它们的文档，但不知道从哪里发射它们。

当我尝试 nsq_tail --channel=MyTestChannel --topic=test --lookupd-http-address=127.0.0.1:4161 时，我得到 nsq_tail 命令未找到。我唯一知道的另一件事是，在我们的情况下，NSQ 由 docker 管理。任何帮助/朝着正确方向的插入都会很棒。谢谢!

最佳答案

做了一些挖掘并回答了我自己的问题。希望这对某人有所帮助，因为文档实际上并不存在:

  1. 通过查看仪表板确保 NSQ 正在运行:localhost:4171
  2. 安装 NSQ 库(不同于 nsq-go)go get github.com/bitly/nsq
  3. 安装godep，如何bitly管理依赖go get github.com/tools/godep
  4. 进入bitly src目录 cd $GOPATH/src/github.com/bitly
  5. 使用docker编译测试nsq命令行工具 sudo docker build nsq
    • 您应该会看到运行了大约 5 或 6 个步骤，然后是一系列测试和一条成功消息。
  6. 运行 nsq_tail 你应该看到类似 --topic is required
    7. 的内容
  7. 拍拍手，您刚刚安装了 NSQ 的命令行工具。

如果您没有 docker，可能还需要安装它，上面没有提到，仅供引用。

关于Golang 和 NSQ(位)，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/25577155/

GolangNSQcodesectionligo

有关Golang 和 NSQ(位)的更多相关文章

  1. 华为OD机试Golang解题 - 任务总执行时长 - 2

    华为Od必看系列华为OD机试全流程解析+经验分享,题型分享,防作弊指南）华为od机试，独家整理已参加机试人员的实战技巧华为od2023|什么是华为od，od薪资待遇，od机试题清单华为OD机试真题大全，用Python解华为机试题|机试宝典文章目录华为Od必看系列使用说明本期题目：任务总执行时长题目输入输出示例一输入输出说明go代码实现华为OD其它语言版本

  2. 【编程实践】Golang 获取HTTP请求的IP地址 - 2

    目录Golang获取HTTP请求的IP地址HTTP的发展历史3，HTTP所在的网络层次4，HTTP请求与响应

  3. Golang SQL 查询语法 - 2

    关闭。这个问题需要debuggingdetails.它目前不接受答案。编辑问题以包含desiredbehavior,aspecificproblemorerror,andtheshortestcodenecessarytoreproducetheproblem.这将有助于其他人回答问题。关闭4年前。Improvethisquestion在golang代码中使用sql查询获取语法错误。golang中此SQL查询所需的正确语法:rows,errQuery:=dbCon.Query("SELECTB.LatestDate,A.SVRNameASServerName,A.DRIVE,A.Tot

  4. go - 在golang中的表达式中检查括号是否平衡[保持] - 2

    给定表达式字符串exp，编写程序检查exp中“{”、“}”、“（”、“）”、“[”、“]的对和顺序是否正确。packagemainimport("fmt"stack"github.com/golang-collections/collections/stack")funcmain(){s:="(a[0]+b[2c[6]])){24+53}"stackO:=stack.New()stackmap:=map[string]string{"[":"]","(":")","{":"}"}varstr=""for_,num:=ranges{str=string(num)if(str=="{"||

  5. Golang libphonenumber - 2

    关闭。这个问题是notreproducibleorwascausedbytypos.它目前不接受答案。这个问题是由于错别字或无法再重现的问题引起的。虽然类似的问题可能是on-topic在这里，这个问题的解决方式不太可能帮助future的读者。关闭3年前。Improvethisquestion如何通过使用此库在golang中传递数字来获取国家代码:https://godoc.org/github.com/nyaruka/phonenumbers？

  6. go - func 的语法 Golang 错误 - 2

    为什么下面的代码会抛出意外的函数错误？我看到错误./func_correct.go:4:syntaxerror:unexpectedfunc,expectingnamepackagemainfunc(st*Stack)Pop()int{v:=0forix:=len(st)-1;ix>=0;ix--{ifv=st[ix];v!=0{st[ix]=0returnv}}return0}funcmain(){Pop()} 最佳答案 定义堆栈类型在main中为其创建一个变量对其调用Pop代码:packagemainimport"fmt"typ

  7. go - 进程花费了太长时间程序退出:Golang错误 - 2

    Thisquestionalreadyhasanswershere:ForloopoftwovariablesinGo(3个答案)2年前关闭。我正在通过Gotour在Go中使用for循环我跑的时候packagemainimport"fmt"funcmain(){sum:=1forsum程序运行正常，输出为1024但是当我更改sum:=0时packagemainimport"fmt"funcmain(){sum:=0forsum它给出了错误的说法processtooktoolongProgramexited.编辑:我沉迷于Go巡回赛，以至于我无法意识到，我犯了一个逻辑错误:P。

  8. json - 如何在golang中将结构解码到 map 中 - 2

    关闭。这个问题需要debuggingdetails.它目前不接受答案。编辑问题以包含desiredbehavior,aspecificproblemorerror,andtheshortestcodenecessarytoreproducetheproblem.这将有助于其他人回答问题。关闭4年前。Improvethisquestion我有一个Json:{"id":"me","name":"myname","planets":{"EARTH":3,"MARS":4}}我不知道如何将planets字段解码为map[string]int，所以我将访问元素而无需解码它们，就像在这个例子中一样

  9. mysql - golang MySQL "connection refused" - 2

    我是Go(Golang)的新手。我写了一个简单的基准程序来测试MySQL的并发处理。当我增加并发channel数时，不断收到“dialtcp52.55.254.165:3306:getsockopt:connectionrefused”、“unexpectedEOF”错误。每个go例程都将1到n行批量插入到一个简单的客户表中。该程序允许设置可变插入大小(单个语句中的行数)和并行go例程的数量(每个go例程执行上面的一个插入)。程序在小数字row寻找线索。基于它们，我设置了数据库最大连接数以及“max_allowed_pa​​cket”和“max_connections”。我还设置了go

  10. go - Golang "func (t *SomeType) myFuncName(param1, param2)"语法是什么意思 - 2

    这个问题在这里已经有了答案:Functiondeclarationsyntax:thingsinparenthesisbeforefunctionname(3个答案)WhatsthedifferenceoffunctionsandmethodsinGo?(5个答案)ParameterbeforethefunctionnameinGo?[duplicate](1个回答)WhatdothebracketsafterfuncmeaninGo?[duplicate](1个回答)关闭8个月前。我正在学习Golang-在教程中我经常看到这样的语法:typeSomeTypestruct{//stru

随机推荐