记得我之前写过 redis主动向页面push数据 的文章，但文中所描述的方法要应用到J2EE的项目中还是比较困难的（还需用到nodejs什么的）。于是本文来探究下比较适合web项目的主动推技术。
Comet是一种用于web的推送技术，能使服务器能实时地将更新的信息传送到客户端，而无须客户端发出请求，目前有两种实现方式:长轮询（long-polling）和iframe流（streaming）。下面就用iframe流的实现方式来实现服务端主动向客户端（这里客户端指的是jsp页面）推送的效果，并且结合了redis的发布订阅，算是比较典型的例子了。
客户端（页面）：
<script type="text/javascript">
$(function() {
setCometUrl();
bindLinstener();
});
function bindLinstener() {
if (window.addEventListener) {
window.addEventListener("load", comet.initialize, false);
window.addEventListener("unload", comet.onUnload, false);
} else if (window.attachEvent) {
window.attachEvent("onload", comet.initialize);
window.attachEvent("onunload", comet.onUnload);
}
}
function setCometUrl(){
comet.cometUrl = "pubsub/push.json";
}
//服务器推送代码
var comet = {
connection : false,
iframediv : false,
initialize : function() {
if (navigator.appVersion.indexOf("MSIE") != -1) {
// For IE browsers
comet.connection = new ActiveXObject("htmlfile");
comet.connection.open();
comet.connection.write("<html>");
comet.connection.write("<script>document.domain = '" + document.domain + "'");
comet.connection.write("</html>");
comet.connection.close();
comet.iframediv = comet.connection.createElement("div");
comet.connection.appendChild(comet.iframediv);
comet.connection.parentWindow.comet = comet;
comet.iframediv.innerHTML = "<iframe id='comet_iframe' src='"+comet.cometUrl+"'></iframe>";
} else if (navigator.appVersion.indexOf("KHTML") != -1) {
// for KHTML browsers
comet.connection = document.createElement('iframe');
comet.connection.setAttribute('id', 'comet_iframe');
comet.connection.setAttribute('src', comet.cometUrl);
with (comet.connection.style) {
position = "absolute";
left = top = "-100px";
height = width = "1px";
visibility = "hidden";
}
document.body.appendChild(comet.connection);
} else {
// For other browser (Firefox...)
comet.connection = document.createElement('iframe');
comet.connection.setAttribute('id', 'comet_iframe');
comet.iframediv = document.createElement('iframe');
comet.iframediv.setAttribute('src', comet.cometUrl);
comet.connection.appendChild(comet.iframediv);
document.body.appendChild(comet.connection);
}
},
onUnload : function() {
if (comet.connection) {
comet.connection = false; // release the iframe to prevent problems with IE when reloading the page
closePage();
}
},
receiveMsg : function(msg) {
$("#content").append(msg + "<br/>");
}
}
function closePage() {
$.ajax({
async : true,
cache : false,
type : "POST",
//data:{objId:objId},
dataType:"json",
url :"pubsub/close.json",
success : function(data) {
},
error: function(){
}
});
}
</script>
</head>
<body >
<div id="content" class="show"></div>
</body>
这个客户端页面是利用浏览器支持的Comet，仅发起一次ajax请求，打通后台后，后台就会源源不断主动往这个页面发送数据。
后台较为复杂，并且还结合了redis的发布订阅。数据来源则是订阅redis的一个channel而得到。
Action:
@Controller
public class PubSubAction {
LinkedList<String> queue = new LinkedList<String>();
PrintWriter out;
//线程
MsgSubHandler subT = null;
CheckQueueHandler checkT = null;
@RequestMapping("/pubsub/push.json")
@ResponseBody
public void pushMsg(HttpServletResponse response) {
System.out.println("这儿进几次.........");
//订阅
subT = new MsgSubHandler("pubsub_channel", queue);
subT.start();
//检查
checkT = new CheckQueueHandler(queue);
checkT.start();
//创建Comet Iframe
sendHtmlScript(response, "<script type=\"text/javascript\"> var comet = window.parent.comet;</script>");
while (true) {
try {
Thread.sleep(1000);//每隔1s从队列取数
if(queue.size() > 0) {
String msg = queue.pop();
System.out.println("从队列里取到的信息:" + msg);
sendHtmlScript(response, "<script type=\"text/javascript\"> comet.receiveMsg('"+msg+"');</script>");
}
}catch(InterruptedException e) {
e.printStackTrace();
}
}
}
@RequestMapping("/pubsub/close.json")
@ResponseBody
public void shutdownServer() throws InterruptedException {
System.out.println("开始关闭操作..");
//关闭流
out.flush();
out.close();
//队列情空
queue.clear();
//消息的关闭处理
subT.shut();
checkT.shut();
//线程停止
if(checkT.isAlive()) {
checkT.interrupt();
checkT.join();
}
if(subT.isAlive()) {
subT.interrupt();
subT.join();
}
}
private void sendHtmlScript(HttpServletResponse response,String script){
response.setCharacterEncoding("UTF-8");
response.setContentType("text/html");
response.setDateHeader("Expires", 0);
response.setHeader("Pragma", "No-cache");
response.setHeader("Cache-Control", "no-cache,no-store,max-age=0");
try {
out = response.getWriter();
out.write(script);
out.flush();
} catch (IOException e) {
e.printStackTrace();
log.error(e.getMessage(), e);
}
}
}
其中，订阅消息的线程类和检查消息队列大小的线程类分别如下：
1：定时检查队列大小的线程类，目的是避免消息队列大小过大
public class CheckQueueHandler extends Thread {
private LinkedList<String> queue;
private boolean runFlag = true;
public CheckQueueHandler(LinkedList<String> queue) {
this.queue = queue;
}
@Override
public void run() {
try {
while (runFlag && queue.size()>0) {
Thread.sleep(60 * 1000);//每隔1分钟检查指定队列的大小
if (queue.size() >= 500) {
queue.clear();
}
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public void shut() {
runFlag = false;
}
}
2：订阅相应的channel的线程类：
public class MsgSubHandler extends Thread{
private LinkedList<String> queue;
private String channel;
JedisPool pool;
Jedis jedis;
PubSubListener listener;
public MsgSubHandler(String channel, LinkedList<String> queue) {
this.channel = channel;
this.queue = queue;
//redis资源初始化
pool = SysBeans.getBean("jedisPool");
jedis = pool.getResource();
//发布/订阅监听初始化
listener = new PubSubListener(queue);
}
@Override
public void run() {
//订阅指定的渠道信息
jedis.subscribe(listener, channel);
}
public void shut() {
//归还redis资源
if(pool !=null && jedis != null) {
pool.returnResource(jedis);
}
//取消渠道订阅
listener.unsubscribe();
}
}
3：redis的发布/订阅监听类
public class PubSubListener extends JedisPubSub {
private LinkedList<String> queue =null;
public PubSubListener(LinkedList<String> queue) {
this.queue = queue;
}
//取得订阅后消息的处理
@Override
public void onMessage(String channel, String message) {
//System.out.print("onMessage:取得订阅后消息的处理 ");
queue.add(message);
}
//取得按表达式的方式订阅的消息后的处理
@Override
public void onPMessage(String pattern, String channel, String message) {
System.out.print("onPMessage:取得按表达式的方式订阅的消息后的处理 ");
System.out.println(pattern + "=" + channel + "=" + message);
}
//初始化按表达式的方式订阅时候的处理
@Override
public void onPSubscribe(String pattern, int subscribedChannels) {
System.out.print("onPSubscribe:初始化按表达式的方式订阅时候的处理 ");
System.out.println(pattern + "=" + subscribedChannels);
}
//取消化按表达式的方式订阅时候的处理
@Override
public void onPUnsubscribe(String pattern, int subscribedChannels) {
System.out.print("onPUnsubscribe:取消化按表达式的方式订阅时候的处理 ");
System.out.println(pattern + "=" + subscribedChannels);
}
//初始化订阅时候的处理
@Override
public void onSubscribe(String channel, int subscribedChannels) {
System.out.print("onSubscribe:初始化订阅时候的处理 ");
System.out.println(channel + "=" + subscribedChannels);
}
//取消订阅时候的处理
@Override
public void onUnsubscribe(String channel, int subscribedChannels) {
System.out.print("onUnsubscribe:取消订阅时候的处理 ");
System.out.println(channel + "=" + subscribedChannels);
}
}
启动工程，打开客户端页面，最初始的div：
同时控制台打印：
这儿进几次.........
onSubscribe:初始化订阅时候的处理 pubsub_channel=1
这说明：一打开客户端，就实现了订阅对应channel的目的。
接下来，为了让这个div中有数据，我们开始来对这个channel进行publish一些数据，模拟：
public static void main(String[] args) {
Jedis jedis = new Jedis("localhost");
while(true) {
try {
Thread.sleep(2000);
jedis.publish("pubsub_channel", "I like " + Math.random()*100 );
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
然后你再观察这个div，会发现如下现象（某一时刻）：
由此说明：我们达到了如题所想要的目的！——结合了redis的发布/订阅 并且客户端只请求服务端一次，服务端主动向客户端推送了数据。
最后，我们再试着关闭客户端页面，会发现控制台打印：
onUnsubscribe:取消订阅时候的处理 pubsub_channel=0
说明，客户端一关闭，就取消了对channel的订阅了。并且queue队列也会被清空。
其实Comet并不是新兴的技术，关于【反ajax】技术，最新的有WebSocket，以后有机会再研究。
相关推荐
但随着Web应用的发展，尤其是在需要实时通信的场景下（如在线聊天室、实时推送消息等），短连接已不能满足需求。长连接技术允许连接在一定时间内保持打开状态，服务器端在接收到新数据时才响应客户端，这样可以减少...
内容概要：本文详细探讨了在主从博弈框架下，共享储能与综合能源微网的优化运行及其仿真复现。通过MATLAB和CPLEX的联合使用，展示了微网运营商和用户聚合商之间的动态博弈过程。上层模型关注微网运营商的定价策略，旨在最大化利润，考虑售电收益、储能运维成本等因素。下层模型则聚焦于用户聚合商的响应，根据电价调整电热负荷并参与共享储能调度。文中还介绍了电热耦合约束、充放电互斥约束等关键技术细节，并通过迭代博弈实现了策略更新。最终仿真结果显示，在引入电制热设备后，用户侧热负荷弹性提升，博弈收敛速度加快，达到双赢效果。 适合人群：从事能源系统优化、博弈论应用、MATLAB编程的研究人员和技术人员。 使用场景及目标：适用于希望深入了解主从博弈在综合能源系统中应用的学者和工程师。目标是掌握如何通过数学建模和编程实现复杂的能源系统优化，理解电热耦合机制和共享储能的作用。 其他说明：文章提供了详细的代码片段和仿真结果，帮助读者更好地理解和复现实验。此外，还讨论了一些常见的调试问题和解决方案，如约束冲突等。
1.版本：matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点：参数化编程、参数可方便更改、代码编程思路清晰、注释明细。 4.适用对象：计算机，电子信息工程、数学等专业的大学生课程设计、期末大作业和毕业设计。
内容概要：深度学习在多个领域有着广泛应用。在计算机视觉方面，涵盖图像分类、目标检测、图像分割等任务，应用于自动驾驶、医疗影像分析等领域；在自然语言处理上，包括机器翻译、文本分类、文本生成等功能，服务于信息检索、内容创作等；语音识别与合成领域，实现了语音到文本的转换以及文本到语音的生成，推动了智能交互的发展；医疗领域，深度学习助力医学影像分析、疾病预测、个性化治疗及健康监测；金融领域，深度学习用于信用风险评估、欺诈检测、高频交易等，保障金融安全并优化投资策略；自动驾驶方面，环境感知与决策控制系统确保车辆安全行驶；娱乐与媒体领域，个性化推荐和内容生成提升了用户体验；工业与制造业中，质量检测和预测性维护提高了生产效率和产品质量。 适合人群：对深度学习及其应用感兴趣的初学者、研究人员以及相关领域的从业者。 使用场景及目标：帮助读者全面了解深度学习在不同行业的具体应用场景，明确各领域中深度学习解决的实际问题，为后续深入研究或项目实施提供方向指引。 其他说明：随着深度学习技术的持续进步，其应用范围也在不断扩大，文中提及的应用实例仅为当前主要成果展示，未来还有更多潜力待挖掘。
1.版本：matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点：参数化编程、参数可方便更改、代码编程思路清晰、注释明细。 4.适用对象：计算机，电子信息工程、数学等专业的大学生课程设计、期末大作业和毕业设计。
周梁伟-大模型在融合通信中的应用实践
内容概要：本文详细介绍了利用西门子S7-200 PLC和组态王软件构建的一个花式喷泉控制系统的设计与实现。首先阐述了系统的硬件组成，包括三个环形喷泉组、七彩LED灯带以及功放喇叭等组件，并给出了详细的IO分配表。接着深入解析了关键的梯形图程序逻辑，如自动模式循环、灯光控制、喷泉舞步等部分的具体实现方法。此外，还分享了一些实际调试过程中遇到的问题及其解决方案，例如电源隔离、电磁干扰处理等。最后展示了组态王界面上生动有趣的动画效果设计思路。 适合人群：对PLC编程和工业自动化感兴趣的工程师和技术爱好者。 使用场景及目标：适用于需要设计类似互动娱乐设施的专业人士，旨在帮助他们掌握从硬件选型、程序编写到界面美化的完整流程，从而能够独立完成类似的工程项目。 其他说明：文中不仅提供了理论知识讲解，还包括了许多实践经验教训，对于初学者来说非常有价值。同时，作者还在系统中加入了一些趣味性的元素，如隐藏模式等，增加了项目的吸引力。
内容概要：本文详细介绍了利用COMSOL进行电弧熔池多物理场耦合仿真的方法和技术要点。首先解释了电弧熔池的本质及其复杂性，然后依次讲解了几何建模、材料属性设置、求解器配置以及后处理等方面的具体步骤和注意事项。文中提供了大量实用的MATLAB、Java和Python代码片段，帮助用户更好地理解和应用相关技术。此外，作者分享了许多实践经验，如分阶段激活物理场、使用光滑过渡函数处理相变、优化网格划分等，强调了参数选择和边界条件设定的重要性。 适合人群：从事电弧熔池仿真研究的专业人士，尤其是有一定COMSOL使用经验的研究人员。 使用场景及目标：适用于需要精确模拟电弧熔池行为的研究项目，旨在提高仿真精度并减少计算时间。主要目标是掌握多物理场耦合仿真的关键技术，解决实际工程中遇到的问题。 其他说明：文章不仅提供了详细的理论指导，还包括许多实用的操作技巧和常见错误的解决方案，有助于读者快速上手并深入理解电弧熔池仿真的难点和重点。
9f148310e17f2960fea3ff60af384a37_098bb292f553b9f4ff9c67367379fafd
# 【spring-ai-hanadb-store-1.0.0-M7.jar中文-英文对照文档.zip】 中包含： 中文-英文对照文档：【spring-ai-hanadb-store-1.0.0-M7-javadoc-API文档-中文(简体)-英语-对照版.zip】 jar包下载地址：【spring-ai-hanadb-store-1.0.0-M7.jar下载地址(官方地址+国内镜像地址).txt】 Maven依赖：【spring-ai-hanadb-store-1.0.0-M7.jar Maven依赖信息(可用于项目pom.xml).txt】 Gradle依赖：【spring-ai-hanadb-store-1.0.0-M7.jar Gradle依赖信息(可用于项目build.gradle).txt】 源代码下载地址：【spring-ai-hanadb-store-1.0.0-M7-sources.jar下载地址(官方地址+国内镜像地址).txt】 # 本文件关键字： spring-ai-hanadb-store-1.0.0-M7.jar中文-英文对照文档.zip,java,spring-ai-hanadb-store-1.0.0-M7.jar,org.springframework.ai,spring-ai-hanadb-store,1.0.0-M7,org.springframework.ai.vectorstore.hanadb,jar包,Maven,第三方jar包,组件,开源组件,第三方组件,Gradle,springframework,spring,ai,hanadb,store,中文-英文对照API文档,手册,开发手册,使用手册,参考手册 # 使用方法： 解压 【spring-ai-hanadb-store-1.0.0-M7.jar中文-英文
# 压缩文件中包含： 中文文档 jar包下载地址 Maven依赖 Gradle依赖 源代码下载地址 # 本文件关键字： jar中文文档.zip,java,jar包,Maven,第三方jar包,组件,开源组件,第三方组件,Gradle,中文API文档,手册,开发手册,使用手册,参考手册 # 使用方法： 解压最外层zip，再解压其中的zip包，双击 【index.html】 文件，即可用浏览器打开、进行查看。 # 特殊说明： ·本文档为人性化翻译，精心制作，请放心使用。 ·只翻译了该翻译的内容，如：注释、说明、描述、用法讲解 等； ·不该翻译的内容保持原样，如：类名、方法名、包名、类型、关键字、代码 等。 # 温馨提示： （1）为了防止解压后路径太长导致浏览器无法打开，推荐在解压时选择“解压到当前文件夹”（放心，自带文件夹，文件不会散落一地）； （2）有时，一套Java组件会有多个jar，所以在下载前，请仔细阅读本篇描述，以确保这就是你需要的文件；
3dmax插件
内容概要：本文详细介绍了单相全桥PWM整流器采用双闭环控制策略的具体实现方法和技术要点。电压环采用PI控制器来稳定直流侧电压，电流环则使用PR控制器确保交流电流与电压同相位并实现单位功率因数。文中提供了详细的MATLAB、C和Python代码片段，解释了各个控制器的设计思路和参数整定方法。此外，文章还讨论了突加负载测试、电压前馈补偿、PWM生成以及硬件选型等方面的内容，强调了系统的稳定性和快速响应能力。 适合人群：从事电力电子、自动控制领域的工程师和技术人员，尤其是对PWM整流器和双闭环控制感兴趣的读者。 使用场景及目标：适用于需要精确控制直流电压和交流电流的应用场景，如工业电源、新能源发电等领域。目标是提高系统的电能质量和动态响应速度，确保在负载变化时仍能保持稳定的输出。 其他说明：文章不仅提供了理论分析，还包括了大量的实际测试数据和波形图，帮助读者更好地理解和掌握双闭环控制的实际效果。同时，文中提到的一些调试技巧和注意事项对于实际工程应用非常有价值。
easyocr安装包和模型
AC_DIMMER交流调光灯stm32.7z
仲量联行-负责任的房地产：实现社会价值，赋能建筑环境，创造积极的环境和社会影响
C语言全部知识点复习资料.doc
【蓝桥杯EDA】客观题解析
内容概要：本文详细介绍了电-气-热综合能源系统的优化调度方法，重点探讨了如何利用MATLAB和CPLEX进行建模和求解。文章首先分别阐述了电网、气网和热网的建模方法，包括电网的直流潮流模型、气网的线性化处理以及热网的状态空间方程。接着深入讨论了各个网络之间的耦合关系，如电转气设备(P2G)、燃气轮机和电热锅炉的作用机制。文中还分享了一些实用技巧，如变量定义顺序对求解速度的影响、分段线性化的精度与效率权衡等。最后展示了完整的优化模型结构，并通过实例验证了模型的有效性和优越性。 适合人群：从事综合能源系统研究和开发的技术人员，尤其是熟悉MATLAB和CPLEX工具的研究者。 使用场景及目标：适用于希望深入了解并掌握电-气-热综合能源系统调度优化方法的专业人士。主要目标是提高能源利用效率，降低成本，增强系统的稳定性和可靠性。 其他说明：文章不仅提供了详细的理论解释和技术实现步骤，还分享了许多实践经验，帮助读者更好地理解和应用相关技术。