注意 SSE 是单向传输通道，只能服务器向浏览器发送。如果浏览器向服务器发送信息，就变成了另一次 HTTP 请求。
SSE连接只能由客户端浏览器关闭，后端停止发送数据会触发sse的error 事件。可以在前端设置sse的error事件触发时停止sse连接。
适用场景：向服务器请求一些连续数据，而且不用前端给出反馈，而且服务器只负责传输数据。
例子：实时推送随机数到前端画echart曲线图
例子实现图：
询问按钮是开启sse请求，停止按钮是停止sse请求。(目前停止后没有清除图表，可以自行添加)
app.py
import json
import random
import time
from datetime import datetime
from flask import Flask, Response, render_template, stream_with_context, jsonify
app = Flask(__name__)
random.seed() # Initialize the random number generator
@app.route('/')
def index():
return render_template('index2.html')
@app.route('/chart-data')
def chart_data():
print('chart_data-' * 5)
def generate_random_data():
print('generate_random_data-' * 5)
a = 0 # 设置如果前端不中止SSE连接，就在a=1000时完成数据传输
while True:
a += 1
if a ==1000:
break
json_data = json.dumps(
{'time': a, 'value': random.random() * 100})
# 1 SSE 返回格式是json字符串，要使用yield返回，字符串后面一定要跟随 \n\n
yield f"data:{json_data}\n\n"
time.sleep(1) # 1s 发送一次
# 2 stream_with_context 设置SSE连接函数，mimetype="text/event-stream" 是设置SSE返回格式
response = Response(stream_with_context(generate_random_data()), mimetype="text/event-stream")
response.headers["Cache-Control"] = "no-cache"
response.headers["X-Accel-Buffering"] = "no"
return response
if __name__ == '__main__':
# 需要开启多线程模式
app.run(debug=True, port=5143)
前端文件
templates/index2.html
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>Creating Real-Time Charts with Flask</title>
<link href="https://cdnjs.cloudflare.com/ajax/libs/twitter-bootstrap/4.3.1/css/bootstrap.min.css" rel="stylesheet">
<!--suppress JSUnresolvedLibraryURL -->
<script src="https://cdnjs.cloudflare.com/ajax/libs/jquery/3.4.0/jquery.min.js"></script>
<script type="text/javascript" src="https://fastly.jsdelivr.net/npm/echarts@5.3.3/dist/echarts.min.js"></script>
</head>
<body>
<div class="container">
<div class="row">
<div class="col-5"></div>
<div class="col-12">
<div class="card">
<!-- 放置图表的元素-->
<div class="card-body" id="mychart" style="width: 900px;height: 400px">
</div>
</div>
<br>
<div>
<button id="btn1" type="button" class="btn btn-primary">询问</button>
<button id="btn2" type="button" class="btn btn-primary">停止</button>
</div>
</div>
<div class="col-5"></div>
</div>
</div>
<script>
$(document).ready(function () {
var dom = document.getElementById('mychart');
var myChart = echarts.init(dom, null, {
renderer: 'canvas',
useDirtyRect: false
});
var option; // 图表参数
option = {
title: {
text: 'Stacked Line',
zlevel: 0, //默认值
z: 6, //默认值
},
// 滚动条配置
dataZoom: [
{
type: 'slider',
show: true,
xAxisIndex: [0],
start: 0, //初始化时，滑动条宽度开始标度
end: 100,
bottom: '3%',
height: 10, //组件高度
fillerColor: '#3E86FF',
borderColor: "transparent",
backgroundColor: 'white',//两边未选中的滑动条区域的颜色
showDataShadow: false,//是否显示数据阴影 默认auto
showDetail: false,//即拖拽时候是否显示详细数值信息 默认true
},
//下面这个属性是里面拖动配置
{
type: 'inside',
xAxisIndex: 0,
start: 0,//默认为1
end: 100,//默认为100
}
],
// 显示鼠标接触位置曲线数据
tooltip: {
trigger: 'axis'
},
// 曲线图例
legend: {
data: ['Random Dataset', 'Random Dataset2'] //1
},
// 曲线框距离图表框的距离
grid: {
top: '15%',
left: '5%',
right: '140',
bottom: '8%',
containLabel: true,
},
toolbox: {
feature: {
saveAsImage: {},
dataView: {}, // 是否显示出原始数据
}
},
xAxis: {
// x轴配置，两条曲线共用一个x轴
type: 'category',
boundaryGap: false,
data: [] // 2
},
yAxis: {
type: 'value'
},
series: [
// 两条曲线y轴配置
{
name: 'Random Dataset',
data: [],
type: 'line',
showSymbol: false,
// 配置曲线尾端显示数据格式
endLabel: {
show: true,
formatter: function (params) {
return params.seriesName + ': ' + params.data;
}
},
labelLayout: {
moveOverlap: 'shiftY'
},
emphasis: {
focus: 'series'
},
},
{
name: 'Random Dataset2',
data: [],
type: 'line',
showSymbol: false,
endLabel: {
show: true,
formatter: function (params) {
return params.seriesName + ': ' + params.data;
}
},
labelLayout: {
moveOverlap: 'shiftY'
},
emphasis: {
focus: 'series'
},
}
] //3
}
// 初始化图表
if (option && typeof option === 'object') {
// 设置为true的话，就是notMerge，不合并,false的话，就Merge，之前的东西还保留~
myChart.setOption(option, true);
}
//实现了图表跟随窗口大小自适应的需求
window.addEventListener('resize', myChart.resize);
// SSE接收
var source = null;
$("#btn1").click(function () {
source = new EventSource("/chart-data");
// readyState一个 unsigned short 值，代表连接状态。可能值是 CONNECTING (0), OPEN (1), 或者 CLOSED (2)。
console.log('EventSource.readyState ' + source.readyState);
// sse 连接开启时回调函数
source.onopen = function (event) {
console.log("onopen");
console.log('EventSource.readyState ' + source.readyState);
}
// 消息监听，event 是后端返回的数据,相当于python字典
source.onmessage = function (event) {
update_data(event);
}
// 监听 error 事件，后端超时没有传输数据时触发
source.onerror = function (event) {
console.log("error happened");
source.close();
console.log('EventSource.readyState ' + source.readyState);
}
})
// 绑定停止按钮事件
$("#btn2").click(function () {
if (source !== null) {
source.close();
// delete_data();
}
})
// 更新图表数据
function update_data(event) {
const data = JSON.parse(event.data);
console.log(data)
option.xAxis.data.push(data.time);
option.series[0].data.push(data.value);
option.series[1].data.push(data.value + 20);
myChart.setOption(option, true)
}
// 删除图表数据
function delete_data() {
option.xAxis.data = [];
option.series[0].data = [];
option.series[1].data = [];
myChart.setOption(option, true);
}
});
</script>
</body>
</html>
参考
使用服务器发送事件 - Web API 接口参考 | MDN (mozilla.org)
Creating Real-Time Charts with Flask (ron.sh)
后端主动向前端推送消息–SSE_故友dd的博客-CSDN博客_后端主动推送数据给前端
我想安装一个带有一些身份验证的私有(private)Rubygem服务器。我希望能够使用公共(public)Ubuntu服务器托管内部gem。我读到了http://docs.rubygems.org/read/chapter/18.但是那个没有身份验证-如我所见。然后我读到了https://github.com/cwninja/geminabox.但是当我使用基本身份验证(他们在他们的Wiki中有)时，它会提示从我的服务器获取源。所以。如何制作带有身份验证的私有(private)Rubygem服务器？这是不可能的吗？谢谢。编辑:Geminabox问题。我尝试“捆绑”以安装新的gem..
最近，当我启动我的Rails服务器时，我收到了一长串警告。虽然它不影响我的应用程序，但我想知道如何解决这些警告。我的估计是imagemagick以某种方式被调用了两次？当我在警告前后检查我的git日志时。我想知道如何解决这个问题。-bcrypt-ruby(3.1.2)-better_errors(1.0.1)+bcrypt(3.1.7)+bcrypt-ruby(3.1.5)-bcrypt(>=3.1.3)+better_errors(1.1.0)bcrypt和imagemagick有关系吗？/Users/rbchris/.rbenv/versions/2.0.0-p247/lib/ru
在Rails4.0.2中，我使用s3_direct_upload和aws-sdkgems直接为s3存储桶上传文件。在开发环境中它工作正常，但在生产环境中它会抛出如下错误，ActionView::Template::Error(noimplicitconversionofnilintoString)在View中，create_cv_url,:id=>"s3_uploader",:key=>"cv_uploads/{unique_id}/${filename}",:key_starts_with=>"cv_uploads/",:callback_param=>"cv[direct_uplo
我正在尝试在Ruby中制作一个cli应用程序，它接受一个给定的数组，然后将其显示为一个列表，我可以使用箭头键浏览它。我觉得我已经在Ruby中看到一个库已经这样做了，但我记不起它的名字了。我正在尝试对soundcloud2000中的代码进行逆向工程做类似的事情，但他的代码与SoundcloudAPI的使用紧密耦合。我知道cursesgem，我正在考虑更抽象的东西。广告有没有人见过可以做到这一点的库或一些概念证明的Ruby代码可以做到这一点？ 最佳答案 我不知道这是否是您正在寻找的，但也许您可以使用我的想法。由于我没有关于您要完成的工作
我的主要目标是能够完全理解我正在使用的库/gem。我尝试在Github上从头到尾阅读源代码，但这真的很难。我认为更有趣、更温和的踏脚石就是在使用时阅读每个库/gem方法的源代码。例如，我想知道RubyonRails中的redirect_to方法是如何工作的:如何查找redirect_to方法的源代码？我知道在pry中我可以执行类似show-methodmethod的操作，但我如何才能对Rails框架中的方法执行此操作？您对我如何更好地理解Gem及其API有什么建议吗？仅仅阅读源代码似乎真的很难，尤其是对于框架。谢谢! 最佳答案 Ru
您如何在Rails中的实时服务器上进行有效调试，无论是在测试版/生产服务器上？我试过直接在服务器上修改文件，然后重启应用，但是修改好像没有生效，或者需要很长时间(缓存？)我也试过在本地做“脚本/服务器生产”，但是那很慢另一种选择是编码和部署，但效率很低。有人对他们如何有效地做到这一点有任何见解吗？ 最佳答案 我会回答你的问题，即使我不同意这种热修补服务器代码的方式:)首先，你真的确定你已经重启了服务器吗？您可以通过跟踪日志文件来检查它。您更改的代码显示的View可能会被缓存。缓存页面位于tmp/cache文件夹下。您可以尝试手动删除
require"socket"server="irc.rizon.net"port="6667"nick="RubyIRCBot"channel="#0x40"s=TCPSocket.open(server,port)s.print("USERTesting",0)s.print("NICK#{nick}",0)s.print("JOIN#{channel}",0)这个IRC机器人没有连接到IRC服务器，我做错了什么？ 最佳答案 失败并显示此消息::irc.shakeababy.net461*USER:Notenoughparame
我有一个使用PDFKit呈现网页的pdf版本的Rails应用程序。我使用Thin作为开发服务器。问题是当我处于开发模式时。当我使用“bundleexecrailss”启动我的服务器并尝试呈现任何PDF时，整个过程会陷入僵局，因为当您呈现PDF时，会向服务器请求一些额外的资源，如图像和css，看起来只有一个线程.如何配置Rails开发服务器以运行多个工作线程？非常感谢。 最佳答案 我找到的最简单的解决方案是unicorn.geminstallunicorn创建一个unicorn.conf:worker_processes3然后使用它:
我要下载http://foobar.com/song.mp3作为song.mp3，而不是让Chrome在其native中打开它浏览器中的播放器。我怎样才能做到这一点？ 最佳答案 您只需要确保发送这些header:Content-Disposition:attachment;filename=song.mp3;Content-Type:application/octet-streamContent-Transfer-Encoding:binarysend_file方法为您完成:get'/:file'do|file|file=File.
我将以下代码放在一起用于一个简单的RubyTFTP服务器。它工作正常，因为它监听端口69并且我的TFTP客户端连接到它，我能够将数据包写入test.txt，但我不只是写入数据包，我希望能够从我的客户端通过TFTP传输文件到/temp目录。预先感谢您的帮助!require'socket.so'classTFTPServerdefinitialize(port)@port=portenddefstart@socket=UDPSocket.new@socket.bind('',@port)whiletruepacket=@socket.recvfrom(1024)putspacketFile