現(xiàn)在在用flask實(shí)現(xiàn)一個簡單的webserver，為了與前段進(jìn)行通信，加入了flask-socketio模塊，現(xiàn)在在處理前段發(fā)送過來的消息的函數(shù)中直接emit的話，前端可以收到消息。但是想主動發(fā)送消息的話失敗。具體如下：

在這邊的話前端是可以接收到emit發(fā)送的消息的。

@socketio.on('request_for_response')
def handle_request(request):
    print('received socket message:' + json.dumps(request))
    # 這里可以直接發(fā)送,如果單獨(dú)發(fā)送就不可以？
    emit('response', 'ok')
    msgTranslate(request)

如果在普通函數(shù)里直接調(diào)用就會失敗,這里的emit始終不能發(fā)送消息。

def recvThread():
    while True:
        # print("recvThread start---")
        msgNum = c_long(0)
        content = create_string_buffer(1024)
        if recvMsg(byref(msgNum), content) == 0:
            print(content)
            print("the content number is %d, the content is:%s" % (msgNum.value, content.value))
            # 必須要全局的才能調(diào)用
            d = dict(name='djj', age=26)
            print(json.dumps(d))
            # response(json.dumps(d))
            socketio.emit('response')

socketio定義如下

app = Flask(__name__)
app.config['SECRET_KEY'] = 'secret!'
socketio = SocketIO(app, async_mode=async_mode)

前端代碼如下:

 var $SCRIPT_ROOT = {{ request.script_root|tojson|safe }};
 var socket = io.connect($SCRIPT_ROOT);
                socket.on('connect',function()
                    {
                       socket.emit('connected');
                    });
                 socket.on('response', function(data)
                  {
                      console.log(data);
                      alert("receive response");
                      /*
                      if(data.code == '200'){
                          alert(data.param);
                      }
                      else
                      {
                          alert('Error:'+data.param);
                      }
                      */
                      //alert(data.param);

                  });

            $(document).ready(function(){
                $("#btn").click(function () {
                    socket.emit('request_for_response', JSON.stringify({
                            'ip': $("#ip").val(),
                            'cover': $("#cover").val(),
                            'gate': $("#gate").val(),
                    }));
                });
            });

發(fā)現(xiàn)一個問題：socketio.emit放在線程里就無法執(zhí)行，我現(xiàn)在的啟動的部分代碼是這樣的，

if __name__ == '__main__':
    loadDjjque()
    isInit = queInit()
    setCharacter(1)
    if isInit == 0:
        print("--queInit success--")
    t = threading.Thread(target=recvThread, name='recvThread')
    t.setDaemon(True)
    t.start()
    socketio.run(app, host='0.0.0.0', port=5555)

但是官方文檔寫的是：

但對于某些應(yīng)用程序，服務(wù)器需要作為消息的發(fā)起者。 這可以用于向客戶端發(fā)送在服務(wù)器中發(fā)起的事件的通知，例如在后臺線程中。 可以使用socketio.send()和socketio.emit()方法向所有連接的客戶端進(jìn)行廣播：

def some_function():

socketio.emit('some event', {'data': 42})

請注意，socketio.send()和socketio.emit()與上下文感知send()和emit()不同。 還要注意，在上面的用法中沒有客戶端上下文，所以broadcast=True，不需要指定。

作者：1994宅貓
鏈接：https://www.jianshu.com/p/411...
來源：簡書
著作權(quán)歸作者所有。商業(yè)轉(zhuǎn)載請聯(lián)系作者獲得授權(quán)，非商業(yè)轉(zhuǎn)載請注明出處。

不知道為什么不可以發(fā)送出去？？