我正在尝试编写 Java 代码以从流式 HTTP 连接接收数据(我想调试我在针对 spring-websocket 服务器运行 Sockjs XHR-streaming 时遇到的问题)。
我使用一些非常简单的代码来连接:
URI uri = // The server
Socket socket = new Socket();
socket.connect(new InetSocketAddress(uri.getHost(), uri.getPort()));
OutputStream os = socket.getOutputStream();
PrintWriter pw = new PrintWriter(os);
int id = new Random().nextInt() % 100000;
pw.println("POST /socket/" + id + "/xxx/xhr_streaming HTTP/1.1");
pw.println("Content-Type: application/stomp");
pw.println("Content-Length: 0");
pw.println("Connection: keep-alive");
pw.println();
pw.flush();
InputStream is = socket.getInputStream();
ByteArrayOutputStream baos = new ByteArrayOutputStream();
byte[] buffer = new byte[8192];
int bytes;
do {
bytes = is.read(buffer);
if (bytes > 0) {
System.out.println("read: "+ bytes);
System.out.print(new String(buffer, 0, bytes));
System.out.println("----");
}
} while (bytes >= 0);
但是当我运行它时，我只得到 HTTP header 。
这本身并不足为奇。我会怀疑服务器没有正确发送内容。
但是当我使用 Wireshark 监控流量时，我可以看到我收到了三个 TCP 段以响应我的 POST。一个包含 1460 字节(+54 字节 TCP/IP header )，一个 1178 字节(+54 字节 header )和一个 7 字节(+44 字节 header )。
第一个包含 HTTP header 以及 878 字节的内容(Sockjs XHR 流从发送 2048 h 的前导码开始)。下一个包含序言的其余部分，最后一个包含“开放框架”。完全符合我对服务器的期望。
为什么我的 Java 代码没有收到剩余的数据？当我使用原始套接字时，它应该完全不知道 HTTP 协议(protocol)，所以我不明白为什么我只收到 HTTP header 。服务器可能在写入 header 后刷新数据，但我可以在网络转储中看到 header 和数据的第一部分都包含在第一个 TCP 段中。
这是第一个收到的 TCP 段的转储:
0000 e8 39 35 45 20 df 00 0c 29 09 62 3b 08 00 45 00 .95E ...).b;..E.
0010 05 dc 0c 5e 40 00 80 06 5b 27 c0 a8 06 26 c0 a8 ...^@...['...&..
0020 06 20 1f 90 df d9 92 50 c3 f6 ac 89 8a c3 50 10 . .....P......P.
0030 01 00 fc 88 00 00 48 54 54 50 2f 31 2e 31 20 32 ......HTTP/1.1 2
0040 30 30 20 4f 4b 0d 0a 53 65 72 76 65 72 3a 20 41 00 OK..Server: A
0050 70 61 63 68 65 2d 43 6f 79 6f 74 65 2f 31 2e 31 pache-Coyote/1.1
0060 0d 0a 58 2d 55 41 2d 43 6f 6d 70 61 74 69 62 6c ..X-UA-Compatibl
0070 65 3a 20 49 45 3d 65 64 67 65 2c 63 68 72 6f 6d e: IE=edge,chrom
0080 65 3d 31 0d 0a 58 2d 43 6f 6e 74 65 6e 74 2d 54 e=1..X-Content-T
0090 79 70 65 2d 4f 70 74 69 6f 6e 73 3a 20 6e 6f 73 ype-Options: nos
00a0 6e 69 66 66 0d 0a 58 2d 58 53 53 2d 50 72 6f 74 niff..X-XSS-Prot
00b0 65 63 74 69 6f 6e 3a 20 31 3b 20 6d 6f 64 65 3d ection: 1; mode=
00c0 62 6c 6f 63 6b 0d 0a 43 61 63 68 65 2d 43 6f 6e block..Cache-Con
00d0 74 72 6f 6c 3a 20 6e 6f 2d 63 61 63 68 65 2c 20 trol: no-cache,
00e0 6e 6f 2d 73 74 6f 72 65 2c 20 6d 61 78 2d 61 67 no-store, max-ag
00f0 65 3d 30 2c 20 6d 75 73 74 2d 72 65 76 61 6c 69 e=0, must-revali
0100 64 61 74 65 0d 0a 50 72 61 67 6d 61 3a 20 6e 6f date..Pragma: no
0110 2d 63 61 63 68 65 0d 0a 45 78 70 69 72 65 73 3a -cache..Expires:
0120 20 30 0d 0a 58 2d 46 72 61 6d 65 2d 4f 70 74 69 0..X-Frame-Opti
0130 6f 6e 73 3a 20 44 45 4e 59 0d 0a 58 2d 46 72 61 ons: DENY..X-Fra
0140 6d 65 2d 4f 70 74 69 6f 6e 73 3a 20 41 4c 4c 4f me-Options: ALLO
0150 57 2d 46 52 4f 4d 20 2a 0d 0a 58 2d 41 70 70 6c W-FROM *..X-Appl
0160 69 63 61 74 69 6f 6e 2d 43 6f 6e 74 65 78 74 3a ication-Context:
0170 20 61 70 70 6c 69 63 61 74 69 6f 6e 0d 0a 43 61 application..Ca
0180 63 68 65 2d 43 6f 6e 74 72 6f 6c 3a 20 6e 6f 2d che-Control: no-
0190 73 74 6f 72 65 2c 20 6e 6f 2d 63 61 63 68 65 2c store, no-cache,
01a0 20 6d 75 73 74 2d 72 65 76 61 6c 69 64 61 74 65 must-revalidate
01b0 2c 20 6d 61 78 2d 61 67 65 3d 30 0d 0a 41 63 63 , max-age=0..Acc
01c0 65 73 73 2d 43 6f 6e 74 72 6f 6c 2d 41 6c 6c 6f ess-Control-Allo
01d0 77 2d 4f 72 69 67 69 6e 3a 20 2a 0d 0a 41 63 63 w-Origin: *..Acc
01e0 65 73 73 2d 43 6f 6e 74 72 6f 6c 2d 41 6c 6c 6f ess-Control-Allo
01f0 77 2d 43 72 65 64 65 6e 74 69 61 6c 73 3a 20 74 w-Credentials: t
0200 72 75 65 0d 0a 43 6f 6e 74 65 6e 74 2d 54 79 70 rue..Content-Typ
0210 65 3a 20 61 70 70 6c 69 63 61 74 69 6f 6e 2f 6a e: application/j
0220 61 76 61 73 63 72 69 70 74 3b 63 68 61 72 73 65 avascript;charse
0230 74 3d 55 54 46 2d 38 0d 0a 54 72 61 6e 73 66 65 t=UTF-8..Transfe
0240 72 2d 45 6e 63 6f 64 69 6e 67 3a 20 63 68 75 6e r-Encoding: chun
0250 6b 65 64 0d 0a 44 61 74 65 3a 20 46 72 69 2c 20 ked..Date: Fri,
0260 32 36 20 53 65 70 20 32 30 31 34 20 30 39 3a 32 26 Sep 2014 09:2
0270 36 3a 31 37 20 47 4d 54 0d 0a 0d 0a 38 30 31 0d 6:17 GMT....801.
0280 0a 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 .hhhhhhhhhhhhhhh
0290 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
02a0 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
02b0 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
02c0 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
02d0 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
02e0 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
02f0 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0300 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0310 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0320 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0330 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0340 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0350 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0360 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0370 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0380 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0390 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
03a0 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
03b0 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
03c0 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
03d0 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
03e0 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
03f0 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0400 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0410 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0420 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0430 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0440 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0450 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0460 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0470 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0480 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0490 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
04a0 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
04b0 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
04c0 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
04d0 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
04e0 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
04f0 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0500 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0510 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0520 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0530 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0540 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0550 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0560 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0570 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0580 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
0590 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
05a0 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
05b0 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
05c0 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
05d0 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhhhhhhhh
05e0 68 68 68 68 68 68 68 68 68 68 hhhhhhhhhh
这是代码的输出:
read: 582
HTTP/1.1 200 OK
Server: Apache-Coyote/1.1
X-UA-Compatible: IE=edge,chrome=1
X-Content-Type-Options: nosniff
X-XSS-Protection: 1; mode=block
Cache-Control: no-cache, no-store, max-age=0, must-revalidate
Pragma: no-cache
Expires: 0
X-Frame-Options: DENY
X-Frame-Options: ALLOW-FROM *
X-Application-Context: application
Cache-Control: no-store, no-cache, must-revalidate, max-age=0
Access-Control-Allow-Origin: *
Access-Control-Allow-Credentials: true
Content-Type: application/javascript;charset=UTF-8
Transfer-Encoding: chunked
Date: Fri, 26 Sep 2014 09:26:17 GMT
----
如何获取剩余数据？
编辑:如果我减小接收缓冲区大小并在读取后将一个字节写入输出流，我似乎收到了丢失的数据。这是为什么？
最佳答案
原来是我的病毒扫描器的“在线防护”造成的。一旦我关闭 AVG AntiVirus Business Editions 的在线防护，我丢失的数据就开始出现了。看起来它不喜欢流数据。
关于java - 缺少来自套接字的数据，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/26057034/
我主要使用Ruby来执行此操作，但到目前为止我的攻击计划如下:使用gemsrdf、rdf-rdfa和rdf-microdata或mida来解析给定任何URI的数据。我认为最好映射到像schema.org这样的统一模式，例如使用这个yaml文件，它试图描述数据词汇表和opengraph到schema.org之间的转换:#SchemaXtoschema.orgconversion#data-vocabularyDV:name:namestreet-address:streetAddressregion:addressRegionlocality:addressLocalityphoto:i
我真的很习惯使用Ruby编写以下代码:my_hash={}my_hash['test']=1Java中对应的数据结构是什么？ 最佳答案 HashMapmap=newHashMap();map.put("test",1);我假设？ 关于java-等价于Java中的RubyHash，我们在StackOverflow上找到一个类似的问题： https://stackoverflow.com/questions/22737685/
有时我需要处理键/值数据。我不喜欢使用数组，因为它们在大小上没有限制(很容易不小心添加超过2个项目，而且您最终需要稍后验证大小)。此外，0和1的索引变成了魔数(MagicNumber)，并且在传达含义方面做得很差(“当我说0时，我的意思是head...”)。散列也不合适，因为可能会不小心添加额外的条目。我写了下面的类来解决这个问题:classPairattr_accessor:head,:taildefinitialize(h,t)@head,@tail=h,tendend它工作得很好并且解决了问题，但我很想知道:Ruby标准库是否已经带有这样一个类？ 最佳
我正在尝试使用boilerpipe来自JRuby。我看过guide从JRuby调用Java，并成功地将它与另一个Java包一起使用，但无法弄清楚为什么同样的东西不能用于boilerpipe。我正在尝试基本上从JRuby中执行与此Java等效的操作:URLurl=newURL("http://www.example.com/some-location/index.html");Stringtext=ArticleExtractor.INSTANCE.getText(url);在JRuby中试过这个:require'java'url=java.net.URL.new("http://www
我只想对我一直在思考的这个问题有其他意见，例如我有classuser_controller和classuserclassUserattr_accessor:name,:usernameendclassUserController//dosomethingaboutanythingaboutusersend问题是我的User类中是否应该有逻辑user=User.newuser.do_something(user1)oritshouldbeuser_controller=UserController.newuser_controller.do_something(user1,user2)我
什么是ruby的rack或python的Java的wsgi？还有一个路由库。 最佳答案 来自Python标准PEP333:Bycontrast,althoughJavahasjustasmanywebapplicationframeworksavailable,Java's"servlet"APImakesitpossibleforapplicationswrittenwithanyJavawebapplicationframeworktoruninanywebserverthatsupportstheservletAPI.ht
我正在尝试使用Curbgem执行以下POST以解析云curl-XPOST\-H"X-Parse-Application-Id:PARSE_APP_ID"\-H"X-Parse-REST-API-Key:PARSE_API_KEY"\-H"Content-Type:image/jpeg"\--data-binary'@myPicture.jpg'\https://api.parse.com/1/files/pic.jpg用这个:curl=Curl::Easy.new("https://api.parse.com/1/files/lion.jpg")curl.multipart_form_
无论您是想搭建桌面端、WEB端或者移动端APP应用，HOOPSPlatform组件都可以为您提供弹性的3D集成架构，同时，由工业领域3D技术专家组成的HOOPS技术团队也能为您提供技术支持服务。如果您的客户期望有一种在多个平台（桌面/WEB/APP，而且某些客户端是“瘦”客户端）快速、方便地将数据接入到3D应用系统的解决方案，并且当访问数据时，在各个平台上的性能和用户体验保持一致，HOOPSPlatform将帮助您完成。利用HOOPSPlatform，您可以开发在任何环境下的3D基础应用架构。HOOPSPlatform可以帮您打造3D创新型产品，HOOPSSDK包含的技术有：快速且准确的CAD
本教程将在Unity3D中混合Optitrack与数据手套的数据流，在人体运动的基础上，添加双手手指部分的运动。双手手背的角度仍由Optitrack提供，数据手套提供双手手指的角度。 01 客户端软件分别安装MotiveBody与MotionVenus并校准人体与数据手套。MotiveBodyMotionVenus数据手套使用、校准流程参照：https://gitee.com/foheart_1/foheart-h1-data-summary.git02 数据转发打开MotiveBody软件的Streaming，开始向Unity3D广播数据；MotionVenus中设置->选项选择Unit
文章目录一、概述简介原理模块二、配置Mysql使用版本环境要求1.操作系统2.mysql要求三、配置canal-server离线下载在线下载上传解压修改配置单机配置集群配置分库分表配置1.修改全局配置2.实例配置垂直分库水平分库3.修改group-instance.xml4.启动监听四、配置canal-adapter1修改启动配置2配置映射文件3启动ES数据同步查询所有订阅同步数据同步开关启动4.验证五、配置canal-admin一、概述简介canal是Alibaba旗下的一款开源项目，Java开发。基于数据库增量日志解析，提供增量数据订阅&消费。Git地址：https://github.co