首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往
  • 您找到你想要的搜索结果了吗?
    是的
    没有找到

    Docker部属Nsq集群

    用一了段时间NSQ还是很稳定的。除了稳定,还有一个特别值的说的就是部署非常简单。总想写点什么推荐给大家使用nsq来做一些东西。但是就是因为他太简单易用,文档也比较简单易懂。...nsq官网: http://nsq.io/ ?   为了容灾需要对nsqd多机器部属,有了Docker后,快速扩还是很方便的。   部署完后我会用go和c#写一些代码方便大家学习。   ...我用go语言 简单写一个发送信息的例子:   go使用的库是 go-nsq 地址  : github.com/nsqio/go-nsq func main() { config := nsq.NewConfig...() // 随便给哪个ip发都可以 //w1, _ := nsq.NewProducer("192.168.0.105:4150", config) w1, _ := nsq.NewProducer...msgGood int } var consumers []*nsq.Consumer = make([]*nsq.Consumer, 0) var mux *sync.Mutex = &sync.Mutex

    1.6K91

    nsq部署_andlua辅助源码

    看完lookupd和nsqd之后我们再来看下nsq client端的代码。 我是想把nsq系统完完整整的看一遍,从而对他形成一个更整体的 认识。...对message queue来说他的client端就是生产者和消费者,生产者负责想nsq中投递消息,消费者负责从lookupd中获取到 指定nsqd之后,从nsqd中获取消息。...生产者 我们以nsq/apps/to_nsq/to_nsq.go为例,客户端这边的代码逻辑就简单很多,NewProducer实例化一个instance,publish消息 到nsqd。.../// nsq/apps/to_nsq/to_nsq.go producer, err := nsq.NewProducer(addr, cfg) err := producer.Publish(*topic...消费者 回过头我们再来看下消费者部分的代码,client端我们以nsq/apps/nsq_tail/nsq_tail.go为例,代码的基本逻辑如下: // 1. new comsunmer instanace

    1.4K30

    高性能消息中间件 NSQ 解析-窥探 nsq 设计思路(一)

    我们在前面介绍了 nsq 的相关概念以及 nsq 的安装与应用以及 nsqd 的实现原理、nsqlookupd 的实现细节。 本文将会介绍 nsq 在设计方面的一些思路。 ?...在可靠性、有序性方便, nsq 保证消息至少被投递消费一次(幂等消费),当某个 nsqd 节点出现故障时,极端情况下内存里面的消息还未来得及存入磁盘,这部分消息将丢失;通过分布式多个 consumer...多路分发 - producer 会同时连上 nsq 集群中所有 nsqd 节点,当然这些节点的地址是在初始化时,通过外界传递进去;当发布消息时,producer 会随机选择一个 nsqd 节点发布某个...只有一个客户端,那么 Channel 就将消息投递给这个客户端;如果 Channel 的客户端不止一个,那么 Channel 将把消息随机投递给任何一个客户端,这也可以看做是客户端的负载均衡 小结 本文主要介绍 nsq

    1K20

    Golang 语言编写的消息队列 NSQ 官方客户端 go-nsq 怎么使用?

    NSQ 支持跨平台和多语言客户端。使用 Mac 的读者朋友们可以使用 brew 方便的安装 NSQ。本文我们主要介绍 NSQ 官方提供的 golang 客户端 go-nsq。...关于 NSQ 的更多内容,感兴趣的读者朋友们可以查阅官方文档,限于篇幅,本文不再赘述。 使用 go-nsq 操作 NSQ,需要安装 go-nsq 库,它提供了许多用于操作 NSQ 的函数和方法。...安装方式: // Mac 安装 nsq brew install nsq // 安装 go-nsq go get -u github.com/nsqio/go-nsq 02 生产者 go-nsq 包中的...它是 NSQ 官方提供的 NSQ Golang 客户端。并且分别介绍了 Producer 和 Consumer 的简单使用方法,大家可以根据自己的业务需求,使用 go-nsq 灵活运用 NSQ。.../go-nsq@v1.0.8

    1.7K20

    NSQ分布式消息基础入门

    作者 | 陌无崖 转载请联系授权 介绍 NSQ是一个基于Go语言的分布式实时消息平台,可以大规模的运用于实时消息服务,每天可以处理数亿级别的消息,设计目标是为在分布式环境下运行的去中心化服务提供一个强大的基础架构...NSQ核心组件 nsqlookupd 用于守护进程负责管理拓扑信息,它使用tcp(默认端口4160)管理nsqd服务,使用http(默认端口4161)管理nsqadmin服务。...Nsq服务端与客户端的关系 消费者 1、消费者直接连接nsqd,缺点是服务无法实现动态伸缩(可以自己实现)。...安装 docker部署 docker-compose.yml version: '3' services: nsqlookupd: image: nsqio/nsq command:.../nsqlookupd ports: - "4160" - "4161" nsqd: image: nsqio/nsq command: /nsqd

    1.1K10

    有赞NSQ多集群多机房设计

    本文主要介绍了 NSQ 双机房以及多机房设计以及经验总结。 二、场景和需求 下图是一个机房内基本的 NSQ 消息生产和消费的部署。一个机房内生产者往 NSQ 集群发消息,多个消费者订阅消息。 ?...三、NSQ 双机房设计 我们结合 NSQ 中的服务发现组件 nsqlookupd 的功能实现 NSQ 的双机房功能。...一旦本地机房 NSQ 无法正常服务,已经落盘的消息不会丢失(恢复前无法被消费)。 根据代理的路由配置,NSQ 的双机房方案经历了两个阶段。...3.1 NSQ 双机房方案一期 NSQ 的双机房方案目前计划分为两期,一期中读写流量全部通过 migrate 导到一个机房,对端机房中的 NSQ 集群作为冷备。...{ "lookupSchema": { "nsq1": "this.is.url.of.nsq1:4161", "nsq2": "this.is.url.of.nsq2:4161", "nsq3

    2K20
    领券