1

pip install nsq-py

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12

# Windows 下使用
from nsq.reader import Reader
from nsq.client import Client
# Linux 使用
# from nsq.gevent import Reader,Client
# 必须是byte类型
reader = Reader(b'topic', b'channel', nsqd_tcp_addresses=['localhost:4150'])

for message in reader:
    print('message:', message)
    # 必须调用fin表示消费成功
    message.fin()

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11

# Windows 下使用
from nsq.reader import Reader
from nsq.client import Client
# Linux 使用
# from nsq.gevent import Reader,Client


cli = Client(nsqd_tcp_addresses=['192.168.80.128:4150'])

# 必须是byte类型
cli.pub(b'topic', b'test')