Клиентская библиотека Socket.IO в Python [закрыта]

Ответ Archie1986 был хорош, но устарел с обновлениями сокетио (в частности, его протоколом: https://github.com/LearnBoost/socket.io-spec)... насколько я могу судить, вам нужно выполнить рукопожатие вручную, прежде чем вы сможете запросить транспортное соединение (например, веб-сокеты)... обратите внимание приведенный ниже код является неполным и небезопасным... во-первых, он игнорирует список поддерживаемых транспортов, возвращенных в ответе на рукопожатие, и всегда пытается получить веб-сокет... также предполагается, что рукопожатие всегда завершается успешно... тем не менее, это хорошее место для начала

import websocket, httplib

...

'''
    connect to the socketio server

    1. perform the HTTP handshake
    2. open a websocket connection '''
def connect(self) :
    conn  = httplib.HTTPConnection('localhost:8124')
    conn.request('POST','/socket.io/1/')
    resp  = conn.getresponse() 
    hskey = resp.read().split(':')[0]

    self._ws = websocket.WebSocket(
                    'ws://localhost:8124/socket.io/1/websocket/'+hskey,
                    onopen   = self._onopen,
                    onmessage = self._onmessage)

....

вы также можете прочитать о python-websockets: https://github.com/mtah/python-websocket

Прежде всего, я не уверен, почему некоторые из ваших серверов Socket.IO не будут поддерживать веб-сокеты... цель Socket.IO состоит в том, чтобы упростить разработку веб-приложений во внешнем браузере, предоставив абстрактный интерфейс для реального -time потоки данных, обслуживаемые сервером Socket.IO. Возможно, Socket.IO — это не то, что вам следует использовать для своего приложения? Кроме того, позвольте мне попытаться ответить на ваш вопрос...

На данный момент не существует клиентских библиотек Socket.IO для Python (gevent-socketio не является клиентской библиотекой Socket.IO для Python... это Socket.IO серверную библиотеку для Python). На данный момент вам придется собрать исходный код, чтобы напрямую взаимодействовать с Socket.IO в качестве клиента, принимая различные типы соединений.

Я знаю, что вы ищете панацею, которая работает с различными типами соединений (WebSocket, long-polling и т. д.), но поскольку такой библиотеки пока не существует, я могу, по крайней мере, дать вам некоторые рекомендации по используя тип подключения WebSocket, основанный на моем опыте.

Для типа подключения WebSocket создайте клиент WebSocket в Python. Из командной строки установите этот пакет клиента Python WebSocket здесь с помощью pip, чтобы он находился на вашем пути к Python, например:

pip install -e git+https://github.com/liris/websocket-client.git#egg=websocket

После того, как вы это сделаете, попробуйте следующее, заменив SOCKET_IO_HOST и SOCKET_IO_PORT соответствующим расположением вашего сервера Socket.IO:

import websocket

SOCKET_IO_HOST = "127.0.0.1"
SOCKET_IO_PORT = 8080

socket_io_url = 'ws://' + SOCKET_IO_HOST + ':' + str(SOCKET_IO_PORT) + '/socket.io/websocket'

ws = websocket.create_connection(socket_io_url)

На данный момент у вас есть средство взаимодействия с сервером Socket.IO непосредственно из Python. Чтобы отправлять сообщения на сервер Socket.IO, просто отправьте сообщение через это соединение WebSocket. Чтобы сервер Socket.IO правильно интерпретировал входящие сообщения через этот WebSocket от вашего клиента Python Socket.IO, вам необходимо придерживаться протокола Socket.IO и кодировать любые строки или словари, которые вы можете отправлять через соединение WebSocket. Например, после того, как вы выполнили все вышеперечисленное, сделайте следующее:

def encode_for_socketio(message):
    """
    Encode 'message' string or dictionary to be able
    to be transported via a Python WebSocket client to 
    a Socket.IO server (which is capable of receiving 
    WebSocket communications). This method taken from 
    gevent-socketio.
    """
    MSG_FRAME = "~m~"
    HEARTBEAT_FRAME = "~h~"
    JSON_FRAME = "~j~"

    if isinstance(message, basestring):
            encoded_msg = message
    elif isinstance(message, (object, dict)):
            return encode_for_socketio(JSON_FRAME + json.dumps(message))
    else:
            raise ValueError("Can't encode message.")

    return MSG_FRAME + str(len(encoded_msg)) + MSG_FRAME + encoded_msg

msg = "Hello, world!"
msg = encode_for_socketio(msg)
ws.send(msg)

Библиотека socketIO-client поддерживает обратные вызовы событий и каналы благодаря работе участников и доступна на PyPI под лицензией MIT.

Выдать с обратным вызовом.

from socketIO_client import SocketIO

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

with SocketIO('localhost', 8000) as socketIO:
    socketIO.emit('bbb', {'xxx': 'yyy'}, on_bbb_response)
    socketIO.wait_for_callbacks(seconds=1)

Определить события.

from socketIO_client import SocketIO

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

socketIO = SocketIO('localhost', 8000)
socketIO.on('aaa_response', on_aaa_response)
socketIO.emit('aaa')
socketIO.wait(seconds=1)

Определение событий в пространстве имен.

from socketIO_client import SocketIO, BaseNamespace

class Namespace(BaseNamespace):

    def on_aaa_response(self, *args):
        print 'on_aaa_response', args
        self.emit('bbb')

socketIO = SocketIO('localhost', 8000)
socketIO.define(Namespace)
socketIO.emit('aaa')
socketIO.wait(seconds=1)

Определение разных пространств имен для одного сокета.

from socketIO_client import SocketIO, BaseNamespace

class ChatNamespace(BaseNamespace):

    def on_aaa_response(self, *args):
        print 'on_aaa_response', args

class NewsNamespace(BaseNamespace):

    def on_aaa_response(self, *args):
        print 'on_aaa_response', args

socketIO = SocketIO('localhost', 8000)
chatNamespace = socketIO.define(ChatNamespace, '/chat')
newsNamespace = socketIO.define(NewsNamespace, '/news')

chatNamespace.emit('aaa')
newsNamespace.emit('aaa')
socketIO.wait(seconds=1)

Библиотека SocketTornad.IO с популярным асинхронным Веб-сервер Tornado также является одним из вариантов, доступных для Python.

Написал один: https://github.com/amitu/amitu-websocket-client/blob/master/amitu/socketio_client.py. Он поддерживает только веб-сокеты, поэтому он может иметь для вас лишь незначительную пользу.

Вы видели gevent-socketio?

Надеюсь, поможет.