python - 如何在 python 中实现 pub/sub socket.io 客户端?

标签 python socket.io publish-subscribe

我一直在尝试实现与以下代码等效的 python,但似乎无法使其正常工作。

var io = require('socket.io-client')
var socket = io('http://devel.hz.udoidio.info:5000')

socket.on('connect', function () {
  socket.emit('subscribe', 'new-tx')
})

socket.on('new-tx', function (txid) {
  console.log('New tx: ' + txid)
})

我试过这种方法,但它似乎没有产生任何结果。

from socketIO_client import SocketIO, LoggingNamespace

def on_response(*args):
    print 'on_response', args

baseurl = "http://v1.livenet.bitcoin.chromanode.net"
socketIO = SocketIO(baseurl, 80, LoggingNamespace)
socketIO.on('subscribe', on_response)
socketIO.emit('subscribe', 'new-block')
socketIO.wait()

最佳答案

我解决了这个问题,下面是正确的解决方案。

from socketIO_client import SocketIO

def on_response(*args):
    print 'on_response', args

baseurl = "http://devel.hz.udoidio.info"
with SocketIO(baseurl, 5000) as socketIO:
    socketIO.on('new-tx', on_response)
    socketIO.emit('subscribe', 'new-tx')
    socketIO.wait()

关于python - 如何在 python 中实现 pub/sub socket.io 客户端?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/30353579/

相关文章:

iot - Google IOT - 设备订阅/devices/XXXX/config 以外的内容

python - 使用 Andy McCurdy 的 python-for-redis 库配置连接池大小

python - 程序退出时消息中的异常被忽略

http - 使用 HTTP keep-alive 和 websockets (socket.io) 时的 TCP 连接数

PHP Websockets Mysql 发布/订阅

android - 如何发布和解析 pubsub xmpp smack 库的自定义负载

Python/Django 使用 python-instagram (400) APISubscriptionError-Unable to reach callback URL

python - 动态选择要继承的类

javascript - Angular 套接字 io : how to disconnect the client

javascript - 在子位置的 nginx 后面运行 socket.io