如何使用okhttp3连接到flask-sockets后端

如何解决如何使用okhttp3连接到flask-sockets后端

我非常有信心这是一个新问题，有点麻烦，但是如果之前已解决此问题，请告诉我。我也只是从websockets开始。我知道socket.io和普通websockets之间的区别。我尝试使用前者来流式传输jpeg数据，但是并不能完成任务（我正在寻找30 fps，并且在保持连接少于一分钟的时间后会有巨大的延迟尖峰），我发现了这篇文章，所以没有继续进行下去。 https://github.com/socketio/socket.io/issues/1175

https://github.com/TwilioDevEd/mediastreams-consume-websockets-flask/blob/master/app.py教我如何设置烧瓶插槽后端，https://medium.com/@ssaurel/learn-to-use-websockets-on-android-with-okhttp-ba5f00aea988教了我okhttp3。还请注意，我使用okhttp3的唯一原因是因为我知道它，并且假定websockets可以与客户端/服务器一起使用，但事实并非如此。

这是okhttp3客户端上onFailure侦听器的打印输出。

Failed to connect: Failed to connect /localip:5000

在服务器端，我可以报告未建立连接。

这是我在后端的代码。（打算通过websocket发送jpeg帧，从而通过相机对象发送

）

HTTP_SERVER_PORT = 5000
camera = Camera(app,'./get.py',960,720)
socket = SocketLocal(app,camera)
thread = None

@sockets.route('/data')
def echo(ws):
    app.logger.info("Connected accepted")
    has_seen_media = False
    #send through to client
    while not ws.closed:
        gevent.sleep(0.1)
        try:
            data = gevent.with_timeout(0.1,ws.receive,timeout_value="")
            if data is None:
                raise Exception("socket closed")
        except:
            break
        message = ws.receive()
        if message is None:
            app.logger.info("No message received...")
            continue

        data = loads("message")
        if data['event'] == "connected":
            app.logger.info("Connected Message Received: {}".format(message))
        if data['event'] == "start":
            app.logger.info("Start Message received: {}".format(message))
        if data['event'] == "media":
            global socket
            global thread

            socket.ws = ws
            thread = threading.Thread(target=socket._camerathread)
            thread.start()
        if data['event'] == 'closed':
            app.logger.info("Closed Message received: {}".format(message))
            break

    thread = None
    app.logger.info("Connection closed")

if __name__== "__main__":
    #app.run(host='0.0.0.0',threaded=True)
    config['thermal']['url'] = url_for('video_Feed')
    from gevent import pywsgi
    from geventwebsocket.handler import WebSocketHandler

    server = pywsgi.WsgiServer(('',HTTP_SERVER_PORT),app,handler_class=WebSocketHandler)
    server.serve_forever()

我正在通过gunicorn运行烧瓶后端。我使用的命令直接来自flask-sockets页面。

gunicorn -k flask_sockets.worker --access-logfile gunicorn_access.log --error-logfile gunicorn_error.log --log-level=debug wsgi:application

如果有更好的方法可以做到这一点，那么我就会不知所措。