haoningabc
- 浏览: 1489888 次
- 性别:
- 来自: 北京
-
文章分类
- 全部博客 (691)
- linux (207)
- shell (33)
- java (42)
- 其他 (22)
- javascript (33)
- cloud (16)
- python (33)
- c (48)
- sql (12)
- 工具 (6)
- 缓存 (16)
- ubuntu (7)
- perl (3)
- lua (2)
- 超级有用 (2)
- 服务器 (2)
- mac (22)
- nginx (34)
- php (2)
- 内核 (2)
- gdb (13)
- ICTCLAS (2)
- mac android (0)
- unix (1)
- android (1)
- vim (1)
- epoll (1)
- ios (21)
- mysql (3)
- systemtap (1)
- 算法 (2)
- 汇编 (2)
- arm (3)
- 我的数据结构 (8)
- websocket (12)
- hadoop (5)
- thrift (2)
- hbase (1)
- graphviz (1)
- redis (1)
- raspberry (2)
- qemu (31)
- opencv (4)
- socket (1)
- opengl (1)
- ibeacons (1)
- emacs (6)
- openstack (24)
- docker (1)
- webrtc (11)
- angularjs (2)
- neutron (23)
- jslinux (18)
- 网络 (13)
- tap (9)
- tensorflow (8)
- nlu (4)
- asm.js (5)
- sip (3)
- xl2tp (5)
- conda (1)
- emscripten (6)
- ffmpeg (10)
- srt (1)
- wasm (5)
- bert (3)
- kaldi (4)
- 知识图谱 (1)
最新评论
-
wahahachuang8：
我喜欢代码简洁易读，服务稳定的推送服务，前段时间研究了一下go ...
websocket的helloworld -
q114687576：
http://www.blue-zero.com/WebSoc ...
websocket的helloworld -
zhaoyanzimm：
感谢您的分享，给我提供了很大的帮助，在使用过程中发现了一个问题 ...
nginx的helloworld模块的helloworld -
haoningabc：
leebyte 写道太NB了，期待早日用上Killinux！么 ...
qemu+emacs+gdb调试内核 -
leebyte：
太NB了，期待早日用上Killinux！
qemu+emacs+gdb调试内核
nginx的上传
查看http://haoningabc.iteye.com/blog/2344484
效果如图
这几天有个需求
上传大文件，需要带进度条，
nginx这个版本有7，8年了，担心有bug，不如用websocket重新写一个
原理
使用websocket.jar
前端需要分片，把一定字节的用websocket传过去
后端用流顺序写到文件里面
（理论上，如果用session把当前存的字节数就可以断点续传）
html代码如下：
java的服务端代码如下
只需要一个jar
websocket.jar
http://dl.iteye.com/topics/download/decd7d91-9d2a-381f-bcea-fb0e202f6e3c
查看http://haoningabc.iteye.com/blog/2344484
效果如图
这几天有个需求
上传大文件，需要带进度条，
nginx这个版本有7，8年了，担心有bug，不如用websocket重新写一个
原理
使用websocket.jar
前端需要分片，把一定字节的用websocket传过去
后端用流顺序写到文件里面
（理论上，如果用session把当前存的字节数就可以断点续传）
html代码如下：
<!DOCTYPE html>
<html>
<head>
<title>WebSocket Chat Client</title>
<meta charset="utf-8" />
<script type="text/javascript" src="jquery-1.11.0.min.js"></script>
<script type="text/javascript" src="jquery.json-2.3.js"></script>
<script type="text/javascript">
$().ready(
function() {
if (window.File && window.FileReader && window.FileList
&& window.Blob) {
} else {
alert('The File APIs are not fully supported in this browser.');
}
});
//在消息框中打印内容
function log(text) {
$("#log").append(text+"\n");
}
//全局的websocket变量
var ws;
var paragraph = 10485760;
//var paragraph = 1024;
var fileList ;
var file;
var startSize,endSize = 0;
var i = 0; j = 0;
//连接服务器
$(function() {
$("#connect").click(function() {
ws = new WebSocket($("#uri").val());
//连接成功建立后响应
ws.onopen = function() {
log("成功连接到" + $("#uri").val());
}
//收到服务器消息后响应
ws.onmessage = function(e) {
console.log("iiiiiiiiii:"+i);
log("服务器说" + e.data + " "+(e.data=="ok"));
if((e.data+"") == "ok"){
if(endSize < file.size){
console.log("file.size:"+file.size);
startSize = endSize;
endSize += paragraph ;
console.log("startSize:"+startSize);
console.log("endSize:"+endSize);
console.log("file---haha----:"+file);
document.getElementById('progress').innerHTML=Math.round(startSize / file.size * 10000) / 100.00 + "%";
if (file.webkitSlice) {
console.log("webkitSlice--->");
var blob = file.webkitSlice(startSize, endSize);
} else if (file.mozSlice) {
console.log("mozSlice--->");
var blob = file.mozSlice(startSize, endSize);
}else {
console.log("Slice--->");
var blob = file.slice(startSize, endSize);
}
var reader = new FileReader();
reader.readAsArrayBuffer(blob);
reader.onload = function loaded(evt) {
var ArrayBuffer = evt.target.result;
log("发送文件第" + (i++) + "部分");
ws.send(ArrayBuffer);
}
}else{
console.log("endSize >= file.size-->"+e.data+"<---");
console.log("endSize >= file.size-->endSize:"+endSize);
console.log("endSize >= file.size-->file.size:"+file.size);
startSize = endSize = 0;
i = 0;
log("发送" + file.name +"完毕");
log("发送文件完毕");
}
}
//连接关闭后响应
ws.onclose = function() {
log("关闭连接");
ws = null;
}
return false;
}
});
});
$(function() {
$("#sendFileForm").click(function() {
fileList = document.getElementById("file").files;
file = fileList[0];
ws.send(file.name);
})
});
$(function() {
$("#reset").click(function() {
$("#log").empty();
return false;
});
});
</script>
</head>
<body>
<span>上传的百分比</span>
<span id="progress">0</span><br>
<input type="text" id="uri" value="ws://localhost:8887"
style="width: 200px;"> <input type="button" id="connect"
value="Connect"><input type="button" id="disconnect"
value="Disconnect" disabled="disabled"><!--ws://192.168.137.178:8081/websocketchat/hao/binupload?r=haha-->
<form >
<input id="file" type="file" multiple />
<input type="button" id="sendFileForm" value="测试" />
<input type="button" id="reset" value="清空消息框" />
</form>
<form>
<textarea id="log" rows="30" cols="100"
style="font-family: monospace; color: red;"></textarea>
</form>
</body>
</html>
java的服务端代码如下
package testupload;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.UnknownHostException;
import java.nio.channels.NotYetConnectedException;
import java.util.Set;
import org.java_websocket.WebSocket;
import org.java_websocket.WebSocketServer;
import org.java_websocket.handshake.ClientHandshake;
public class UploadServer extends WebSocketServer {
public UploadServer(int port) throws UnknownHostException {
super(new InetSocketAddress(InetAddress.getByName("192.168.137.178"), port));
}
public UploadServer(InetSocketAddress address) {
super(address);
}
@Override
public void onOpen(WebSocket conn, ClientHandshake handshake) {
try {
this.sendToAll("new");
} catch (InterruptedException ex) {
ex.printStackTrace();
}
System.out.println(conn + " entered the room!");
}
@Override
public void onClose(WebSocket conn, int code, String reason, boolean remote) {
try {
this.sendToAll(conn + " has left the room!");
} catch (InterruptedException ex) {
ex.printStackTrace();
}
System.out.println(conn + " has left the room!");
}
public String fileName;
public String getFileName() {
return fileName;
}
public void setFileName(String fileName) {
this.fileName = fileName;
}
@Override
public void onMessage(WebSocket conn, String message) {
// try {
// this.sendToAll( message );
// } catch ( InterruptedException ex ) {
// ex.printStackTrace();
// }
// System.out.println( conn + ": " + message );
System.out.println("文件名" + message);
// 将文件名写入连接对象中,(需要手动修改webSocket类)
this.setFileName(message);
try {
conn.send("ok");
} catch (NotYetConnectedException e) {
e.printStackTrace();
} catch (IllegalArgumentException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public void onMessage(WebSocket conn, byte[] message) {
System.out.println("收到二进制流:");
// 将二进制流保存为文件, 文件名从连接对象中取出
saveFileFromBytes(message, "D:/c/apache-tomcat-7.0.62/webapps/websocketchat/src/" + this.getFileName());
// 告诉前台可以继续发送了.
try {
conn.send("ok");
} catch (NotYetConnectedException e) {
e.printStackTrace();
} catch (IllegalArgumentException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public static boolean saveFileFromBytes(byte[] b, String outputFile) {
FileOutputStream fstream = null;
File file = null;
try {
file = new File(outputFile);
fstream = new FileOutputStream(file, true);
fstream.write(b);
} catch (Exception e) {
e.printStackTrace();
return false;
} finally {
if (fstream != null) {
try {
fstream.close();
} catch (IOException e1) {
e1.printStackTrace();
}
}
}
return true;
}
@Override
public void onError(WebSocket conn, Exception ex) {
ex.printStackTrace();
}
public void sendToAll(String text) throws InterruptedException {
Set<WebSocket> con = connections();
synchronized (con) {
for (WebSocket c : con) {
c.send(text);
}
}
}
public static void main(String[] args) throws InterruptedException, IOException {
WebSocket.DEBUG = true;
int port = 8887;
try {
port = Integer.parseInt(args[0]);
} catch (Exception ex) {
}
UploadServer s = new UploadServer(port);
s.start();
System.out.println("UploadServer started on port: " + s.getPort());
// 服务端 发送消息处理部份
BufferedReader sysin = new BufferedReader(new InputStreamReader(System.in));
while (true) {
String in = sysin.readLine();
s.sendToAll(in);
}
}
}
只需要一个jar
websocket.jar
http://dl.iteye.com/topics/download/decd7d91-9d2a-381f-bcea-fb0e202f6e3c
分享到：
发表评论
-
indexedDB存图片减少请求
2020-05-21 19:23 572getImageFile()获取网络图片 showImage ... -
vizceral-example的例子
2020-03-19 18:53 371自定义图和加载结构 代码在 https://github.c ... -
jsonpath的helloworld
2020-03-17 14:58 423基本语法：https://www.cnblogs.com/jp ... -
流动图神器vizceral
2019-10-12 19:04 544把c的代码生成json：https://github.com/ ... -
emscripten asm.js的helloworld
2018-03-01 20:15 1131mac下安装： brew install SDL2 SDL2_ ... -
webpack的helloworld
2016-11-02 10:42 924参考 http://www.jianshu.com/p/42e ... -
iphone6等移动端的css自适应
2016-10-17 01:18 1222参考 http://jingyan.baidu.com/art ... -
javascript自定义事件
2016-06-01 21:49 563一言不合上代码 <input value=" ... -
html5的fiesystem api 浏览器本地存储
2016-06-01 15:59 932html5的fiesystem api可以存取本地文件 一言不 ... -
websocket传传图片
2015-12-25 17:51 7256参考[url]http://www.adobe.com/dev ... -
angularjs使用include后双向绑定失败的解决
2015-12-20 19:41 1880原理参考 http://segmentfault.com/q/ ... -
html5 陀螺仪
2014-11-26 21:05 5898<html> <head> ... -
webgl的贝塞尔曲线
2014-11-12 00:56 2550BezierCurve webgl的贝塞尔曲线 webgl ... -
chrome app的helloworld
2014-11-11 13:56 728参考 http://blog.csdn.net/rydiy/a ... -
shader and Program编程基本概念 - 转
2014-11-04 11:50 1570原地址:http://blog.csdn.net/myarro ... -
javascript对象转json
2014-10-17 14:09 1020<html> <head>& ... -
jquery 的svg中国地图
2012-12-16 14:37 28113三种吧 1.d3.js很强大 2.jquery的 jvecto ... -
纯css的树型结构
2012-10-03 18:29 1295<html><head> ... -
D3 的3d图
2012-09-16 17:05 1468LCF http://mathworld.wolfram. ... -
jquery table拖拽排序
2012-07-14 21:45 7139参考http://dragsort.codeplex.com/ ...
相关推荐
1、文件内容：ibus-table-chinese-erbi-1.4.6-3.el7.rpm以及相关依赖 2、文件形式：tar.gz压缩包 3、安装指令： #Step1、解压 tar -zxvf /mnt/data/output/ibus-table-chinese-erbi-1.4.6-3.el7.tar.gz #Step2、进入解压后的目录，执行安装 sudo rpm -ivh *.rpm 4、更多资源/技术支持：公众号禅静编程坊
选择Java后台技术和MySQL数据库，在前台界面为提升用户体验，使用Jquery、Ajax、CSS等技术进行布局。 系统包括两类用户：学生、管理员。 学生用户只要实现了前台信息的查看，打开首页，查看网站介绍、自习室信息、在线留言、轮播图信息公告等，通过点击首页的菜单跳转到对应的功能页面菜单，包括网站首页、自习室信息、注册登录、个人中心、后台登录。 学生用户通过账户账号登录，登录后具有所有的操作权限，如果没有登录，不能在线预约。学生用户退出系统将注销个人的登录信息。 管理员通过后台的登录页面，选择管理员权限后进行登录，管理员的权限包括轮播公告管理、老师学生信息管理和信息审核管理，管理员管理后点击退出，注销登录信息。 管理员用户具有在线交流的管理，自习室信息管理、自习室预约管理。 在线交流是对前台用户留言内容进行管理，删除留言信息，查看留言信息。
面向基层就业个性化大学生服务平台(源码+数据库+论文+ppt)java开发springboot框架javaweb，可做计算机毕业设计或课程设计 【功能需求】 面向基层就业个性化大学生服务平台(源码+数据库+论文+ppt)java开发springboot框架javaweb，可做计算机毕业设计或课程设计 面向基层就业个性化大学生服务平台中的管理员角色主要负责了如下功能操作。 （1）职业分类管理功能需求：对职业进行划分分类管理等。 （2）用户管理功能需求：对用户信息进行维护管理等。 （3）职业信息管理功能需求：对职业信息进行发布等。 （4）问卷信息管理功能需求：可以发布学生的问卷调查操作。 （5）个性化测试管理功能需求：可以发布个性化测试试题。 （6）试题管理功能需求：对测试试题进行增删改查操作。 （7）社区交流管理功能需求：对用户的交流论坛信息进行维护管理。 面向基层就业个性化大学生服务平台中的用户角色主要负责了如下功能操作。 （1）注册登录功能需求：没有账号的用户，可以输入账号，密码，昵称，邮箱等信息进行注册操作，注册后可以输入账号和密码进行登录。 （2）职业信息功能需求：用户可以对职业信息进行查看。 （3）问卷信息功能需求：可以在线进行问卷调查答卷操作。 （4）社区交流功能需求：可以在线进行社区交流。 （5）个性化测试功能需求：可以在线进行个性化测试。 （6）公告资讯功能需求：可以查看浏览系统发布的公告资讯信息。 【环境需要】 1.运行环境：最好是java jdk 1.8，我们在这个平台上运行的。其他版本理论上也可以。 2.IDE环境：IDEA，Eclipse,Myeclipse都可以。 3.tomcat环境：Tomcat 7.x,8.x,9.x版本均可 4.数据库：MySql 5.7/8.0等版本均可； 【购买须知】 本源码项目经过严格的调试，项目已确保无误，可直接用于课程实训或毕业设计提交。里面都有配套的运行环境软件，讲解视频，部署视频教程，一应俱全，可以自己按照教程导入运行。附有论文参考，使学习者能够快速掌握系统设计和实现的核心技术。
三菱Fx3u程序：自动检测包装机电机控制模板，PLC脉冲与伺服定位，手自动切换功能,三菱Fx3u程序：自动检测包装机电机控制模板——涵盖伺服定位与手自动切换功能,三菱Fx3u程序，自动检测包装机。 该程序六个电机，plc本体脉冲控制3个轴，3个1pg控制。 程序内包括伺服定位，手自动切，功能快的使用，可作为模板程序，很适合新手。 ,三菱Fx3u程序; 自动检测包装机; 六个电机; PLC脉冲控制; 伺服定位; 手自动切换; 功能快捷键; 模板程序。,三菱Fx3u PLC控制下的自动包装机程序：六电机伺服定位与手自动切换模板程序
1.版本：matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点：参数化编程、参数可方便更改、代码编程思路清晰、注释明细。 4.适用对象：计算机，电子信息工程、数学等专业的大学生课程设计、期末大作业和毕业设计。
计及信息间隙决策与多能转换的综合能源系统优化调度模型：实现碳经济最大化与源荷不确定性考量,基于信息间隙决策与多能转换的综合能源系统优化调度模型：源荷不确定性下的高效碳经济调度策略,计及信息间隙决策及多能转的综合能源系统优化调度 本代码构建了含风电、光伏、光热发电系统、燃气轮机、燃气锅炉、电锅炉、储气、储电、储碳、碳捕集装置的综合能源系统优化调度模型，并考虑P2G装置与碳捕集装置联合运行，从而实现碳经济的最大化，最重要的是本文引入了信息间隙决策理论考虑了源荷的不确定性（本代码的重点）与店铺的47代码形成鲜明的对比，注意擦亮眼睛，认准原创，该代码非常适合修改创新，，提供相关的模型资料 ,计及信息间隙决策; 综合能源系统; 优化调度; 多能转换; 碳经济最大化; 风电; 光伏; 燃气轮机; 储气; 储电; 储碳; 碳捕集装置; P2G装置联合运行; 模型资料,综合能源系统优化调度模型：基于信息间隙决策和多能转换的原创方案
IPG QCW激光模块电源驱动电路设计与实现：包含安全回路、紧急放电回路及光纤互锁功能的多版本原理图解析,IPG QCW激光模块电源驱动电路设计与实现：含安全回路、紧急放电及光纤互锁等多重保护功能的原理图解析,IPG QCW激光模块电源驱动电路， 包含安全回路，紧急放电回路，光纤互锁回路等， 元件参数请根据实际设计适当调整，此电路仅供参考，不提供pcb文件 原理图提供PDF和KICAD两个版本。 ,IPG激光模块; QCW激光电源驱动; 安全回路; 紧急放电回路; 光纤互锁回路; 原理图PDF和KICAD版本。,IPG激光模块电源驱动电路图解：含安全与紧急放电回路
基于LSSVM的短期电力负荷预测模型及其性能评估：结果揭露精确度与误差分析,LSSVM在短期电力负荷预测中的结果分析：基于均方根误差、平均绝对误差及平均相对百分误差的评估。,LSSVM最小二乘支持向量机做短期电力负荷预测。 结果分析 均方根误差(RMSE)：0.79172 平均绝对误差（MAE）：0.4871 平均相对百分误差（MAPE）：13.079% ,LSSVM（最小二乘支持向量机）；短期电力负荷预测；均方根误差（RMSE）;平均绝对误差（MAE）;平均相对百分误差（MAPE）,LSSVM在电力负荷短期预测中的应用及性能分析
1、文件内容：libmtp-examples-1.1.14-1.el7.rpm以及相关依赖 2、文件形式：tar.gz压缩包 3、安装指令： #Step1、解压 tar -zxvf /mnt/data/output/libmtp-examples-1.1.14-1.el7.tar.gz #Step2、进入解压后的目录，执行安装 sudo rpm -ivh *.rpm 4、更多资源/技术支持：公众号禅静编程坊
资源内项目源码是均来自个人的课程设计、毕业设计或者具体项目，代码都测试ok，都是运行成功后才上传资源，答辩评审绝对信服的，拿来就能用。放心下载使用！源码、说明、论文、数据集一站式服务，拿来就能用的绝对好资源！！！ 项目备注 1、该资源内项目代码都经过测试运行成功，功能ok的情况下才上传的，请放心下载使用！ 2、本项目适合计算机相关专业(如计科、人工智能、通信工程、自动化、电子信息等)的在校学生、老师或者企业员工下载学习，也适合小白学习进阶，当然也可作为毕设项目、课程设计、大作业、项目初期立项演示等。 3、如果基础还行，也可在此代码基础上进行修改，以实现其他功能，也可用于毕设、课设、作业等。 下载后请首先打开README.md文件（如有），仅供学习参考, 切勿用于商业用途。 4、如有侵权请私信博主，感谢支持
2023-04-06-项目笔记-第四百一十六阶段-课前小分享_小分享1.坚持提交gitee 小分享2.作业中提交代码 小分享3.写代码注意代码风格 4.3.1变量的使用 4.4变量的作用域与生命周期 4.4.1局部变量的作用域 4.4.2全局变量的作用域 4.4.2.1全局变量的作用域_1 4.4.2.414局变量的作用域_414- 2025-02-21
MINIST数据集和春风机器学习框架
1、文件内容：ibus-table-chinese-wu-1.4.6-3.el7.rpm以及相关依赖 2、文件形式：tar.gz压缩包 3、安装指令： #Step1、解压 tar -zxvf /mnt/data/output/ibus-table-chinese-wu-1.4.6-3.el7.tar.gz #Step2、进入解压后的目录，执行安装 sudo rpm -ivh *.rpm 4、更多资源/技术支持：公众号禅静编程坊
宿舍管理系统(源码+数据库+论文+ppt)java开发springboot框架javaweb，可做计算机毕业设计或课程设计 【功能需求】 系统拥有管理员和学生两个角色，主要具备系统首页、个人中心、学生管理、宿舍信息管理、宿舍分配管理、水电费管理、进入宿舍管理、出入宿舍管理、维修信息管理、卫生信息管理、考勤信息管理、留言板、交流论坛、系统管理等功能模块。 【环境需要】 1.运行环境：最好是java jdk 1.8，我们在这个平台上运行的。其他版本理论上也可以。 2.IDE环境：IDEA，Eclipse,Myeclipse都可以。 3.tomcat环境：Tomcat 7.x,8.x,9.x版本均可 4.数据库：MySql 5.7/8.0等版本均可； 【购买须知】 本源码项目经过严格的调试，项目已确保无误，可直接用于课程实训或毕业设计提交。里面都有配套的运行环境软件，讲解视频，部署视频教程，一应俱全，可以自己按照教程导入运行。附有论文参考，使学习者能够快速掌握系统设计和实现的核心技术。
1.版本：matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点：参数化编程、参数可方便更改、代码编程思路清晰、注释明细。 4.适用对象：计算机，电子信息工程、数学等专业的大学生课程设计、期末大作业和毕业设计。
人凤飞飞凤飞飞是粉色丰富
2024蓝桥杯嵌入式学习资料
image_download_1740129191509.jpg
基于Multisim仿真的带优先病房呼叫系统设计（仿真图） 设计一个病房呼叫系统。 功能 （1）当有病人紧急呼叫时，产生声，光提示，并显示病人的编号； （2）根据病人的病情设计优先级别，当有多人呼叫时，病情严重者优先； （3）医护人员处理完当前最高级别的呼叫后，系统按优先级别显示其他呼叫病人的病号。
基于STM32F103的3.6kW全桥逆变器资料：并网充电放电、智能切换与全方位保护方案,基于STM32F103的3.6kW全桥逆变器资料：并网充电放电、智能控制与全方位保护方案,逆变器光伏逆变器，3.6kw储能逆变器全套资料 STM32储能逆变器 BOOST 全桥 基于STM32F103设计，具有并网充电、放电；并网离网自动切；485通讯，在线升级；风扇智能控制，提供过流、过压、短路、过温等全方位保护。 基于arm的方案区别于dsp。 有PCB、原理图及代码ad文件。 ,逆变器; 储能逆变器; STM32F103; 3.6kw; 485通讯; 全方位保护; 智能控制; 方案区别; PCB文件; 原理图文件; ad文件。,基于STM32F103的3.6kw储能逆变器：全方位保护与智能控制