Отправка данных JSON через WebSocket из Matlab с использованием Python Twisted и Autobahn

Ответ 1

Настройка WebSocket с использованием Python и Matlab

Проверить, что Matlab указывает на правильную версию python

Во-первых, вам нужно убедиться, что вы используете правильный бинарный код python. На Mac вы можете использовать стандартную версию системы вместо той, которая была установлена, например, для Homebrew. Проверьте местоположение вашей установки python с помощью:

pyversion

Вы можете указать Matlab на правильную версию, используя:

pyversion('path/to/python')

для этого может потребоваться перезагрузка python.

Как указано выше, я использую Twisted для мультиплексирования данных Matlab для клиентов WebSocket. Лучший способ решить эту проблему - просто создать сервер, который обрабатывает POSTS, а затем передает его вместе с клиентами WebSocket. Сжатие просто замедляет работу, поэтому я отправляю 280 Кбайт JSON за запрос, который принимает примерно 0,05 секунды за сообщение. Я бы хотел, чтобы это было быстрее, 0,01 секунды, но это хороший старт.

Код Matlab

server = 'http://127.0.0.1:7080/update.json';
headers = py.dict(pyargs('Charset','UTF-8','Content-Type','application/json'));
while true
    tic;
    packet = rand(100, 100);
    json_packet = savejson('', packet);
    r = py.requests.post(server, pyargs('data', json_packet, 'headers', headers));
    toc;
end

Я мог бы использовать функцию Matlab webwrite, но обычно я нахожу, что вызов на python является более гибким.

Сервер Python WebSocket-WebClient

import sys

from twisted.internet import reactor
from twisted.python import log
from twisted.web.resource import Resource
from twisted.web.server import Site
from twisted.web.static import File

from autobahn.twisted.websocket import WebSocketServerFactory, \
    WebSocketServerProtocol, \
    listenWS


class BroadcastServerProtocol(WebSocketServerProtocol):

    def onOpen(self):
        self.factory.registerClient(self)

    def onMessage(self, payload, isBinary):
        if not isBinary:
            message = "{} from {}".format(payload.decode('utf8'), self.peer)
            self.factory.broadcastMessage(message)

    def connectionLost(self, reason):
        WebSocketServerProtocol.connectionLost(self, reason)
        self.factory.unregisterClient(self)


class BroadcastServerFactory(WebSocketServerFactory):

    def __init__(self, url, debug=False, debugCodePaths=False):
        WebSocketServerFactory.__init__(self, url, debug=debug, debugCodePaths=debugCodePaths)
        self.clients = []

    def registerClient(self, client):
        if client not in self.clients:
            print("registered client {}".format(client.peer))
            self.clients.append(client)

    def unregisterClient(self, client):
        if client in self.clients:
            print("unregistered client {}".format(client.peer))
            self.clients.remove(client)

    def broadcastMessage(self, message):
        for client in self.clients:
            client.sendMessage(message.encode('utf8'))


class BroadcastPreparedServerFactory(BroadcastServerFactory):

    def broadcastMessage(self, message, isBinary=False):
        if isBinary is True:
            message = message.encode('utf8')
        preparedMessage = self.prepareMessage(message, isBinary=isBinary)
        for client in self.clients:
            client.sendPreparedMessage(preparedMessage)


class WebClient(Resource):

    webSocket = None

    def render_POST(self, request):
        self.webSocket.broadcastMessage(request.content.read())

        return 'OK'


if __name__ == '__main__':

    if len(sys.argv) > 1 and sys.argv[1] == 'debug':
        log.startLogging(sys.stdout)
        debug = True
    else:
        debug = False
    factory = BroadcastPreparedServerFactory(u"ws://127.0.0.1:9000",
                                             debug=debug,
                                             debugCodePaths=debug)

    factory.protocol = BroadcastServerProtocol
    listenWS(factory)

    root = Resource()
    webClient = WebClient()
    webClient.webSocket = factory
    root.putChild('update.json', webClient)
    webFactory = Site(root)
    reactor.listenTCP(7080, webFactory)

    webdir = File(".")
    web = Site(webdir)
    reactor.listenTCP(8080, web)

    reactor.run()

Я избавился от попытки RPC и просто пошел с прямым POST. Еще много возможностей для повышения производительности.