文档章节

nsqlookupd httpServer 命令分析

智深
 智深
发布于 2014/08/03 11:15
字数 198
阅读 44
收藏 0
这篇文章分析 httpServer 处理什么命令,基本处理过程

路径分类

1、"/ping"     健康检查,返回 “OK”

2、"/lookup”     topic,channel 查询

     reqParams, err := util.NewReqParams(req)
     topicName, err := reqParams.Get("topic”)

     解析请求参数 topic

     registration := s.context.nsqlookupd.DB.FindRegistrations("topic", topicName, “”)
     // 查找 topic,来验证用的,如果 registration 长度为0,提示出错

     channels := s.context.nsqlookupd.DB.FindRegistrations("channel", topicName, "*").SubKeys()
     // 查找 topic 所有的 channel

     producers := s.context.nsqlookupd.DB.FindProducers("topic", topicName, “")
     // 找到所有的生产者

     producers = producers.FilterByActive(s.context.nsqlookupd.options.InactiveProducerTimeout,
          s.context.nsqlookupd.options.TombstoneLifetime)
     // 过滤, 两个超时参数,300s 和 45s


3、"/topics"     查询所有的 topic

4、"/channels"     查询某个 topic 所有的 channel

5、"/nodes"     查找所有的 client,topic

6、"/topic/create”     创建 topic

7、"/topic/delete”     删除 topic 关联的所有的 channel,继而删除 topic

8、"/topic/tombstone”     ? 暂时没看

9、"/channel/create”     创建 channel

10、"/channel/delete”     删除 channel
      

© 著作权归作者所有

智深
粉丝 91
博文 65
码字总数 42744
作品 0
朝阳
程序员
私信 提问
NSQLookupd Main方法分析

上一篇 http://my.oschina.net/astute/blog/296955 已经分析了 nsqlookupd 启动时的命令行解析,最终构造了 NSQLookupd 结构体,这是一个很重要的结构体。 type NSQLookupd struct { options...

智深
2014/08/01
386
0
NSQ系列之nsqlookupd代码分析一(初探nsqlookup)

NSQ系列之nsqlookupd代码分析一(初探nsqlookup) 是守护进程负责管理拓扑信息。客户端通过查询 来发现指定话题()的生产者,并且提供 节点广播话题()和通道()信息。 有两个接口: 接口...

大蓝妹
2015/08/27
1.8K
0
NSQ系列之nsqlookupd代码分析二(初识nsqlookupd tcpServer)

NSQ系列之nsqlookupd代码分析二(初识nsqlookupd tcpServer) 在上一章初探中了解到,中开启了一个 和一个 ,那么今天我们来初步了解下。 废话不多说,直接上代码吧,简单粗暴点比较好。 通过...

大蓝妹
2015/08/29
530
0
NSQ系列之nsqlookupd代码分析四(详解nsqlookupd中的RegitrationDB)

NSQ系列之nsqlookupd代码分析四(详解nsqlookupd中的RegitrationDB操作方法) 上一章我们大致了解了的中的协议的处理逻辑,里面有提到一个存储的以及 数据信息的的一些操作方法。今天我们就来...

大蓝妹
2015/09/02
306
2
NSQ系列之nsqlookupd代码分析三(详解tcpServer 中的IOLoop方法)

NSQ系列之nsqlookupd代码分析三(详解nsqlookupd tcpServer 中的IOLoop) 上一章我们大致了解了中的的大致的代码,与client也就之间协议处理在这个方法中,今天我们就分析一下这个方法 废话不...

大蓝妹
2015/09/01
691
0

没有更多内容

加载失败,请刷新页面

加载更多

应急广播户户通平台

一、平台概述 应急广播户户通平台为软硬一体化广播服务解决方案。实现了应急广播、视音频及图片文字信息、调频及数字广播FM、天气预报信息接收功能,以及视音频播放、智能机器人、电子日历等...

neocean
30分钟前
47
0
如何为Apache 2.2启用mod_rewrite

我已经在我的Vista机器上安装了新的Apache 2.2,一切正常,除了mod重写。 我没有注释 LoadModule rewrite_module modules/mod_rewrite.s 但是我的重写规则都没有,即使是简单的重写规则 Re...

javail
36分钟前
23
0
移除Python unicode字符串中的重音符号的最佳方法是什么?

我在Python中有一个Unicode字符串,我想删除所有的重音符号(变音符号)。 我在网上发现了一种用Java实现此目的的优雅方法: 将Unicode字符串转换为长规范化格式(带有单独的字母和变音符号)...

技术盛宴
52分钟前
48
0
ActiveMQ学习之SpringBoot整合ActiveMQ------>主题生产者和消费者

一、pom <!--聚合工程集成关系--> <!--统一整合第三方框架依赖信息--> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</a......

冥焱
今天
89
0
两周自制脚本语言-第11天 优化变量读写性能

第11天 优化变量读写性能 以变量值的读写为例,向读者介绍基于这种理念的语言处理器性能优化方式。 11.1 通过简单数组来实现环境 假如函数包含局部变量x与y,程序可以事先将x设为数组的第0个...

果汁分你一半
今天
58
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部