pip3 install flask-cors
pip3 install flask-socketio
pip3 install celery

from flask_cors import CORS
from flask_socketio import SocketIO,send,emit,join_room, leave_room
import urllib.parse
from celery import Celery
from datetime import timedelta  app = Flask(__name__)  app.config['BROKER_URL'] = 'redis://localhost:6379'
app.config['CELERY_RESULT_BACKEND'] = 'redis://localhost:6379'
app.config['CELERY_ACCEPT_CONTENT'] = ['json', 'pickle']
app.config['REDIS_URL'] = 'redis://localhost:6379'

socketio = SocketIO(app,cors_allowed_origins='*',async_mode="threading",message_queue=app.config['CELERY_RESULT_BACKEND'])

celery = Celery(app.name)
celery.conf.update(app.config)

@celery.task()
def get_sendback():  socketio.emit('sendback','message',broadcast=True)  @app.route('/task')
def start_background_task():  get_sendback.delay()  return '开始'  @socketio.on('join')
def on_join(data):  username = 'user1'  room = 'room1'  join_room(room)  send(username + ' has entered the room.', room=room)  @socketio.on('message')
def handle_message(message):  message = urllib.parse.unquote(message)  print(message)  send(message,broadcast=True)  @socketio.on('connect', namespace='/chat')
def test_connect():  emit('my response', {'data': 'Connected'})  @socketio.on('disconnect', namespace='/chat')
def test_disconnect():  print('Client disconnected')  @app.route("/sendback",methods=['GET'])
def sendback():  socketio.emit('sendback','message')  return 'ok'  if __name__ == '__main__':  app.config['JSON_AS_ASCII'] = False  socketio.run(app,debug=True,host="0.0.0.0",port=5000)

python manage.py

celery worker -A manage.celery --loglevel=info -P eventlet

npm install vue-socket.io@2.1.0

<template>  <div>  <div v-for="item in log_list"  >  {{item}}  </div>  <input v-model="msg" />  <button @click="send">发送消息</button>  </div>  </template>  <script>  export default {  data () {  return {  msg: "",  log_list:[]  }  },  //注册组件标签  components:{  },  sockets:{  connect: function(){  console.log('socket 连接成功')  },  message: function(val){  console.log('返回:'+val);  alert(val);  this.log_list.push(val);  },
sendback: function(val){  console.log('返回:'+val);  alert(val);  }
},  mounted:function(){  },  methods:{  send(){  this.$socket.emit('join',encodeURI("加入房间"))  this.$socket.emit('message',encodeURI("用户:"+this.msg));  },  }
}  </script>  <style>  </style>

celery = Celery(app.name)
celery.conf.update(app.config)  celery.conf.CELERYBEAT_SCHEDULE = {  "test":{  "task":"get_cron",  "schedule":timedelta(seconds=10)  }  }

@celery.task(name="get_cron")
def get_cron():  get_sendback.delay()

celery -A manage.celery beat --loglevel=debug