发布请求后，如何向客户端发送消息？我将post请求中的数据存储到数据库中，并希望通知客户端数据库已更改。有没有办法把restapi和websocket结合起来？我发现的例子是使用websocket接收数据并发送到客户端，而我使用post方法接收并希望使用websockets进行警报。任何帮助都将不胜感激。
服务器.py
import sqlite3
from flask import Flask, render_template
from flask_socketio import SocketIO
app = Flask(__name__)
app.config['SECRET_KEY'] = 'secret!'
socketio = SocketIO(app)
@app.route('/', methods=['GET'])
def index():
render_template('index.html')
# listen for data
@app.route('/listen/<data>',methods=['POST'])
def listen(data):
# insert to db
conn = sqlite3.connect('storage.db')
c = conn.cursor()
c.execute('''CREATE TABLE info(num text)''')
c.execute('''INSERT INTO info(num) VALUES(?)''',(data))
conn.commit()
conn.close()
#send alert to client
@socketio.on('message')
def handle_message(message):
send(message)
if __name__ == '__main__':
socketio.run(app)
index.html
<head>
<script type="text/javascript"src="https://cdnjs.cloudflare.com/ajax/libs/socket.io/1.3.6/socket.io.min.js"></script>
<script type="text/javascript" charset="utf-8">
var socket = io.connect('http://' + document.domain + ':' + location.port);
socket.on('message', function(data) {
console.log(data);
});
</script>
</head>
你只是搞错了。您来自烧瓶插槽的send或emit应该是POST请求后的最后一条语句，如下所示：
import sqlite3
from flask import Flask, render_template
from flask_socketio import SocketIO, emit
app = Flask(__name__)
app.config['SECRET_KEY'] = 'secret!'
socketio = SocketIO(app)
@app.route('/', methods=['GET'])
def index():
render_template('index.html')
# listen for data
@app.route('/listen/<data>',methods=['POST'])
def listen(data):
# insert to db
conn = sqlite3.connect('storage.db')
c = conn.cursor()
c.execute('''CREATE TABLE info(num text)''')
c.execute('''INSERT INTO info(num) VALUES(?)''',(data))
conn.commit()
conn.close()
emit('message', 'Change has been made', broadcast=True) # To send all who listen
# This part is, if client sends to server something through 'message' socket. You don't need that,
# @socketio.on('message')
# def handle_message(message):
# send(message)
if __name__ == '__main__':
socketio.run(app)
因为客户端侦听来自"消息"套接字的消息，所以您需要在index.html中处理它，如下所示：
<head>
<script type="text/javascript"src="https://cdnjs.cloudflare.com/ajax/libs/socket.io/1.3.6/socket.io.min.js"></script>
<script type="text/javascript" charset="utf-8">
var socket = io.connect('http://' + document.domain + ':' + location.port);
socket.on('message', function(data) {
console.log(data);
});
</script>
</head>
有客户端和服务器端。他们都在监听socket.on()的一些变化。它们发送消息或发出消息时使用send()和emit()。
客户端可以通过"ImHere"套接字发出->服务器将用socket.on('ImHere')处理该消息->服务器可以用emit或send启动其他套接字，比如说"message"套接字->客户端可以用"socket.on"("message"，function(data(｛…｝(处理它。
如@Dinko所述，您已经拥有了一切，您只需要在conn.close((之后在侦听函数中再添加一个，即：
socketio.emit('message', {'data': 'Records Affected'}, broadcast=True)
您的回拨功能将被触发，因为它将听到"消息"套接字。
这里要添加的另一件事是，如果您有特定频道的名称空间，那么您也需要传递
socketio.emit('message', {'data': 'Records Affected'}, broadcast=True, namespace='/test')
希望这有帮助。。！