妙音

 

双机nsq如果部署集群，如何保证高可用性

 

1. 单节点nsqlookup故障?

 

2. 单节点nsq故障?

 

3. 消息丢失?

 

 

两台机器

 

机器A 192.168.120.1

 

机器B 192.168.120.101

 

 

部署方法

 

1. 机器A部署一套nsqlookup+nsqd

 

2. 机器B部署一套nsqlookup+nsqd

 

3. 生产者将消息同时写入两个nsqd

 

3. 消费者监听两个nsqlookup

 

结构图

 

 

机器A

 

nsqlookupd -broadcast-address 192.168.120.1
nsqd -lookupd-tcp-address=192.168.120.1:4160 -lookupd-tcp-address=192.168.120.101:4160 -broadcast-address 192.168.120.1

 

机器B

 

nsqlookupd -broadcast-address 192.168.120.101
nsqd -lookupd-tcp-address=192.168.120.1:4160 -lookupd-tcp-address=192.168.120.101:4160 -broadcast-address 192.168.120.101

 

 

生产者

 

import nsq
import tornado.ioloop
import time

def pub_message():
    writer.pub('test', str(time.strftime('%H:%M:%S')).encode("utf-8"), finish_pub)

def finish_pub(conn, data):
    print(data)

# 写入两个nsq好处: 1.防止nsqd单点故障  2.防止消息丢失
writer = nsq.Writer(['192.168.120.101:4150', '192.168.120.1:4150'])

tornado.ioloop.PeriodicCallback(pub_message, 1000).start()
nsq.run()

 

消费者

 

import nsq


def handler(message):
    print(message, message.id, message.timestamp, message.attempts, message.body)
    return True

# 防止nsqlookup故障
r = nsq.Reader(message_handler=handler,
               lookupd_http_addresses=['http://192.168.120.1:4161', 'http://192.168.120.101:4161'],
               topic='test', channel='abc', lookupd_poll_interval=15)

nsq.run()

 

 

只要有一个nsqlookup和一个nsqd存活，系统就不会挂

 

 

佛說大乘無量壽莊嚴清淨平等覺經pdf

净土大经科注2014-doc

此生必看的科学实验-水知道答案

印光大师十念法（胡小林主讲第1集）

 

描述

 

学习官网例子时，会碰到的一个小错误. 过程描述:

 

1. 按照nsq官网，搭建一个nsq小集群

 

2.使用python客户端pynsq编写测试客户端

 

3. 如果上面过程在一台机子上完成，不会有问题

 

4. 如果客户端与nsq不在一台机子上，会出现下面错误

 

 

WARNING:nsq.reader:[localhost.localdomain:4150:test:abc] connection closed

 

 

 

import nsq

def handler(message):
    print(message, message.body)
    return True


r = nsq.Reader(message_handler=handler,
               lookupd_http_addresses=['http://192.168.120.101:4161'],
               topic='test', channel='abc', lookupd_poll_interval=15)

nsq.run()

 

import nsq
import tornado.ioloop
import time

def pub_message():
    writer.pub('test', str(time.strftime('%H:%M:%S')).encode("utf-8"), finish_pub)

def finish_pub(conn, data):
    print(data)

writer = nsq.Writer(['127.0.0.1:4150'])

tornado.ioloop.PeriodicCallback(pub_message, 1000).start()
nsq.run()

 

 

启动nsqd时，指定nsqd的广播ip，也就是其它机子可以访问的ip，而非默认的localhost。例如："-broadcast-address 192.168.120.101"

 

佛說大乘無量壽莊嚴清淨平等覺經pdf

净土大经科注2014-doc

此生必看的科学实验-水知道答案

印光大师十念法（胡小林主讲第1集）