SleekXMPP и Flask Socketio Подвесные нити
Я пытаюсь создать XMPP-клиент, которым я могу управлять из своего браузера. Я использую SleekXMPP для XMPP-клиента и flask-socketio для веб-сайта, чтобы я мог передавать информацию с XMPP-сервера на мой XMPP-клиент на мой веб-интерфейс. Если бы я использовал чистую флягу, мне нужно было бы опросить мой сервер на предмет дополнительных обновлений, которые я бы предпочел, чтобы сервер отправлялся на мой клиент.
У меня возникли проблемы с темами. Подключение к серверу работает нормально. Но когда я отключаюсь, я получаю сообщение об ошибке, показывающее, что 3 потока не могут быть уничтожены. Как я могу убить эти темы при отключении? Или почему их не убивают? Или есть лучшая настройка, которую я должен использовать?
Спасибо!!
Ошибка:
DEBUG Event triggered: session_end
DEBUG Waiting for 3 threads to exit.
DEBUG Finished exiting event runner thread after early termination from disconnect() call. 3 threads remain.
DEBUG Finished exiting send thread after early termination from disconnect() call. 3 threads remain.
DEBUG Quitting Scheduler thread
DEBUG Finished exiting scheduler thread after early termination from disconnect() call. 3 threads remain.
ERROR Hanged threads: [<_MainThread(MainThread, started 140735076622336)>, <Thread(read_thread, started 4452692848)>, <Thread(Thread-1, started daemon 4454843728)>]
ERROR This may be due to calling disconnect() from a non-threaded event handler. Be sure that event handlers that call disconnect() are registered using: add_event_handler(..., threaded=True)
DEBUG Event triggered: disconnected
DEBUG ==== TRANSITION connected -> disconnected
Вот мой скрипт на python.
import eventlet
eventlet.monkey_patch()
from flask import Flask, render_template
from flask_socketio import SocketIO, emit, disconnect
import sleekxmpp
import logging
app = Flask(__name__)
app.debug = True
app.config['SECRET_KEY'] = 'secret!'
socketio = SocketIO(app)
logging.basicConfig(level=logging.DEBUG, format='%(levelname)-8s %(message)s')
class XMPPClient(sleekxmpp.ClientXMPP):
def __init__(self, full_jid, pwd):
self.full_jid = full_jid
self.pwd = pwd
sleekxmpp.ClientXMPP.__init__(self, self.full_jid, self.pwd)
self.HOST = "XXX"
self.PORT = "XXX"
def conn(self):
self.connect(address=(self.HOST, self.PORT))
self.process(threaded=True)
def disconn(self):
self.disconnect(wait=True, send_close=False)
@app.route('/')
def index():
return render_template('index.html')
@socketio.on('socket_connect', namespace='/vibe')
def _socket_connect():
xmpp_client.conn()
return ""
@socketio.on('socket_disconnect', namespace='/vibe')
def _socket_disconnect():
xmpp_client.disconn()
return ""
if __name__ == '__main__':
xmpp_client = XMPPClient(full_jid="XXX", pwd="XXX")
socketio.run(app)
И для моего интерфейса
<!DOCTYPE HTML>
<html>
<head>
<script src="http://ajax.aspnetcdn.com/ajax/jQuery/jquery-1.11.3.min.js"></script>
<script type="text/javascript" src="//cdnjs.cloudflare.com/ajax/libs/socket.io/1.3.6/socket.io.min.js"></script>
<script type="text/javascript" charset="utf-8">
var socket
$(document).ready(function(){
namespace = '/vibe';
socket = io.connect('http://' + document.domain + ':' + location.port + namespace);
});
function handle_connect(cmd) {
socket.emit(cmd)
}
</script>
</head>
<body>
<button type="button" onclick="handle_connect('socket_connect')">Connect</button>
<button type="button" onclick="handle_connect('socket_disconnect')">Disconnect</button>
</body>
</html>