请教在 celery 中运行 flask socket-io 的问题！

项目结构如下：

website/
	celery/
    	task.py
    socketio/
    	socket.py
    views/
    	index.py
    init.py
manage.py

我的 flask app 在 init 里初始化，celery 在 task 里初始化，socket 在 socket.py 里初始化。 然后在 index 里创建一个路由

@app.route('/index')
def indexx():
    from website.celery.tasks import test
    test.delay()
    return 'a'

test 如下：

from website.socketio.socket import socket
@celery.task
def test():
    # socketio = SocketIO(message_queue='redis://localhost:6379/1')
    socketio.emit('response',{'data':'sdasda'},broadcast=True)
    print "aaaa"

然后运行，celery shell 显示任务执行了，但是 socket 发的消息并没有在前端收到怎么办呢？好急 请教各位大神啦！