Форматирование сообщений для отправки на сервер socket.io node.js из клиента Python - PullRequest
20 голосов
/ 14 июля 2011

Я пытаюсь заставить клиента Python общаться с сервером Node.js с помощью Socket.io 0.7, отправляя на сервер пользовательское событие.

На основе найденной мной ссылки на Socket.ioна GitHub и следующей библиотеке WebSocket Python .

Вот мой код:

Узловой сервер

io.sockets.on('connection', function (socket) {
  socket.on('newimg', function(data) {
        console.log(data);
  });
});

Python-клиент

def handshake(host, port):
    u = urlopen("http://%s:%d/socket.io/1/" % (host, port))
    if u.getcode() == 200:
        response = u.readline()
        (sid, hbtimeout, ctimeout, supported) = response.split(":")
        supportedlist = supported.split(",")
        if "websocket" in supportedlist:
            return (sid, hbtimeout, ctimeout)
        else:
            raise TransportException()
    else:
        raise InvalidResponseException()


try:
    (sid, hbtimeout, ctimeout) = handshake(HOSTNAME, PORT) #handshaking according to socket.io spec.
Except Exception as e:
    print e
    sys.exit(1)
ws = websocket.create_connection("ws://%s:%d/socket.io/1/websocket/%s" % (HOSTNAME, PORT, sid))
print ws.recv()
ws.send("2::")
ws.send("5:1::{'name':'newimg', 'args':'bla'}")
print ws.recv()
print "Closing connection"
ws.close()

Узел вывода на консоль

debug - client authorized
info  - handshake authorized 12738935571241622933
debug - setting request GET /socket.io/1/websocket/12738935571241622933
debug - set heartbeat interval for client 12738935571241622933
debug - client authorized for 
debug - websocket writing 1::
debug - websocket received data packet 2::
debug - got heartbeat packet
debug - websocket received data packet 5:1::{'name':'newimg', 'args':'bla'}
debug - acknowledging packet automatically
debug - websocket writing 6:::1
info  - transport end
debug - set close timeout for client 12738935571241622933
debug - cleared close timeout for client 12738935571241622933
debug - cleared heartbeat interval for client 12738935571241622933
debug - discarding transport 

Вывод на консоль Python

Done
1::
6:::1
Closing connection

Теперь кажется, что событие сокета не запускается, несмотря на то, что сервер отвечает ACK.Таким образом, сообщение принимается правильно, но я предполагаю, что оно неправильно отформатировано для socket.io для запуска события.

Я не думал, что кадрирование было необходимо, однако Archie1986, похоже, не согласен с его ответом на это: Клиентская библиотека Socket.IO в Python

Что я могу здесь делать не так?

Ответы [ 2 ]

20 голосов
/ 14 апреля 2012

Я завернул исследование rod в клиентскую библиотеку barebones socket.io .

pip install -U socketIO-client
python
    from socketIO_client import SocketIO
    with SocketIO('localhost', 8000) as socketIO:
        socketIO.emit('aaa')
        socketIO.wait(seconds=1)
14 голосов
/ 15 июля 2011

Решено.Мне нужно было использовать двойные кавычки.Одинарные кавычки не действительны в формате JSON.Woops.

ws.send("5:1::{'name':'newimg', 'args':'bla'}")

Становится:

ws.send('5:1::{"name":"newimg", "args":"bla"}')
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...